feat(remote): add transport providers with Cloudflare WS stub

Author: Dimillian

memory/decisions.md

@@ -204,3 +204,10 @@ Type: decision
 Event: Added daemon-side RPC parity coverage for recently extracted workspace/prompts/local-usage adapters and improved open-app failure diagnostics.
 Action: Added RPC tests in `src-tauri/src/bin/codex_monitor_daemon.rs` for `add_clone`, `prompts_list`, and `local_usage_snapshot` routing; updated `open_workspace_in_core` in `src-tauri/src/shared/workspaces_core.rs` to include bounded stdout/stderr snippets in non-zero exit errors.
 Rule: Keep daemon adapter parity guarded by RPC-level tests for representative workspace/prompts/local-usage methods, and preserve process-output context in open-app failure errors.
+
+## 2026-02-07 17:52
+Context: Remote backend transport abstraction for mobile bridge prep
+Type: decision
+Event: Remote backend was a single TCP-specific module with no transport-level provider split.
+Action: Refactored `src-tauri/src/remote_backend.rs` into `remote_backend/{mod,protocol,transport,tcp_transport,cloudflare_ws_transport}.rs`, added `remoteBackendProvider` + Cloudflare settings fields, kept TCP behavior as default, and added a Cloudflare transport stub that returns a clear not-implemented error.
+Rule: Keep remote transport wiring behind `RemoteTransport` and use provider selection in settings so new bridge transports can be added without touching command callsites.

memory/todo.md

@@ -2,6 +2,7 @@
 
 ## Open
 - [ ] 2026-02-07: Implement Orbit-only mobile remote foundation: Orbit transport in `remote_backend`, runner Orbit mode, hosted/self-host settings + pairing UX, and iOS keychain-backed auth storage.
+- [ ] 2026-02-07: Implement Cloudflare WebSocket transport internals behind `remoteBackendProvider=cloudflare` (handshake/auth/send/subscribe/reconnect/replay) and wire settings UX for worker/session inputs.
 
 ## Done
 - [x] 2026-02-07: Restored Sentry frontend reporting removed in `83a37da` (`@sentry/react`, `Sentry.init`, captureException callsites, and metrics instrumentation).

src-tauri/src/backend/app_server.rs

@@ -13,8 +13,8 @@ use tokio::sync::{mpsc, oneshot, Mutex};
 use tokio::time::timeout;
 
 use crate::backend::events::{AppServerEvent, EventSink};
-use crate::shared::process_core::{kill_child_process_tree, tokio_command};
 use crate::codex::args::parse_codex_args;
+use crate::shared::process_core::{kill_child_process_tree, tokio_command};
 use crate::types::WorkspaceEntry;
 
 #[cfg(target_os = "windows")]
@@ -110,14 +110,18 @@ pub(crate) fn build_codex_path_env(codex_bin: Option<&str>) -> Option<String> {
 
     #[cfg(not(target_os = "windows"))]
     {
-        extras.extend([
-            "/opt/homebrew/bin",
-            "/usr/local/bin",
-            "/usr/bin",
-            "/bin",
-            "/usr/sbin",
-            "/sbin",
-        ].into_iter().map(PathBuf::from));
+        extras.extend(
+            [
+                "/opt/homebrew/bin",
+                "/usr/local/bin",
+                "/usr/bin",
+                "/bin",
+                "/usr/sbin",
+                "/sbin",
+            ]
+            .into_iter()
+            .map(PathBuf::from),
+        );
 
         if let Ok(home) = env::var("HOME") {
             let home_path = Path::new(&home);
@@ -237,16 +241,14 @@ pub(crate) fn build_codex_command_with_bin(
 pub(crate) async fn check_codex_installation(
     codex_bin: Option<String>,
 ) -> Result<Option<String>, String> {
-    let mut command =
-        build_codex_command_with_bin(codex_bin, None, vec!["--version".to_string()])?;
+    let mut command = build_codex_command_with_bin(codex_bin, None, vec!["--version".to_string()])?;
     command.stdout(std::process::Stdio::piped());
     command.stderr(std::process::Stdio::piped());
 
     let output = match timeout(Duration::from_secs(5), command.output()).await {
         Ok(result) => result.map_err(|e| {
             if e.kind() == ErrorKind::NotFound {
-                "Codex CLI not found. Install Codex and ensure `codex` is on your PATH."
-                    .to_string()
+                "Codex CLI not found. Install Codex and ensure `codex` is on your PATH.".to_string()
             } else {
                 e.to_string()
             }
@@ -269,8 +271,7 @@ pub(crate) async fn check_codex_installation(
         };
         if detail.is_empty() {
             return Err(
-                "Codex CLI failed to start. Try running `codex --version` in Terminal."
-                    .to_string(),
+                "Codex CLI failed to start. Try running `codex --version` in Terminal.".to_string(),
             );
         }
         return Err(format!(
@@ -279,7 +280,11 @@ pub(crate) async fn check_codex_installation(
     }
 
     let version = String::from_utf8_lossy(&output.stdout).trim().to_string();
-    Ok(if version.is_empty() { None } else { Some(version) })
+    Ok(if version.is_empty() {
+        None
+    } else {
+        Some(version)
+    })
 }
 
 pub(crate) async fn spawn_workspace_session<E: EventSink>(

src-tauri/src/codex/args.rs

@@ -54,20 +54,20 @@ mod tests {
     #[test]
     fn parses_empty_args() {
         assert!(parse_codex_args(None).expect("parse none").is_empty());
-        assert!(parse_codex_args(Some("   ")).expect("parse blanks").is_empty());
+        assert!(parse_codex_args(Some("   "))
+            .expect("parse blanks")
+            .is_empty());
     }
 
     #[test]
     fn parses_simple_args() {
-        let args =
-            parse_codex_args(Some("--profile personal --flag")).expect("parse args");
+        let args = parse_codex_args(Some("--profile personal --flag")).expect("parse args");
         assert_eq!(args, vec!["--profile", "personal", "--flag"]);
     }
 
     #[test]
     fn parses_quoted_args() {
-        let args =
-            parse_codex_args(Some("--path \"a b\" --name='c d'")).expect("parse args");
+        let args = parse_codex_args(Some("--path \"a b\" --name='c d'")).expect("parse args");
         assert_eq!(args, vec!["--path", "a b", "--name=c d"]);
     }
 

src-tauri/src/codex/config.rs

@@ -90,7 +90,9 @@ fn read_feature_flag(key: &str) -> Result<Option<bool>, String> {
         return Ok(None);
     };
     let contents = read_config_contents_from_root(&root)?;
-    Ok(contents.as_deref().and_then(|value| find_feature_flag(value, key)))
+    Ok(contents
+        .as_deref()
+        .and_then(|value| find_feature_flag(value, key)))
 }
 
 fn write_feature_flag(key: &str, enabled: bool) -> Result<(), String> {
@@ -340,9 +342,7 @@ impl<T> RetainWithIndex<T> for Vec<T> {
 
 #[cfg(test)]
 mod tests {
-    use super::{
-        parse_personality_from_toml, remove_top_level_key, upsert_top_level_string_key,
-    };
+    use super::{parse_personality_from_toml, remove_top_level_key, upsert_top_level_string_key};
 
     #[test]
     fn parse_personality_reads_supported_values() {
@@ -354,21 +354,30 @@ mod tests {
             parse_personality_from_toml("personality = \"pragmatic\"\n"),
             Some("pragmatic")
         );
-        assert_eq!(parse_personality_from_toml("personality = \"unknown\"\n"), None);
+        assert_eq!(
+            parse_personality_from_toml("personality = \"unknown\"\n"),
+            None
+        );
     }
 
     #[test]
     fn upsert_top_level_personality_before_tables() {
         let input = "[features]\nsteer = true\n";
         let updated = upsert_top_level_string_key(input, "personality", "friendly");
-        assert_eq!(updated, "personality = \"friendly\"\n[features]\nsteer = true\n");
+        assert_eq!(
+            updated,
+            "personality = \"friendly\"\n[features]\nsteer = true\n"
+        );
     }
 
     #[test]
     fn upsert_replaces_existing_top_level_personality() {
         let input = "personality = \"friendly\"\n[features]\nsteer = true\n";
         let updated = upsert_top_level_string_key(input, "personality", "pragmatic");
-        assert_eq!(updated, "personality = \"pragmatic\"\n[features]\nsteer = true\n");
+        assert_eq!(
+            updated,
+            "personality = \"pragmatic\"\n[features]\nsteer = true\n"
+        );
     }
 
     #[test]

src-tauri/src/codex/home.rs

@@ -273,7 +273,10 @@ mod tests {
         assert_eq!(appdata, Some(PathBuf::from("/tmp/appdata-root/Codex")));
 
         let appdata_lower = normalize_codex_home("$appdata/Codex");
-        assert_eq!(appdata_lower, Some(PathBuf::from("/tmp/appdata-root/Codex")));
+        assert_eq!(
+            appdata_lower,
+            Some(PathBuf::from("/tmp/appdata-root/Codex"))
+        );
 
         match prev_home {
             Some(value) => std::env::set_var("HOME", value),