KYC Session Manual Review

{
  "eventId": "5ebcc965-3d96-4af1-8e75-9c97c26ef6da",
  "eventType": "kyc_session_manual_review",
  "timestamp": "2026-03-17T16:41:28.447Z",
  "data": {
    "sessionId": "f4456ae8-bf7b-4d48-a2a6-4fd0f3d598e9",
    "userId": "d67f9318-bce0-4600-98fc-e0d98d2b1a31",
    "entityType": "user"
  }
}

{
  "eventId": "d6dc91db-20e0-424b-9ad8-b45f27f88dcb",
  "eventType": "kyc_session_manual_review",
  "timestamp": "2026-03-17T16:45:03.993Z",
  "data": {
    "sessionId": "57b5628f-c392-4b43-aa00-e56b8bb25316",
    "relatedPartyId": "6cad4109-093d-4c29-ac84-d41a40ff2442",
    "entityType": "related-party"
  }
}

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

  if (eventType === 'kyc_session_manual_review') {
    const { sessionId, entityType, userId, relatedPartyId } = data;
    const subjectId = userId ?? relatedPartyId;

    console.log(`KYC session ${sessionId} moved to manual review for ${entityType} ${subjectId}`);

    await updateKycSessionStatus(sessionId, 'REVIEW');

    if (entityType === 'user' && userId) {
      await notifyComplianceTeam(userId, sessionId);
    }

    if (entityType === 'related-party' && relatedPartyId) {
      await notifyRelatedPartyComplianceTeam(relatedPartyId, sessionId);
    }

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

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

    if payload['eventType'] == 'kyc_session_manual_review':
        data = payload['data']
        session_id = data['sessionId']
        entity_type = data['entityType']
        user_id = data.get('userId')
        related_party_id = data.get('relatedPartyId')
        subject_id = user_id or related_party_id
        print(f"KYC session {session_id} moved to manual review for {entity_type} {subject_id}")
        update_kyc_session_status(session_id, 'REVIEW')
        if entity_type == 'user' and user_id:
            notify_compliance_team(user_id, session_id)

        if entity_type == 'related-party' and related_party_id:
            notify_related_party_compliance_team(related_party_id, session_id)

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

func handleWebhook(w http.ResponseWriter, r *http.Request) {
    var payload struct {
        EventType string `json:"eventType"`
        Data  struct {
            SessionID      string `json:"sessionId"`
            UserID         string `json:"userId"`
            RelatedPartyID string `json:"relatedPartyId"`
            EntityType     string `json:"entityType"`
        } `json:"data"`
    }

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

    if payload.EventType == "kyc_session_manual_review" {
        subjectID := payload.Data.UserID
        if subjectID == "" {
            subjectID = payload.Data.RelatedPartyID
        }

        log.Printf("KYC session %s moved to manual review for %s %s", payload.Data.SessionID, payload.Data.EntityType, subjectID)

        if err := updateKycSessionStatus(payload.Data.SessionID, "REVIEW"); err != nil {
            http.Error(w, "Internal error", http.StatusInternalServerError)
            return
        }

        if payload.Data.EntityType == "user" && payload.Data.UserID != "" {
            if err := notifyComplianceTeam(payload.Data.UserID, payload.Data.SessionID); err != nil {
                http.Error(w, "Internal error", http.StatusInternalServerError)
                return
            }
        }

        if payload.Data.EntityType == "related-party" && payload.Data.RelatedPartyID != "" {
            if err := notifyRelatedPartyComplianceTeam(payload.Data.RelatedPartyID, payload.Data.SessionID); 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})
    }
}