Function downloadZip

packages/fetch-engine/src/downloadZip.ts:59–157

(
  url: string,
  target: string,
  progressCb?: (progress: number) => void,
)

}

export async function downloadZip(
  url: string,
  target: string,
  progressCb?: (progress: number) => void,
): Promise<DownloadResult> {
  const tmpDir = tempy.directory()
  const partial = path.join(tmpDir, 'partial')

  // We try 3 times,
  // Once + 2 retries
  const RETRIES_COUNT = 2

  const [zippedSha256, sha256] = await retry(
    async () => {
      return await Promise.all([fetchChecksum(url), fetchChecksum(url.slice(0, url.length - 3))])
    },
    {
      retries: RETRIES_COUNT,
      onFailedAttempt: (err) => debug('An error occurred while downloading the checksums files', err),
    },
  )

  const result = await retry(
    async () => {
      const response = await fetch(url, {
        compress: false,
        agent: getProxyAgent(url),
      })
      if (!response.ok) {
        throw new Error(`Failed to fetch the engine file at ${url} - ${response.status} ${response.statusText}`)
      }

      const lastModified = response.headers.get('last-modified')!
      const size = parseFloat(response.headers.get('content-length') as string)
      const ws = fs.createWriteStream(partial)

      // eslint-disable-next-line no-async-promise-executor
      return await new Promise(async (resolve, reject) => {
        let bytesRead = 0

        if (response.body === null) {
          return reject(new Error(`Failed to fetch the engine file at ${url} - response.body is null`))
        }

        response.body.once('error', reject).on('data', (chunk) => {
          bytesRead += chunk.length

          if (size && progressCb) {
            progressCb(bytesRead / size)
          }
        })

        const gunzip = zlib.createGunzip()
        gunzip.on('error', reject)

        const zipStream = response.body.pipe(gunzip)
        const zippedHashPromise = hasha.fromStream(response.body, {
          algorithm: 'sha256',