Method httpCall

plugins/experimental/wasm/ats_context.cc:537–592

}

WasmResult
Context::httpCall(std::string_view /* target ATS_UNUSED */, const Pairs &request_headers, std::string_view             request_body,
                  const Pairs & /* request_trailers ATS_UNUSED */, int /* timeout_millisconds ATS_UNUSED */, uint32_t *token_ptr)
{
  Wasm    *wasm         = this->wasm();
  Context *root_context = this->root_context();

  TSCont      contp;
  std::string request, method, path, authority;

  // setup local address for API call
  struct sockaddr_in addr;
  addr.sin_family      = AF_INET;
  addr.sin_addr.s_addr = LOCAL_IP_ADDRESS;
  addr.sin_port        = LOCAL_PORT;

  for (const auto &p : request_headers) {
    std::string key(p.first);
    std::string value(p.second);

    if (key == ":method") {
      method = value;
    } else if (key == ":path") {
      path = value;
    } else if (key == ":authority") {
      authority = value;
    }
  }

  /* request */
  request = method + " https://" + authority + path + " HTTP/1.1\r\n";
  for (const auto &p : request_headers) {
    std::string key(p.first);
    std::string value(p.second);
    request += key + ": " + value + "\r\n";
  }
  request += "\r\n";
  request += request_body;

  TSFetchEvent event_ids;
  event_ids.success_event_id = FETCH_EVENT_ID_BASE;
  event_ids.failure_event_id = FETCH_EVENT_ID_BASE + 1;
  event_ids.timeout_event_id = FETCH_EVENT_ID_BASE + 2;

  contp            = TSContCreate(async_handler, TSMutexCreate());
  AsyncInfo *ai    = new AsyncInfo();
  ai->token        = wasm->nextHttpCallId();
  ai->root_context = root_context;
  *token_ptr       = ai->token; // to be returned to the caller
  TSContDataSet(contp, ai);

  // API call for async fetch
  TSFetchUrl(request.c_str(), request.size(), reinterpret_cast<struct sockaddr const *>(&addr), contp, AFTER_BODY, event_ids);

  return WasmResult::Ok;
}

// Metrics