Chat

const response = await fetch('https://api.lvng.ai/api/v2/chat/stream', {
  method: 'POST',
  headers: {
    'Authorization': 'Bearer YOUR_JWT_TOKEN',
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    message: 'Summarize this week in the #general channel',
    userId: 'f6a7b8c9-0d1e-2f3a-4b5c-6d7e8f901234',
    channelId: 'a1b2c3d4-e5f6-7890-abcd-ef1234567890',
  }),
})

const reader = response.body!.getReader()
const decoder = new TextDecoder()
let buffer = ''
let fullText = ''

while (true) {
  const { done, value } = await reader.read()
  if (done) break

  buffer += decoder.decode(value, { stream: true })
  const lines = buffer.split('\n')
  buffer = lines.pop() || ''

  let currentEvent = ''
  for (const line of lines) {
    if (line.startsWith('event: ')) {
      currentEvent = line.slice(7)
    } else if (line.startsWith('data: ')) {
      const data = JSON.parse(line.slice(6))

      switch (currentEvent) {
        case 'connected':
          console.log('Stream started:', data.streamId)
          break
        case 'text_delta':
          fullText += data.content
          process.stdout.write(data.content)
          break
        case 'tool_start':
          console.log('\nTool started:', data.tool)
          break
        case 'tool_complete':
          console.log('Tool done:', data.tool, data.duration + 'ms')
          break
        case 'done':
          console.log('\n---')
          console.log('Response time:', data.responseTime + 'ms')
          console.log('Tools used:', data.toolsUsed)
          break
        case 'error':
          console.error('Stream error:', data.message)
          break
      }
    }
  }
}