Function completeAtpTask

src/atp/atpExecute.js:209–276

* End-to-end ATP task completion driver. * * @param {object} opts * @param {string} opts.taskId - Hub task row id (required) * @param {string} opts.orderId - ATP DeliveryProof id (required) * @param {string} opts.answerFile - Path to file holding the merchant answer (required) * @param

(opts)

 * @returns {Promise<{ok:boolean, stage?:string, error?:string, assetId?:string}>}
 */
async function completeAtpTask(opts) {
  const taskId = opts && opts.taskId;
  const orderId = opts && opts.orderId;
  const answerFile = opts && opts.answerFile;
  if (!taskId || !orderId || !answerFile) {
    return { ok: false, stage: 'input', error: 'taskId, orderId, answerFile are required' };
  }

  let answer;
  try {
    answer = _readAnswer(answerFile);
  } catch (e) {
    return { ok: false, stage: 'read_answer', error: e && e.message };
  }

  const handshakeOk = await _ensureNodeSecret();
  if (!handshakeOk) {
    return { ok: false, stage: 'hello', error: 'failed to register with hub; node_secret missing' };
  }

  const gene = _buildGene(opts.capabilities, opts.signals);
  const capsule = _buildCapsule({
    gene,
    answer,
    summary: opts.summary,
    orderId,
    taskId,
    capabilities: opts.capabilities,
    signals: opts.signals,
  });

  const pub = await _publishBundle(gene, capsule);
  if (!pub.ok) {
    return { ok: false, stage: 'publish', error: pub.error || 'publish_failed', details: pub };
  }
  const decision = pub.data && pub.data.payload && pub.data.payload.decision;
  if (decision && decision !== 'accept') {
    const reason = pub.data.payload.reason || 'unknown';
    return { ok: false, stage: 'publish', error: 'publish_rejected: ' + reason, details: pub.data };
  }

  const complete = await _completeTaskOnHub(taskId, capsule.asset_id);
  if (!complete.ok) {
    return { ok: false, stage: 'complete', error: complete.error || 'complete_failed', details: complete };
  }

  const proofPayload = {
    asset_id: capsule.asset_id,
    result: capsule.summary,
    content_hash: capsule.asset_id,
    pass_rate: 1.0,
    delivered_by: getNodeId(),
    task_id: taskId,
  };

  const delivery = await submitDelivery(orderId, proofPayload);
  if (!delivery || !delivery.ok) {
    return {