Function syncVersion

services/storage/lib/clone-legacy-package.js:80–126

(storage, pkg, version, data)

}

async function syncVersion(storage, pkg, version, data) {
  const tarball = pacote.tarball.stream(`${pkg}@${version}`);
  const untar = new tar.Parse();
  const files = {};
  const pending = [];

  untar.on('entry', entry => {
    if (entry.type === 'File') {
      const filename = './' + String(entry.path).replace(/^\/+/g, '');
      const passthrough = new PassThrough();
      passthrough.pause();

      const stream = entry.pipe(passthrough);
      const addFile = storage.add(stream).then(r => {
        files[filename] = r;
      });
      addFile.catch(() => {});
      pending.push(addFile);
    } else {
      entry.resume();
    }
  });

  try {
    await new Promise((resolve, reject) => {
      tarball.on('error', reject);
      untar.on('end', resolve).on('error', reject);
      tarball.pipe(untar);
    });
  } catch {
    return;
  }

  await Promise.all(pending);

  return {
    version,
    signatures: [],
    dependencies: data.dependencies || {},
    devDependencies: data.devDependencies || {},
    optionalDependencies: data.optionalDependencies || {},
    peerDependencies: data.peerDependencies || {},
    bundledDependencies: data.bundledDependencies || {},
    files,
    derivedFiles: {}
  };
}