feat: added monitor device in vision tables and search query

screenpipe-server/src/db.rs

@@ -325,12 +325,13 @@ impl DatabaseManager {
 
         // Insert the new frame with file_path as name
         let id = sqlx::query(
-            "INSERT INTO frames (video_chunk_id, offset_index, timestamp, name) VALUES (?1, ?2, ?3, ?4)",
+            "INSERT INTO frames (video_chunk_id, offset_index, timestamp, name, device_name) VALUES (?1, ?2, ?3, ?4, ?5)",
         )
         .bind(video_chunk_id)
         .bind(offset_index)
         .bind(timestamp)
         .bind(file_path)
+        .bind(device_name)
         .execute(&mut *tx)
         .await?
         .last_insert_rowid();
@@ -339,6 +340,8 @@ impl DatabaseManager {
         // Commit the transaction
         tx.commit().await?;
 
+        debug!("Inserted frame {} for device {}", id, device_name);
+
         Ok(id)
     }
 
@@ -746,6 +749,7 @@ impl DatabaseManager {
                 ocr_text.app_name,
                 ocr_text.ocr_engine,
                 ocr_text.window_name,
+                video_chunks.device_name,
                 GROUP_CONCAT(tags.name, ',') as tags
             FROM {}
             JOIN frames ON ocr_text.frame_id = frames.id
@@ -795,6 +799,7 @@ impl DatabaseManager {
                 app_name: raw.app_name,
                 ocr_engine: raw.ocr_engine,
                 window_name: raw.window_name,
+                device_name: raw.device_name,
                 tags: raw
                     .tags
                     .map(|t| t.split(',').map(String::from).collect())
@@ -2095,6 +2100,7 @@ impl DatabaseManager {
                 ocr_engine: raw.ocr_engine,
                 window_name: raw.window_name,
                 frame_name: raw.frame_name,
+                device_name: raw.device_name,
                 tags: raw
                     .tags
                     .map(|t| t.split(',').map(String::from).collect())

screenpipe-server/src/db_types.rs

@@ -36,6 +36,7 @@ pub struct OCRResultRaw {
     pub ocr_engine: String,
     pub window_name: String,
     pub tags: Option<String>,
+    pub device_name: String,
 }
 
 #[derive(Debug, Serialize, Deserialize)]
@@ -51,6 +52,7 @@ pub struct OCRResult {
     pub ocr_engine: String,
     pub window_name: String,
     pub tags: Vec<String>,
+    pub device_name: String,
 }
 
 #[derive(Debug, Deserialize, PartialEq, Default, Clone)]

screenpipe-server/src/migrations/20250201232938_add_device_name_to_chunks.sql

@@ -0,0 +1,3 @@
+-- Add migration script here
+ALTER TABLE frames ADD COLUMN device_name TEXT NOT NULL DEFAULT '';
+CREATE INDEX idx_frames_device_name ON frames(device_name);