Abonneren op stream

curl -N https://www.macaly.com/api/chat/abc123/subscribe \
  -H "Authorization: Bearer macaly_abc123..."

const response = await fetch(
  `https://www.macaly.com/api/chat/${chatId}/subscribe`,
  {
    headers: {
      'Authorization': 'Bearer macaly_abc123...',
    },
  }
);

if (response.status === 204) {
  console.log('No active stream');
  process.exit(0);
}

const reader = response.body.getReader();
const decoder = new TextDecoder();

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

  const chunk = decoder.decode(value);
  for (const line of chunk.split('\n')) {
    if (line.startsWith('0:')) {
      // Text content
      const text = JSON.parse(line.slice(2));
      process.stdout.write(text);
    }
  }
}

import requests

response = requests.get(
    f'https://www.macaly.com/api/chat/{chat_id}/subscribe',
    headers={
        'Authorization': 'Bearer macaly_abc123...',
    },
    stream=True,
)

if response.status_code == 204:
    print('No active stream')
else:
    for line in response.iter_lines():
        if line:
            line = line.decode('utf-8')
            if line.startswith('0:'):
                import json
                text = json.loads(line[2:])
                print(text, end='')