Streaming WebSocket

Connectez-vous à wss://gpt-de-babi.perfproai.com/api/partners/v1/chat avec les sous-protocoles gpt-de-babi.partner.v1 et le token utilisateur. Pendant le traitement, GPT de Babi envoie des statuts publics tels que « Je recherche les informations utiles ». Ils permettent à votre interface d’expliquer ce qui se passe sans exposer les outils internes, les prompts, les données de débogage ou le raisonnement privé du système.

Exemple complet prêt à copier

La fonction suivante fonctionne dans un navigateur et dans React Native. Fournissez les fonctions d’affichage adaptées à votre application.

const GPT_DE_BABI_WS_URL =
  "wss://gpt-de-babi.perfproai.com/api/partners/v1/chat";

export function streamGptDeBabiMessage({
  userToken,
  conversationId,
  clientMessageId,
  message,
  location,
  onStatus,
  onAnswer,
  onTurnAccepted,
  onCompleted,
  onError,
}) {
  const socket = new WebSocket(GPT_DE_BABI_WS_URL, [
    "gpt-de-babi.partner.v1",
    userToken,
  ]);

  let answer = "";

  socket.addEventListener("open", () => {
    socket.send(JSON.stringify({
      type: "user.message",
      conversation_id: conversationId,
      client_message_id: clientMessageId,
      message,
      location,
    }));
  });

  socket.addEventListener("message", ({ data }) => {
    const event = JSON.parse(data);

    switch (event.type) {
      case "turn.accepted":
        onTurnAccepted?.(event.turn_id);
        onStatus?.("Demande reçue par GPT de Babi…");
        break;

      case "turn.running":
        onStatus?.("GPT de Babi démarre la recherche…");
        break;

      case "assistant.status":
        // Texte public produit par GPT de Babi : affichez toujours `label`.
        onStatus?.(event.label, event.code);
        break;

      case "assistant.delta":
        answer += event.text;
        onAnswer?.(answer);
        break;

      case "assistant.completed":
        // `message.answer` est la version finale et persistée.
        onAnswer?.(event.message.answer);
        onCompleted?.(event.message);
        socket.close(1000, "completed");
        break;

      case "assistant.error":
        onError?.(event.error);
        break;
    }
  });

  socket.addEventListener("error", () => {
    onError?.({
      code: "websocket_error",
      message: "Connexion temps réel interrompue.",
      retryable: true,
    });
  });

  return () => socket.close(1000, "client_closed");
}

Exemple d’appel :

const stop = streamGptDeBabiMessage({
  userToken,
  conversationId,
  clientMessageId: crypto.randomUUID(),
  message: "Quelle pharmacie est de garde à Cocody ?",
  location: { city: "Abidjan", commune: "Cocody" },
  onStatus: (label) => setProgressLabel(label),
  onAnswer: (answer) => setAnswer(answer),
  onTurnAccepted: (turnId) => saveTurnId(turnId),
  onCompleted: (message) => {
    setProgressLabel("");
    setCards(message.cards ?? []);
    setSources(message.sources ?? []);
  },
  onError: (error) => showError(error.message),
});

// Appelez `stop()` si l'utilisateur quitte l'écran.

Progression publique de GPT de Babi

Un statut public est envoyé sous cette forme :

{
  "type": "assistant.status",
  "conversation_id": "0d1fc89d-bbb6-4826-a4e7-7e25738c2755",
  "turn_id": "944bc91d-a2c9-4c7b-952a-a5237636bf75",
  "code": "router",
  "label": "Je recherche les pharmacies de garde disponibles à Cocody."
}

Le champ label est le texte destiné à l’utilisateur. Utilisez code uniquement pour la télémétrie ou pour choisir une animation générique : de nouveaux codes peuvent être ajoutés sans changement de version.

Code	Signification actuelle
`router`	Mise à jour contextuelle rédigée par GPT de Babi pendant la recherche
`tool_selection`	Sélection des sources ou capacités nécessaires
`planning`	Traitement d’une demande comportant plusieurs étapes dépendantes
`context`	Rattachement de la demande au contexte de conversation
`response`	Préparation de la réponse finale
`working`	Valeur de repli lorsqu’aucune étape précise n’est disponible

Un même tour peut produire plusieurs événements assistant.status. Remplacez le statut affiché à chaque nouvel événement au lieu de les concaténer. Ces messages sont complets : ils ne sont pas diffusés caractère par caractère.

Événements serveur

Type	Usage
`turn.accepted`	Le message a été accepté et un `turn_id` a été attribué
`turn.snapshot`	État courant renvoyé après une reprise de suivi
`turn.running`	GPT de Babi a commencé le traitement
`assistant.status`	Étape publique de GPT de Babi à afficher temporairement
`assistant.delta`	Fragment incrémental de la réponse
`assistant.completed`	Réponse finale persistée et données de présentation
`assistant.error`	Erreur publique structurée
`pong`	Réponse au heartbeat `ping`

Reprendre après une déconnexion

Conservez le turn_id reçu avec turn.accepted. Après avoir recréé le WebSocket, abonnez-vous au tour pour obtenir son dernier état :

const socket = new WebSocket(GPT_DE_BABI_WS_URL, [
  "gpt-de-babi.partner.v1",
  userToken,
]);

socket.addEventListener("open", () => {
  socket.send(JSON.stringify({
    type: "turn.subscribe",
    turn_id: savedTurnId,
  }));
});

Le serveur répond avec turn.snapshot. Si le statut est encore queued ou running, laissez la connexion ouverte pour recevoir la suite. Si le tour est completed, la propriété message contient la réponse finale persistée.

N’ajoutez jamais le token dans la query string. Pour un client web, enregistrez exactement son origine HTTPS dans la console partenaire. Les clients mobiles natifs peuvent se connecter sans en-tête Origin.

Démarrage

Intégration

Exemple complet prêt à copier

Progression publique de GPT de Babi

Événements serveur

Reprendre après une déconnexion

​Exemple complet prêt à copier

​Progression publique de GPT de Babi

​Événements serveur

​Reprendre après une déconnexion

Exemple complet prêt à copier

Progression publique de GPT de Babi

Événements serveur

Reprendre après une déconnexion