KYB State Updated

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

  if (eventType === 'kyb_state_updated') {
    const { kybId, userId, state } = data;

    console.log(
      `KYB ${kybId} for business user ${userId} changed to ${state}`
    );

    await updateBusinessUserKybLevel(userId, state);

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

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

    if payload['eventType'] == 'kyb_state_updated':
        data = payload['data']
        kyb_id = data['kybId']
        user_id = data['userId']
        state = data['state']

        print(f"KYB {kyb_id} for business user {user_id} changed to {state}")

        update_business_user_kyb_level(user_id, state)

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

func handleWebhook(w http.ResponseWriter, r *http.Request) {
    var payload struct {
        EventType string `json:"eventType"`
        Data      struct {
            KybID  int    `json:"kybId"`
            UserID string `json:"userId"`
            State  string `json:"state"`
        } `json:"data"`
    }

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

    if payload.EventType == "kyb_state_updated" {
        log.Printf(
            "KYB %d for business user %s changed to %s",
            payload.Data.KybID,
            payload.Data.UserID,
            payload.Data.State,
        )

        if err := updateBusinessUserKybLevel(payload.Data.UserID, payload.Data.State); 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})
    }
}