Herald + Hono

import { Hono } from 'hono';
import { liquidationRoute } from './routes/liquidation';
import { webhookRoute } from './routes/webhooks';
import { usageRoute } from './routes/usage';

const app = new Hono();

app.route('/', liquidationRoute);
app.route('/', webhookRoute);
app.route('/', usageRoute);

const port = process.env.PORT ?? 3004;
export default {
  port,
  fetch: app.fetch,
};

console.log(`Hono Herald API running on http://localhost:${port}`);

import { Hono } from 'hono';
import { Herald } from '@herald-protocol/sdk';

const herald = new Herald({ apiKey: process.env.HERALD_API_KEY! });
export const liquidationRoute = new Hono();

liquidationRoute.post('/liquidation', async (c) => {
  const { wallet, positionId, healthFactor, debtAmount, asset } = await c.req.json();

  if (!wallet || !positionId) {
    return c.json({ error: 'wallet and positionId are required' }, 400);
  }

  const idempotencyKey = `liquidation_${positionId}_${Math.floor(Date.now() / 30000)}`;

  const result = await herald.notify({
    wallet,
    subject: `⚠️ Liquidation Warning — Health factor: ${healthFactor}`,
    body: [
      `Position #${positionId} is approaching liquidation.`,
      `Health factor: ${healthFactor}`,
      `Debt: ${debtAmount} ${asset}`,
      `Add collateral or repay immediately.`,
    ].join('\n'),
    category: 'defi',
    receipt: true,
    idempotencyKey,
  });

  return c.json(result, 202);
});

import { Hono } from 'hono';
import { Herald } from '@herald-protocol/sdk';

const WEBHOOK_SECRET = process.env.HERALD_WEBHOOK_SECRET!;
export const webhookRoute = new Hono();

webhookRoute.post('/webhooks/herald', async (c) => {
  const signature = c.req.header('x-herald-signature');
  const payload = await c.req.json();
  const rawBody = JSON.stringify(payload);

  if (!signature || !WEBHOOK_SECRET) {
    return c.json({ error: 'Missing signature or secret' }, 401);
  }

  const isValid = await Herald.verifyWebhookSignature(rawBody, signature, WEBHOOK_SECRET);

  if (!isValid) {
    return c.json({ error: 'Invalid signature' }, 401);
  }

  switch (payload.event) {
    case 'delivery.confirmed':
      console.log(`✅ ${payload.notificationId} delivered`);
      break;
    case 'delivery.failed':
      console.error(`❌ ${payload.notificationId} failed`);
      break;
  }

  return c.json({ received: true });
});