Apply suggestions

crates/tabby-common/src/config.rs

@@ -147,9 +147,6 @@ impl Default for ServerConfig {
 pub trait RepositoryAccess: Send + Sync {
     async fn list_repositories(&self) -> Result<Vec<RepositoryConfig>>;
 
-    fn start_snapshot(&self) -> u64 {
-        Default::default()
-    }
     fn process_file(&self, _version: u64, _file: SourceFile) {}
     fn finish_snapshot(&self, _version: u64) {}
 }

crates/tabby-scheduler/src/dataset.rs

@@ -29,7 +29,7 @@ trait RepositoryExt {
         &self,
         writer: &mut impl Write,
         access: &impl RepositoryAccess,
-        cache_version: u64,
+        snapshot_version: u64,
     ) -> Result<()>;
 }
 
@@ -38,7 +38,7 @@ impl RepositoryExt for RepositoryConfig {
         &self,
         writer: &mut impl Write,
         access: &impl RepositoryAccess,
-        cache_version: u64,
+        snapshot_version: u64,
     ) -> Result<()> {
         let dir = self.dir();
 
@@ -81,7 +81,7 @@ impl RepositoryExt for RepositoryConfig {
                         content: file_content,
                     };
                     writer.write_json_lines([source_file.clone()])?;
-                    access.process_file(cache_version.clone(), source_file);
+                    access.process_file(snapshot_version.clone(), source_file);
                 }
                 Err(e) => {
                     error!("Cannot read {relative_path:?}: {e:?}");
@@ -119,7 +119,10 @@ pub fn create_dataset(config: &[RepositoryConfig], access: &impl RepositoryAcces
         None,
     );
 
-    let snapshot_version = access.start_snapshot();
+    let snapshot_version = std::time::SystemTime::now()
+        .duration_since(std::time::UNIX_EPOCH)
+        .expect("Failed to read system clock")
+        .as_millis() as u64;
     let mut deps = DependencyFile::default();
     for repository in config {
         deps::collect(repository.dir().as_path(), &mut deps);

ee/tabby-webserver/src/hub/api.rs

@@ -199,23 +199,6 @@ impl RepositoryAccess for SchedulerClient {
         Ok(self.0.list_repositories(Context::current()).await?)
     }
 
-    fn start_snapshot(&self) -> u64 {
-        let cache = match RepositoryCache::new() {
-            Ok(cache) => cache,
-            Err(e) => {
-                error!("Failed to open repository cache: {e}");
-                return 0;
-            }
-        };
-        match cache.get_next_version() {
-            Ok(v) => v,
-            Err(e) => {
-                error!("Failed to get next repository cache version: {e}");
-                0
-            }
-        }
-    }
-
     fn process_file(&self, version: u64, file: SourceFile) {
         let cache = match RepositoryCache::new() {
             Ok(cache) => cache,