server_interface.hpp

Go to the documentation of this file.

// Copyright (c) 2022 MIT Digital Currency Initiative,
//                    Federal Reserve Bank of Boston
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef OPENCBDC_TX_SRC_PARSEC_AGENT_SERVER_INTERFACE_H_
#define OPENCBDC_TX_SRC_PARSEC_AGENT_SERVER_INTERFACE_H_
 
#include "interface.hpp"
#include "messages.hpp"
#include "parsec/agent/impl.hpp"
#include "parsec/broker/interface.hpp"
#include "parsec/directory/interface.hpp"
#include "util/common/blocking_queue.hpp"
#include "util/common/thread_pool.hpp"
 
#include <atomic>
#include <memory>
#include <secp256k1.h>
#include <thread>
 
namespace cbdc::parsec::agent::rpc {
    class server_interface {
      public:
        server_interface(std::shared_ptr<broker::interface> broker,
                         std::shared_ptr<logging::log> log,
                         const cbdc::parsec::config& cfg);
 
        virtual ~server_interface();
 
        virtual auto init() -> bool = 0;
 
        server_interface(const server_interface&) = delete;
        auto operator=(const server_interface&) -> server_interface& = delete;
        server_interface(server_interface&&) = delete;
        auto operator=(server_interface&&) -> server_interface& = delete;
 
      private:
        friend class server;
        friend class http_server;
 
        std::shared_ptr<broker::interface> m_broker;
        std::shared_ptr<logging::log> m_log;
        const cbdc::parsec::config& m_cfg;
 
        mutable std::mutex m_agents_mut;
        std::atomic<size_t> m_next_id{};
        std::unordered_map<size_t, std::shared_ptr<agent::impl>> m_agents;
 
        blocking_queue<size_t> m_cleanup_queue;
        std::thread m_cleanup_thread;
 
        blocking_priority_queue<size_t, std::greater<>> m_retry_queue;
        std::thread m_retry_thread;
 
        std::shared_ptr<thread_pool> m_threads{
            std::make_shared<thread_pool>()};
 
        std::shared_ptr<secp256k1_context> m_secp{
            secp256k1_context_create(SECP256K1_CONTEXT_SIGN
                                     | SECP256K1_CONTEXT_VERIFY),
            &secp256k1_context_destroy};
    };
}
 
#endif