ApiStateChangeSubscriber.h

Go to the documentation of this file.

 
#pragma once
#include "ChainScoreProvider.h"
#include "ExternalCacheStorage.h"
#include "catapult/subscribers/StateChangeInfo.h"
#include "catapult/subscribers/StateChangeSubscriber.h"
 
namespace catapult { namespace mongo {
 
    class ApiStateChangeSubscriber : public subscribers::StateChangeSubscriber {
    public:
        ApiStateChangeSubscriber(
                std::unique_ptr<ChainScoreProvider>&& pChainScoreProvider,
                std::unique_ptr<ExternalCacheStorage>&& pCacheStorage)
                : m_pChainScoreProvider(std::move(pChainScoreProvider))
                , m_pCacheStorage(std::move(pCacheStorage))
        {}
 
    public:
        void notifyScoreChange(const model::ChainScore& chainScore) override {
            m_pChainScoreProvider->saveScore(chainScore);
        }
 
        void notifyStateChange(const subscribers::StateChangeInfo& stateChangeInfo) override {
            m_pCacheStorage->saveDelta(stateChangeInfo.CacheChanges);
        }
 
    private:
        std::unique_ptr<ChainScoreProvider> m_pChainScoreProvider;
        std::unique_ptr<ExternalCacheStorage> m_pCacheStorage;
    };
}}