Concevoir un système de paiement qui ne perd jamais aucune transaction

Pourquoi les paiements sont plus compliqués qu'on ne le croit

Modèle 1 : Clés d'idempotence

import uuid 
from django.db import models 

class Payment(models.Model):    
 class Status(models.TextChoices):        
 PENDING = 'pending'        
 PROCESSING = 'processing'        
 COMPLETED = 'completed'        
 FAILED = 'failed'    

 idempotency_key = models.UUIDField(        
 default=uuid.uuid4, unique=True, db_index=True
    )
    status = models.CharField(
        max_length=20, choices=Status.choices, default=Status.PENDING
    )
    amount = models.DecimalField(max_digits=10, decimal_places=2)
    stripe_payment_intent_id = models.CharField(
        max_length=255, null=True, blank=True
    )
    attempts = models.IntegerField(default=0)    

 class Meta:
        constraints = [
            models.UniqueConstraint(
                fields=['idempotency_key'],
                name='unique_payment_idempotency'
            )
        ]

Modèle 2 : Machine à états de paiement

VALID_TRANSITIONS = {
    'en attente' :    ['en cours de traitement', 'échec'],
    'en cours de traitement' : ['terminé', 'échec', 'en attente'],  # en attente = nouvelle tentative
    'terminé' :  ['refunded'],
    'failed':     ['pending'],  # réessayer
    'refunded':   [],  # état terminal
}

def transition_payment(payment, new_status):
    allowed = VALID_TRANSITIONS.get(payment.status, [])
    si new_status n'est pas dans allowed :
        lance une exception InvalidTransition(
            f"Impossible de passer de {payment.status} à {new_status}"
        )    

 old_status = payment.status
    payment.status = new_status
    payment.save()    

 # Enregistrer chaque transition dans le 
journal d'audit    PaymentAuditLog.objects.create(
        payment=payment,
        from_status=old_status,
        to_status=new_status,
    )

Modèle 3 : Réconciliation via Webhook

# Gestionnaire de webhook : la source de 

vérité@csrf_exemptdef stripe_webhook(request):
    payload = request.body
    sig = request.headers.get('Stripe-Signature')    

 try:
        event = stripe.Webhook.construct_event(
            payload, sig, settings.STRIPE_WEBHOOK_SECRET
        )
    except (ValueError, stripe.error.SignatureVerificationError) :
        return HttpResponse(status=400)    

 if event['type'] == 'payment_intent.succeeded' :
        intent = event['data']['object']
        payment = Payment.objects.get(
            stripe_payment_intent_id=intent['id']
        )
        transition_payment(payment, 'completed')
        # Traiter la commande ICI, pas dans la réponse de l'API
        fulfill_order(payment.order)

     elif event['type'] == 'payment_intent.payment_failed':
        intent = event['data']['object']
        payment = Payment.objects.get(
            stripe_payment_intent_id=intent['id']
        )
        transition_payment(payment, 'failed')    

 return HttpResponse(status=200)

Les règles d'or du traitement des paiements

Dans les systèmes de paiement, l'optimisme est un bug. Partez du principe que chaque requête réseau échouera, que chaque webhook sera retardé et que chaque utilisateur cliquera deux fois sur le bouton.

— Blog technique de Stripe