big heckin reworkerino to use the standard #line directive as per spec

server/logging/Cargo.toml

@@ -0,0 +1,13 @@
+[package]
+name = "logging"
+version = "0.9.5"
+authors = ["Noah Santschi-Cooney <noah@santschi-cooney.ch>"]
+edition = "2021"
+
+[dependencies]
+slog = { version = "2.7", features = [ "max_level_trace", "release_max_level_trace" ] }
+slog-term = "2.9"
+slog-scope = "4.4"
+slog-atomic = "3.1"
+rand = "0.8"
+lazy_static = "1.4"

server/logging/src/lib.rs

@@ -0,0 +1,43 @@
+use rand::{rngs, Rng};
+use slog::slog_o;
+use slog_scope::GlobalLoggerGuard;
+use slog_term::{FullFormat, PlainSyncDecorator};
+use std::{cell::RefCell, sync::Arc};
+
+use std::io::Stderr;
+
+use lazy_static::lazy_static;
+use slog::*;
+use slog_atomic::*;
+
+fn new_trace_id() -> String {
+    let rng = CURRENT_RNG.with(|rng| rng.borrow_mut().gen::<[u8; 4]>());
+    return format!("{:04x}", u32::from_be_bytes(rng));
+}
+
+pub fn slog_with_trace_id<F: FnOnce()>(f: F) {
+    slog_scope::scope(&slog_scope::logger().new(slog_o!("trace" => new_trace_id())), f)
+}
+
+pub fn set_logger_with_level(level: Level) -> GlobalLoggerGuard {
+    let drain = Arc::new(logger_base(level).fuse());
+    DRAIN_SWITCH.ctrl().set(drain.clone());
+    slog_scope::set_global_logger(Logger::root(drain, o!()))
+}
+
+fn logger_base(level: Level) -> LevelFilter<Fuse<FullFormat<PlainSyncDecorator<Stderr>>>> {
+    let plain = slog_term::PlainSyncDecorator::new(std::io::stderr());
+    let drain = slog_term::FullFormat::new(plain).build().fuse();
+    drain.filter_level(level)
+}
+
+thread_local! {
+    static CURRENT_RNG: RefCell<rngs::ThreadRng> = RefCell::new(rngs::ThreadRng::default());
+}
+
+lazy_static! {
+    static ref DRAIN_SWITCH: AtomicSwitch<()> = {
+        let logger = logger_base(Level::Info).fuse();
+        AtomicSwitch::new(logger)
+    };
+}