mj_controller/
server.rs

1//! Daemon-owned, phone-oriented control surface for Hel.
2//!
3//! The server deliberately owns no controller business logic. It publishes a
4//! redacted projection of controller state and forwards validated, typed
5//! actions through a channel supplied by the controller.
6
7use std::collections::BTreeMap;
8use std::convert::Infallible;
9use std::net::SocketAddr;
10use std::path::{Component, PathBuf};
11use std::sync::{Arc, Mutex};
12use std::time::{Duration, Instant, SystemTime, UNIX_EPOCH};
13
14use anyhow::{Context, Result as AnyResult};
15use axum::body::{Body, Bytes, to_bytes};
16use axum::extract::{DefaultBodyLimit, Path, Query, Request, State};
17use axum::http::header::{
18    CACHE_CONTROL, CONTENT_SECURITY_POLICY as CONTENT_SECURITY_POLICY_HEADER, CONTENT_TYPE, COOKIE,
19    HeaderValue, LOCATION, REFERRER_POLICY, SET_COOKIE, X_CONTENT_TYPE_OPTIONS,
20};
21use axum::http::{HeaderMap, Response, StatusCode};
22use axum::middleware::Next;
23use axum::response::IntoResponse;
24use axum::response::sse::{Event, KeepAlive, Sse};
25use axum::routing::{get, post, put};
26use axum::{Json, Router};
27use base64::Engine as _;
28use hmac::{Hmac, KeyInit, Mac};
29use serde::{Deserialize, Serialize};
30use sha2::Sha256;
31use tokio::sync::Semaphore;
32use tokio::sync::{mpsc, watch};
33use tokio_stream::wrappers::ReceiverStream;
34use tokio_util::sync::CancellationToken;
35
36use mj_core::attachment::{AttachmentRef, AttachmentStore, MAX_IMAGE_BYTES, MAX_IMAGES};
37use mj_core::config::{Config, TargetTemplate, project_history_host, validate_id};
38use mj_core::elicitation::{ElicitationRequest, ElicitationResponse, MAX_ELICITATION_BYTES};
39use mj_core::path_completion::{CompletionHost, CompletionKind, PathCompletion};
40use mj_core::refusal::{Refusal, RefusalKind};
41use mj_core::state::{
42    MoveOperation, MovePhase, MovePreparation, MoveSelection, MoveSessionRequest,
43    ProjectSourceIdentity, SessionResourceAllocation, SessionState, SessionTransitionKind,
44    State as AppState,
45};
46
47use crate::targets::AdditionalMount;
48
49use crate::dictation::{
50    DictationError, DictationOperation, DictationRequest, DictationResponse, MAX_AUDIO_BYTES,
51    validate_wav,
52};
53use crate::image::optimize_image;
54
55pub mod api;
56
57pub use api::{
58    ApiFailure, ApiSession, PromptRequest, PromptResponse, SessionListResponse,
59    StartSessionRequest, StartSessionResponse, SubagentBackend, WaitOutcome, WaitRequest,
60    WaitResponse, api_token_path, load_or_create_api_token, map_stop_reason, resolve_wait,
61};
62
63pub use mj_client::web::{
64    BrowserDiffStat, BrowserTranscript, BrowserTranscriptEntry, WebListenerProcess,
65    WebViewerAccess, WebViewerRecovery,
66};
67
68// Keep all control surfaces on the same queue vocabulary. The resume flow
69// used to define a private copy here, which made a move request impossible to
70// pass through the web and daemon boundaries without lossy conversion.
71pub use mj_core::state::ResumeQueueDisposition;
72
73/// Select the process-wide rustls provider before any TLS configuration is built.
74///
75/// Dependency feature unification can enable both rustls providers. Rustls
76/// deliberately refuses to guess in that case, so each executable that links
77/// the controller installs the ring provider at process startup. A provider
78/// installed even earlier is already sufficient and remains in place.
79pub fn install_rustls_crypto_provider() {
80    let _ = rustls::crypto::ring::default_provider().install_default();
81}
82
83pub const COOKIE_NAME: &str = "hel_viewer_session";
84const DEFAULT_SESSION_TTL: Duration = Duration::from_secs(30 * 24 * 60 * 60);
85const EPHEMERAL_SESSION_TTL: Duration = Duration::from_secs(24 * 60 * 60);
86const MAX_BODY_BYTES: usize = 128 * 1024;
87const MAX_CODE_FAILURES: u32 = 5;
88const CODE_LOCKOUT_BASE: Duration = Duration::from_secs(30);
89const CODE_LOCKOUT_CAP: Duration = Duration::from_secs(60 * 60);
90const MAX_TITLE_CHARS: usize = 120;
91const MAX_PROMPT_CHARS: usize = 64 * 1024;
92/// How many repositories one dirty-worktree acknowledgement may name. A bundle
93/// with more repositories than this than has bigger problems than the phone.
94const MAX_DIRTY_ACKNOWLEDGEMENTS: usize = 32;
95/// The largest draft a phone may store. A composer is for a prompt, and a
96/// prompt this size has other problems; the bound exists so one viewer cannot
97/// fill the daemon's database with text it never sent.
98const MAX_DRAFT_BYTES: usize = 64 * 1024;
99/// How many prompt-history matches one search returns. Public because the
100/// controller loop performs the search and must use the same bound the phone
101/// was promised.
102pub const MAX_HISTORY_MATCHES: usize = 40;
103/// Image prompts need far more room than any other phone request. Browser
104/// uploads are base64-encoded, so two ordinary photographs already exceed the
105/// general body limit even when each one fits it. The larger bound therefore
106/// stays scoped to the action route that carries prompts.
107const MAX_PROMPT_BODY_BYTES: usize = 32 * 1024 * 1024;
108/// A browser uploads one source image at a time. The image optimizer has its
109/// own decoded-allocation bound; this is the HTTP envelope bound before that
110/// work starts.
111const MAX_ATTACHMENT_UPLOAD_BYTES: usize = 64 * 1024 * 1024;
112/// Keep two browser uploads/transcriptions in flight. The permit is acquired
113/// before reading the request body, so an overloaded client is rejected
114/// without accepting megabytes that cannot be processed yet.
115const MAX_CONCURRENT_DICTATIONS: usize = 2;
116/// Keep this in sync with the prompt admission bound and the browser composer.
117pub const MAX_PROMPT_IMAGES: usize = MAX_IMAGES;
118const COOKIE_KEY_BYTES: usize = 32;
119const COOKIE_KEY_FILE: &str = "phone-cookie-key";
120
121/// How long stored viewer state outlives its last use.
122///
123/// It matches the session cookie's own lifetime: state keyed to an identity
124/// that can no longer authenticate has nothing left to belong to.
125pub const fn default_session_ttl() -> Duration {
126    DEFAULT_SESSION_TTL
127}
128
129pub fn cookie_key_path() -> PathBuf {
130    mj_core::config::data_dir().join(COOKIE_KEY_FILE)
131}
132
133/// Load the phone cookie signing key, creating it on first use.
134///
135/// This signing key keeps a signed-in phone signed in across daemon restarts.
136/// Logged-out identities are tracked separately. Deleting the key is
137/// therefore the explicit sign-everyone-out gesture: the next start writes a
138/// new key and every outstanding cookie stops validating. A missing file is
139/// ordinary first use; an unreadable or too-short one is replaced loudly,
140/// because refusing to start would be a worse answer than asking phones to
141/// enter the viewer code again.
142pub fn load_or_create_cookie_key(path: &std::path::Path) -> AnyResult<Vec<u8>> {
143    match std::fs::read(path) {
144        Ok(key) if key.len() >= COOKIE_KEY_BYTES => return Ok(key),
145        Ok(key) => tracing::warn!(
146            path = %path.display(),
147            bytes = key.len(),
148            "phone cookie key is shorter than {COOKIE_KEY_BYTES} bytes; generating a new key signs every phone out"
149        ),
150        Err(error) if error.kind() == std::io::ErrorKind::NotFound => {}
151        Err(error) => tracing::warn!(
152            path = %path.display(),
153            "could not read the phone cookie key ({error}); generating a new key signs every phone out"
154        ),
155    }
156    let key = generate_cookie_key()?;
157    mj_core::config::atomic_write(path, &key)
158        .with_context(|| format!("persist Mjolnir phone cookie key {}", path.display()))?;
159    Ok(key.to_vec())
160}
161
162/// Options for the daemon's phone service.
163///
164/// `ServerOptions::new` generates both the six-digit viewer code and an
165/// ephemeral cookie key. A caller that wants cookies to survive server
166/// restarts loads its key and logout records with `load_cookie_credentials`.
167/// `set_cookie_key` installs a key for callers managing storage themselves. The
168/// key and viewer code are intentionally omitted from `Debug` output.
169#[derive(Clone)]
170pub struct ServerOptions {
171    pub bind: SocketAddr,
172    pub snapshot_rx: watch::Receiver<ViewerSnapshot>,
173    pub conversation_rx: watch::Receiver<BTreeMap<String, BrowserTranscript>>,
174    pub action_tx: mpsc::Sender<ControllerRequest>,
175    pub bundle_tx: mpsc::Sender<BundleRequest>,
176    pub receipt_tx: mpsc::Sender<ReadReceiptRequest>,
177    pub preflight_tx: mpsc::Sender<PreflightRequest>,
178    pub move_preparation_tx: mpsc::Sender<MovePreparationRequest>,
179    pub client_state_tx: mpsc::Sender<ClientStateRequest>,
180    pub dictation_tx: mpsc::Sender<DictationRequest>,
181    /// Dedicated bounded path for stopping one live background task. This is
182    /// deliberately separate from [`ControllerAction`]: stopping a provider
183    /// task does not occupy the controller's action admission slot.
184    background_task_stop_tx: mpsc::Sender<BackgroundTaskStopRequest>,
185    pub shutdown: CancellationToken,
186    pub session_ttl: Duration,
187    /// Keep this enabled for direct HTTPS or an HTTPS reverse proxy. It may be
188    /// disabled only for an explicitly trusted HTTP development endpoint.
189    pub secure_cookie: bool,
190    tls_config: Option<axum_server::tls_rustls::RustlsConfig>,
191    viewer_code: String,
192    login_token: String,
193    cookie_key: Vec<u8>,
194    viewer_revocations: Arc<ViewerRevocations>,
195    api_token: String,
196    subagent: Option<Arc<dyn api::SubagentBackend>>,
197}
198
199/// Typed request channels served by the authenticated HTTP surface.
200pub struct ServerRequests {
201    pub action_tx: mpsc::Sender<ControllerRequest>,
202    pub bundle_tx: mpsc::Sender<BundleRequest>,
203    pub receipt_tx: mpsc::Sender<ReadReceiptRequest>,
204    pub preflight_tx: mpsc::Sender<PreflightRequest>,
205    pub move_preparation_tx: mpsc::Sender<MovePreparationRequest>,
206    pub client_state_tx: mpsc::Sender<ClientStateRequest>,
207    pub dictation_tx: mpsc::Sender<DictationRequest>,
208}
209
210impl ServerOptions {
211    pub fn new(
212        bind: SocketAddr,
213        snapshot_rx: watch::Receiver<ViewerSnapshot>,
214        conversation_rx: watch::Receiver<BTreeMap<String, BrowserTranscript>>,
215        requests: ServerRequests,
216    ) -> AnyResult<Self> {
217        let cookie_key = generate_cookie_key()?.to_vec();
218        Ok(Self {
219            bind,
220            snapshot_rx,
221            conversation_rx,
222            action_tx: requests.action_tx,
223            bundle_tx: requests.bundle_tx,
224            receipt_tx: requests.receipt_tx,
225            preflight_tx: requests.preflight_tx,
226            move_preparation_tx: requests.move_preparation_tx,
227            client_state_tx: requests.client_state_tx,
228            dictation_tx: requests.dictation_tx,
229            background_task_stop_tx: mpsc::channel(1).0,
230            shutdown: CancellationToken::new(),
231            session_ttl: DEFAULT_SESSION_TTL,
232            secure_cookie: true,
233            tls_config: None,
234            viewer_code: generate_viewer_code()?,
235            login_token: derive_login_token(&cookie_key),
236            cookie_key,
237            viewer_revocations: Arc::new(ViewerRevocations::default()),
238            // An empty token authenticates nothing: the daemon installs the
239            // persisted one, and a server without it serves the viewer only.
240            api_token: String::new(),
241            subagent: None,
242        })
243    }
244
245    pub fn viewer_code(&self) -> &str {
246        &self.viewer_code
247    }
248
249    pub fn login_token(&self) -> &str {
250        &self.login_token
251    }
252
253    /// Serve HTTPS directly using the supplied Rustls configuration. Hel's
254    /// CLI can load its persisted certificate (including a Tailscale-issued
255    /// certificate) and pass it here without coupling this module to disk.
256    pub fn set_tls_config(&mut self, config: axum_server::tls_rustls::RustlsConfig) {
257        self.tls_config = Some(config);
258        self.secure_cookie = true;
259    }
260
261    /// Install a persisted signing key. Rotating this value signs every phone
262    /// out and revokes QR login URLs. This does not load durable logout records;
263    /// use `load_cookie_credentials` for the daemon's persisted credentials.
264    pub fn set_cookie_key(&mut self, key: Vec<u8>) -> AnyResult<()> {
265        anyhow::ensure!(
266            key.len() >= COOKIE_KEY_BYTES,
267            "cookie signing key must be at least {COOKIE_KEY_BYTES} bytes"
268        );
269        self.login_token = derive_login_token(&key);
270        self.cookie_key = key;
271        Ok(())
272    }
273
274    /// Load the signing key and durable logout records off the async runtime.
275    pub async fn load_cookie_credentials(&mut self, path: PathBuf) -> AnyResult<()> {
276        let (key, revocations) = tokio::task::spawn_blocking(move || {
277            let key = load_or_create_cookie_key(&path)?;
278            let revocations =
279                ViewerRevocations::load(path.with_file_name("phone-cookie-revocations.json"))?;
280            Ok::<_, anyhow::Error>((key, revocations))
281        })
282        .await
283        .context("load viewer credentials task")??;
284        self.set_cookie_key(key)?;
285        self.viewer_revocations = Arc::new(revocations);
286        Ok(())
287    }
288
289    /// Install the controller's bounded background-task stop path.
290    pub fn set_background_task_stop_tx(&mut self, tx: mpsc::Sender<BackgroundTaskStopRequest>) {
291        self.background_task_stop_tx = tx;
292    }
293
294    /// Install the persisted bearer token for the `/api/v1` routes. Rotating
295    /// it revokes every client that still holds the old one.
296    pub fn set_api_token(&mut self, token: String) {
297        self.api_token = token;
298    }
299
300    /// Install the daemon-side backend the `/api/v1` routes drive sessions
301    /// through. Without it those routes answer 503.
302    pub fn set_subagent_backend(&mut self, backend: Arc<dyn api::SubagentBackend>) {
303        self.subagent = Some(backend);
304    }
305
306    #[cfg(test)]
307    fn with_test_credentials(mut self, code: &str, key: &[u8]) -> Self {
308        self.viewer_code = code.to_string();
309        self.login_token = "test-login-token".into();
310        self.cookie_key = key.to_vec();
311        self.secure_cookie = false;
312        self.api_token = "test-api-token".into();
313        self
314    }
315}
316
317/// Run the phone server until its shutdown token is cancelled.
318///
319/// This binds only the requested listener. It does not daemonize, provision a
320/// target, or keep sessions alive: controller availability is required, just
321/// like MJ's explicit remote-viewer model.
322pub async fn run_server(options: ServerOptions) -> AnyResult<()> {
323    let listener = tokio::net::TcpListener::bind(options.bind)
324        .await
325        .with_context(|| format!("bind web viewer to {}", options.bind))?;
326    run_server_on_listener(options, listener).await
327}
328
329/// Serve a reserved socket so readiness and advertised ports reflect a real listener.
330pub async fn run_server_on_listener(
331    options: ServerOptions,
332    listener: tokio::net::TcpListener,
333) -> AnyResult<()> {
334    let mut options = options;
335    let bind = listener.local_addr().context("read web viewer address")?;
336    let shutdown = options.shutdown.clone();
337    let viewer_code = options.viewer_code.clone();
338    let tls_config = options.tls_config.take();
339    let app = router(options);
340    println!("Mjolnir viewer code: {viewer_code}");
341    let listener = listener.into_std().context("prepare web viewer listener")?;
342    let handle = axum_server::Handle::new();
343    let shutdown_handle = handle.clone();
344    let serve = async move {
345        if let Some(tls_config) = tls_config {
346            axum_server::from_tcp_rustls(listener, tls_config)
347                .handle(handle)
348                .serve(app.into_make_service())
349                .await
350        } else {
351            axum_server::from_tcp(listener)
352                .handle(handle)
353                .serve(app.into_make_service())
354                .await
355        }
356    };
357    tokio::pin!(serve);
358    tokio::select! {
359        result = &mut serve => result,
360        _ = shutdown.cancelled() => {
361            shutdown_handle.graceful_shutdown(Some(Duration::from_secs(2)));
362            serve.await
363        }
364    }
365    .with_context(|| format!("serve web viewer on {bind}"))
366}
367
368mod viewer_types;
369pub use viewer_types::*;
370mod actions;
371pub use actions::*;
372mod routes;
373use routes::*;
374mod handlers;
375use handlers::*;
376mod validation;
377use validation::*;
378mod errors;
379use errors::*;
380mod auth;
381pub use auth::*;
382mod assets;
383use assets::*;
384mod config_view;
385pub use config_view::*;
386
387#[cfg(test)]
388mod tests;
mj_controller/server.rs

mj_controller/
server.rs
