fix: change vidoes table schema and fix entitiy logics accordingly

migrations/2025-08-19-034235_create_videos/up.sql

@@ -2,5 +2,6 @@ CREATE TABLE videos (
     id BIGINT GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
     l SMALLINT NOT NULL,
     v SMALLINT NOT NULL,
+    watch_url TEXT NOT NULL,
     UNIQUE (l, v)
 )

migrations/2025-08-19-041510_create_keyframes/up.sql

@@ -2,6 +2,6 @@ CREATE TABLE keyframes (
     id BIGINT GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
     video_id BIGINT NOT NULL REFERENCES videos (id),
     video_related_frame_id SMALLINT NOT NULL,
-    video_related_frame_timestamp DOUBLE PRECISION NOT NULL,
+    video_related_frame_timestamp REAL NOT NULL,
     UNIQUE (video_id, video_related_frame_id)
 )

src/models/dtos/keyframes/mod.rs

@@ -4,7 +4,7 @@ use crate::models::entities::{keyframes::KeyframeEntity, videos::VideoEntity};
 pub struct KeyframeDto {
     id: i64,
     path: String,
-    timestamp: f64,
+    timestamp: f32,
 }
 
 impl From<(KeyframeEntity, VideoEntity)> for KeyframeDto {

src/models/dtos/videos/mod.rs

@@ -3,15 +3,14 @@ use crate::models::entities::videos::VideoEntity;
 #[derive(Debug, Clone, serde::Serialize, utoipa::ToSchema)]
 pub struct VideoDto {
     id: i64,
-    path: String,
+    watch_url: String,
 }
 
 impl From<VideoEntity> for VideoDto {
-    fn from(value: VideoEntity) -> Self {
-        let path = format!("/static/videos/L{}_V{:0>3}.mp4", value.l(), value.v());
+    fn from(mut value: VideoEntity) -> Self {
         Self {
             id: value.id(),
-            path,
+            watch_url: std::mem::take(value.watch_url_mut()),
         }
     }
 }

src/models/entities/keyframes/mod.rs

@@ -4,7 +4,7 @@
 pub struct KeyframeEntity {
     id: i64,
     video_related_frame_id: i16,
-    video_related_frame_timestamp: f64,
+    video_related_frame_timestamp: f32,
 }
 
 impl KeyframeEntity {
@@ -16,7 +16,7 @@ impl KeyframeEntity {
         self.video_related_frame_id
     }
 
-    pub fn video_related_frame_timestamp(&self) -> f64 {
+    pub fn video_related_frame_timestamp(&self) -> f32 {
         self.video_related_frame_timestamp
     }
 }

src/models/entities/videos/mod.rs

@@ -5,6 +5,7 @@ pub struct VideoEntity {
     id: i64,
     l: i16,
     v: i16,
+    watch_url: String,
 }
 
 impl VideoEntity {
@@ -19,4 +20,8 @@ impl VideoEntity {
     pub fn v(&self) -> i16 {
         self.v
     }
+
+    pub fn watch_url_mut(&mut self) -> &mut String {
+        &mut self.watch_url
+    }
 }

src/schema.rs

@@ -5,7 +5,7 @@ diesel::table! {
         id -> Int8,
         video_id -> Int8,
         video_related_frame_id -> Int2,
-        video_related_frame_timestamp -> Float8,
+        video_related_frame_timestamp -> Float4,
     }
 }
 
@@ -14,9 +14,13 @@ diesel::table! {
         id -> Int8,
         l -> Int2,
         v -> Int2,
+        watch_url -> Text,
     }
 }
 
 diesel::joinable!(keyframes -> videos (video_id));
 
-diesel::allow_tables_to_appear_in_same_query!(keyframes, videos,);
+diesel::allow_tables_to_appear_in_same_query!(
+    keyframes,
+    videos,
+);

src/services/vectors/keyframes/mod.rs

@@ -1,6 +1,6 @@
 use candle_core::{Device, Tensor};
 use candle_transformers::models::clip::ClipModel;
-use qdrant_client::{Qdrant, qdrant::SearchPointsBuilder};
+use qdrant_client::{Qdrant, qdrant::QueryPointsBuilder};
 use rayon::iter::{IntoParallelIterator, ParallelIterator};
 use tokenizers::Tokenizer;
 
@@ -50,11 +50,11 @@ impl<'a> VectorizedKeyframeService<'a> {
 
         let query_result = self
             .client
-            .search_points(SearchPointsBuilder::new(
-                "keyframes",
-                embeddings.squeeze(0)?.to_vec1::<f32>()?,
-                top_k,
-            ))
+            .query(
+                QueryPointsBuilder::new("keyframes")
+                    .query(embeddings.squeeze(0)?.to_vec1::<f32>()?)
+                    .limit(top_k),
+            )
             .await?
             .result;