refactor(webserver): cache list_repositories in CodeService

Cargo.toml

@@ -21,7 +21,7 @@ authors = ["TabbyML Team"]
 homepage = "https://github.com/TabbyML/tabby"
 
 [workspace.dependencies]
-cached = { version = "0.49.3", features = ["async"] }
+cached = "0.49.3"
 lazy_static = "1.4.0"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1"

crates/tabby-common/src/api/code.rs

@@ -36,6 +36,9 @@ pub enum CodeSearchError {
 
     #[error(transparent)]
     TantivyError(#[from] tantivy::TantivyError),
+
+    #[error(transparent)]
+    Other(#[from] anyhow::Error),
 }
 
 #[async_trait]

crates/tabby/Cargo.toml

@@ -59,7 +59,8 @@ thiserror.workspace = true
 chrono.workspace = true
 axum-prometheus = "0.4.0"
 uuid.workspace = true
-nucleo = { workspace = true }
+nucleo.workspace = true
+cached = { workspace = true, features = ["async"] }
 
 [dependencies.openssl]
 optional = true

crates/tabby/src/routes/search.rs

@@ -60,5 +60,9 @@
             warn!("{}", err);
             Err(StatusCode::BAD_REQUEST)
         }
+        Err(CodeSearchError::Other(err)) => {
+            warn!("{}", err);
+            Err(StatusCode::INTERNAL_SERVER_ERROR)
+        }
     }
 }

crates/tabby/src/services/code.rs

@@ -2,6 +2,7 @@
 
 use anyhow::Result;
 use async_trait::async_trait;
+use cached::{CachedAsync, TimedCache};
 use nucleo::Utf32String;
 use tabby_common::{
     api::code::{CodeSearch, CodeSearchError, Hit, HitDocument, SearchResponse},
@@ -25,6 +26,7 @@
 
     schema: CodeSearchSchema,
     repository_access: Arc<dyn RepositoryAccess>,
+    repo_cache: Mutex<TimedCache<(), Vec<RepositoryConfig>>>,
 }
 
 impl CodeSearchImpl {
@@ -47,6 +49,7 @@
             reader,
             query_parser,
             schema: code_schema,
+            repo_cache: Mutex::new(TimedCache::with_lifespan(10 * 60)),
         })
     }
 
@@ -126,11 +129,14 @@
         let language_query = self.schema.language_query(language);
         let body_query = self.schema.body_query(tokens);
 
-        let repos = self
-            .repository_access
-            .list_repositories()
-            .await
-            .unwrap_or_default();
+        let mut cache = self.repo_cache.lock().await;
+
+        let repos = cache
+            .try_get_or_set_with((), || async {
+                let repos = self.repository_access.list_repositories().await?;
+                Ok::<_, anyhow::Error>(repos)
+            })
+            .await?;
 
         let Some(git_url) = closest_match(git_url, repos.iter()) else {
             return Ok(SearchResponse::default());

crates/tabby/src/services/completion/completion_prompt.rs

@@ -200,6 +200,10 @@
             warn!("Failed to parse query: {}", err);
             return ret;
         }
+        Err(CodeSearchError::Other(err)) => {
+            warn!("Failed to search: {}", err);
+            return ret;
+        }
     };
 
     let mut count_characters = 0;

ee/tabby-db/Cargo.toml

@@ -18,7 +18,7 @@ sql_query_builder = { version = "2.1.0", features = ["sqlite"] }
 sqlx = { version = "0.7.3", features = ["sqlite", "chrono", "runtime-tokio", "macros"] }
 tokio = { workspace = true, features = ["fs"] }
 uuid.workspace = true
-cached.workspace = true
+cached = { workspace = true, features = ["async"]}
 
 [dev-dependencies]
 assert_matches = "1.5.0"

ee/tabby-webserver/Cargo.toml

@@ -15,7 +15,6 @@ async-trait.workspace = true
 axum = { workspace = true, features = ["ws", "headers"] }
 base64 = "0.22.0"
 bincode = "1.3.3"
-cached = { workspace = true }
 chrono = { workspace = true, features = ["serde"] }
 futures.workspace = true
 hash-ids.workspace = true

ee/tabby-webserver/src/handler.rs

@@ -8,7 +8,6 @@
     response::{IntoResponse, Response},
     routing, Extension, Json, Router,
 };
-use cached::{CachedAsync, TimedCache};
 use hyper::{header::CONTENT_TYPE, Body, StatusCode};
 use juniper::ID;
 use juniper_axum::{graphiql, playground};
@@ -21,7 +20,6 @@
     config::{RepositoryAccess, RepositoryConfig},
 };
 use tabby_db::DbConn;
-use tokio::sync::Mutex;
 use tracing::{error, warn};
 
 use crate::{
@@ -45,14 +43,18 @@
 struct RepositoryAccessImpl {
     git_repository_service: Arc<dyn GitRepositoryService>,
     github_repository_service: Arc<dyn GithubRepositoryProviderService>,
-    url_cache: Mutex<TimedCache<(), Vec<RepositoryConfig>>>,
 }
 
 #[async_trait]
 impl RepositoryAccess for RepositoryAccessImpl {
     async fn list_repositories(&self) -> anyhow::Result<Vec<RepositoryConfig>> {
-        let mut cache = self.url_cache.lock().await;
-        let mut repos = vec![];
+        let mut repos: Vec<RepositoryConfig> = self
+            .git_repository_service
+            .list(None, None, None, None)
+            .await?
+            .into_iter()
+            .map(|repo| RepositoryConfig::new(repo.git_url))
+            .collect();
 
         repos.extend(
             self.github_repository_service
@@ -63,24 +65,6 @@
                 .map(RepositoryConfig::new),
         );
 
-        repos.extend(
-            cache
-                .try_get_or_set_with((), || async {
-                    let repos = self
-                        .git_repository_service
-                        .list(None, None, None, None)
-                        .await?;
-                    Ok::<_, anyhow::Error>(
-                        repos
-                            .into_iter()
-                            .map(|repo| RepositoryConfig::new(repo.git_url))
-                            .collect(),
-                    )
-                })
-                .await?
-                .clone(),
-        );
-
         Ok(repos)
     }
 }
@@ -112,7 +96,6 @@
             repository_access: Arc::new(RepositoryAccessImpl {
                 git_repository_service,
                 github_repository_service,
-                url_cache: Mutex::new(TimedCache::with_lifespan(10 * 60)),
             }),
         }
     }