Function buildPublishMessageFromAssets

src/gep/cliContracts.js:336–361

(assets, deps, opts)

}

function buildPublishMessageFromAssets(assets, deps, opts) {
  const preview = Boolean(opts && opts.preview);
  const a2a = deps.a2a || require('./a2aProtocol');
  const gene = assets.find(asset => asset.type === 'Gene');
  const capsule = assets.find(asset => asset.type === 'Capsule');
  const event = assets.find(asset => asset.type === 'EvolutionEvent') || null;
  if (!gene || !capsule) throw new ContractError('bundle_required', 'publish requires Gene + Capsule bundle');
  if (preview) {
    const previewNodeId = nonPersistedNodeId(deps) || DRY_RUN_NODE_ID;
    try {
      return a2a.buildPublishBundle({ gene, capsule, event, nodeId: previewNodeId });
    } catch (e) {
      if (!isPublishSigningAuthError(e)) throw e;
      if (!hasHubAuthorization(deps)) throw new ContractError('auth_required', 'Hub authentication required');
      return buildUnsignedPublishPreviewMessage({ gene, capsule, event, nodeId: previewNodeId });
    }
  }
  if (!getHubUrl(deps)) throw new ContractError('auth_required', 'Hub URL is required');
  if (!hasHubAuthorization(deps)) throw new ContractError('auth_required', 'Hub authentication required');
  try {
    return a2a.buildPublishBundle({ gene, capsule, event });
  } catch (e) {
    if (!isPublishSigningAuthError(e)) throw e;
    return buildUnsignedPublishPreviewMessage({ gene, capsule, event, nodeId: nonPersistedNodeId(deps) || DRY_RUN_NODE_ID });
  }
}

function finalizePublishMessage(message, deps, opts) {
  const signedAssets = publishPayloadAssets(message);