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/migrations/0021_repository-name-index.down.sql

@@ -0,0 +1 @@
+DROP INDEX idx_repository_name;

ee/tabby-db/migrations/0021_repository-name-index.up.sql

@@ -0,0 +1 @@
+CREATE INDEX idx_repository_name ON repositories(name);

ee/tabby-db/src/repositories.rs

@@ -64,6 +64,15 @@ impl DbConn {
             Err(anyhow!("failed to update: repository not found"))
         }
     }
+
+    pub async fn get_repository_by_name(&self, name: String) -> Result<RepositoryDAO> {
+        let repository =
+            sqlx::query_as("SELECT id, name, git_url FROM repositories WHERE name = ?;")
+                .bind(name)
+                .fetch_one(&self.pool)
+                .await?;
+        Ok(repository)
+    }
 }
 
 #[cfg(test)]
@@ -99,5 +108,12 @@ mod tests {
             .unwrap()[0];
         assert_eq!(repository.git_url, "testurl2");
         assert_eq!(repository.name, "test2");
+        assert_eq!(
+            conn.get_repository_by_name("test2".into())
+                .await
+                .unwrap()
+                .git_url,
+            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!