Method send_handshake

runners/client/ClientProxyConnection.cpp:20–55

}

void ClientProxyConnection::send_handshake() {
  LOG(INFO) << "created connection " << connection_id() << ", sending handshake";
  if (runner()->check_image_hashes()) {
    if (!runner()->runner_config()->root_contract_config->has_proxy_hash(remote_app_hash())) {
      fail_connection(td::Status::Error("invalid proxy hash"));
      return;
    }
  }
  {
    auto S = runner()->check_verification_key(remote_app_type(), verified_by());
    if (S.is_error()) {
      return fail_connection(std::move(S));
    }
  }
  auto params = ton::create_tl_object<cocoon_api::client_params>(3, runner()->cocoon_wallet_address().rserialize(true),
                                                                 runner()->is_test(), runner()->min_proto_version(),
                                                                 runner()->max_proto_version());
  auto req = cocoon::create_serialize_tl_object<cocoon_api::client_connectToProxy>(
      std::move(params), runner()->runner_config()->root_contract_config->version());
  runner()->send_handshake_query_to_connection(
      connection_id(), "connect", std::move(req), td::Timestamp::in(30.0),
      [runner_actor_id = actor_id(runner()), runner = runner(),
       connection_id = connection_id()](td::Result<td::BufferSlice> R) {
        td::actor::send_lambda(runner_actor_id, [runner, connection_id, R = std::move(R)]() mutable {
          auto self = (ClientProxyConnection *)runner->get_connection(connection_id);
          if (!self) {
            return;
          }
          if (R.is_ok()) {
            self->received_handshake_answer(R.move_as_ok());
          } else {
            self->fail_connection(R.move_as_error());
          }
        });
      });
}

void ClientProxyConnection::received_handshake_answer(td::BufferSlice answer) {
  std::shared_ptr<ClientProxyInfo> proxy;