Method get_private_keys_from_key_manager

runners/BaseRunner.cpp:816–872

}

void BaseRunner::get_private_keys_from_key_manager() {
  if (!is_initialized()) {
    return;
  }

  if (role_ != RunnerRole::Worker && role_ != RunnerRole::Proxy) {
    return;
  }

  auto conf = runner_config_;
  if (!conf || !conf->root_contract_config) {
    return;
  }

  auto fail = [&]() {
    if (key_manager_socket_id_ > 0) {
      td::actor::send_closure(client_, &TcpClient::del_outbound_address, key_manager_socket_id_);
      key_manager_socket_id_ = 0;
      key_manager_addr_ = td::IPAddress();
      if (key_manager_connection_id_ > 0) {
        fail_connection(key_manager_connection_id_, td::Status::Error("closing key manager"));
        key_manager_connection_id_ = 0;
      }
    }
  };

  auto key_manager_addr = conf->root_contract_config->key_manager_address();
  if (!key_manager_addr.is_valid()) {
    return fail();
  }
  if (key_manager_addr != key_manager_addr_) {
    fail();
    key_manager_addr_ = key_manager_addr;
    key_manager_socket_id_ = generate_unique_uint64();

    td::actor::send_closure(client_, &TcpClient::add_outbound_address, key_manager_socket_id_, key_manager_addr,
                            remote_app_type_key_manager());
  }

  if (key_manager_connection_id_ > 0) {
    td::BufferSlice req;
    if (role_ == RunnerRole::Proxy) {
      req = cocoon::create_serialize_tl_object<cocoon_api::keyManager_getProxyPrivateKeys>(0);
    } else if (role_ == RunnerRole::Worker) {
      req = cocoon::create_serialize_tl_object<cocoon_api::keyManager_getWorkerPrivateKeys>(0);
    } else {
      return;
    }

    send_query_to_connection(key_manager_connection_id_, "get_private_keys", std::move(req), td::Timestamp::in(60.0),
                             [runner = this](td::Result<td::BufferSlice> R) mutable {
                               if (R.is_ok()) {
                                 runner->got_private_keys_from_key_manager(R.move_as_ok());
                               }
                             });
  }
}