Webhooks

app.post("/webhooks/djonanko", express.json(), async (req, res) => {
  const event = req.body;

  // 1. Répondre vite : on accuse réception avant tout traitement lourd
  res.sendStatus(200);

  try {
    // 2. Retrouver la commande
    const order = await findOrderByPaymentReference(event.reference);
    if (!order) return console.warn("Webhook pour une référence inconnue", event.reference);

    // 3. Idempotence : un webhook peut être rejoué
    if (order.status === "PAID") return;

    // 4. Confirmer côté Djonanko avant d'agir
    const { status } = await getPaymentStatus(event.reference);

    if (status === "SUCCESS") {
      await markOrderPaid(order.id, { fees: event.fees, provider: event.provider });
      await fulfillOrder(order.id);
    } else if (status === "FAILED") {
      await markOrderFailed(order.id);
    }
  } catch (err) {
    console.error("Erreur traitement webhook", err);
  }
});

// routes/api.php
Route::post('/webhooks/djonanko', [DjonankoWebhookController::class, 'handle'])
    ->withoutMiddleware([VerifyCsrfToken::class]);

// app/Http/Controllers/DjonankoWebhookController.php
public function handle(Request $request)
{
    $event = $request->all();

    // Traitement différé : la réponse 200 part immédiatement
    ProcessDjonankoPayment::dispatch($event['reference'], $event);

    return response()->noContent(200);
}

// app/Jobs/ProcessDjonankoPayment.php
public function handle(DjonankoClient $djonanko)
{
    $order = Order::where('payment_reference', $this->reference)->first();
    if (!$order || $order->status === 'paid') return;

    $status = $djonanko->paymentStatus($this->reference)['status'];

    if ($status === 'SUCCESS') {
        $order->markAsPaid($this->event['fees'] ?? 0);
    } elseif ($status === 'FAILED') {
        $order->markAsFailed();
    }
}

import json
from django.http import HttpResponse
from django.views.decorators.csrf import csrf_exempt
from django.views.decorators.http import require_POST

@csrf_exempt
@require_POST
def djonanko_webhook(request):
    event = json.loads(request.body)

    # Traitement asynchrone (Celery, RQ, …)
    process_djonanko_payment.delay(event["reference"], event)

    return HttpResponse(status=200)


@shared_task
def process_djonanko_payment(reference, event):
    order = Order.objects.filter(payment_reference=reference).first()
    if not order or order.status == "paid":
        return

    status = djonanko.payment_status(reference)["status"]
    if status == "SUCCESS":
        order.mark_paid(fees=event.get("fees", 0))
    elif status == "FAILED":
        order.mark_failed()