Webhook Middleware

import { webhookMiddleware, verifyWebhookSignature, verifyAndParseWebhook } from '@keystoneos/node';

import express from 'express';
import { webhookMiddleware } from '@keystoneos/node';

app.post(
  '/webhooks/keystone',
  express.raw({ type: 'application/json' }),
  webhookMiddleware({ secret: process.env.WEBHOOK_SECRET }),
  (req, res) => {
    const { event, data } = req.keystoneEvent;

    switch (event) {
      case 'settlement.state.awaiting_deposits':
        console.log(`${data.settlement_id}: ${data.state} - trigger deposits`);
        break;
      case 'settlement.state.finalized':
        console.log(`Finalized: ${data.settlement_id}`);
        break;
      case 'settlement.state.rejected':
        console.log(`Rejected: ${data.settlement_id}`);
        break;
    }

    res.sendStatus(200);
  },
);

import { verifyAndParseWebhook } from '@keystoneos/node';

// Hono example
app.post('/webhooks/keystone', async (c) => {
  const body = await c.req.text();
  const signature = c.req.header('x-keystone-signature');

  const event = verifyAndParseWebhook(body, signature, process.env.WEBHOOK_SECRET);
  if (!event) {
    return c.json({ error: 'Invalid signature' }, 401);
  }

  // Handle event...
  return c.json({ ok: true });
});

import { verifyWebhookSignature } from '@keystoneos/node';

const isValid = verifyWebhookSignature(rawBody, signature, secret);

interface WebhookEvent {
  event: string;
  data: Record<string, unknown>;
}