http.h

/*
 * Copyright (C) 2018 Microchip Technology Inc.  All rights reserved.
 *
 * SPDX-License-Identifier: Apache-2.0
 */
#ifndef EGT_NETWORK_HTTP_H
#define EGT_NETWORK_HTTP_H
 
#include <egt/app.h>
#include <egt/detail/meta.h>
#include <memory>
#include <string>
#include <vector>
 
namespace egt
{
inline namespace v1
{
 
namespace detail
{
struct HttpClientRequestData;
class HttpClientRequestManager;
}
 
namespace experimental
{
 
class EGT_API HttpClientRequest
{
public:
 
    using ReadCallback = std::function < void(const unsigned char* data, size_t len, bool done) >;
 
    explicit HttpClientRequest() noexcept;
 
    HttpClientRequest(const HttpClientRequest&) = delete;
    HttpClientRequest& operator=(const HttpClientRequest&) = delete;
    HttpClientRequest(HttpClientRequest&&) noexcept;
    HttpClientRequest& operator=(HttpClientRequest&&) noexcept;
 
    virtual void start_async(const std::string& url, ReadCallback callback);
 
    inline detail::HttpClientRequestData* impl()
    {
        return m_impl.get();
    }
 
    virtual ~HttpClientRequest() noexcept;
 
protected:
 
    void finish();
 
    void cleanup();
 
    std::unique_ptr<detail::HttpClientRequestData> m_impl;
 
    friend class detail::HttpClientRequestManager;
};
 
template<class T>
T load_file_from_network(const std::string& url)
{
    T buffer;
    bool finished = false;
    HttpClientRequest request;
    request.start_async(url, [&buffer, url, &finished](const unsigned char* data, size_t len, bool done)
    {
        if (data && len)
            buffer.insert(buffer.end(), data, data + len);
 
        if (done)
            finished = true;
    });
 
    // TODO: super nasty way to block here
 
    while (!finished)
        Application::instance().event().step();
 
    return buffer;
}
 
}
}
}
 
#endif