UtUpdater.h

Go to the documentation of this file.

 
#pragma once
#include "ChainFunctions.h"
#include "ExecutionConfiguration.h"
#include "catapult/model/EntityInfo.h"
#include "catapult/observers/ObserverTypes.h"
#include "catapult/utils/ArraySet.h"
 
namespace catapult {
    namespace cache {
        class CatapultCache;
        class UtCache;
        class UtCacheModifierProxy;
    }
}
 
namespace catapult { namespace chain {
 
    class UtUpdater {
    public:
        enum class TransactionSource {
            New,
 
            Reverted,
 
            Existing
        };
 
        struct ThrottleContext {
            UtUpdater::TransactionSource TransactionSource;
 
            Height CacheHeight;
 
            const cache::ReadOnlyCatapultCache& UnconfirmedCatapultCache;
 
            const cache::UtCacheModifierProxy& TransactionsCache;
        };
 
        using Throttle = predicate<const model::TransactionInfo&, const ThrottleContext&>;
 
    public:
        UtUpdater(
                cache::UtCache& transactionsCache,
                const cache::CatapultCache& confirmedCatapultCache,
                BlockFeeMultiplier minFeeMultiplier,
                const ExecutionConfiguration& executionConfig,
                const TimeSupplier& timeSupplier,
                const FailedTransactionSink& failedTransactionSink,
                const Throttle& throttle);
 
        ~UtUpdater();
 
    public:
        void update(const std::vector<model::TransactionInfo>& utInfos);
 
        void update(const utils::HashPointerSet& confirmedTransactionHashes, const std::vector<model::TransactionInfo>& utInfos);
 
    private:
        class Impl;
        std::unique_ptr<Impl> m_pImpl;
    };
}}