oxygine-framework/oxygine/src/core/emscripten/HttpRequestEmscriptenTask.cpp

#include "HttpRequestEmscriptenTask.h"
#include <emscripten.h>
#include "core/file.h"

namespace oxygine
{

    static HttpRequestTask* createTask()
    {
        return new HttpRequestEmscriptenTask;
    }

    void HttpRequestTask::init()
    {
        setCustomRequests(createTask);
    }

    void HttpRequestTask::release()
    {
    }

    HttpRequestEmscriptenTask::HttpRequestEmscriptenTask()
    {
        _progressOnWrite = false;//manual send
    }

    void HttpRequestEmscriptenTask::_onload(void* data, unsigned size)
    {
        _responseCode = 200;
        gotHeaders();
        write(data, size);

        onComplete();
        releaseRef();
    }

    void HttpRequestEmscriptenTask::_onerror(int, const char*)
    {
        onError();
        releaseRef();
    }

    void HttpRequestEmscriptenTask::_onprogress(int a, int b)
    {
        log::messageln(" HttpRequestEmscriptenTask::_onprogress %d %d", a, b);
        int delta = a - _receivedContentSize;
        _receivedContentSize = a;
        _expectedContentSize = b;
        dispatchProgress(delta, _receivedContentSize, b);
    }

    void HttpRequestEmscriptenTask::_run()
    {
        addRef();

        const char* method = _postData.empty() ? "GET" : "POST";
        if (!_postData.empty())
            _postData.push_back(0);

        emscripten_async_wget2_data(_url.c_str(), method, (char*)&_postData.front(), this, true, onload, onerror, onprogress);
    }
    //int  emscripten_async_wget2_data(const char* url, const char* requesttype, const char* param, void *arg, int free, em_async_wget2_data_onload_func onload, em_async_wget2_data_onerror_func onerror, em_async_wget2_data_onprogress_func onprogress);
    //void emscripten_async_wget2_data(const char* url, const char* requesttype, const char* param, void *arg, int free, void (*onload)(void*, void*, unsigned), void (*onerror)(void*, int, const char*), void (*onprogress)(void*, int, int));
    //void emscripten_async_wget2_data(const char* url, const char* requesttype, const char* param, void *arg, int free, em_async_wget2_data_onload_func onload, em_async_wget2_data_onerror_func onerror, em_async_wget2_data_onprogress_func onprogress);
}