Function fetchObject

cli/lib/fetch-object.js:17–48

({ registry, cache }, integrity, load = false)

const EMPTY_BUF = Buffer.from([]);

async function fetchObject({ registry, cache }, integrity, load = false) {
  const parsed = ssri.parse(integrity);
  const algo = parsed.pickAlgorithm();
  const [{ digest }] = parsed[algo];

  if (digest === EMPTY_HASH && algo === 'sha512') {
    return load ? { data: EMPTY_BUF } : true;
  }

  if (await cacache.get.hasContent(cache, integrity)) {
    return load ? cacache.get(cache, integrity) : true;
  }

  const response = await fetch(
    `${registry}/v1/objects/object/${algo}/${encodeURIComponent(digest)}`
  );

  if (response.status > 399) {
    throw new Error('error fetching object');
  }

  let destIntegrity = null;
  const dest = cacache.put.stream(cache, integrity);
  dest.on('integrity', i => (destIntegrity = i));
  await pipeline(response.body, dest);

  if (!parsed.match(destIntegrity)) {
    throw new Error('file integrity mismatch!');
  }

  return load ? cacache.get(cache, integrity) : true;
}