uhs/atomizer/atomizer/messages.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_ATOMIZER_MESSAGES_H_
#define OPENCBDC_TX_SRC_ATOMIZER_MESSAGES_H_
 
#include "block.hpp"
#include "uhs/atomizer/watchtower/tx_error_messages.hpp"
#include "uhs/transaction/transaction.hpp"
 
namespace cbdc::atomizer {
    struct tx_notify_request {
        auto operator==(const tx_notify_request& rhs) const -> bool;
 
        transaction::compact_tx m_tx;
        std::unordered_set<uint64_t> m_attestations;
        uint64_t m_block_height{};
    };
 
    struct aggregate_tx_notification {
        auto operator==(const aggregate_tx_notification& rhs) const -> bool;
 
        transaction::compact_tx m_tx;
        uint64_t m_oldest_attestation{};
    };
 
    struct aggregate_tx_notify_request {
        auto operator==(const aggregate_tx_notify_request& rhs) const -> bool;
 
        std::vector<aggregate_tx_notification> m_agg_txs;
    };
 
    struct make_block_request {};
 
    struct prune_request {
        uint64_t m_block_height{};
    };
 
    struct get_block_request {
        uint64_t m_block_height{};
    };
 
    using errors = std::vector<watchtower::tx_error>;
 
    struct make_block_response {
        block m_blk;
        errors m_errs;
    };
 
    struct get_block_response {
        block m_blk;
    };
 
    using request
        = std::variant<tx_notify_request, prune_request, get_block_request>;
}
 
#endif