Agent webhooks

curl -X POST https://api.prudra.dev/webhooks \
  -H "Authorization: Bearer prv_test_sk_..." \
  -H "Content-Type: application/json" \
  -d '{
    "url":    "https://your-agent.example.com/webhooks/prudra",
    "events": ["payment.received", "vault.sealed", "deposit.success"]
  }'

import { verifyWebhook } from '@prudra/webhooks';

app.post('/webhooks/prudra', express.raw({ type: '*/*' }), (req, res) => {
  res.sendStatus(200);  // respond immediately

  const isValid = verifyWebhook({
    payload:   req.body as Buffer,
    signature: req.headers['x-prudra-signature'] as string,
    timestamp: req.headers['x-prudra-timestamp'] as string,
    secret:    process.env.PRUDRA_WEBHOOK_SECRET!,
  });

  if (!isValid) return;

  const event = JSON.parse((req.body as Buffer).toString());

  if (event.type === 'payment.received') {
    const { vaultId, amount, protocol } = event.payload;
    console.log(`Payment: $${amount} via ${protocol}`);
    // Trigger your agent's downstream processing
    processPayment(vaultId);
  }

  if (event.type === 'vault.sealed') {
    const { vaultId, summary } = event.payload;
    console.log(`Work complete: ${summary}`);
    // Notify end users, send emails, update your DB, etc.
  }
});

if (event.type === 'deposit.success') {
  const { walletId, amount, tokenSymbol, txHash } = event.payload;
  console.log(`Deposit: ${amount} ${tokenSymbol}`);
  // Top up agent balance, trigger sweep, etc.
}

const { eventId, type, payload } = event;

const alreadyProcessed = await db.processedEvents.has(eventId);
if (alreadyProcessed) return;

await db.processedEvents.add(eventId);
await handleEvent(type, payload);