Method process_answer_ex_impl

runners/client/ClientRunningRequest.cpp:96–137

}

void ClientRunningRequest::process_answer_ex_impl(cocoon_api::client_queryAnswerEx &ans) {
  if (answer_sent_) {
    LOG(ERROR) << "client request " << request_id_.to_hex() << ": received duplicate answer";
    return;
  }

  LOG(DEBUG) << "client request " << request_id_.to_hex() << ": received answer";

  auto R = fetch_tl_object<cocoon_api::http_response>(std::move(ans.answer_), true);
  if (R.is_error()) {
    LOG(ERROR) << "client request " << request_id_.to_hex() << ": received malformed answer: " << R.move_as_error();
    return;
  }
  auto response = R.move_as_ok();

  received_answer_at_unix_ = td::Clocks::system();

  stats()->answer_bytes_sent += (double)response->payload_.size();

  std::vector<std::pair<std::string, std::string>> headers;
  for (auto &x : response->headers_) {
    headers.emplace_back(x->name_, x->value_);
  }
  headers.emplace_back("X-Cocoon-Client-Start", PSTRING() << td::StringBuilder::FixedDouble(started_at_unix_, 6));
  headers.emplace_back("X-Cocoon-Client-End", PSTRING() << td::StringBuilder::FixedDouble(td::Clocks::system(), 6));

  callback_->receive_answer(response->status_code_, "application/json", std::move(headers));
  answer_sent_ = true;

  bool is_completed = ans.flags_ & 1;

  if (response->payload_.size() > 0) {
    payload_parts_++;
    payload_bytes_ += response->payload_.size();

    add_payload_part(std::move(response->payload_), is_completed, ans.final_info_);
  }

  if (is_completed) {
    finish_request(true, std::move(ans.final_info_));
  }
}

void ClientRunningRequest::process_answer_ex_impl(cocoon_api::client_queryAnswerErrorEx &ans) {
  LOG(DEBUG) << "client request " << request_id_.to_hex() << ": received error";