BlockChainSyncHandlers.h

Go to the documentation of this file.

 
#pragma once
#include "BlockChainProcessor.h"
#include "catapult/subscribers/StateChangeInfo.h"
#include "catapult/utils/ArraySet.h"
 
namespace catapult {
    namespace cache { class CatapultCache; }
    namespace chain { struct ObserverState; }
}
 
namespace catapult { namespace consumers {
 
    struct TransactionsChangeInfo {
    public:
        TransactionsChangeInfo(
                const utils::HashPointerSet& addedTransactionHashes,
                const std::vector<model::TransactionInfo>& revertedTransactionInfos)
                : AddedTransactionHashes(addedTransactionHashes)
                , RevertedTransactionInfos(revertedTransactionInfos)
        {}
 
    public:
        const utils::HashPointerSet& AddedTransactionHashes;
 
        const std::vector<model::TransactionInfo>& RevertedTransactionInfos;
    };
 
    enum class UndoBlockType {
        Rollback,
 
        Common
    };
 
    enum class CommitOperationStep : uint16_t {
        Blocks_Written,
 
        State_Written,
 
        All_Updated
    };
 
    struct BlockChainSyncHandlers {
    public:
        using DifficultyCheckerFunc = predicate<const std::vector<const model::Block*>&, const cache::CatapultCache&>;
 
        using UndoBlockFunc = consumer<const model::BlockElement&, observers::ObserverState&, UndoBlockType>;
 
        using StateChangeFunc = consumer<const subscribers::StateChangeInfo&>;
 
        using PreStateWrittenFunc = consumer<const cache::CatapultCacheDelta&, const state::CatapultState&, Height>;
 
        using TransactionsChangeFunc = consumer<const TransactionsChangeInfo&>;
 
        using CommitStepFunc = consumer<CommitOperationStep>;
 
    public:
        DifficultyCheckerFunc DifficultyChecker;
 
        BlockChainProcessor Processor;
 
        UndoBlockFunc UndoBlock;
 
        StateChangeFunc StateChange;
 
        PreStateWrittenFunc PreStateWritten;
 
        TransactionsChangeFunc TransactionsChange;
 
        CommitStepFunc CommitStep;
    };
}}