{
  "id": "evt_01JY3M1X7Z4V8Q2H5B6C9N0KRP",
  "type": "guarantee.settled",
  "created_at": "2026-06-22T15:00:00.000Z",
  "api_version": "2026-06-01",
  "data": {
    "guarantee_id": "0xGuaranteeId",
    "req_id": "0x1",
    "cycle_id": "42",
    "version": 1,
    "user_address": "0x1111111111111111111111111111111111111111",
    "recipient_address": "0x2222222222222222222222222222222222222222",
    "asset_address": "0x3333333333333333333333333333333333333333",
    "amount": "100000",
    "network": "eip155:84532",
    "status": "SETTLED",
    "settled_at": "2026-06-22T14:59:58.000Z"
  }
}

app.post("/webhooks/4mica", rawBodyMiddleware, async (req, res) => {
  verifyWebhookSignature(req);
  const event = JSON.parse(req.body.toString("utf8"));

  if (await eventStore.has(event.id)) return res.sendStatus(200);

  if (event.type === "guarantee.settled") {
    await payments.markSettled({
      guaranteeId: event.data.guarantee_id,
      requestId: event.data.req_id,
      cycleId: event.data.cycle_id,
      settledAt: event.data.settled_at,
    });
  }

  await eventStore.record(event.id);
  res.sendStatus(200);
});

@app.post("/webhooks/4mica")
async def handle_webhook(request: Request):
    raw_body = await request.body()
    verify_webhook_signature(request.headers, raw_body)
    event = json.loads(raw_body)

    if await event_store.has(event["id"]):
        return Response(status_code=200)

    if event["type"] == "guarantee.settled":
        data = event["data"]
        await payments.mark_settled(
            guarantee_id=data["guarantee_id"],
            request_id=data["req_id"],
            cycle_id=data["cycle_id"],
            settled_at=data["settled_at"],
        )

    await event_store.record(event["id"])
    return Response(status_code=200)