{
  "id": "evt_01JY3K8F4TQ9M5C2N7A6B1D0EP",
  "type": "collateral.deposited",
  "created_at": "2026-06-22T14:30:00.000Z",
  "api_version": "2026-06-01",
  "data": {
    "user_address": "0x1111111111111111111111111111111111111111",
    "asset_address": "0x3333333333333333333333333333333333333333",
    "amount": "10000000",
    "network": "eip155:84532",
    "transaction_hash": "0xDepositTransaction",
    "block_number": 28123456,
    "status": "finalized"
  }
}

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 === "collateral.deposited") {
    await wallets.refreshCollateral(
      event.data.user_address,
      event.data.asset_address,
      event.data.network,
    );
  }

  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"] == "collateral.deposited":
        data = event["data"]
        await wallets.refresh_collateral(
            data["user_address"],
            data["asset_address"],
            data["network"],
        )

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