block_cache.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_WATCHTOWER_BLOCK_CACHE_H_
#define OPENCBDC_TX_SRC_WATCHTOWER_BLOCK_CACHE_H_
 
#include "uhs/atomizer/atomizer/block.hpp"
#include "util/common/hashmap.hpp"
 
#include <forward_list>
#include <memory>
#include <mutex>
#include <optional>
#include <queue>
#include <shared_mutex>
#include <unordered_map>
 
namespace cbdc::watchtower {
    using block_cache_result = std::pair<size_t, hash_t>;
    class block_cache {
      public:
        block_cache() = delete;
 
        explicit block_cache(size_t k);
 
        void push_block(cbdc::atomizer::block&& blk);
 
        auto check_unspent(const hash_t& uhs_id) const
            -> std::optional<block_cache_result>;
 
        auto check_spent(const hash_t& uhs_id) const
            -> std::optional<block_cache_result>;
 
        auto best_block_height() const -> uint64_t;
 
      private:
        size_t m_k_blks;
        std::queue<cbdc::atomizer::block> m_blks;
        uint64_t m_best_blk_height{0};
        std::unordered_map<hash_t,
                           block_cache_result,
                           hashing::const_sip_hash<hash_t>>
            m_unspent_ids;
        std::unordered_map<hash_t,
                           block_cache_result,
                           hashing::const_sip_hash<hash_t>>
            m_spent_ids;
    };
}
 
#endif // OPENCBDC_TX_SRC_WATCHTOWER_BLOCK_CACHE_H_