trx_retry_db.hpp

Go to the documentation of this file.

#pragma once
#include <sysio/chain/types.hpp>
#include <sysio/chain/block_state.hpp>
#include <sysio/chain/trace.hpp>
 
namespace sysio::chain_apis {
 
template<typename T>
using next_function = std::function<void(const std::variant<fc::exception_ptr, T>&)>;
 
class trx_retry_db {
public:
 
   explicit trx_retry_db( const chain::controller& controller, size_t max_mem_usage_size,
                          fc::microseconds retry_interval, fc::microseconds max_expiration_time,
                          fc::microseconds abi_serializer_max_time );
   ~trx_retry_db();
 
   trx_retry_db(trx_retry_db&&) = delete;
   trx_retry_db& operator=(trx_retry_db&&) = delete;
 
   fc::time_point_sec get_max_expiration_time()const;
 
   size_t size()const;
 
   void track_transaction( chain::packed_transaction_ptr ptrx, std::optional<uint16_t> num_blocks, next_function<std::unique_ptr<fc::variant>> next );
 
   void on_applied_transaction( const chain::transaction_trace_ptr& trace, const chain::packed_transaction_ptr& ptrx );
 
   void on_block_start( uint32_t block_num );
 
   void on_accepted_block(const chain::block_state_ptr& block );
 
   void on_irreversible_block(const chain::block_state_ptr& block );
 
private:
   std::unique_ptr<struct trx_retry_db_impl> _impl;
};
 
} // namespace sysio::chain_apis