{
  "eventId": "c1d2e3f4-5a6b-7c8d-9e0f-1a2b3c4d5e6f",
  "eventType": "viban_failed",
  "timestamp": "2026-05-10T12:34:56.789Z",
  "data": {
    "vibanId": "7a1f3c5b-2d8e-4f0a-9b6c-1e3d4f5a6b7c",
    "accountId": "4c2b8e5d-1f6a-4e7c-9d3b-2a8f5c1e9b4d",
    "rail": "SEPA",
    "status": "REJECTED",
    "reason": "OFAC hit on UBO 2026-05-10"
  }
}

app.post('/webhooks/ralio', async (req, res) => {
  const { eventType, data } = req.body;

  if (eventType === 'viban_failed') {
    const { vibanId, accountId, reason } = data;
    console.warn(`vIBAN ${vibanId} rejected on account ${accountId}: ${reason}`);

    // Mark the vIBAN as rejected and surface the reason to your operators
    await markVibanRejected(vibanId, reason);

    return res.status(200).json({ received: true });
  }
});

@app.route('/webhooks/ralio', methods=['POST'])
def handle_webhook():
    payload = request.get_json()

    if payload['eventType'] == 'viban_failed':
        data = payload['data']
        viban_id = data['vibanId']
        reason = data['reason']

        # Mark the vIBAN as rejected and surface the reason to your operators
        mark_viban_rejected(viban_id, reason)

        return jsonify({'received': True}), 200

func handleWebhook(w http.ResponseWriter, r *http.Request) {
    var payload struct {
        EventType string `json:"eventType"`
        Data      struct {
            VibanID   string `json:"vibanId"`
            AccountID string `json:"accountId"`
            Rail      string `json:"rail"`
            Status    string `json:"status"`
            Reason    string `json:"reason"`
        } `json:"data"`
    }

    if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
        http.Error(w, "Invalid JSON", http.StatusBadRequest)
        return
    }

    if payload.EventType == "viban_failed" {
        log.Printf("vIBAN %s rejected: %s", payload.Data.VibanID, payload.Data.Reason)

        if err := markVibanRejected(payload.Data.VibanID, payload.Data.Reason); err != nil {
            http.Error(w, "Internal error", http.StatusInternalServerError)
            return
        }

        w.Header().Set("Content-Type", "application/json")
        w.WriteHeader(http.StatusOK)
        json.NewEncoder(w).Encode(map[string]bool{"received": true})
    }
}