SynchronizerTaskCallbacks.h

Go to the documentation of this file.

 
#pragma once
#include "NodeInteractionUtils.h"
#include "ServiceState.h"
#include "catapult/chain/RemoteApiForwarder.h"
#include "catapult/chain/RemoteNodeSynchronizer.h"
#include "catapult/plugins/PluginManager.h"
 
namespace catapult { namespace extensions {
 
    template<typename TRemoteApi, typename TRemoteApiFactory>
    thread::TaskCallback CreateSynchronizerTaskCallback(
            chain::RemoteNodeSynchronizer<TRemoteApi>&& synchronizer,
            TRemoteApiFactory remoteApiFactory,
            net::PacketIoPicker& packetIoPicker,
            const extensions::ServiceState& state,
            const std::string& taskName) {
        auto syncTimeout = state.config().Node.SyncTimeout;
        chain::RemoteApiForwarder forwarder(packetIoPicker, state.pluginManager().transactionRegistry(), syncTimeout, taskName);
 
        auto syncHandler = [&nodes = state.nodes()](auto&& future) {
            auto result = future.get();
            IncrementNodeInteraction(nodes, result);
            return thread::TaskResult::Continue;
        };
 
        return [forwarder, syncHandler, synchronizer, remoteApiFactory]() {
            return forwarder.processSync(synchronizer, remoteApiFactory).then(syncHandler);
        };
    }
 
    template<typename TRemoteApi, typename TRemoteApiFactory>
    thread::TaskCallback CreateChainSyncAwareSynchronizerTaskCallback(
            chain::RemoteNodeSynchronizer<TRemoteApi>&& synchronizer,
            TRemoteApiFactory remoteApiFactory,
            net::PacketIoPicker& packetIoPicker,
            const extensions::ServiceState& state,
            const std::string& taskName) {
        const auto& chainSynced = state.hooks().chainSyncedPredicate();
        auto synchronize = CreateSynchronizerTaskCallback(std::move(synchronizer), remoteApiFactory, packetIoPicker, state, taskName);
        return [chainSynced, synchronize]() {
            if (!chainSynced())
                return thread::make_ready_future(thread::TaskResult::Continue);
 
            return synchronize();
        };
    }
}}