Method initialize_rpc_server

runners/BaseRunner.cpp:358–397

  });
}
void BaseRunner::initialize_rpc_server(td::Promise<td::Unit> promise) {
  client_ = TcpClient::create(make_tcp_client_callback());
  for (auto &x : rpc_ports_) {
    td::actor::send_closure(client_, &TcpClient::add_listening_port, generate_unique_uint64(), x.first, x.second);
  }

  if (connection_to_proxy_via_.is_valid()) {
    LOG(INFO) << "using proxy " << connection_to_proxy_via_;
    td::actor::send_closure(client_, &TcpClient::add_connection_to_remote_app_type_rule, remote_app_type_proxy(),
                            std::make_shared<TcpConnectionType>(TcpConnectionSocks5(connection_to_proxy_via_)));
    td::actor::send_closure(client_, &TcpClient::add_connection_to_remote_app_type_rule, remote_app_type_key_manager(),
                            std::make_shared<TcpConnectionType>(TcpConnectionSocks5(connection_to_proxy_via_)));
  } else {
    LOG(INFO) << "using " << (fake_tee_ ? "fake" : "real") << " tdx-tls connection";

    auto make_tee = [&](bool fake) -> td::Result<TeeInterfaceRef> {
      TRY_RESULT(tee_type, TeeInterface::this_cpu_tee_type());

      switch (tee_type) {
        case TeeType::Sev:
          return sev::make_tee(fake, sev_tee_config_);
        case TeeType::Tdx:
          return tdx::make_tee(fake, tdx_tee_config_);
      }

      UNREACHABLE();
    };
    TRY_RESULT_PROMISE(promise, tee_interface, make_tee(fake_tee_));
    TRY_RESULT_PROMISE(promise, cert_and_key, generate_cert_and_key(tee_interface.get()));
    TRY_RESULT_PROMISE(promise, ratls_interface, RATLSInterface::make(scheduler_, fake_tee_, ratls_config_));

    td::actor::send_closure(
        client_, &TcpClient::add_connection_to_remote_app_type_rule, remote_app_type_proxy(),
        std::make_shared<TcpConnectionType>(TcpConnectionTls(cert_and_key, RATLSPolicy::make(ratls_interface))));
    td::actor::send_closure(
        client_, &TcpClient::add_connection_to_remote_app_type_rule, remote_app_type_key_manager(),
        std::make_shared<TcpConnectionType>(TcpConnectionTls(cert_and_key, RATLSPolicy::make(ratls_interface))));
  }
  promise.set_value(td::Unit());
}
void BaseRunner::rpc_server_initialized() {
  coro_init().start().detach("BaseRunner::coro_init");
}