plugins/exchange/http_auction_handler.h

/* http_auction_handler.h                                          -*- C++ -*-
   Jeremy Barnes, 14 December 2012
   Copyright (c) 2012 Datacratic.  All rights reserved.

   Class to deal with http connections to an exchange.
*/

#pragma once

#include "soa/service/http_endpoint.h"
#include "soa/service/stats_events.h"
#include "rtbkit/common/auction.h"

namespace RTBKIT {

struct HttpExchangeConnector;


/*****************************************************************************/
/* HTTP AUCTION HANDLER                                                      */
/*****************************************************************************/

struct HttpAuctionHandler
    : public HttpConnectionHandler,
      public std::enable_shared_from_this<HttpAuctionHandler> {

    HttpAuctionHandler();
    ~HttpAuctionHandler();

    void onGotTransport();

    HttpExchangeConnector * endpoint;

    std::shared_ptr<Auction> auction;
    bool hasTimer;
    bool disconnected;
    bool servingRequest;  

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

    virtual void handleDisconnect();

    void cancelTimer();

    virtual void sendErrorResponse(const std::string & error,
                                   const std::string & details = "");
    
    virtual void dropAuction(const std::string & reason = "");

    virtual void handleTimeout(Date date, size_t cookie);

    virtual void onDisassociate();
    virtual void onCleanup();
    virtual std::string status() const;

    void doEvent(const char * eventName,
                 EventType type = ET_COUNT,
                 float value = 1.0,
                 const char * units = "");

    void incNumServingRequest();
    
    virtual void sendResponse();

    virtual HttpResponse getResponse() const;

    virtual std::shared_ptr<BidRequest>
    parseBidRequest(const HttpHeader & header,
                    const std::string & payload);

    virtual double
    getTimeAvailableMs(const HttpHeader & header,
                       const std::string & payload);

    virtual double
    getRoundTripTimeMs(const HttpHeader & header);

    static long created;
    static long destroyed;
};


} // namespace RTBKIT