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

27 lines
721 B
TOML
Raw Permalink 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"
feat(appd): add compositor IPC client; send AppSurfaceCreated/Destroyed on session lifecycle Adds crates/weft-appd/src/compositor_client.rs: async Tokio client that connects to the compositor's Unix socket (/weft/compositor.sock or WEFT_COMPOSITOR_SOCKET), retrying every 2s on failure and 500ms on write error. Incoming CompositorToAppd frames are decoded and logged (SurfaceReady, ClientDisconnected). Wires compositor_tx into SessionRegistry. The supervise task now sends AppSurfaceCreated (with child PID) immediately after process spawn, and AppSurfaceDestroyed when the process exits. All three existing supervisor tests updated to pass None for compositor_tx.
2026-03-11 13:40:55 +00:00
weft-ipc-types = { path = "../weft-ipc-types" }
feat(appd): add QueryInstalledApps IPC request; wire launcher in system UI
2026-03-11 10:23:46 +00:00
toml = "0.8"
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"] }
feat: appd IPC relay, WIT interfaces, UI kit, gesture routing, and CI hardening - weft-appd: per-session IPC socket paths; bidirectional Wasm-HTML JSON relay via spawn_ipc_relay; SO_PEERCRED UID check on Unix socket connections; PanelGesture request and NavigationGesture broadcast for compositor gestures - weft-runtime: weft:app/ipc, weft:app/fetch, weft:app/notifications WIT interfaces; IpcState non-blocking Unix socket host functions; ureq-backed net:fetch host function (net-fetch feature); notify-send notifications host - weft-file-portal: spawn a thread per accepted connection for concurrent access - weft-app-shell: weft-system:// URL translation; WEFT UI Kit UserScript injection; resolve_weft_system_url helper - weft-servo-shell: forward compositor navigation gestures to weft-appd WebSocket as PanelGesture; WEFT UI Kit UserScript injection - infra/shell: weft-ui-kit.js with 11 custom elements (weft-button, weft-card, weft-dialog, weft-icon, weft-list, weft-list-item, weft-menu, weft-menu-item, weft-progress, weft-input, weft-label); system-ui.html handles NAVIGATION_GESTURE messages and dispatches weft:navigation-gesture CustomEvent - infra/systemd: add missing env vars to weft-appd.service; correct servo-shell.service binary path and system-ui.html argument - .github/workflows/ci.yml: exclude weft-servo-shell and weft-app-shell from cross-platform job; add them to linux-only job with libsystemd-dev dependency
2026-03-12 11:49:45 +00:00
libc = "0.2"
fix(appd): stabilize tests and unix-gate sd-notify
2026-03-13 11:52:39 +00:00
[target.'cfg(unix)'.dependencies]
sd-notify = "0.4"
Reference in a new issue Copy permalink