Event Reference

{
  "eventId": "evt_abc123",
  "eventType": "INTENT_STATUS_CHANGED",
  "timestamp": "2026-03-29T10:00:00.000Z",
  "projectId": "proj_xyz789",
  "data": {
    "intentId": "int_def456",
    "customerId": "user-12345",
    "status": "COMPLIANCE_APPROVED",
    "previousStatus": "COMPLIANCE_IN_PROGRESS",
    "failureReason": null
  }
}

{
  "data": {
    "intentId": "int_def456",
    "status": "COMPLIANCE_FAILED",
    "failureReason": "KYC verification rejected - document expired"
  }
}

{
  "eventId": "evt_ghi789",
  "eventType": "COMPLIANCE_UPDATED",
  "timestamp": "2026-03-29T10:01:00.000Z",
  "projectId": "proj_xyz789",
  "data": {
    "intentId": "int_def456",
    "customerId": "user-12345",
    "requirementCode": "KYC_VERIFICATION",
    "status": "COMPLETED",
    "previousStatus": "IN_PROGRESS"
  }
}

{
  "eventId": "evt_jkl012",
  "eventType": "MONEY_MOVEMENT_UPDATED",
  "timestamp": "2026-03-29T10:05:00.000Z",
  "projectId": "proj_xyz789",
  "data": {
    "intentId": "int_def456",
    "customerId": "user-12345",
    "transactionId": "txn_mno345",
    "status": "SUCCESS",
    "previousStatus": "IN_PROGRESS"
  }
}

app.post('/webhooks/gnosis-ramp', (req, res) => {
  verifyWebhook(req, process.env.CLIENT_SECRET);

  const { eventType, data, eventId } = req.body;

  // Check for duplicate
  if (await isDuplicate(eventId)) {
    return res.status(200).send('OK');
  }

  switch (eventType) {
    case 'INTENT_STATUS_CHANGED':
      await handleIntentStatusChange(data);
      break;

    case 'COMPLIANCE_UPDATED':
      await handleComplianceUpdate(data);
      break;

    case 'MONEY_MOVEMENT_UPDATED':
      await handleTransactionUpdate(data);
      break;
  }

  await markProcessed(eventId);
  res.status(200).send('OK');
});

async function handleIntentStatusChange({ intentId, status, failureReason }) {
  switch (status) {
    case 'COMPLETED':
      await notifyUser(intentId, 'Your transfer is complete!');
      break;
    case 'COMPLIANCE_FAILED':
    case 'TRANSACTION_FAILED':
      await notifyUser(intentId, `Transfer failed: ${failureReason}`);
      break;
  }
}

async function handleTransactionUpdate({ intentId, status }) {
  if (status === 'SUCCESS') {
    await updateOrderStatus(intentId, 'completed');
  }
}