NodePingRequestor.h

Go to the documentation of this file.

 
#pragma once
#include "NodePingUtils.h"
#include "nodediscovery/src/api/RemoteNodeApi.h"
#include "catapult/net/BriefServerRequestor.h"
 
namespace catapult { namespace nodediscovery {
 
    class NodePingResponseCompatibilityChecker {
    public:
        explicit NodePingResponseCompatibilityChecker(model::NetworkIdentifier networkIdentifier)
                : m_networkIdentifier(networkIdentifier)
        {}
 
    public:
        bool isResponseCompatible(const ionet::Node& requestNode, const ionet::Node& responseNode) const {
            if (IsNodeCompatible(responseNode, m_networkIdentifier, requestNode.identityKey()))
                return true;
 
            CATAPULT_LOG(warning) << "rejecting incompatible partner node '" << responseNode << "'";
            return false;
        }
 
    private:
        model::NetworkIdentifier m_networkIdentifier;
    };
 
    struct NodePingRequestPolicy {
        using ResponseType = ionet::Node;
 
        static constexpr auto Friendly_Name = "ping";
 
        static thread::future<ResponseType> CreateFuture(ionet::PacketIo& packetIo) {
            return api::CreateRemoteNodeApi(packetIo)->nodeInfo();
        }
    };
 
    using NodePingRequestor = net::BriefServerRequestor<NodePingRequestPolicy, NodePingResponseCompatibilityChecker>;
 
    std::shared_ptr<NodePingRequestor> CreateNodePingRequestor(
            const std::shared_ptr<thread::IoThreadPool>& pPool,
            const crypto::KeyPair& keyPair,
            const net::ConnectionSettings& settings,
            model::NetworkIdentifier networkIdentifier);
}}