nodemanager/core/HttpFetcher.h

#ifndef HTTPFETCHER_H
#define HTTPFETCHER_H

#include <cpprest/json.h>
#include <cpprest/http_client.h>
#include <functional>
#include "Reporter.h"

namespace hpc
{
    namespace core
    {
        using namespace web;

        class HttpFetcher : public Reporter<void>
        {
            public:
                HttpFetcher(
                    const std::string& name,
                    std::function<std::string(pplx::cancellation_token)> getReportUri,
                    int hold,
                    int interval,
                    std::function<bool(http::http_request&)> requestHandler,
                    std::function<bool(http::http_response&)> responseHandler,
                    std::function<void(int)> onErrorFunc)
                : Reporter<void>(name, getReportUri, hold, interval, nullptr, onErrorFunc),
                requestHandler(requestHandler),
                responseHandler(responseHandler)
                {
                }

                virtual ~HttpFetcher()
                {
                    this->cts.cancel();
                    this->Stop();
                }

                virtual int Report();

            private:
                std::function<bool(http::http_request&)> requestHandler;
                std::function<bool(http::http_response&)> responseHandler;
        };
    }
}

#endif // HTTPFETCHER_H