Function downloadToTempFile

src/platforms/install-source.ts:115–187

(
  tempDir: string,
  url: string,
  headers?: Record<string, string>,
  options?: { signal?: AbortSignal; downloadTimeoutMs?: number },
)

// fallow-ignore-next-line complexity
async function downloadToTempFile(
  tempDir: string,
  url: string,
  headers?: Record<string, string>,
  options?: { signal?: AbortSignal; downloadTimeoutMs?: number },
): Promise<string> {
  let parsedUrl: URL;
  try {
    parsedUrl = new URL(url);
  } catch {
    throw new AppError('INVALID_ARGS', `Invalid source URL: ${url}`);
  }
  await validateDownloadSourceUrl(parsedUrl);
  const requestSignal = options?.signal;
  if (requestSignal?.aborted) {
    throw new AppError('COMMAND_FAILED', 'request canceled', { reason: 'request_canceled' });
  }
  const timeoutMs = options?.downloadTimeoutMs ?? DEFAULT_SOURCE_DOWNLOAD_TIMEOUT_MS;
  const timeoutSignal = AbortSignal.timeout(timeoutMs);
  const signal = requestSignal ? AbortSignal.any([requestSignal, timeoutSignal]) : timeoutSignal;
  try {
    const response = await fetch(parsedUrl, {
      headers,
      redirect: 'follow',
      signal,
    });
    if (!response.ok) {
      throw new AppError(
        'COMMAND_FAILED',
        `Failed to download app source: ${response.status} ${response.statusText}`,
        {
          status: response.status,
          statusText: response.statusText,
          url: parsedUrl.toString(),
        },
      );
    }
    const downloadName = resolveDownloadFileName(response, parsedUrl);
    const destinationPath = path.join(tempDir, downloadName);
    const body = response.body;
    if (!body) {
      throw new AppError('COMMAND_FAILED', 'Download response body was empty', {
        url: parsedUrl.toString(),
      });
    }
    await pipeline(
      Readable.fromWeb(body as Parameters<typeof Readable.fromWeb>[0]),
      createWriteStream(destinationPath),
    );
    return destinationPath;
  } catch (error) {
    if (requestSignal?.aborted) {
      throw new AppError(
        'COMMAND_FAILED',
        'request canceled',
        { reason: 'request_canceled' },
        error,
      );