threaded_http_server.h

Go to the documentation of this file.

 
#ifndef PKG_RPC_RPC_DETAIL_THREAD_HTTP_SERVER_H_
#define PKG_RPC_RPC_DETAIL_THREAD_HTTP_SERVER_H_
 
#include <a_util/result/result_type.h>
 
#include <map>
#include <memory>
#include <string>
 
namespace rpc {
namespace http {

namespace detail {
 
class cThreadedHttpServer {
public:
    cThreadedHttpServer();
    ~cThreadedHttpServer();
    cThreadedHttpServer(const cThreadedHttpServer&) = delete;
    cThreadedHttpServer& operator=(const cThreadedHttpServer&) = delete;
    cThreadedHttpServer(cThreadedHttpServer&&) = default;
    cThreadedHttpServer& operator=(cThreadedHttpServer&&) = default;

    a_util::result::Result StartListening(const char* strURL, int reuse = 1);

    a_util::result::Result StopListening();
 
protected:
    virtual bool HandleRequest(const std::string& strUrl,
                               const std::string& strRequest,
                               std::string& strResponse,
                               std::string& strContentType) = 0;
 
    struct tRequest {
        const std::string& method;
        const std::string& url;
        const std::multimap<std::string, std::string>& headers;
        const std::string& body;
        const std::map<std::string, std::string>& params;
    };
 
    struct tResponse {
        int& status;
        std::multimap<std::string, std::string>& headers;
        std::string& body;
    };
 
    virtual bool HandleRequest(const tRequest& sRequest, tResponse& sResponse);
 
private:
    class cImplementation;
    std::unique_ptr<cImplementation> m_pImplementation;
};
 
} // namespace detail
} // namespace http
} // namespace rpc
 
#endif