Build a Real-Time Text Chat Interface

const token = 'YOUR_WEB_INTEGRATION_TOKEN';
const ws = new WebSocket(
  `wss://blackbox.dasha.ai/api/v1/ws/webCall?token=${token}`
);

ws.onopen = () => {
  // Send initialize message to start chat session
  ws.send(JSON.stringify({
    type: 'initialize',
    timestamp: new Date().toISOString(),
    request: {
      callType: 'chat',
      additionalData: {
        // Custom data passed to agent prompts
        userId: 'user-123',
        context: 'support'
      }
    }
  }));
};

{
  "type": "event",
  "name": "connection",
  "timestamp": "2025-01-20T10:00:01Z",
  "data": {
    "recordId": "call-abc123"
  }
}

function sendMessage(text) {
  if (ws.readyState !== WebSocket.OPEN) {
    console.error('WebSocket not connected');
    return;
  }

  ws.send(JSON.stringify({
    type: 'incomingChatMessage',
    content: text,
    timestamp: new Date().toISOString()
  }));
}

// Usage
sendMessage('Hello, I need help with my order');

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);

  switch (message.type) {
    case 'event':
      handleEvent(message);
      break;
    case 'text':
      handleTextMessage(message);
      break;
    case 'toolCall':
      handleToolCall(message);
      break;
    case 'toolCallResult':
      handleToolResult(message);
      break;
    case 'conversationResult':
      handleConversationResult(message);
      break;
    case 'error':
      handleError(message);
      break;
  }
};

function handleEvent(message) {
  switch (message.name) {
    case 'connection':
      console.log('Agent session ready');
      break;
    case 'opened':
      console.log('Conversation opened');
      break;
    case 'closed':
      console.log('Conversation closed');
      break;
  }
}

function handleTextMessage(message) {
  const { source, text } = message.content;

  if (source === 'assistant') {
    // Agent response
    displayAgentMessage(text);
  } else if (source === 'user') {
    // Echo of user message (for transcript)
    console.log('Message confirmed:', text);
  }
}

function handleError(message) {
  console.error('Error:', message.data.message);
  showErrorToUser(message.data.message);
}

{
  "type": "text",
  "timestamp": "2025-01-20T10:00:05Z",
  "content": {
    "source": "assistant",
    "text": "Hello! I'd be happy to help you with your order. Could you provide your order number?",
    "name": null
  }
}

function endConversation() {
  return new Promise((resolve, reject) => {
    let conversationResult = null;
    const timeout = setTimeout(() => {
      reject(new Error('Timeout waiting for conversation result'));
    }, 5000);

    const originalHandler = ws.onmessage;
    ws.onmessage = (event) => {
      const message = JSON.parse(event.data);

      if (message.type === 'conversationResult') {
        conversationResult = message.result;
        clearTimeout(timeout);
        ws.onmessage = originalHandler;
        resolve(conversationResult);
      } else {
        originalHandler(event);
      }
    };

    ws.send(JSON.stringify({
      type: 'terminate',
      timestamp: new Date().toISOString()
    }));
  });
}

// Usage
const result = await endConversation();
console.log('Conversation summary:', result);
ws.close();

{
  "type": "conversationResult",
  "timestamp": "2025-01-20T10:05:00Z",
  "result": {
    "status": "completed",
    "duration": 300,
    "metadata": {
      "callId": "call-abc123",
      "agentId": "agent-xyz"
    }
  }
}