Function runReuseCommand

src/gep/cliContracts.js:60–106

(args, deps)

]);

async function runReuseCommand(args, deps) {
  deps = deps || {};
  const out = deps.out || process.stdout;
  const parsed = parseReuseArgs(args || []);
  const machineJson = parsed.jsonOut || out === process.stdout;
  const write = (value, code) => writeJson(out, value, code, deps, machineJson);
  if (!parsed.ok) return write(reuseFailure(parsed.reason, parsed.message), 1);
  return withMachineJsonConsole(machineJson, deps, async () => {
    try {
      const asset = deps.fetchAssetById
        ? await deps.fetchAssetById(parsed.assetId)
        : await fetchAssetById(parsed.assetId, deps);
      if (!asset) return write(reuseFailure('not_found', 'asset not found'), 1);
      const cleaned = stripHubMetadata(asset);
      const verifiedId = verifyReuseAssetId(cleaned, parsed.assetId);
      if (!verifiedId.ok) {
        return write(reuseFailure('internal_error', 'asset integrity verification failed'), 1);
      }
      if (!isReuseAssetStoreStable(cleaned)) {
        return write(reuseFailure('internal_error', 'asset integrity verification failed'), 1);
      }
      const store = prepareReuseAssetStore(cleaned, deps);
      const provenance = prepareHubProvenance(deps);
      markHubProvenance(parsed.assetId, deps, provenance);
      let storedId;
      try {
        storedId = storeReusedAsset(cleaned, deps, store);
        if (storedId !== parsed.assetId) {
          throw new ContractError('internal_error', 'asset integrity verification failed');
        }
      } catch (e) {
        rollbackHubProvenance(provenance);
        throw e;
      }
      return write({
        ok: true,
        contract: REUSE_CONTRACT,
        status: 'ok',
        asset_id: storedId,
        action: 'reused',
      }, 0);
    } catch (e) {
      const f = classifyError(e, 'reuse');
      return write(reuseFailure(f.reason, f.message), 1);
    }
  });
}

async function runPublishCommand(args, deps) {
  deps = deps || {};