Subscribe to Webhooks

1
{
2
  "attestationId": "att_abc123",
3
  "userId": "usr_xyz789",
4
  "issuerId": "iss_def456",
5
  "attestationType": "kyc",
6
  "claimHash": "0xabc...def",
7
  "kycLevel": 2,
8
  "investorClass": 2,
9
  "countryCode": "US",
10
  "expiresAt": 1735689600000,
11
  "metadata": {},
12
  "timestamp": 1720000000000
13
}

1
function extractTraceContext(headers: Record<string, string>) {
2
  const traceparent = headers["traceparent"];
3
  // Format: 00-{32-char trace-id}-{16-char parent-id}-{2-char flags}
4
  const parts = traceparent.split("-");
5
6
  return {
7
    traceId: parts[1],
8
    parentId: parts[2],
9
    flags: parts[3],
10
  };
11
}

1
import { serve } from "@hono/node-server";
2
import { Hono } from "hono";
3
4
const app = new Hono();
5
6
app.post("/webhooks/signum", async (c) => {
7
  const payload = await c.req.json();
8
  const traceparent = c.req.header("traceparent");
9
10
  // Log with trace context for observability
11
  console.log(`[${traceparent}] Received event`, payload);
12
13
  // Route by event type based on payload shape
14
  if ("attestationId" in payload && "claimHash" in payload) {
15
    await handleAttestationEvent(payload);
16
  } else if ("checkId" in payload) {
17
    await handleComplianceCheckEvent(payload);
18
  } else if ("changeType" in payload) {
19
    await handleRuleChangeEvent(payload);
20
  }
21
22
  // Return 200 to acknowledge receipt
23
  return c.json({ received: true });
24
});
25
26
async function handleAttestationEvent(event: any) {
27
  console.log(`Attestation ${event.attestationId} for user ${event.userId}`);
28
  // Process idempotently — use attestationId as dedup key
29
}
30
31
async function handleComplianceCheckEvent(event: any) {
32
  console.log(`Check ${event.checkId} passed: ${event.passed}`);
33
}
34
35
async function handleRuleChangeEvent(event: any) {
36
  console.log(`Rule ${event.changeType} changed for asset ${event.assetId}`);
37
}
38
39
serve({ fetch: app.fetch, port: 3000 });

1
// 1. Issue a command and capture the resource ID
2
const result = await signum.attestations.create({
3
  walletAddress: "0xabc...def",
4
  chainEid: 30101,
5
});
6
const attestationId = result.attestationId; // "att_xyz789"
7
8
// 2. Track the pending operation
9
await db.pendingOperations.insert({
10
  attestationId,
11
  type: "attestation_create",
12
  createdAt: new Date(),
13
});
14
15
// 3. In your webhook handler, match by resource ID
16
async function handleWebhook(payload: any) {
17
  const pending = await db.pendingOperations.findByAttestationId(
18
    payload.attestationId
19
  );
20
  if (pending) {
21
    console.log(`Attestation ${pending.attestationId} created on-chain`);
22
    await db.pendingOperations.markComplete(pending.attestationId);
23
  }
24
}