Function pickOne

src/atp/atpTaskPickup.js:169–209

* Fetch a pickup action if one is due. Idempotent -- safe to call from the * main loop every cycle. * * @param {object} [opts] * @param {number} [opts.limit=5] -- how many Hub tasks to consider per call * @param {string} [opts.evolverExec] -- how the wrapper should invoke Evolver * @returns {P

(opts)

 *   we picked so the caller can log it.
 */
async function pickOne(opts) {
  if (!_isEnabled()) return null;
  const limit = Math.max(1, Math.min(20, Number(opts && opts.limit) || 5));

  let listResult;
  try {
    listResult = await hubClient.listMyTasks(limit);
  } catch (_) {
    return null;
  }
  if (!listResult || !listResult.ok) return null;

  const tasks = (listResult.data && Array.isArray(listResult.data.tasks))
    ? listResult.data.tasks
    : (Array.isArray(listResult.data) ? listResult.data : []);
  if (!tasks.length) return null;

  const ledger = _readLedger();
  let picked = null;
  for (const t of tasks) {
    if (!_isEligible(t)) continue;
    if (_recentlySpawned(ledger, t.id)) continue;
    picked = t;
    break;
  }
  if (!picked) return null;

  const spawnTask = _buildSpawnTask(picked, opts);
  const spawnCall = renderSessionsSpawnCall({
    task: spawnTask,
    agentId: 'atp_pickup',
    cleanup: 'delete',
    label: 'atp_pickup_' + String(picked.id).slice(0, 32),
  });

  ledger.spawned = ledger.spawned || {};
  ledger.spawned[picked.id] = { at: Date.now(), order_id: picked.atp_order_id };
  _writeLedger(ledger);

  return { spawnCall, task: picked };
}

/**
 * Forget a previously-spawned task so the main loop will retry it next cycle.