synchronizer.hpp

Go to the documentation of this file.

#ifndef KAGOME_NETWORK_SYNCHRONIZER
#define KAGOME_NETWORK_SYNCHRONIZER

#include <libp2p/peer/peer_id.hpp>

#include "network/types/state_request.hpp"
#include "outcome/outcome.hpp"
#include "primitives/block_header.hpp"
#include "primitives/common.hpp"

namespace kagome::network {

  class Synchronizer {
   public:
    using SyncResultHandler =
        std::function<void(outcome::result<primitives::BlockInfo>)>;

    virtual ~Synchronizer() = default;

    virtual bool syncByBlockInfo(const primitives::BlockInfo &block_info,
                                 const libp2p::peer::PeerId &peer_id,
                                 SyncResultHandler &&handler,
                                 bool subscribe_to_block) = 0;

    virtual bool syncByBlockHeader(const primitives::BlockHeader &header,
                                   const libp2p::peer::PeerId &peer_id,
                                   SyncResultHandler &&handler) = 0;

    virtual void syncMissingJustifications(const libp2p::peer::PeerId &peer_id,
                                           primitives::BlockInfo target_block,
                                           std::optional<uint32_t> limit,
                                           SyncResultHandler &&handler) = 0;

    virtual void syncState(const libp2p::peer::PeerId &peer_id,
                           const primitives::BlockInfo &block,
                           SyncResultHandler &&handler) = 0;

    virtual bool hasIncompleteRequestOfStateSync() const = 0;
  };

}  // namespace kagome::network

#endif  // KAGOME_NETWORK_SYNCHRONIZER