cpp-libp2p/include/libp2p/injector/kademlia_injector.hpp

/**
 * Copyright Quadrivium LLC
 * All Rights Reserved
 * SPDX-License-Identifier: Apache-2.0
 */

#pragma once

#include <libp2p/injector/host_injector.hpp>

// implementations
#include <libp2p/basic/scheduler.hpp>
#include <libp2p/crypto/random_generator/boost_generator.hpp>
#include <libp2p/protocol/kademlia/config.hpp>
#include <libp2p/protocol/kademlia/impl/content_routing_table_impl.hpp>
#include <libp2p/protocol/kademlia/impl/kademlia_impl.hpp>
#include <libp2p/protocol/kademlia/impl/peer_routing_table_impl.hpp>
#include <libp2p/protocol/kademlia/impl/storage_backend_default.hpp>
#include <libp2p/protocol/kademlia/impl/storage_impl.hpp>
#include <libp2p/protocol/kademlia/impl/validator_default.hpp>

namespace libp2p::injector {

  template <typename Injector>
  std::shared_ptr<libp2p::protocol::kademlia::Kademlia> get_kademlia(
      const Injector &injector) {
    static auto initialized =
        boost::optional<std::shared_ptr<libp2p::protocol::kademlia::Kademlia>>(
            boost::none);
    if (initialized) {
      return initialized.value();
    }

    [[maybe_unused]] auto config =
        injector.template create<protocol::kademlia::Config>();
    [[maybe_unused]] auto host =
        injector.template create<std::shared_ptr<Host>>();
    [[maybe_unused]] auto storage =
        injector
            .template create<std::shared_ptr<protocol::kademlia::Storage>>();
    [[maybe_unused]] auto table = injector.template create<
        std::shared_ptr<protocol::kademlia::PeerRoutingTable>>();
    [[maybe_unused]] auto content_routing_table = injector.template create<
        std::shared_ptr<protocol::kademlia::ContentRoutingTable>>();
    [[maybe_unused]] auto validator =
        injector
            .template create<std::shared_ptr<protocol::kademlia::Validator>>();
    [[maybe_unused]] auto scheduler =
        injector.template create<std::shared_ptr<basic::Scheduler>>();
    [[maybe_unused]] auto random_generator = injector.template create<
        std::shared_ptr<crypto::random::RandomGenerator>>();
    [[maybe_unused]] auto bus =
        injector.template create<std::shared_ptr<event::Bus>>();

    initialized = std::make_shared<libp2p::protocol::kademlia::KademliaImpl>(
        config,
        std::move(host),
        std::move(storage),
        std::move(content_routing_table),
        std::move(table),
        std::move(validator),
        std::move(scheduler),
        std::move(bus),
        std::move(random_generator));
    return initialized.value();
  }

  template <
      typename T,
      typename C = std::decay_t<T>,
      typename = std::enable_if<std::is_same_v<C, protocol::kademlia::Config>>>
  inline auto useKademliaConfig(T &&c) {
    return boost::di::bind<C>().to(
        [c = std::forward<C>(c)](const auto &injector) mutable -> const C & {
          static C instance = std::move(c);
          return instance;
        })[boost::di::override];
  }

  // clang-format off
  template <typename InjectorConfig = BOOST_DI_CFG, typename... Ts>
  auto makeKademliaInjector(Ts &&... args) {
    namespace di = boost::di;

    return di::make_injector<InjectorConfig>(
        // clang-format off

        di::bind<protocol::kademlia::Config>.to<protocol::kademlia::Config>(),
        di::bind<protocol::kademlia::ContentRoutingTable>.to<protocol::kademlia::ContentRoutingTableImpl>(),
        di::bind<protocol::kademlia::PeerRoutingTable>.to<protocol::kademlia::PeerRoutingTableImpl>(),
        di::bind<protocol::kademlia::StorageBackend>.to<protocol::kademlia::StorageBackendDefault>(),
        di::bind<protocol::kademlia::Storage>.to<protocol::kademlia::StorageImpl>(),
        di::bind<protocol::kademlia::Validator>.to<protocol::kademlia::ValidatorDefault>(),

        di::bind<protocol::kademlia::MessageObserver>.to<protocol::kademlia::KademliaImpl>(),
        di::bind<protocol::kademlia::Kademlia>.to<protocol::kademlia::KademliaImpl>(),

        // user-defined overrides...
        std::forward<decltype(args)>(args)...
        // clang-format on
    );
  }

}  // namespace libp2p::injector