BlockChainProcessor.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/chain/BatchEntityProcessor.h"
#include "catapult/disruptor/DisruptorElement.h"
#include "catapult/model/WeakEntityInfo.h"
#include <functional>
 
namespace catapult {
    namespace cache { class ReadOnlyCatapultCache; }
    namespace chain { struct ObserverState; }
}
 
namespace catapult { namespace consumers {
 
    class WeakBlockInfo : public model::WeakEntityInfoT<model::Block> {
    public:
            constexpr WeakBlockInfo() : m_pGenerationHash(nullptr)
            {}
 
            constexpr explicit WeakBlockInfo(const model::BlockElement& blockElement)
                    : WeakEntityInfoT(blockElement.Block, blockElement.EntityHash)
                    , m_pGenerationHash(&blockElement.GenerationHash)
            {}
 
        public:
            constexpr const GenerationHash& generationHash() const {
                return *m_pGenerationHash;
            }
 
        private:
            const GenerationHash* m_pGenerationHash;
    };
 
    using BlockChainProcessor = std::function<validators::ValidationResult (
            const WeakBlockInfo&,
            disruptor::BlockElements&,
            observers::ObserverState&)>;
 
    using BlockHitPredicate = predicate<const model::Block&, const model::Block&, const GenerationHash&>;
 
    using BlockHitPredicateFactory = std::function<BlockHitPredicate (const cache::ReadOnlyCatapultCache&)>;
 
    enum class ReceiptValidationMode {
        Disabled,
 
        Enabled
    };
 
    BlockChainProcessor CreateBlockChainProcessor(
            const BlockHitPredicateFactory& blockHitPredicateFactory,
            const chain::BatchEntityProcessor& batchEntityProcessor,
            ReceiptValidationMode receiptValidationMode);
}}