Function _considerOrderSerialized

src/atp/autoBuyer.js:252–304

(opts)

}

async function _considerOrderSerialized(opts) {
  const now = Date.now();
  let ledger = _readLedger();
  ledger = _rotateIfNewDay(ledger, now);
  ledger = _pruneDedup(ledger, now);

  const hash = _questionHash(opts);
  if (ledger.dedup[hash]) {
    return { ok: false, skipped: true, reason: 'dedup_hit', hash: hash };
  }

  const dailyCap = _effectiveCap(_config.dailyCap, now);
  const perOrderCap = _effectiveCap(_config.perOrderCap, now);
  const remaining = Math.max(0, dailyCap - (ledger.spent || 0));
  if (remaining <= 0) {
    console.warn('[ATP-AutoBuyer] Daily cap reached, skipping order (spent=' + ledger.spent + ', cap=' + dailyCap + ')');
    return { ok: false, skipped: true, reason: 'daily_cap_reached', spent: ledger.spent, cap: dailyCap };
  }

  const requested = Math.max(1, Math.floor(Number(opts.budget) || perOrderCap));
  const budget = Math.min(requested, perOrderCap, remaining);
  if (budget <= 0) {
    return { ok: false, skipped: true, reason: 'budget_clamped_to_zero' };
  }

  const orderOpts = {
    capabilities: opts.capabilities,
    budget: budget,
    routingMode: opts.routingMode || 'fastest',
    verifyMode: opts.verifyMode || 'auto',
    question: opts.question,
    signals: opts.signals,
    minReputation: opts.minReputation,
  };

  const result = await _withTimeout(hubClient.placeOrder(orderOpts), _config.timeoutMs);

  if (result && result.ok) {
    ledger.spent = (ledger.spent || 0) + budget;
    ledger.dedup[hash] = { ts: now, failed: false };
    _writeLedger(ledger);
    console.log('[ATP-AutoBuyer] Order placed: ' + (result.data && result.data.order_id) + ' budget=' + budget + ' remaining_today=' + Math.max(0, dailyCap - ledger.spent));
    return { ok: true, data: result.data, spent: budget };
  }

  // On failure record a SHORT-TTL dedup entry (5 min) so we don't hammer the
  // hub for the same capability gap inside a tight retry loop, but the user
  // can retry the same question once the transient error clears — far better
  // than the previous 24h block for a single 503.
  ledger.dedup[hash] = { ts: now, failed: true };
  _writeLedger(ledger);
  return { ok: false, error: (result && result.error) || 'unknown_error' };
}

// Write the consent ack file. Used by `evolver atp enable|disable` and the
// first-run prompt. `enabled=true` persists opt-in; `enabled=false` persists