server.h

/* Copyright (c) 2016, Human Brain Project
 *                     Stefan.Eilemann@epfl.ch
 */

#ifndef ZEROEQ_HTTP_SERVER_H
#define ZEROEQ_HTTP_SERVER_H

#include <zeroeq/http/api.h>
#include <zeroeq/receiver.h> // base class
#include <zeroeq/log.h>

namespace zeroeq
{
namespace http
{
class Server : public zeroeq::Receiver
{
public:
    ZEROEQHTTP_API Server( const URI& uri, Receiver& shared );
    ZEROEQHTTP_API explicit Server( const URI& uri );
    ZEROEQHTTP_API explicit Server( Receiver& shared );
    ZEROEQHTTP_API Server();
    ZEROEQHTTP_API explicit Server( Server& shared )
        : Server( static_cast< Receiver& >( shared )) {}
    ZEROEQHTTP_API ~Server();

    ZEROEQHTTP_API
    static std::unique_ptr< Server > parse( int argc, const char* const* argv);
    ZEROEQHTTP_API
    static std::unique_ptr< Server > parse( int argc, const char* const* argv,
                                            Receiver& shared );
    ZEROEQHTTP_API const URI& getURI() const;

    ZEROEQHTTP_API SocketDescriptor getSocketDescriptor() const;

    bool handle( servus::Serializable& object )
        { return handlePUT( object ) && handleGET( object );}

    ZEROEQHTTP_API bool remove( const servus::Serializable& object );

    ZEROEQHTTP_API bool remove( const std::string& event );

    ZEROEQHTTP_API bool handlePUT( servus::Serializable& object );

    ZEROEQHTTP_API
    bool handlePUT( const std::string& event, const PUTFunc& func );

    ZEROEQHTTP_API bool handlePUT( const std::string& event,
                               const std::string& schema, const PUTFunc& func );

    ZEROEQHTTP_API bool handlePUT( const std::string& event,
                               const PUTPayloadFunc& func );

    ZEROEQHTTP_API bool handlePUT( const std::string& event,
                               const std::string& schema,
                               const PUTPayloadFunc& func );
    ZEROEQHTTP_API bool handleGET( servus::Serializable& object );

    ZEROEQHTTP_API
    bool handleGET( const std::string& event, const GETFunc& func );

    ZEROEQHTTP_API
    bool handleGET( const std::string& event, const std::string& schema,
                    const GETFunc& func );

    ZEROEQHTTP_API
    std::string getSchema( const servus::Serializable& object) const;

    ZEROEQHTTP_API std::string getSchema( const std::string& event ) const;

private:
    class Impl;
    std::unique_ptr< Impl > _impl;

    // Receiver API
    void addSockets( std::vector< detail::Socket >& entries ) final;
    void process( detail::Socket& socket, uint32_t timeout ) final;
    void addConnection( const std::string& ) final { ZEROEQDONTCALL; } // LCOV_EXCL_LINE
};
}
}

#endif