Real-Time Stream

[
  {
    "id": "log_7f3a1b9c-…",
    "projectId": "YOUR_PROJECT_ID",
    "level": "ERROR",
    "message": "Unhandled exception in /v1/orders",
    "source": "api.handler",
    "ts": "2026-04-07T09:41:03Z",
    "tags": ["prod"],
    "meta": { "orderId": 9921 }
  }
]

const ws = new WebSocket(
  `wss://api.streamlogia.com/v1/projects/${projectId}/logs/stream?token=${apiKey}`
);

ws.onmessage = (event) => {
  const entries = JSON.parse(event.data);
  entries.forEach((log) => console.log(`[${log.level}] ${log.message}`));
};

import WebSocket from "ws";

const ws = new WebSocket(
  `wss://api.streamlogia.com/v1/projects/${projectId}/logs/stream?token=${apiKey}`
);

ws.on("message", (data) => {
  const entries = JSON.parse(data.toString());
  entries.forEach((log) => console.log(log));
});

function connect(delay = 1000) {
  const ws = new WebSocket(
    `wss://api.streamlogia.com/v1/projects/${projectId}/logs/stream?token=${apiKey}`
  );

  ws.onclose = () =>
    setTimeout(() => connect(Math.min(delay * 2, 30_000)), delay);

  ws.onmessage = (event) => {
    const entries = JSON.parse(event.data);
    // handle entries
  };
}

connect();