WebSocket Connection

const token = "your-jwt-token";
const sessionId = "session-uuid";

const ws = new WebSocket(
  `wss://api.logfleet.io/api/v1/stream/ws/${sessionId}?token=${token}`
);

ws.onopen = () => {
  console.log("Connected to log stream");
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  if (data.type === "log") {
    console.log(`[${data.level}] ${data.message}`);
  } else if (data.type === "control") {
    console.log(`Control: ${data.event}`);
  }
};

ws.onclose = () => {
  console.log("Stream ended");
};

import websockets
import asyncio
import json

async def stream_logs(session_id, token):
    uri = f"wss://api.logfleet.io/api/v1/stream/ws/{session_id}?token={token}"

    async with websockets.connect(uri) as ws:
        async for message in ws:
            data = json.loads(message)
            if data["type"] == "log":
                print(f"[{data['level']}] {data['message']}")
            elif data["type"] == "control":
                print(f"Control: {data['event']}")

asyncio.run(stream_logs("session-uuid", "your-jwt-token"))