cleanup.hpp

См. документацию.

#pragma once
 
#include <eosio/eosio.hpp>
#include <eosio/../../capi/eosio/db.h> // C API узла; тот же путь, что у CDT в instant_finality.hpp
#include <limits>
#include <map>
#include <type_traits>
 
namespace Cleanup {
 
  static constexpr uint32_t BUDGET = 100; 
 
  inline bool row_exists(eosio::name code, uint64_t scope, eosio::name table, uint64_t primary_key) {
    return db_find_i64(code.value, scope, table.value, primary_key) >= 0;
  }
 
  template <typename Index>
  inline bool next_index_value(eosio::name code, uint64_t scope, uint64_t from, uint64_t &value) {
    uint64_t secondary = from;
    uint64_t primary = 0;
    const int32_t itr = db_idx64_lowerbound(code.value, scope, Index::name(), &secondary, &primary);
    if (itr < 0) return false;
    value = secondary;
    return true;
  }
 
  struct budget {
    uint32_t left = BUDGET;
    uint32_t erased = 0;
 
    bool exhausted() const { return left == 0; }
    void take() {
      --left;
      ++erased;
    }
  };
 
  template <typename Index, typename Pred>
  inline void erase_where(Index &index, budget &b, Pred pred) {
    for (auto it = index.begin(); it != index.end() && !b.exhausted();) {
      if (pred(*it)) {
        it = index.erase(it);
        b.take();
      } else {
        ++it;
      }
    }
  }
 
  template <typename Table>
  inline void erase_all(Table &table, budget &b) {
    erase_where(table, b, [](const auto &) { return true; });
  }
 
  inline void report(eosio::name contract, const budget &b) {
    eosio::print("cleanup ", contract, ": удалено строк ", b.erased,
                 b.exhausted() ? ", бюджет исчерпан — продолжит следующий вызов" : "");
  }
 
} // namespace Cleanup