Webhooks

curl -X POST https://dloopiq.onrender.com/api/v1/webhooks/configs \
  -H "Authorization: Bearer <jwt_acheteur>" \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://votre-serveur.com/webhook/dloopiq",
    "events": ["task.completed", "task.failed"],
    "secret": "votre_secret_pour_verifier_la_signature"
  }'

{
  "id": "cmpkb4ghw00016qduu44p7n2q",
  "url": "https://votre-serveur.com/webhook/dloopiq",
  "events": ["task.completed", "task.failed"],
  "isActive": true,
  "createdAt": "2026-05-25T10:00:00Z"
}

{
  "event": "task.completed",
  "taskId": "cmpkb4ghw00016qduu44p7n2q",
  "type": "SENTIMENT_ANALYSIS",
  "result": "Positif",
  "confidence": 0.87,
  "totalResponses": 3,
  "costCents": 20,
  "validatedAt": "2026-05-25T10:05:00Z"
}

{
  "event": "task.failed",
  "taskId": "cmpkb4ghw00016qduu44p7n2r",
  "type": "BINARY_CHOICE",
  "reason": "NO_CONSENSUS",
  "totalResponses": 3,
  "failedAt": "2026-05-25T10:10:00Z"
}

x-dloopiq-signature: sha256=abc123def456...

curl https://dloopiq.onrender.com/api/v1/webhooks/configs \
  -H "Authorization: Bearer <jwt_acheteur>"

curl -X PATCH https://dloopiq.onrender.com/api/v1/webhooks/configs/:id \
  -H "Authorization: Bearer <jwt_acheteur>" \
  -H "Content-Type: application/json" \
  -d '{ "isActive": false }'

curl -X DELETE https://dloopiq.onrender.com/api/v1/webhooks/configs/:id \
  -H "Authorization: Bearer <jwt_acheteur>"

// Express — endpoint webhook minimal
app.post('/webhook/dloopiq', express.raw({ type: 'application/json' }), (req, res) => {
  // 1. Vérifier la signature (voir guide)
  const isValid = verifySignature(req.body, req.headers['x-dloopiq-signature'], SECRET)
  if (!isValid) return res.status(401).send('Invalid signature')

  // 2. Traiter l'événement
  const event = JSON.parse(req.body.toString())

  if (event.event === 'task.completed') {
    console.log(`Tâche ${event.taskId} validée : ${event.result} (${event.confidence})`)
    // → Stocker en DB, notifier votre équipe, déclencher fine-tuning, etc.
  }

  // 3. Répondre rapidement
  res.status(200).json({ received: true })
})