Related Party KYC Session Created

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

  if (eventType === 'related_party.kyc_session_created') {
    const { businessUser, relatedParty, kycSession } = data;

    console.log(
      `KYC session ${kycSession.id} created for related party ${relatedParty.id} of ${businessUser.name}`,
    );

    await sendKycInvitation({
      to: relatedParty.email,
      verificationUrl: kycSession.url,
      expiresAt: kycSession.expiresAt,
      businessName: businessUser.name,
      relatedPartyName: `${relatedParty.firstName} ${relatedParty.lastName}`,
    });

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

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

    if payload['eventType'] == 'related_party.kyc_session_created':
        data = payload['data']
        business_user = data['businessUser']
        related_party = data['relatedParty']
        kyc_session = data['kycSession']

        send_kyc_invitation(
            to=related_party['email'],
            verification_url=kyc_session['url'],
            expires_at=kyc_session.get('expiresAt'),
            business_name=business_user['name'],
            related_party_name=f"{related_party['firstName']} {related_party['lastName']}",
        )

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

func handleWebhook(w http.ResponseWriter, r *http.Request) {
    var payload struct {
        EventType string `json:"eventType"`
        Data      struct {
            BusinessUser struct {
                ID   uint   `json:"id"`
                Name string `json:"name"`
            } `json:"businessUser"`
            RelatedParty struct {
                ID        string `json:"id"`
                FirstName string `json:"firstName"`
                LastName  string `json:"lastName"`
                Email     string `json:"email"`
            } `json:"relatedParty"`
            KycSession struct {
                ID        string  `json:"id"`
                URL       string  `json:"url"`
                ExpiresAt *string `json:"expiresAt,omitempty"`
            } `json:"kycSession"`
        } `json:"data"`
    }

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

    if payload.EventType == "related_party.kyc_session_created" {
        if err := sendKycInvitation(
            payload.Data.RelatedParty.Email,
            payload.Data.KycSession.URL,
            payload.Data.KycSession.ExpiresAt,
            payload.Data.BusinessUser.Name,
            payload.Data.RelatedParty.FirstName+" "+payload.Data.RelatedParty.LastName,
        ); 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})
    }
}