release-app fix windows screenpipe install path

Author: louis030195

.github/workflows/ci.yml

@@ -112,7 +112,7 @@ jobs:
           cp screenpipe-vision/tests/testing_OCR.png target/debug/deps/
 
       - name: Run specific Windows OCR cargo test
-        run: cargo test test_process_ocr_task_windows
+        run: cargo test test_process_ocr_task_windows pipes_test
 
   test-macos:
     runs-on: macos-latest

Cargo.toml

@@ -11,7 +11,7 @@ exclude = ["screenpipe-app-tauri/src-tauri"]
 resolver = "2"
 
 [workspace.package]
-version = "0.2.60"
+version = "0.2.61"
 authors = ["louis030195 <hi@louis030195.com>"]
 description = ""
 repository = "https://github.com/mediar-ai/screenpipe"

pipes/rewind/package.json

@@ -1,6 +1,10 @@
 {
   "name": "rewind",
+<<<<<<< Updated upstream
   "version": "0.1.13",
+=======
+  "version": "0.1.14",
+>>>>>>> Stashed changes
   "private": true,
   "scripts": {
     "dev": "next dev --turbopack",

screenpipe-app-tauri/src-tauri/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "screenpipe-app"
-version = "0.38.8"
+version = "0.38.9"
 description = ""
 authors = ["you"]
 license = ""

screenpipe-core/src/pipes.rs

@@ -818,6 +818,14 @@ pub async fn download_pipe(source: &str, screenpipe_dir: PathBuf) -> anyhow::Res
         debug!("Source is a URL: {}", parsed_url);
         if parsed_url.host_str() == Some("github.com") {
             download_github_folder(&parsed_url, &temp_dir).await
+        } else if cfg!(windows) && parsed_url.scheme().len() == 1 {
+            // This is likely a Windows path with drive letter being interpreted as URL scheme
+            debug!("Detected Windows path with drive letter, treating as local path");
+            let source_path = Path::new(source);
+            if !source_path.exists() || !source_path.is_dir() {
+                anyhow::bail!("Invalid local source path");
+            }
+            copy_dir_all(source_path, &temp_dir).await
         } else {
             anyhow::bail!("Unsupported URL format");
         }

screenpipe-core/tests/pipes_test.rs

@@ -238,4 +238,49 @@ mod tests {
             time_diff
         );
     }
+
+    #[tokio::test]
+    #[cfg(windows)]
+    async fn test_download_pipe_windows_path() {
+        init();
+        let temp_dir = TempDir::new().unwrap();
+        let screenpipe_dir = temp_dir.path().to_path_buf();
+
+        // Create a source directory with a simple pipe
+        let source_dir = temp_dir.path().join("source_pipe");
+        tokio::fs::create_dir_all(&source_dir).await.unwrap();
+
+        // Create a basic pipe.js file
+        tokio::fs::write(
+            source_dir.join("pipe.js"),
+            r#"console.log("Hello from Windows pipe test!");"#,
+        )
+        .await
+        .unwrap();
+
+        // Get the absolute Windows path with backslashes
+        let source_path = source_dir.to_str().unwrap().replace("/", "\\");
+        println!("Testing Windows path: {}", source_path);
+
+        // Try to download the pipe using the Windows path
+        let result = download_pipe(&source_path, screenpipe_dir.clone()).await;
+
+        // The function should succeed with a Windows path
+        assert!(
+            result.is_ok(),
+            "Failed to handle Windows path: {:?}",
+            result.err()
+        );
+
+        // Verify the pipe was copied correctly
+        let pipe_name = source_dir.file_name().unwrap().to_str().unwrap();
+        let dest_path = screenpipe_dir
+            .join("pipes")
+            .join(format!("{}_local", pipe_name));
+        assert!(dest_path.exists(), "Destination pipe directory not found");
+        assert!(
+            dest_path.join("pipe.js").exists(),
+            "pipe.js not found in destination"
+        );
+    }
 }