Function fetchAssetById

src/gep/cliContracts.js:537–555

(assetId, deps)

}

async function fetchAssetById(assetId, deps) {
  const hubUrl = getHubUrl(deps);
  if (!hubUrl) throw new ContractError('auth_required', 'Hub URL is required');
  if (!hasHubAuthorization(deps)) throw new ContractError('auth_required', 'Hub authentication required');
  const a2a = deps.a2a || require('./a2aProtocol');
  const message = a2a.buildFetch({ assetIds: [assetId] });
  const posted = await postEnvelope('/a2a/fetch', message, deps);
  if (!posted.ok) {
    const stableReason = stableHubReason(posted.body, REUSE_FAILURE_REASONS);
    if (stableReason === 'unsupported' || stableReason === 'cli_unavailable') {
      throw new ContractError(stableReason, reuseReasonMessage(stableReason));
    }
    if (posted.status === 401 || posted.status === 403) throw new ContractError('auth_required', 'Hub authentication required');
    if (posted.status === 404) return null;
    throw new ContractError('network_error', 'Hub fetch failed');
  }
  const assets = assetsFromBody(posted.body);
  return assets.find(asset => asset && asset.asset_id === assetId) || null;
}

async function postValidate(message, deps) {
  if (deps.validate) return normalizeValidateResult(await deps.validate(message));