diff --git a/src/api/universal_search.rs b/src/api/universal_search.rs index 4b60aab..054a1f4 100644 --- a/src/api/universal_search.rs +++ b/src/api/universal_search.rs @@ -310,7 +310,7 @@ async fn search_chunks( }; let mut sql = format!( - "SELECT chunk_id, chunk_type, start_time, end_time, start_frame, end_frame, text_content, content FROM chunks WHERE uuid = '{}'", + "SELECT chunk_id, chunk_type, start_time, end_time, start_frame, end_frame, text_content, content FROM chunks WHERE file_uuid = '{}'", uuid ); if let Some(tr) = &req.time_range { @@ -454,13 +454,13 @@ async fn search_frames_internal( let video_table = "videos"; let mut sql = format!( - "SELECT f.frame_number, f.timestamp, f.yolo_objects, f.ocr_results, f.face_results, f.pose_results, v.uuid + "SELECT f.frame_number, f.timestamp, f.yolo_objects, f.ocr_results, f.face_results, f.pose_results, v.file_uuid FROM {} f JOIN {} v ON f.file_id = v.id WHERE 1=1", table, video_table ); if let Some(uuid) = &req.uuid { - sql.push_str(&format!(" AND v.uuid = '{}'", uuid)); + sql.push_str(&format!(" AND v.file_uuid = '{}'", uuid)); } if let Some(tr) = &req.time_range { sql.push_str(&format!( @@ -623,13 +623,13 @@ async fn search_frames_internal_v2( let video_table = "videos"; let mut sql = format!( - "SELECT f.frame_number, f.timestamp, f.yolo_objects, f.ocr_results, f.face_results, f.pose_results, v.uuid + "SELECT f.frame_number, f.timestamp, f.yolo_objects, f.ocr_results, f.face_results, f.pose_results, v.file_uuid FROM {} f JOIN {} v ON f.file_id = v.id WHERE 1=1", table, video_table ); if let Some(uuid) = &req.uuid { - sql.push_str(&format!(" AND v.uuid = '{}'", uuid)); + sql.push_str(&format!(" AND v.file_uuid = '{}'", uuid)); } if let Some(tr) = &req.time_range { sql.push_str(&format!(