rewards_stats.hpp

Go to the documentation of this file.

#pragma once
 
#include "config/hardfork.hpp"
#include "rewards/block_stats.hpp"
#include "storage/storage.hpp"
 
namespace taraxa::rewards {
class Stats {
 public:
  Stats(uint32_t committee_size, const HardforksConfig& hardforks, std::shared_ptr<DbStorage> db,
        std::function<uint64_t(EthBlockNumber)>&& dpos_eligible_total_vote_count, EthBlockNumber last_blk_num = 0);
 
  std::vector<BlockStats> processStats(const PeriodData& current_blk, const std::vector<gas_t>& trxs_gas_used,
                                       Batch& write_batch);
  void clear(uint64_t current_period);
 
 protected:
  void recoverFromDb(EthBlockNumber last_blk_num);
  uint32_t getCurrentDistributionFrequency(uint64_t current_period) const;
  /*
   * @brief gets all needed data and makes(processes) BlocksStats
   * @param current_blk block to process
   * @return block statistics needed for rewards distribution
   */
  BlockStats getBlockStats(const PeriodData& current_blk, const std::vector<gas_t>& trxs_fees);
  void saveBlockStats(uint64_t number, const BlockStats& stats, Batch& write_batch);
 
  const uint32_t kCommitteeSize;
  const HardforksConfig kHardforksConfig;
  std::shared_ptr<DbStorage> db_;
  const std::function<uint64_t(EthBlockNumber)> dpos_eligible_total_vote_count_;
  std::unordered_map<PbftPeriod, BlockStats> blocks_stats_;
};
}  // namespace taraxa::rewards