EntitiesSynchronizer.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/ionet/NodeInteractionResultCode.h"
#include "catapult/thread/FutureUtils.h"
 
namespace catapult { namespace chain {
 
    template<typename TSynchronizerTraits>
    class EntitiesSynchronizer {
    public:
        using RemoteApiType = typename TSynchronizerTraits::RemoteApiType;
 
    private:
        using NodeInteractionFuture = thread::future<ionet::NodeInteractionResultCode>;
 
    public:
        explicit EntitiesSynchronizer(TSynchronizerTraits&& traits) : m_traits(std::move(traits))
        {}
 
    public:
        NodeInteractionFuture operator()(const RemoteApiType& api) {
            return m_traits.apiCall(api).then([&traits = m_traits, sourcePublicKey = api.remotePublicKey()](auto&& rangeFuture) {
                try {
                    auto range = rangeFuture.get();
                    if (range.empty())
                        return ionet::NodeInteractionResultCode::Neutral;
 
                    CATAPULT_LOG(debug) << "peer returned " << range.size() << " " << TSynchronizerTraits::Name;
                    traits.consume(std::move(range), sourcePublicKey);
                    return ionet::NodeInteractionResultCode::Success;
                } catch (const catapult_runtime_error& e) {
                    CATAPULT_LOG(warning) << "exception thrown while requesting " << TSynchronizerTraits::Name << ": " << e.what();
                    return ionet::NodeInteractionResultCode::Failure;
                }
            });
        }
 
    private:
        TSynchronizerTraits m_traits;
    };
}}