Function streamFileToHttpRequestAttempt

src/upload-stream.ts:54–194

(options: {
  url: URL;
  method: 'POST' | 'PUT';
  headers: Record<string, string>;
  payloadPath: string;
  timeoutMessage: string;
  timeoutHint?: string;
  errorMessage: string;
  errorHint?: string;
  retryable?: boolean;
  redirectCount: number;
  startOffset: number;
  progress?: UploadStreamProgressOptions;
})

}

async function streamFileToHttpRequestAttempt(options: {
  url: URL;
  method: 'POST' | 'PUT';
  headers: Record<string, string>;
  payloadPath: string;
  timeoutMessage: string;
  timeoutHint?: string;
  errorMessage: string;
  errorHint?: string;
  retryable?: boolean;
  redirectCount: number;
  startOffset: number;
  progress?: UploadStreamProgressOptions;
}): Promise<UploadStreamResponse> {
  const transport = options.url.protocol === 'https:' ? https : http;
  const payloadSize = fs.statSync(options.payloadPath).size;
  const headers = buildUploadRequestHeaders(options.headers, options.startOffset, payloadSize);
  emitUploadAttemptStarted(options.progress, options.startOffset, payloadSize);

  return await new Promise((resolve, reject) => {
    let responseReceived = false;
    const req = transport.request(
      {
        protocol: options.url.protocol,
        host: options.url.hostname,
        port: options.url.port,
        method: options.method,
        path: options.url.pathname + options.url.search,
        headers,
      },
      (res) => {
        responseReceived = true;
        void readNodeHttpResponseBody(res)
          .then((body) => {
            clearTimeout(timeout);
            const statusCode = res.statusCode ?? 500;
            const location = res.headers.location;
            if (location && isUploadRedirectStatus(statusCode)) {
              if (options.redirectCount >= MAX_UPLOAD_REDIRECTS) {
                reject(
                  new AppError('COMMAND_FAILED', 'Artifact upload exceeded redirect limit', {
                    maxRedirects: MAX_UPLOAD_REDIRECTS,
                    url: options.url.toString(),
                  }),
                );
                return;
              }
              const redirectedUrl = new URL(location, options.url);
              void streamFileToHttpRequestAttempt({
                ...options,
                url: redirectedUrl,
                redirectCount: options.redirectCount + 1,
              }).then(resolve, reject);
              return;
            }

            const resumeOffset = isUploadResumeStatus(statusCode)
              ? parseUploadResumeOffset(res.headers, payloadSize)