marcoallegretti/WEFT_OS
marcoallegretti/WEFT_OS
1
0
Fork 0
mirror of https://github.com/marcoallegretti/WEFT_OS.git synced 2026-03-27 09:23:09 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions
WEFT_OS/crates/weft-appd/Cargo.toml

22 lines
612 B
TOML
Raw Normal View History

feat(appd): add weft-appd skeleton crate and service unit New crate implementing the application daemon entry point: - crates/weft-appd/Cargo.toml: tokio (current-thread runtime), anyhow, sd-notify, tracing dependencies - crates/weft-appd/src/main.rs: async run() resolves IPC socket path from WEFT_APPD_SOCKET or XDG_RUNTIME_DIR/weft/appd.sock; stubs for AppRegistry, IpcServer, CompositorClient, RuntimeSupervisor, CapabilityBroker, ResourceController per WEFT-OS-APPD-DESIGN.md; sd_notify(READY=1) to be sent after IpcServer bind + CompositorClient connect - infra/systemd/weft-appd.service: Type=notify, Requires+After weft-compositor.service, After servo-shell.service Also fix two winit backend issues that were present in the working tree: - remove spurious mut on display binding (never mutated after init) - wrap std::env::set_var in unsafe block (required since Rust 1.80)
2026-03-11 00:13:18 +00:00
[package]
name = "weft-appd"
version.workspace = true
edition.workspace = true
rust-version.workspace = true
[[bin]]
name = "weft-appd"
path = "src/main.rs"
[dependencies]
anyhow = "1.0"
sd-notify = "0.4"
feat(appd): implement runtime supervisor with process spawning and READY signal runtime.rs — process lifecycle manager: - supervise(session_id, app_id, registry): spawns the weft-runtime child process identified by WEFT_RUNTIME_BIN env var. If unset, logs debug and returns immediately (no-op until runtime binary is available). - Child process invoked as: <WEFT_RUNTIME_BIN> <app_id> <session_id> with stdout/stderr piped, stdin closed. - wait_for_ready(): reads stdout line-by-line; returns Ok(()) on first line matching 'READY'; returns Err if stdout closes without it. - 30-second READY_TIMEOUT via tokio::time::timeout; on expiry, kills the child and transitions session to Stopped. - On success: sets session state to Running, broadcasts AppReady to all connected WebSocket clients via registry broadcast channel. - drain_stderr(): async task that forwards child stderr lines to tracing at WARN level for observability. - On process exit: sets session state to Stopped regardless of exit code. main.rs — wiring: - SessionRegistry now owns broadcast::Sender<Response>; Default creates the channel internally. Added set_state(), subscribe(), broadcast() methods. Removed standalone broadcast_tx from run(); WS handlers subscribe via registry.lock().await.subscribe(). - dispatch::LaunchApp spawns a tokio task calling runtime::supervise immediately after creating the session. supervise is a no-op when WEFT_RUNTIME_BIN is unset, so existing tests are unaffected. Cargo.toml: added tokio 'process' and 'time' features.
2026-03-11 08:17:20 +00:00
tokio = { version = "1", features = ["rt-multi-thread", "macros", "net", "io-util", "signal", "sync", "process", "time"] }
feat(appd): implement IPC server with Unix socket and MessagePack framing Replaces the skeleton bail with a functional IPC server. ipc.rs — transport layer: - Request enum: LaunchApp, TerminateApp, QueryRunning, QueryAppState. Serialized with serde MessagePack (rmp-serde, SCREAMING_SNAKE_CASE type tag). - Response enum: LaunchAck, AppReady, RunningApps, AppState, Error. - AppStateKind: Starting, Running, Stopping, Stopped, NotFound. - read_frame / write_frame: async 4-byte LE length-prefixed codec over any AsyncRead / AsyncWrite. main.rs — server: - SessionRegistry: in-memory HashMap<session_id, AppStateKind> with monotonic ID counter; launch / terminate / running_ids / state. - run(): creates socket parent directory, removes stale socket, binds UnixListener, sends sd_notify READY=1, then accept-loops with ctrl-c / SIGTERM shutdown. Cleans up socket on exit. - handle_connection(): splits stream into BufReader/BufWriter, reads request frames, calls dispatch, writes response frames. - dispatch(): maps Request variants to SessionRegistry operations; returns typed Response. Wasmtime spawning and compositor client deferred to later implementation. New deps: serde (derive), rmp-serde, tokio net/io-util/sync/rt-multi-thread.
2026-03-11 07:25:55 +00:00
serde = { version = "1", features = ["derive"] }
rmp-serde = "1"
feat(appd): add WebSocket UI endpoint for Servo shell integration Implements the weft-appd WebSocket server that allows the system-ui.html page running inside Servo to send requests and receive push notifications without requiring custom SpiderMonkey bindings. ws.rs — WebSocket connection handler: - Accepts a tokio TcpStream, performs WebSocket handshake via tokio-tungstenite accept_async. - Reads JSON Text frames, deserializes as Request (serde_json), calls dispatch(), sends Response as JSON Text. - Subscribes to a broadcast::Receiver<Response> for server-push notifications (APP_READY, etc.); forwards to client via select!. - Handles close frames, partial errors, and lagged broadcast gracefully. main.rs — server changes: - broadcast::channel(16) created at startup; WebSocket handlers subscribe for push delivery. - TcpListener bound on 127.0.0.1:7410 (default) or WEFT_APPD_WS_PORT. - ws_port() / write_ws_port(): port written to XDG_RUNTIME_DIR/weft/appd.wsport for runtime discovery. - WS accept branch added to the main select! loop alongside Unix socket. ipc.rs — Response and AppStateKind now derive Clone (required by broadcast::Sender<Response>). system-ui.html — appd WebSocket client: - appdConnect(): opens ws://127.0.0.1:<port>/appd with exponential backoff reconnect (1s → 16s max). - On open: sends QUERY_RUNNING to populate taskbar with live sessions. - handleAppdMessage(): maps LAUNCH_ACK and RUNNING_APPS to taskbar entries; APP_READY shows a timed notification; APP_STATE::stopped removes the taskbar entry. - WEFT_APPD_WS_PORT window global overrides the default port. New deps: tokio-tungstenite 0.24, futures-util 0.3 (sink+std), serde_json 1.
2026-03-11 08:01:54 +00:00
serde_json = "1"
tokio-tungstenite = "0.24"
futures-util = { version = "0.3", default-features = false, features = ["sink", "std"] }
feat(appd): add weft-appd skeleton crate and service unit New crate implementing the application daemon entry point: - crates/weft-appd/Cargo.toml: tokio (current-thread runtime), anyhow, sd-notify, tracing dependencies - crates/weft-appd/src/main.rs: async run() resolves IPC socket path from WEFT_APPD_SOCKET or XDG_RUNTIME_DIR/weft/appd.sock; stubs for AppRegistry, IpcServer, CompositorClient, RuntimeSupervisor, CapabilityBroker, ResourceController per WEFT-OS-APPD-DESIGN.md; sd_notify(READY=1) to be sent after IpcServer bind + CompositorClient connect - infra/systemd/weft-appd.service: Type=notify, Requires+After weft-compositor.service, After servo-shell.service Also fix two winit backend issues that were present in the working tree: - remove spurious mut on display binding (never mutated after init) - wrap std::env::set_var in unsafe block (required since Rust 1.80)
2026-03-11 00:13:18 +00:00
tracing = "0.1"
tracing-subscriber = { version = "0.3", features = ["env-filter"] }
Reference in a new issue Copy permalink