Real-time Features

{
  "type": "rate-limit-exceeded",
  "retryAfter": 5000
}

import { io } from "socket.io-client";

const socket = io("wss://api.ansa.so", {
  path: "/socket",
  auth: {
    token: "your-api-key",
    conversationId: "conv_xxx"
  }
});

// Join a conversation
socket.emit("join-conversation", { conversationId: "conv_xxx" });

// Listen for typing indicators
socket.on("typing", ({ isTyping, userId }) => {
  if (isTyping) {
    showTypingIndicator(userId);
  } else {
    hideTypingIndicator(userId);
  }
});

// Send typing status
let typingTimeout;
input.addEventListener("input", () => {
  socket.emit("typing-start", { conversationId });
  clearTimeout(typingTimeout);
  typingTimeout = setTimeout(() => {
    socket.emit("typing-stop", { conversationId });
  }, 2000);
});

// Handle agent joining
socket.on("agent-joined", ({ agentName }) => {
  showSystemMessage(`${agentName} joined the conversation`);
});

// Handle reconnection
socket.on("message-replay", (messages) => {
  messages.forEach(appendMessage);
});