Proactive Inbox

import { User } from 'lua-cli';

async function checkRefunds() {
  const spike = await detectRefundSpike(); // your own logic

  if (!spike) return { status: 'all clear' };

  // ── 1. The notice — keyed, so re-runs REVISE instead of re-knocking ──
  const receipt = await User.Inbox.push({
    title: `${spike.count} refunds on ${spike.sku} within the hour`,
    body: 'All from the same checkout flow — want a summary before it spreads?',
    deeplink: `https://yourdashboard.example.com/refunds?sku=${spike.sku}`,
    priority: spike.count > 5 ? 'urgent' : 'high',
    key: `refund-spike-${spike.sku}`, // stable per incident
  });

  // ── 2. Handle the receipt — capped is a NORMAL outcome ──
  if (receipt.outcome === 'capped') {
    // Budget spent or the org has disabled pushes. Don't retry, don't
    // throw — carry the finding in your run summary instead.
    return {
      status: 'anomaly found',
      note: `Refund spike on ${spike.sku} (${spike.count} in the last hour). ` +
            `Inbox push unavailable: ${receipt.reason}`,
    };
  }

  return { status: 'user notified', outcome: receipt.outcome };
}

// Ten minutes later, the spike grew — same key, so the card revises:
await User.Inbox.push({
  title: `9 refunds on ${spike.sku} within the hour`,
  body: 'Still climbing. Draft response ready when you are.',
  key: `refund-spike-${spike.sku}`,
});
// → { outcome: 'updated' } — the card changed, the user was NOT re-notified

await User.Inbox.push({
  title: 'Pause the checkout flow for SKU-2481?',
  body: 'The refund spike traces to a broken discount code. I can disable it now.',
  actions: ['approve'],
  priority: 'urgent',
  threadId: currentThreadId, // acting hands off into this conversation
});

await User.Inbox.push({
  title: 'How should I handle the affected orders?',
  body: '12 orders hit the broken discount before I caught it.',
  options: [
    { label: 'Refund all 12', description: 'Full refunds, apology email' },
    { label: 'Honor the discount', description: 'Keep the orders, eat the margin' },
    { label: 'Ask me per order' },
  ],
});

try {
  await fetchRefundData();
} catch (err) {
  if (isAuthError(err)) {
    await User.Inbox.push({
      title: 'Stripe disconnected',
      body: "Refund monitoring is blind until it's reconnected.",
      actions: ['fix'],
      connection: { type: 'stripe', name: 'Stripe' },
    });
    return { status: 'blocked on connection' };
  }
  throw err;
}