twophase_client.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_CLIENT_TWOPHASE_CLIENT_H_
#define OPENCBDC_TX_SRC_CLIENT_TWOPHASE_CLIENT_H_
 
#include "client.hpp"
#include "uhs/twophase/coordinator/client.hpp"
#include "uhs/twophase/locking_shard/status_client.hpp"
 
namespace cbdc {
    class twophase_client : public client {
      public:
        twophase_client(const cbdc::config::options& opts,
                        const std::shared_ptr<logging::log>& logger,
                        const std::string& wallet_file,
                        const std::string& client_file);
 
        ~twophase_client() override = default;
 
        twophase_client() = delete;
        twophase_client(const twophase_client&) = delete;
        auto operator=(const twophase_client&) -> twophase_client& = delete;
        twophase_client(twophase_client&&) = delete;
        auto operator=(twophase_client&&) -> twophase_client& = delete;
 
        auto sync() -> bool override;
 
        auto check_tx_id(const hash_t& tx_id) -> std::optional<bool>;
 
        auto check_unspent(const hash_t& uhs_id) -> std::optional<bool>;
 
      protected:
        auto init_derived() -> bool override;
 
        auto send_mint_tx(const transaction::full_tx& mint_tx)
            -> bool override;
 
      private:
        coordinator::rpc::client m_coordinator_client;
        cbdc::locking_shard::rpc::status_client m_shard_status_client;
        std::shared_ptr<logging::log> m_logger;
        cbdc::config::options m_opts;
 
        std::unique_ptr<secp256k1_context,
                        decltype(&secp256k1_context_destroy)>
            m_secp{secp256k1_context_create(SECP256K1_CONTEXT_SIGN),
                   &secp256k1_context_destroy};
 
        static constexpr auto m_client_timeout
            = std::chrono::milliseconds(5000);
    };
}
 
#endif