server.h

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

#pragma once

#include <zeroeq/api.h>
#include <zeroeq/receiver.h> // base class
#include <zeroeq/sender.h>   // base class
#include <zeroeq/types.h>

namespace zeroeq
{
class Server : public Receiver, public Sender
{
public:
    ZEROEQ_API Server();

    ZEROEQ_API explicit Server(const std::string& session);

    ZEROEQ_API explicit Server(const URI& uri);

    ZEROEQ_API Server(const URI& uri, const std::string& session);

    ZEROEQ_API explicit Server(Receiver& shared);

    ZEROEQ_API Server(const std::string& session, Receiver& shared);

    ZEROEQ_API Server(const URI& uri, Receiver& shared);

    ZEROEQ_API Server(const URI& uri, const std::string& session,
                      Receiver& shared);

    ZEROEQ_API ~Server();

    ZEROEQ_API Server(Server&&);
    ZEROEQ_API Server& operator=(Server&&);

    ZEROEQ_API bool handle(const uint128_t& request, const HandleFunc& func);

    ZEROEQ_API bool remove(const uint128_t& request);

    ZEROEQ_API const URI& getURI() const;

    ZEROEQ_API const std::string& getSession() const;

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

    Server(const Server&) = delete;
    Server& operator=(const Server&) = delete;

    // Receiver API
    void addSockets(std::vector<detail::Socket>& entries) final;
    bool process(detail::Socket& socket) final;
    void addConnection(const std::string& uri) final;

    // Sender API
    ZEROEQ_API zmq::SocketPtr getSocket() final;
};
}