soa/service/json_endpoint.h

/* json_endpoint.h                                                 -*- C++ -*-
   Jeremy Barnes, 22 February 2011
   Copyright (c) 2011 Datacratic.  All rights reserved.

   Endpoint that does JSON.
*/

#pragma once


#include "soa/service//http_endpoint.h"
#include "soa/jsoncpp/json.h"


namespace Datacratic {


/*****************************************************************************/
/* JSON CONNECTION HANDLER                                                   */
/*****************************************************************************/

struct JsonConnectionHandler : public HttpConnectionHandler {

    JsonConnectionHandler();

    virtual void handleHttpHeader(const HttpHeader & header);

    virtual void handleHttpPayload(const HttpHeader & header,
                                   const std::string & payload);


    virtual void handleHttpChunk(const HttpHeader & header,
                                 const std::string & chunkHeader,
                                 const std::string & chunk);

    virtual void handleJson(const HttpHeader & header,
                            const Json::Value & json,
                            const std::string & jsonStr) = 0;
};


/*****************************************************************************/
/* ADHOC JSON CONNECTION HANDLER                                             */
/*****************************************************************************/

struct AdHocJsonConnectionHandler : public JsonConnectionHandler {

    typedef std::function<void (const HttpHeader & header,
                                const Json::Value & json,
                                const std::string & jsonStr,
                                AdHocJsonConnectionHandler * connection)>
    OnJson;

    AdHocJsonConnectionHandler()
    {
    }

    AdHocJsonConnectionHandler(OnJson onJson)
        : onJson(onJson)
    {
    }

    OnJson onJson;

    virtual void handleJson(const HttpHeader & header,
                            const Json::Value & json,
                            const std::string & jsonStr)
    {
        onJson(header, json, jsonStr, this);
    }
};

} // namespace Datacratic