storage_changes_tracker_impl.hpp¶

Namespaces¶

Name
sgns
sgns::storage
sgns::storage::trie
sgns::api
sgns::storage::changes_trie

Classes¶

	Name
class	sgns::storage::changes_trie::StorageChangesTrackerImpl

Functions¶

	Name
	OUTCOME_HPP_DECLARE_ERROR_2(sgns::storage::changes_trie , StorageChangesTrackerImpl::Error )

Functions Documentation¶

function OUTCOME_HPP_DECLARE_ERROR_2¶

OUTCOME_HPP_DECLARE_ERROR_2(
    sgns::storage::changes_trie ,
    StorageChangesTrackerImpl::Error 
)

Source code¶

#ifndef SUPERGENIUS_STORAGE_CHANGES_TRIE_STORAGE_CHANGES_TRACKER_IMPL
#define SUPERGENIUS_STORAGE_CHANGES_TRIE_STORAGE_CHANGES_TRACKER_IMPL

#include <set>
#include <map>

#include "primitives/extrinsic.hpp"
#include "storage/changes_trie/changes_tracker.hpp"
#include "subscription/subscriber.hpp"

namespace sgns::storage::trie {
  class Codec;
  class SuperGeniusTrieFactory;
}  // namespace sgns::storage::trie

namespace sgns::api {
  class Session;
}

namespace sgns::storage::changes_trie {

  class StorageChangesTrackerImpl : public ChangesTracker {
    using SessionPtr = std::shared_ptr<api::Session>;
    using SubscriptionEngineType =
        subscription::SubscriptionEngine<base::Buffer,
                                         SessionPtr,
                                         base::Buffer,
                                         primitives::BlockHash>;
    using SubscriptionEnginePtr = std::shared_ptr<SubscriptionEngineType>;

   public:
    enum class Error {
      EXTRINSIC_IDX_GETTER_UNINITIALIZED = 1,
      INVALID_PARENT_HASH
    };

    StorageChangesTrackerImpl(
        std::shared_ptr<storage::trie::SuperGeniusTrieFactory> trie_factory,
        std::shared_ptr<storage::trie::Codec> codec,
        SubscriptionEnginePtr subscription_engine);

    ~StorageChangesTrackerImpl() override = default;

    void setExtrinsicIdxGetter(GetExtrinsicIndexDelegate f) override;

    outcome::result<void> onBlockChange(
        primitives::BlockHash new_parent_hash,
        primitives::BlockNumber new_parent_number) override;

    outcome::result<void> onPut(const base::Buffer &key,
                                const base::Buffer &value,
                                bool new_entry) override;
    outcome::result<void> onRemove(const base::Buffer &key) override;

    outcome::result<base::Hash256> constructChangesTrie(
        const primitives::BlockHash &parent,
        const ChangesTrieConfig &conf) override;

    std::string GetName() override
    {
      return "StorageChangesTrackerImpl";
    }

   private:
    std::shared_ptr<storage::trie::SuperGeniusTrieFactory> trie_factory_;
    std::shared_ptr<storage::trie::Codec> codec_;

    std::map<base::Buffer, std::vector<primitives::ExtrinsicIndex>>
        extrinsics_changes_;
    std::set<base::Buffer> new_entries_;  // entries that do not yet exist in
                                            // the underlying storage
    primitives::BlockHash parent_hash_;
    primitives::BlockNumber parent_number_;
    GetExtrinsicIndexDelegate get_extrinsic_index_;
    SubscriptionEnginePtr subscription_engine_;
  };

}  // namespace sgns::storage::changes_trie

OUTCOME_HPP_DECLARE_ERROR_2(sgns::storage::changes_trie,
                          StorageChangesTrackerImpl::Error);

#endif  // SUPERGENIUS_STORAGE_CHANGES_TRIE_STORAGE_CHANGES_TRACKER_IMPL

Updated on 2026-03-04 at 13:10:45 -0800