feat(document): add web document for preset / custom docs

ee/tabby-db/migrations/0036_web_document.down.sql

@@ -0,0 +1 @@
+DROP TABLE web_documents;

ee/tabby-db/migrations/0036_web_document.up.sql

@@ -0,0 +1,10 @@
+CREATE TABLE web_documents(
+     id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+     name VARCHAR(255) NOT NULL,
+     url TEXT NOT NULL,
+     is_preset BOOLEAN NOT NULL DEFAULT FALSE,
+     created_at TIMESTAMP NOT NULL DEFAULT(DATETIME('now')),
+     updated_at TIMESTAMP NOT NULL DEFAULT(DATETIME('now')),
+     CONSTRAINT idx_name UNIQUE(name),
+     CONSTRAINT idx_url UNIQUE(url)
+);

ee/tabby-db/schema/schema.sql

@@ -190,3 +190,13 @@ CREATE TABLE thread_messages(
   updated_at TIMESTAMP NOT NULL DEFAULT(DATETIME('now')),
   FOREIGN KEY(thread_id) REFERENCES threads(id) ON DELETE CASCADE
 );
+CREATE TABLE web_documents(
+  id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+  name VARCHAR(255) NOT NULL,
+  url TEXT NOT NULL,
+  is_preset BOOLEAN NOT NULL DEFAULT FALSE,
+  created_at TIMESTAMP NOT NULL DEFAULT(DATETIME('now')),
+  updated_at TIMESTAMP NOT NULL DEFAULT(DATETIME('now')),
+  CONSTRAINT idx_name UNIQUE(name),
+  CONSTRAINT idx_url UNIQUE(url)
+);

ee/tabby-db/src/lib.rs

@@ -22,6 +22,7 @@ use user_completions::UserCompletionDailyStatsDAO;
 pub use user_events::UserEventDAO;
 pub use users::UserDAO;
 pub use web_crawler::WebCrawlerUrlDAO;
+pub use web_documents::WebDocumentDAO;
 
 pub mod cache;
 mod email_setting;
@@ -41,6 +42,7 @@ mod user_completions;
 mod user_events;
 mod users;
 mod web_crawler;
+mod web_documents;
 
 use anyhow::Result;
 use sql_query_builder as sql;

ee/tabby-db/src/web_documents.rs

@@ -0,0 +1,77 @@
+use anyhow::{anyhow, Result};
+use chrono::{DateTime, Utc};
+use sqlx::{prelude::FromRow, query};
+use tabby_db_macros::query_paged_as;
+
+use crate::DbConn;
+
+#[allow(unused)]
+#[derive(FromRow)]
+pub struct WebDocumentDAO {
+    pub id: i64,
+    pub name: String,
+    pub url: String,
+    pub is_preset: bool,
+    pub created_at: DateTime<Utc>,
+    pub updated_at: DateTime<Utc>,
+}
+
+impl DbConn {
+    pub async fn list_web_documents(
+        &self,
+        limit: Option<usize>,
+        skip_id: Option<i32>,
+        backwards: bool,
+        is_preset: bool,
+    ) -> Result<Vec<WebDocumentDAO>> {
+        let condition = Some(format!("is_preset={}", is_preset));
+
+        let urls = query_paged_as!(
+            WebDocumentDAO,
+            "web_documents",
+            ["id", "name", "url", "is_preset", "created_at" as "created_at!: DateTime<Utc>", "updated_at" as "updated_at!: DateTime<Utc>"],
+            limit,
+            skip_id,
+            backwards,
+            condition
+        ).fetch_all(&self.pool)
+            .await?;
+
+        Ok(urls)
+    }
+
+    pub async fn create_web_document(
+        &self,
+        name: String,
+        url: String,
+        is_preset: bool,
+    ) -> Result<i64> {
+        let res = query!(
+            "INSERT INTO web_documents(name, url, is_preset) VALUES (?,?,?);",
+            name,
+            url,
+            is_preset
+        )
+        .execute(&self.pool)
+        .await?;
+
+        Ok(res.last_insert_rowid())
+    }
+
+    pub async fn deactivate_preset_web_document(&self, name: String) -> Result<()> {
+        let res = query!("DELETE FROM web_documents WHERE name = ?;", name)
+            .execute(&self.pool)
+            .await?;
+        if res.rows_affected() != 1 {
+            return Err(anyhow!("No preset web document to deactivate"));
+        }
+        Ok(())
+    }
+
+    pub async fn delete_web_document(&self, id: i64) -> Result<()> {
+        query!("DELETE FROM web_documents WHERE id = ?;", id)
+            .execute(&self.pool)
+            .await?;
+        Ok(())
+    }
+}

ee/tabby-schema/graphql/schema.graphql

@@ -99,6 +99,11 @@ input CodeSearchParamsOverrideInput {
   numToScore: Int
 }
 
+input CreateCustomDocumentInput {
+  name: String!
+  url: String!
+}
+
 input CreateIntegrationInput {
   displayName: String!
   accessToken: String!
@@ -188,6 +193,11 @@ input SecuritySettingInput {
   disableClientSideTelemetry: Boolean!
 }
 
+input SetPresetDocumentActiveInput {
+  name: String!
+  active: Boolean!
+}
+
 input ThreadRunDebugOptionsInput {
   codeSearchParamsOverride: CodeSearchParamsOverrideInput = null
 }
@@ -238,6 +248,25 @@ type CompletionStats {
   selects: Int!
 }
 
+type CustomDocumentConnection {
+  edges: [CustomDocumentEdge!]!
+  pageInfo: PageInfo!
+}
+
+type CustomDocumentEdge {
+  node: CustomWebDocument!
+  cursor: String!
+}
+
+type CustomWebDocument {
+  url: String!
+  name: String!
+  id: ID!
+  createdAt: DateTime!
+  updatedAt: DateTime!
+  jobInfo: JobInfo!
+}
+
 type DiskUsage {
   filepath: [String!]!
   "Size in kilobytes."
@@ -490,6 +519,9 @@ type Mutation {
   deleteWebCrawlerUrl(id: ID!): Boolean!
   "Delete pair of user message and bot response in a thread."
   deleteThreadMessagePair(threadId: ID!, userMessageId: ID!, assistantMessageId: ID!): Boolean!
+  createCustomDocument(input: CreateCustomDocumentInput!): ID!
+  deleteCustomDocument(id: ID!): Boolean!
+  setPresetDocumentActive(input: SetPresetDocumentActiveInput!): Boolean!
 }
 
 type NetworkSetting {
@@ -510,6 +542,25 @@ type PageInfo {
   endCursor: String
 }
 
+type PresetDocumentConnection {
+  edges: [PresetDocumentEdge!]!
+  pageInfo: PageInfo!
+}
+
+type PresetDocumentEdge {
+  node: PresetWebDocument!
+  cursor: String!
+}
+
+type PresetWebDocument {
+  id: ID!
+  name: String!
+  "`updated_at` is only filled when the preset is active."
+  updatedAt: DateTime
+  "`job_info` is only filled when the preset is active."
+  jobInfo: JobInfo
+}
+
 type ProvidedRepository {
   id: ID!
   integrationId: ID!
@@ -581,6 +632,8 @@ type Query {
     Thread is public within an instance, so no need to check for ownership.
   """
   threadMessages(threadId: ID!, after: String, before: String, first: Int, last: Int): MessageConnection!
+  customWebDocuments(after: String, before: String, first: Int, last: Int): CustomDocumentConnection!
+  presetWebDocuments(after: String, before: String, first: Int, last: Int, isActive: Boolean!): PresetDocumentConnection!
 }
 
 type RefreshTokenResponse {

ee/tabby-schema/src/schema/constants.rs

@@ -5,6 +5,8 @@ lazy_static! {
     pub static ref REPOSITORY_NAME_REGEX: Regex = Regex::new("^[a-zA-Z][\\w.-]+$").unwrap();
     pub static ref USERNAME_REGEX: Regex =
         Regex::new(r"^[^0-9±!@£$%^&*_+§¡€#¢¶•ªº«\\/<>?:;|=.,]{2,20}$").unwrap();
+    pub static ref WEB_DOCUMENT_NAME_REGEX: Regex =
+        Regex::new(r"^[A-Za-z][A-Za-z0-9]*(\ [A-Za-z0-9]+)*$").unwrap();
 }
 
 #[cfg(test)]
@@ -40,4 +42,23 @@ mod tests {
             assert_eq!(result, expected, "Failed for name: {}", name);
         }
     }
+
+    #[test]
+    fn test_web_document_name_regex() {
+        let test_cases = vec![
+            ("John", true),    // English name
+            ("Müller", false), // German name
+            ("abc123", true),
+            ("Abc 123", true),
+            (" abc 123", false),
+            ("abc123*", false),
+            ("abc123_", false),
+            ("abc  123", false), // two space
+        ];
+
+        for (name, expected) in test_cases {
+            let result = WEB_DOCUMENT_NAME_REGEX.is_match(name);
+            assert_eq!(result, expected, "Failed for name: {}", name);
+        }
+    }
 }

ee/tabby-schema/src/schema/mod.rs

@@ -10,6 +10,7 @@
 pub mod thread;
 pub mod user_event;
 pub mod web_crawler;
+pub mod web_documents;
 pub mod worker;
 
 use std::sync::Arc;
@@ -51,10 +52,12 @@
     },
     user_event::{UserEvent, UserEventService},
     web_crawler::{CreateWebCrawlerUrlInput, WebCrawlerService, WebCrawlerUrl},
+    web_documents::{CreateCustomDocumentInput, CustomWebDocument, WebDocumentService},
 };
 use crate::{
     env,
     juniper::relay::{self, query_async, Connection},
+    web_documents::{PresetWebDocument, SetPresetDocumentActiveInput},
 };
 
 pub trait ServiceLocator: Send + Sync {
@@ -71,6 +74,7 @@
     fn analytic(&self) -> Arc<dyn AnalyticService>;
     fn user_event(&self) -> Arc<dyn UserEventService>;
     fn web_crawler(&self) -> Arc<dyn WebCrawlerService>;
+    fn web_documents(&self) -> Arc<dyn WebDocumentService>;
     fn thread(&self) -> Arc<dyn ThreadService>;
 }
 
@@ -580,6 +584,50 @@
         )
         .await
     }
+
+    async fn custom_web_documents(
+        ctx: &Context,
+        after: Option<String>,
+        before: Option<String>,
+        first: Option<i32>,
+        last: Option<i32>,
+    ) -> Result<Connection<CustomWebDocument>> {
+        query_async(
+            after,
+            before,
+            first,
+            last,
+            |after, before, first, last| async move {
+                ctx.locator
+                    .web_documents()
+                    .list_custom_web_documents(after, before, first, last)
+                    .await
+            },
+        )
+        .await
+    }
+    async fn preset_web_documents(
+        ctx: &Context,
+        after: Option<String>,
+        before: Option<String>,
+        first: Option<i32>,
+        last: Option<i32>,
+        is_active: bool,
+    ) -> Result<Connection<PresetWebDocument>> {
+        query_async(
+            after,
+            before,
+            first,
+            last,
+            |after, before, first, last| async move {
+                ctx.locator
+                    .web_documents()
+                    .list_preset_web_documents(after, before, first, last, is_active)
+                    .await
+            },
+        )
+        .await
+    }
 }
 
 #[derive(GraphQLObject)]
@@ -959,6 +1007,36 @@
             .await?;
         Ok(true)
     }
+
+    async fn create_custom_document(ctx: &Context, input: CreateCustomDocumentInput) -> Result<ID> {
+        input.validate()?;
+        let id = ctx
+            .locator
+            .web_documents()
+            .create_custom_web_document(input.name, input.url)
+            .await?;
+        Ok(id)
+    }
+
+    async fn delete_custom_document(ctx: &Context, id: ID) -> Result<bool> {
+        ctx.locator
+            .web_documents()
+            .delete_custom_web_document(id)
+            .await?;
+        Ok(true)
+    }
+
+    async fn set_preset_document_active(
+        ctx: &Context,
+        input: SetPresetDocumentActiveInput,
+    ) -> Result<bool> {
+        input.validate()?;
+        ctx.locator
+            .web_documents()
+            .set_preset_web_documents_active(input.name, input.active)
+            .await?;
+        Ok(true)
+    }
 }
 
 async fn check_analytic_access(ctx: &Context, users: &[ID]) -> Result<(), CoreError> {