T2 (#168) Embedded tooling UI baseline (Open Props + screenshot regen)

.gitignore

@@ -28,3 +28,7 @@ pnpm-debug.log*
 # Temporary
 tmp
 temp
+
+# Playwright artifacts
+test-results
+playwright-report

crates/echo-session-client/examples/publish_pulse.rs

@@ -0,0 +1,103 @@
+// SPDX-License-Identifier: Apache-2.0
+// © James Ross Ω FLYING•ROBOTS <https://github.com/flyingrobots>
+//! Minimal CLI publisher for exercising the session hub / WVP pipeline.
+//!
+//! This example connects to the Unix socket session hub, sends a handshake,
+//! subscribes to a `warp_id`, then publishes:
+//! - a snapshot at epoch 0
+//! - N empty diffs (gapless epochs)
+//!
+//! It exists purely to make it easy to verify that `echo-session-service` +
+//! `echo-session-ws-gateway` + `/dashboard` are alive without needing to run the
+//! full GUI viewer.
+
+use anyhow::{Context, Result};
+use echo_session_proto::{
+    wire::encode_message, HandshakePayload, Message, RenderGraph, WarpDiff, WarpFrame, WarpId,
+    WarpSnapshot,
+};
+use std::io::Write;
+use std::os::unix::net::UnixStream;
+use std::time::Duration;
+
+fn main() -> Result<()> {
+    let mut args = std::env::args().skip(1);
+    let socket_path = args
+        .next()
+        .unwrap_or_else(|| "/tmp/echo-session.sock".to_string());
+    let warp_id: WarpId = args
+        .next()
+        .as_deref()
+        .unwrap_or("1")
+        .parse()
+        .context("parse warp_id")?;
+    let diffs: u64 = args
+        .next()
+        .as_deref()
+        .unwrap_or("5")
+        .parse()
+        .context("parse diffs")?;
+    let delay_ms: u64 = args
+        .next()
+        .as_deref()
+        .unwrap_or("250")
+        .parse()
+        .context("parse delay_ms")?;
+
+    let mut stream =
+        UnixStream::connect(&socket_path).with_context(|| format!("connect {socket_path}"))?;
+
+    // Best-effort: reduce latency if supported.
+    let _ = stream.set_nonblocking(false);
+
+    let pkt = encode_message(
+        Message::Handshake(HandshakePayload {
+            client_version: 1,
+            capabilities: vec!["demo:pulse".into()],
+            agent_id: Some("echo-session-client-example:publish_pulse".into()),
+            session_meta: None,
+        }),
+        0,
+    )
+    .context("encode handshake")?;
+    stream.write_all(&pkt).context("write handshake")?;
+
+    let pkt = encode_message(Message::SubscribeWarp { warp_id }, 0).context("encode subscribe")?;
+    stream.write_all(&pkt).context("write subscribe")?;
+
+    let snapshot = WarpFrame::Snapshot(WarpSnapshot {
+        epoch: 0,
+        graph: RenderGraph::default(),
+        state_hash: None,
+    });
+    let pkt = encode_message(
+        Message::WarpStream {
+            warp_id,
+            frame: snapshot,
+        },
+        0,
+    )
+    .context("encode snapshot")?;
+    stream.write_all(&pkt).context("write snapshot")?;
+
+    for i in 0..diffs {
+        let diff = WarpFrame::Diff(WarpDiff {
+            from_epoch: i,
+            to_epoch: i.saturating_add(1),
+            ops: vec![],
+            state_hash: None,
+        });
+        let pkt = encode_message(
+            Message::WarpStream {
+                warp_id,
+                frame: diff,
+            },
+            0,
+        )
+        .context("encode diff")?;
+        stream.write_all(&pkt).context("write diff")?;
+        std::thread::sleep(Duration::from_millis(delay_ms));
+    }
+
+    Ok(())
+}

crates/echo-session-ws-gateway/Cargo.toml

@@ -17,7 +17,9 @@ anyhow = "1"
 axum = { version = "0.8", features = ["ws"] }
 axum-server = { version = "0.8", features = ["tls-rustls"] }
 clap = { version = "4", features = ["derive"] }
+echo-session-proto = { version = "0.1.0", path = "../echo-session-proto" }
 futures-util = "0.3"
+serde = { version = "1.0", features = ["derive"] }
 tokio = { version = "1", features = ["rt-multi-thread", "macros", "net", "io-util", "signal", "time"] }
 tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["fmt", "env-filter"] }

crates/echo-session-ws-gateway/README.md

@@ -14,10 +14,17 @@ cargo run -p echo-session-ws-gateway -- \
   --tls-cert cert.pem --tls-key key.pem
 ```
 
+Then open:
+
+- `http://localhost:8787/dashboard` (session dashboard)
+- `http://localhost:8787/api/metrics` (JSON metrics)
+- `ws://localhost:8787/ws` (WebSocket endpoint)
+
 ## Features
 
 - Binary WS frames → JS-ABI packets over UDS
 - Payload guard (8 MiB default)
+- Built-in hub observer for `/dashboard` metrics (disable with `--no-observer`; configure with `--observe-warp`)
 - Optional origin allowlist
 - Optional TLS (rustls)
 - Ping/pong keepalive