Method receive_message

runners/client/ClientRunner.cpp:292–346

 */

void ClientRunner::receive_message(TcpClient::ConnectionId connection_id, td::BufferSlice query) {
  auto magic = get_tl_magic(query);
  LOG(DEBUG) << "received message with magic = " << magic;
  switch (magic) {
    case cocoon_api::client_queryAnswerEx::ID:
    case cocoon_api::client_queryAnswerPartEx::ID:
    case cocoon_api::client_queryAnswerErrorEx::ID: {
      auto R = cocoon::fetch_tl_object<cocoon_api::client_QueryAnswerEx>(std::move(query), true);
      if (R.is_error()) {
        LOG(ERROR) << "received malformed message from proxy: " << R.move_as_error();
        return;
      }
      auto obj = R.move_as_ok();
      td::Bits256 request_id;
      cocoon_api::downcast_call(*obj, [&](auto &e) { request_id = e.request_id_; });
      auto it = running_queries_.find(request_id);
      if (it != running_queries_.end()) {
        td::actor::send_closure(it->second, &ClientRunningRequest::process_answer_ex, std::move(obj));
      }
      return;
    }
    case cocoon_api::proxy_signedPayment::ID: {
      auto R = cocoon::fetch_tl_object<cocoon_api::proxy_signedPayment>(std::move(query), true);
      if (R.is_error()) {
        LOG(ERROR) << "received malformed message from proxy: " << R.move_as_error();
        return;
      }
      auto conn = static_cast<ClientProxyConnection *>(get_connection(connection_id));
      if (conn) {
        auto proxy = conn->proxy();
        proxy->process_signed_payment_data(*R.move_as_ok());
      }
      return;
    }
    case cocoon_api::proxy_clientRequestPayment::ID: {
      auto R = cocoon::fetch_tl_object<cocoon_api::proxy_clientRequestPayment>(std::move(query), true);
      if (R.is_error()) {
        LOG(ERROR) << "received malformed message from proxy: " << R.move_as_error();
        return;
      }
      auto obj = R.move_as_ok();
      auto conn = static_cast<ClientProxyConnection *>(get_connection(connection_id));
      if (conn) {
        auto proxy = conn->proxy();
        proxy->update_tokens_used(obj->max_tokens_);
        proxy->update_tokens_committed_to_db(obj->db_tokens_);
        proxy->process_signed_payment_data(*obj->signed_payment_);
      }
      return;
    }
    default:
      LOG(ERROR) << "dropping received message: received message with unknown magic " << td::format::as_hex(magic);
      return;
  };
}

void ClientRunner::receive_http_request(http::HttpCallback::RequestType request_type,
                                        std::vector<std::pair<std::string, std::string>> headers, std::string path,