Messages

1. Client sends message via WebSocket
   ↓
2. Realtime Service receives and broadcasts
   ↓
3. Realtime Service publishes event to Redis
   ↓
4. Backend API persists message to database
   ↓
5. All connected clients receive message

import { Vocantly } from '@vocantly/sdk';

const client = new Vocantly({ /* config */ });
await client.connect();
await client.conversations.join(conversationId);

// Send a message
await client.messages.send({
  conversationId: conversationId,
  content: 'Hello, world!'
});

{
  "type": "message",
  "conversation_id": "conversation-uuid",
  "payload": {
    "message_id": "message-uuid",
    "content": "Hello, world!",
    "message_type": "text"
  }
}

// Using SDK
client.messages.on('message', (message) => {
  console.log('New message:', message.content);
  console.log('From:', message.sender_id);
  console.log('Type:', message.message_type);
});

const response = await fetch(
  `https://api.vocantly.com/api/v1/conversations/${conversationId}/messages?limit=50`,
  {
    headers: {
      'Authorization': `Bearer ${accessToken}`
    }
  }
);

const { messages, pagination } = await response.json();

{
  "success": true,
  "data": {
    "messages": [
      {
        "id": "message-uuid",
        "conversation_id": "conversation-uuid",
        "sender_id": "user-uuid",
        "sender_type": "sdk",
        "content": "Hello, world!",
        "message_type": "text",
        "created_at": "2024-01-01T00:00:00Z"
      }
    ],
    "pagination": {
      "has_next_page": true,
      "next_cursor": "2024-01-01T00:00:00Z",
      "limit": 50
    }
  }
}

{
  "message_type": "text",
  "content": "Hello, world!"
}

{
  "message_type": "system",
  "content": "Bot: I can help you with that!"
}

// Using SDK
client.messages.on('message', (message) => {
  console.log('Message state:', message.receiptState);
  
  // Listen for receipt updates
  message.on('receipt', (receipt) => {
    console.log('Receipt updated:', receipt);
  });
});

// First page
const page1 = await fetch(
  `https://api.vocantly.com/api/v1/conversations/${conversationId}/messages?limit=50`
);

// Next page
const page2 = await fetch(
  `https://api.vocantly.com/api/v1/conversations/${conversationId}/messages?limit=50&cursor=${page1.data.pagination.next_cursor}`
);

await client.messages.send({
  conversationId: conversationId,
  content: 'Check this out!',
  metadata: {
    attachment_url: 'https://example.com/file.pdf',
    attachment_type: 'pdf'
  }
});

client.on('error', (error) => {
  console.error('Connection error:', error);
  // Handle reconnection
});

try {
  await client.messages.send({
    conversationId: conversationId,
    content: 'Hello!'
  });
} catch (error) {
  console.error('Failed to send message:', error);
  // Handle error (e.g., retry, show to user)
}