Function enqueueLogLine

server/index.js:145–154

(line)

let logReadStream = null;

function enqueueLogLine(line) {
    const entry = { timestamp: Date.now(), line };
    logBuffer.push(entry);
    if (logBuffer.length > LOG_BUFFER_SIZE) logBuffer.shift();

    for (const sub of logSubscribers) {
        sub.queue.push(`data: ${JSON.stringify(entry)}\n\n`);
        flushSubscriber(sub);
    }
}

function flushSubscriber(sub) {
    if (sub.draining || sub.closed) return;