Method send_answer

runners/worker/WorkerRunningRequest.cpp:191–247

}

void WorkerRunningRequest::send_answer(td::int32 status_code, std::vector<std::pair<std::string, std::string>> headers,
                                       std::string orig_payload, bool payload_is_completed) {
  if (completed_) {
    return;
  }
  LOG(DEBUG) << "worker request " << proxy_request_id_.to_hex() << ": starting sending answer";

  auto payload_to_send = postprocessor_->add_next_answer_slice(orig_payload);
  if (payload_is_completed) {
    payload_to_send = payload_to_send + postprocessor_->finalize();
  }

  stats()->answer_bytes_sent += (double)payload_to_send.size();
  if (payload_to_send.size() > 0) {
    payload_parts_++;
    payload_bytes_ += payload_to_send.size();
  }

  //http.response http_version:string status_code:int reason:string headers:(vector http.header) payload:bytes = http.Response;
  auto res = cocoon::cocoon_api::make_object<cocoon_api::http_response>(
      "HTTP/1.1", status_code, "", std::vector<ton::tl_object_ptr<cocoon_api::http_header>>{},
      td::BufferSlice(payload_to_send));

  for (auto &h : headers) {
    auto name = h.first;
    std::transform(name.begin(), name.end(), name.begin(), [](unsigned char c) { return std::tolower(c); });
    if (name == "content-length" || name == "transfer-encoding" || name == "connection") {
      continue;
    }
    res->headers_.push_back(cocoon::cocoon_api::make_object<cocoon_api::http_header>(h.first, h.second));
  }

  // Add debug timing headers using Unix timestamps
  res->headers_.push_back(cocoon::cocoon_api::make_object<cocoon_api::http_header>(
      "X-Cocoon-Worker-Start", PSTRING() << td::StringBuilder::FixedDouble(started_at_unix_, 6)));
  res->headers_.push_back(cocoon::cocoon_api::make_object<cocoon_api::http_header>(
      "X-Cocoon-Worker-End", PSTRING() << td::StringBuilder::FixedDouble(td::Clocks::system(), 6)));

  if (payload_is_completed) {
    res->headers_.push_back(
        cocoon::cocoon_api::make_object<cocoon_api::http_header>("Content-Length", PSTRING() << res->payload_.size()));
  } else {
    res->headers_.push_back(cocoon::cocoon_api::make_object<cocoon_api::http_header>("Transfer-Encoding", "chunked"));
  }

  auto serialized_res = cocoon::serialize_tl_object(res, true);
  td::BufferSlice ans;
  auto final_info = payload_is_completed ? create_final_info() : nullptr;
  ans = cocoon::create_serialize_tl_object<cocoon_api::proxy_queryAnswerEx>(
      proxy_request_id_, std::move(serialized_res), payload_is_completed ? 1 : 0, std::move(final_info));
  td::actor::send_closure(runner_, &WorkerRunner::send_message_to_connection, proxy_connection_id_, std::move(ans));
  sent_answer_ = true;

  if (payload_is_completed) {
    finish_request(true);
  }
}