testing/generic_exchange_connector.h

/* generic_exchange_connector.h                                    -*- C++ -*-
   Jeremy Barnes, 1 Febrary 2012
   Copyright (c) 2012 Datacratic.  All rights reserved.

   Base class for all Exchange connectors
*/

#pragma once

#include "rtbkit/plugins/exchange/http_exchange_connector.h"
#include "rtbkit/common/exchange_connector.h"

namespace RTBKIT {


/*****************************************************************************/
/* GENERIC EXCHANGE CONNECTOR                                                */
/*****************************************************************************/

struct GenericExchangeConnector
    : public RTBKIT::HttpExchangeConnector {
    
    GenericExchangeConnector(ServiceBase & owner,
                             Json::Value config);

    ~GenericExchangeConnector();

    virtual void shutdown();

    int numThreads;
    int listenPort;
    std::string bindHost;
    bool performNameLookup;
    int backlog;

    virtual std::string exchangeName() const
    {
        return "rtbkit";
    }

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

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

    virtual double
    getRoundTripTimeMs(HttpAuctionHandler & connection,
                       const HttpHeader & header);

    virtual HttpResponse
    getResponse(const HttpAuctionHandler & connection,
                const HttpHeader & requestHeader,
                const RTBKIT::Auction & auction) const;

    virtual HttpResponse
    getDroppedAuctionResponse(const HttpAuctionHandler & connection,
                              const RTBKIT::Auction & auction,
                              const std::string & reason) const;

    virtual HttpResponse
    getErrorResponse(const HttpAuctionHandler & connection,
                     const RTBKIT::Auction & auction,
                     const std::string & errorMessage) const;

};

} // namespace RTBKIT