import type { RuntimeTrigger } from '@svantic/sdk';

const triggers: RuntimeTrigger[] = [
  /* … */
];

prompt: 'A new order came in for {{amount}} from {{customer}}.'

{
  type: 'webhook',
  path: '/hooks/stripe',
  prompt: 'A payment of {{amount}} just cleared for {{customer}}.',
  payload_map: {
    amount: 'data.object.amount_total',
    customer: 'data.object.customer_email',
  },
}

agent.add_triggers([
  {
    type: 'webhook',
    path: '/hooks/stripe',
    prompt: 'Payment {{id}} of {{amount}} cents just settled; update the order.',
    payload_map: {
      id: 'data.object.id',
      amount: 'data.object.amount_total',
    },
  },
]);

await attach(app, { agent, mesh: { /* … */ } });

{
  type: 'schedule',
  cron: '0 9 * * MON-FRI',
  prompt: 'Email the ops team the overnight order summary.',
}

agent.add_triggers([
  {
    type: 'emit',
    event: 'order_cancelled',
    prompt: 'Order {{order_id}} was cancelled; issue the refund and notify the customer.',
  },
]);

const handle = await attach(app, { agent, mesh: { /* … */ } });

// Somewhere else in the service:
app.post('/orders/:id/cancel', async (req, res) => {
  await db.orders.cancel(req.params.id);
  handle.emit('order_cancelled', { order_id: req.params.id });
  res.sendStatus(204);
});

const summary = await handle.ask('order_cancelled', { order_id });

import { RemoteAgent } from '@svantic/sdk';

agent.on_trigger = async (ctx) => {
  if (ctx.trigger.event === 'order_cancelled') {
    const self = await RemoteAgent.connect(agent.public_url);
    return self.invoke_capability('issue_refund', {
      order_id: ctx.payload.order_id,
    });
  }
};