blocking_server.hpp

Go to the documentation of this file.

// Copyright (c) 2021 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_RPC_BLOCKING_SERVER_H_
#define OPENCBDC_TX_SRC_RPC_BLOCKING_SERVER_H_
 
#include "server.hpp"
 
namespace cbdc::rpc {
    template<typename Request,
             typename Response,
             typename InBuffer = buffer,
             typename OutBuffer = buffer>
    class blocking_server
        : public server<Request, Response, InBuffer, OutBuffer> {
      public:
        blocking_server() = default;
        blocking_server(blocking_server&&) noexcept = default;
        auto operator=(blocking_server&&) noexcept
            -> blocking_server& = default;
        blocking_server(const blocking_server&) = default;
        auto operator=(const blocking_server&) -> blocking_server& = default;
 
        ~blocking_server() override = default;
 
        static constexpr handler_type handler = handler_type::blocking;
 
        using callback_type = std::function<std::optional<Response>(Request)>;
 
        void register_handler_callback(callback_type callback) {
            m_callback = std::move(callback);
        }
 
      protected:
        auto blocking_call(InBuffer request_buf) -> std::optional<OutBuffer> {
            auto req = server_type::deserialize_request(request_buf);
            if(!req.has_value()) {
                return std::nullopt;
            }
            auto resp = std::optional<Response>();
            if(m_callback) {
                resp = m_callback(std::move(req.value().m_payload));
            }
            return server_type::serialize_response(
                std::move(req.value().m_header),
                std::move(resp));
        }
 
      private:
        callback_type m_callback;
 
        using server_type = server<Request, Response, InBuffer, OutBuffer>;
    };
}
 
#endif