Harden recording capture, muxing, and recovery

.github/workflows/ci.yml

@@ -207,6 +207,10 @@ jobs:
       - name: Output .env file
         run: cat apps/desktop/.env
 
+      - name: Build cap-muxer sidecar
+        shell: bash
+        run: ./scripts/build-cap-muxer.sh ${{ matrix.settings.target }}
+
       - name: Build app
         working-directory: apps/desktop
         run: |

.github/workflows/publish.yml

@@ -188,6 +188,10 @@ jobs:
           echo 'VITE_SERVER_URL=${{ secrets.NEXT_PUBLIC_WEB_URL }}' >> .env
           echo 'RUST_TARGET_TRIPLE=${{ matrix.settings.target }}' >> .env
 
+      - name: Build cap-muxer sidecar
+        shell: bash
+        run: ./scripts/build-cap-muxer.sh ${{ matrix.settings.target }}
+
       - name: Build app
         working-directory: apps/desktop
         run: |

.gitignore

@@ -17,6 +17,8 @@ dist-ssr
 .env.test
 target
 target-agent
+target-phase8
+outputs
 .cursorrules
 .github/hooks
 

apps/cli/src/record.rs

@@ -61,6 +61,7 @@ impl RecordStart {
         let actor = studio_recording::Actor::builder(path, target_info)
             .with_system_audio(self.system_audio)
             .with_custom_cursor(false)
+            .with_fragmented(false)
             .build(
                 #[cfg(target_os = "macos")]
                 Some(cap_recording::SendableShareableContent::from(

apps/desktop/src-tauri/Cargo.toml

@@ -48,7 +48,7 @@ serde = { workspace = true }
 serde_json = "1.0.111"
 specta.workspace = true
 specta-typescript = "0.0.7"
-tokio.workspace = true
+tokio = { workspace = true, features = ["signal"] }
 uuid = { version = "1.10.0", features = ["v4"] }
 image = "0.25.2"
 futures-intrusive = "0.5.0"

apps/desktop/src-tauri/binaries/.gitignore

@@ -0,0 +1,2 @@
+cap-muxer-*
+!.gitignore

apps/desktop/src-tauri/src/general_settings.rs

@@ -166,6 +166,10 @@ pub struct GeneralSettingsStore {
     pub camera_window_positions_by_monitor_name: BTreeMap<String, WindowPosition>,
     #[serde(default = "default_true")]
     pub has_completed_onboarding: bool,
+    #[serde(default = "default_true")]
+    pub enable_telemetry: bool,
+    #[serde(default)]
+    pub out_of_process_muxer: bool,
 }
 
 fn default_enable_native_camera_preview() -> bool {
@@ -248,6 +252,8 @@ impl Default for GeneralSettingsStore {
             camera_window_position: None,
             camera_window_positions_by_monitor_name: BTreeMap::new(),
             has_completed_onboarding: false,
+            enable_telemetry: true,
+            out_of_process_muxer: false,
         }
     }
 }
@@ -286,6 +292,8 @@ impl GeneralSettingsStore {
         store.set("general_settings", json!(settings));
         store.save().map_err(|e| e.to_string())?;
 
+        crate::posthog::set_telemetry_enabled(settings.enable_telemetry);
+
         #[cfg(target_os = "macos")]
         crate::permissions::sync_macos_dock_visibility(app);
 
@@ -314,6 +322,9 @@ pub fn init(app: &AppHandle) {
         }
     };
 
+    crate::posthog::set_telemetry_enabled(store.enable_telemetry);
+    register_bundled_muxer_binary(app);
+
     if let Err(e) = store.save(app) {
         error!("Failed to save general settings: {}", e);
     }
@@ -324,6 +335,35 @@ pub fn init(app: &AppHandle) {
     println!("GeneralSettingsState managed");
 }
 
+fn register_bundled_muxer_binary(_app: &AppHandle) {
+    if std::env::var_os(cap_recording::oop_muxer::ENV_BIN_PATH).is_some() {
+        return;
+    }
+
+    if let Ok(exe) = std::env::current_exe()
+        && let Some(dir) = exe.parent()
+    {
+        let candidate = dir.join(bundled_muxer_bin_name());
+        if candidate.exists() {
+            unsafe {
+                std::env::set_var(cap_recording::oop_muxer::ENV_BIN_PATH, &candidate);
+            }
+            tracing::info!(
+                path = %candidate.display(),
+                "Registered executable-adjacent cap-muxer binary for out-of-process muxer"
+            );
+        }
+    }
+}
+
+fn bundled_muxer_bin_name() -> &'static str {
+    if cfg!(windows) {
+        "cap-muxer.exe"
+    } else {
+        "cap-muxer"
+    }
+}
+
 #[tauri::command]
 #[specta::specta]
 #[instrument]

apps/desktop/src-tauri/src/lib.rs

@@ -27,6 +27,7 @@ mod posthog;
 mod presets;
 mod recording;
 mod recording_settings;
+mod recording_telemetry;
 mod recovery;
 mod screenshot_editor;
 mod target_select_overlay;
@@ -3678,6 +3679,31 @@ pub async fn run(recording_logging_handle: LoggingHandle, logs_dir: PathBuf) {
 
             gpu_context::prewarm_gpu();
 
+            #[cfg(unix)]
+            {
+                let app_for_signal = app.clone();
+                tokio::spawn(async move {
+                    use tokio::signal::unix::{SignalKind, signal};
+                    let Ok(mut term) = signal(SignalKind::terminate()) else {
+                        tracing::warn!("Failed to register SIGTERM handler");
+                        return;
+                    };
+                    let Ok(mut hup) = signal(SignalKind::hangup()) else {
+                        tracing::warn!("Failed to register SIGHUP handler");
+                        return;
+                    };
+                    tokio::select! {
+                        _ = term.recv() => {
+                            tracing::info!("Received SIGTERM; initiating graceful shutdown");
+                        }
+                        _ = hup.recv() => {
+                            tracing::info!("Received SIGHUP; initiating graceful shutdown");
+                        }
+                    }
+                    request_app_exit(app_for_signal).await;
+                });
+            }
+
             tokio::spawn({
                 let camera_feed = camera_feed.clone();
                 let app = app.clone();