Function read_log_stream

packages/server/src/logs.rs:172–195

(
    mut child: Child,
    stdout: ChildStdout,
    state: Arc<LogStreamState>,
)

}

async fn read_log_stream(
    mut child: Child,
    stdout: ChildStdout,
    state: Arc<LogStreamState>,
) -> Result<(), String> {
    let mut lines = BufReader::new(stdout).lines();
    while let Some(line) = lines.next_line().await.map_err(|error| error.to_string())? {
        let Some(entry) = parse_log_entry(&line) else {
            continue;
        };

        let mut entries = state.entries.lock().await;
        entries.push_back(entry);
        while entries.len() > MAX_LOG_ENTRIES {
            entries.pop_front();
        }
    }

    if matches!(child.try_wait(), Ok(None)) {
        let _ = child.kill().await;
    }
    let _ = child.wait().await;
    Ok(())
}

fn parse_log_entry(line: &str) -> Option<LogEntry> {
    let trimmed = line.trim();