Function safeRequest

server/modules/safeRequest.js:96–168

(requestOptions, policyContext = {})

}

async function safeRequest(requestOptions, policyContext = {}) {
  const baseOptions = { ...requestOptions };
  const followRedirect = baseOptions.followRedirect !== false;
  const followAllRedirects = baseOptions.followAllRedirects === true;
  const maxRedirects = Number.isInteger(baseOptions.maxRedirects)
    ? baseOptions.maxRedirects
    : DEFAULT_MAX_REDIRECTS;

  let redirectCount = 0;
  let currentUrl = baseOptions.url;
  let currentMethod = baseOptions.method || "GET";
  let currentBody = baseOptions.body;
  let currentForm = baseOptions.form;
  let currentFormData = baseOptions.formData;

  while (true) { // oxlint-disable-line no-constant-condition
    const optionsForRequest = sanitizeOutboundRequestOptions(
      {
        ...baseOptions,
        url: currentUrl,
        method: currentMethod,
        body: currentBody,
        form: currentForm,
        formData: currentFormData,
        followRedirect: false,
      },
      currentUrl
    );

    // Redirect validation must run sequentially to validate each hop in order.
    // oxlint-disable-next-line no-await-in-loop
    const validationResult = await validateOutboundUrl(optionsForRequest.url, {
      ...policyContext,
      redirectCount,
    });

    // oxlint-disable-next-line no-await-in-loop
    const response = await request({
      ...optionsForRequest,
      lookup: createPinnedLookup(
        validationResult.hostname,
        validationResult.resolvedAddresses
      ),
    });
    const statusCode = response && response.statusCode;
    const location = response && response.headers && response.headers.location;

    if (!location || !shouldFollowRedirect({
      statusCode,
      method: currentMethod,
      followRedirect,
      followAllRedirects,
    })) {
      return response;
    }

    if (redirectCount >= maxRedirects) {
      const redirectError = new Error("Exceeded maximum redirect limit for outbound request.");