feat(webserver): Implement file search and meta query

crates/tabby-common/src/lib.rs

@@ -39,7 +39,7 @@
     }
 
     pub fn all() -> Result<impl Iterator<Item = Self>, Error> {
-        let files = glob::glob(format!("{}*", Self::files_jsonl().display()).as_str()).unwrap();
+        let files = glob::glob(&format!("{}*", Self::files_jsonl().display())).unwrap();
         let iter = files.filter_map(|x| x.ok()).flat_map(|path| {
             let fp = BufReader::new(File::open(path).unwrap());
             let reader = JsonLinesReader::new(fp);

ee/tabby-db/src/repositories.rs

@@ -1,5 +1,5 @@
 use anyhow::{anyhow, Result};
-use sqlx::{prelude::FromRow, query};
+use sqlx::{prelude::FromRow, query, query_scalar};
 
 use crate::{make_pagination_query, DbConn, SQLXResultExt};
 
@@ -64,6 +64,13 @@ impl DbConn {
             Err(anyhow!("failed to update: repository not found"))
         }
     }
+
+    pub async fn get_repository_git_url(&self, name: String) -> Result<String> {
+        let url = query_scalar!("SELECT git_url FROM repositories WHERE name = ?", name)
+            .fetch_one(&self.pool)
+            .await?;
+        Ok(url)
+    }
 }
 
 #[cfg(test)]
@@ -99,5 +106,9 @@ mod tests {
             .unwrap()[0];
         assert_eq!(repository.git_url, "testurl2");
         assert_eq!(repository.name, "test2");
+        assert_eq!(
+            conn.get_repository_git_url("test2".into()).await.unwrap(),
+            repository.git_url
+        );
     }
 }

ee/tabby-webserver/Cargo.toml

@@ -12,6 +12,7 @@ prod-db = ['tabby-db/prod-db']
 anyhow.workspace = true
 argon2 = "0.5.1"
 async-trait.workspace = true
+async-walkdir = "1.0.0"
 axum = { workspace = true, features = ["ws", "headers"] }
 base64 = "0.22.0"
 bincode = "1.3.3"

ee/tabby-webserver/graphql/schema.graphql

@@ -17,6 +17,11 @@ enum WorkerKind {
   CHAT
 }
 
+type FileEntry {
+  type: String!
+  path: String!
+}
+
 type Mutation {
   resetRegistrationToken: String!
   requestInvitationEmail(input: RequestInvitationInput!): Invitation!
@@ -81,6 +86,7 @@ type Query {
   networkSetting: NetworkSetting!
   securitySetting: SecuritySetting!
   repositories(after: String, before: String, first: Int, last: Int): RepositoryConnection!
+  repositorySearch(repository: String!, filter: String!): [FileEntry!]!
   oauthCredential(provider: OAuthProvider!): OAuthCredential
   oauthCallbackUrl(provider: OAuthProvider!): String!
   serverInfo: ServerInfo!