use std::io::Write;
use std::sync::{Mutex, OnceLock};
use serde::Serialize;
#[derive(Clone, Copy, Debug, Serialize)]
#[serde(rename_all = "lowercase")]
pub enum Phase {
In,
Out,
End,
Event,
}
struct Sink {
inner: Mutex<Inner>,
path: String,
}
struct Inner {
seq: u64,
file: Option<std::fs::File>,
}
static SINK: OnceLock<Sink> = OnceLock::new();
fn sink() -> &'static Sink {
SINK.get_or_init(|| {
let path = std::env::var("NORNIR_VIZ_TRACE")
.unwrap_or_else(|_| "/tmp/nornir_viz_trace.jsonl".to_string());
let file = std::fs::File::create(&path).ok();
let s = Sink { inner: Mutex::new(Inner { seq: 0, file }), path };
emit_into(&s, "trace.session", Phase::Event, &serde_json::json!({ "file": s.path }));
s
})
}
pub fn emit<T: Serialize>(span: &str, phase: Phase, data: &T) {
emit_into(sink(), span, phase, data);
}
pub fn emit_in<T: Serialize>(span: &str, data: &T) {
emit(span, Phase::In, data);
}
pub fn emit_out<T: Serialize>(span: &str, data: &T) {
emit(span, Phase::Out, data);
}
pub fn emit_end<T: Serialize>(span: &str, data: &T) {
emit(span, Phase::End, data);
}
pub fn emit_event<T: Serialize>(span: &str, data: &T) {
emit(span, Phase::Event, data);
}
fn emit_into<T: Serialize>(s: &Sink, span: &str, phase: Phase, data: &T) {
let now = chrono::Local::now();
let stamp = now.format("%H:%M:%S%.3f").to_string();
let ts_ms = now.timestamp_millis();
let Ok(mut g) = s.inner.lock() else { return };
g.seq += 1;
let line = serde_json::json!({
"seq": g.seq,
"ts_ms": ts_ms,
"stamp": stamp,
"span": span,
"phase": phase,
"data": serde_json::to_value(data).unwrap_or(serde_json::Value::Null),
});
if let Some(f) = g.file.as_mut() {
let _ = writeln!(f, "{line}");
let _ = f.flush();
}
}
#[cfg(test)]
mod tests {
use super::*;
#[derive(Serialize)]
struct Payload {
repo: String,
symbols: usize,
}
#[test]
fn writes_jsonl_lines_with_real_payload() {
let path = "/tmp/nornir_viz_trace_test.jsonl";
std::env::set_var("NORNIR_VIZ_TRACE", path);
emit_in("knowledge.scan", &serde_json::json!({ "repos": ["njord"] }));
emit_end("knowledge.scan.repo", &Payload { repo: "njord".into(), symbols: 642 });
let body = std::fs::read_to_string(path).unwrap();
let lines: Vec<&str> = body.lines().collect();
assert!(lines.len() >= 3, "expected >=3 lines, got {}", lines.len());
for l in &lines {
let v: serde_json::Value = serde_json::from_str(l).unwrap();
assert!(v.get("seq").is_some());
assert!(v.get("span").is_some());
assert!(v.get("phase").is_some());
assert!(v.get("data").is_some());
}
let last: serde_json::Value = serde_json::from_str(lines.last().unwrap()).unwrap();
assert_eq!(last["span"], "knowledge.scan.repo");
assert_eq!(last["phase"], "end");
assert_eq!(last["data"]["symbols"], 642);
}
}