REST API Integration

// streamer.js (Node.js 18+)

const apiKey = '<Your-Secret-Key>'
const agentId = '<Your Agent ID>'
const apiUrl = `https://api.mu.chat/api/v2/agents/${agentId}/chat`

async function readAgentReply() {
  const response = await fetch(apiUrl, {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${apiKey}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      message: '<Your query here>',
      stream: true,
      // conversationId: '<Conversation ID>', // omit to start a new conversation
    }),
  })

  if (!response.ok) {
    const { error } = await response.json()
    throw new Error(`${error.code}: ${error.message}`)
  }

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

  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() // keep any incomplete line for the next chunk

    for (const line of lines) {
      if (!line.startsWith('data: ')) continue
      const data = line.slice('data: '.length)
      if (data === '[DONE]') continue

      const event = JSON.parse(data)
      switch (event.type) {
        case 'text-delta':
          process.stdout.write(event.delta)
          break
        case 'finish':
          conversationId = event.messageMetadata.conversationId
          break
        case 'error':
          console.error('\nStream error:', event.errorText)
          break
      }
    }
  }

  console.log('\nConversation ID:', conversationId)
}

readAgentReply().catch((error) => console.log('Error:', error.message))

## streamer.py

import json
import requests

api_key = '<Your-Secret-Key>'
agent_id = '<Your Agent ID>'
api_url = f'https://api.mu.chat/api/v2/agents/{agent_id}/chat'

def read_agent_reply():
    try:
        headers = {
            'Authorization': f'Bearer {api_key}',
            'Content-Type': 'application/json'
        }

        data = {
            'message': '<Your query here>',
            'stream': True,
            # 'conversationId': '<Conversation ID>',  # omit to start a new conversation
        }

        response = requests.post(api_url, json=data, headers=headers, stream=True)
        response.raise_for_status()

        conversation_id = None
        for line in response.iter_lines(decode_unicode=True):
            if not line or not line.startswith('data: '):
                continue
            payload = line[len('data: '):]
            if payload == '[DONE]':
                continue

            event = json.loads(payload)
            if event['type'] == 'text-delta':
                print(event['delta'], end='', flush=True)
            elif event['type'] == 'finish':
                conversation_id = event['messageMetadata']['conversationId']
            elif event['type'] == 'error':
                print(f"\nStream error: {event['errorText']}")

        print(f'\nConversation ID: {conversation_id}')

    except requests.exceptions.RequestException as error:
        print('Error:', error)

read_agent_reply()