Function _publishBundle

src/atp/atpExecute.js:170–185

(gene, capsule)

}

async function _publishBundle(gene, capsule) {
  const nodeSecret = getHubNodeSecret();
  if (!nodeSecret) return { ok: false, error: 'missing_node_secret_after_hello' };
  const signatureInput = [gene.asset_id, capsule.asset_id].sort().join('|');
  const signature = crypto.createHmac('sha256', nodeSecret).update(signatureInput).digest('hex');
  const msg = {
    protocol: 'gep-a2a',
    protocol_version: '1.0.0',
    message_type: 'publish',
    message_id: 'msg_atp_' + crypto.randomBytes(8).toString('hex'),
    timestamp: new Date().toISOString(),
    sender_id: getNodeId(),
    payload: { assets: [gene, capsule], signature: signature },
  };
  return _postJson(_publishUrl(), msg, PUBLISH_TIMEOUT_MS);
}

async function _completeTaskOnHub(taskId, assetId) {
  const base = String(getHubUrl() || '').replace(/\/+$/, '');