feat(webserver): add jobInfo / triggerJob graphql api

crates/tabby-scheduler/src/code/snapshots/tabby_scheduler__code__index__tests__code_splitter-2.snap

@@ -17,5 +17,5 @@ expression: "format!(\"{:#?}\", text_chunks)"
     "debug!(\"openai-chat request: {:?}\", request);\n        let s = stream! {\n            let s = match self.client.chat().create_stream(request).await {\n                Ok(x) => x,\n                Err(e) => {",
     "warn!(\"Failed to create completion request {:?}\", e);\n                    return;\n                }\n            };",
     "for await x in s {\n                match x {\n                    Ok(x) => {\n                        yield x.choices[0].delta.content.clone().unwrap_or_default();\n                    },\n                    Err(e) => {",
-    "warn!(\"Failed to stream response: {}\", e);\n                        break;\n                    }\n                };\n            }\n        };\n\n        Ok(Box::pin(s))\n    }\n}",
+    "// Stream finished.\n                        debug!(\"openai-chat stream finished: {:?}\", e);\n                        break;\n                    }\n                };\n            }\n        };\n\n        Ok(Box::pin(s))\n    }\n}",
 ]

crates/tabby-scheduler/src/code/snapshots/tabby_scheduler__code__index__tests__code_splitter.snap

@@ -30,5 +30,5 @@ expression: "format!(\"{:#?}\", rust_chunks)"
     "{\n                Ok(x) => x,\n                Err(e) => {\n                    warn!(\"Failed to create completion request {:?}\", e);\n                    return;\n                }\n            };\n\n            for await x in s",
     "{\n                match x",
     "{\n                    Ok(x) => {\n                        yield x.choices[0].delta.content.clone().unwrap_or_default();\n                    },\n                    Err(e) =>",
-    "{\n                        warn!(\"Failed to stream response: {}\", e);\n                        break;\n                    }\n                };\n            }\n        };\n\n        Ok(Box::pin(s))\n    }\n}",
+    "{\n                        // Stream finished.\n                        debug!(\"openai-chat stream finished: {:?}\", e);\n                        break;\n                    }\n                };\n            }\n        };\n\n        Ok(Box::pin(s))\n    }\n}",
 ]

ee/tabby-schema/graphql/schema.graphql

@@ -196,6 +196,7 @@ type GitRepository {
   name: String!
   gitUrl: String!
   refs: [String!]!
+  jobInfo: JobInfo!
 }
 
 type GrepFile {
@@ -262,6 +263,13 @@ type InvitationEdge {
   cursor: String!
 }
 
+type JobInfo {
+  "Last run of the job."
+  lastJobRun: JobRun
+  "The command to submit job run using triggerJobRun mutation."
+  command: String!
+}
+
 type JobRun {
   id: ID!
   job: String!
@@ -332,6 +340,8 @@ type Mutation {
   updateIntegration(input: UpdateIntegrationInput!): Boolean!
   deleteIntegration(id: ID!, kind: IntegrationKind!): Boolean!
   updateIntegratedRepositoryActive(id: ID!, active: Boolean!): Boolean!
+  "Trigger a job run given its command string."
+  triggerJobRun(command: String!): ID!
 }
 
 type NetworkSetting {
@@ -362,6 +372,7 @@ type ProvidedRepository {
   createdAt: DateTime!
   updatedAt: DateTime!
   refs: [String!]!
+  jobInfo: JobInfo!
 }
 
 type ProvidedRepositoryConnection {

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

@@ -22,6 +22,16 @@
     pub stderr: String,
 }
 
+#[derive(Debug, GraphQLObject)]
+#[graphql(context = Context)]
+pub struct JobInfo {
+    /// Last run of the job.
+    pub last_job_run: Option<JobRun>,
+
+    /// The command to submit job run using triggerJobRun mutation.
+    pub command: String,
+}
+
 #[derive(Debug, GraphQLObject)]
 pub struct JobStats {
     pub success: i32,

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

@@ -48,7 +48,7 @@
     user_event::{UserEvent, UserEventService},
 };
 use crate::{
-    env,
+    bail, env,
     juniper::relay::{self, query_async, Connection},
 };
 
@@ -800,6 +800,12 @@
             .await?;
         Ok(true)
     }
+
+    /// Trigger a job run given its command string.
+    async fn trigger_job_run(ctx: &Context, _command: String) -> Result<ID> {
+        check_admin(ctx).await?;
+        bail!("Not implemented")
+    }
 }
 
 async fn check_analytic_access(ctx: &Context, users: &[ID]) -> Result<(), CoreError> {

ee/tabby-schema/src/schema/repository/git.rs

@@ -4,6 +4,7 @@ use validator::Validate;
 
 use super::RepositoryProvider;
 use crate::{
+    job::JobInfo,
     juniper::relay::NodeType,
     schema::{Context, Result},
 };
@@ -27,6 +28,8 @@ pub struct GitRepository {
     pub name: String,
     pub git_url: String,
     pub refs: Vec<String>,
+
+    pub job_info: JobInfo,
 }
 
 impl NodeType for GitRepository {

ee/tabby-schema/src/schema/repository/third_party.rs

@@ -4,7 +4,9 @@ use juniper::{GraphQLObject, ID};
 use tabby_common::config::RepositoryConfig;
 
 use super::RepositoryProvider;
-use crate::{integration::IntegrationKind, juniper::relay::NodeType, schema::Result, Context};
+use crate::{
+    integration::IntegrationKind, job::JobInfo, juniper::relay::NodeType, schema::Result, Context,
+};
 
 #[derive(GraphQLObject)]
 #[graphql(context = Context)]
@@ -18,6 +20,8 @@ pub struct ProvidedRepository {
     pub created_at: DateTime<Utc>,
     pub updated_at: DateTime<Utc>,
     pub refs: Vec<String>,
+
+    pub job_info: JobInfo,
 }
 
 impl NodeType for ProvidedRepository {

ee/tabby-webserver/src/service/repository/git.rs

@@ -3,6 +3,7 @@ use juniper::ID;
 use tabby_common::config::RepositoryConfig;
 use tabby_db::{DbConn, RepositoryDAO};
 use tabby_schema::{
+    job::JobInfo,
     repository::{GitRepository, GitRepositoryService, Repository, RepositoryProvider},
     AsID, AsRowid, Result,
 };
@@ -94,6 +95,10 @@ fn to_git_repository(repo: RepositoryDAO) -> GitRepository {
         name: repo.name,
         refs: tabby_git::list_refs(&RepositoryConfig::new(&repo.git_url).dir()).unwrap_or_default(),
         git_url: repo.git_url,
+        job_info: JobInfo {
+            last_job_run: None,
+            command: "FIXME".to_string(),
+        },
     }
 }
 

ee/tabby-webserver/src/service/repository/third_party.rs

@@ -9,6 +9,7 @@ use tabby_common::config::RepositoryConfig;
 use tabby_db::{DbConn, ProvidedRepositoryDAO};
 use tabby_schema::{
     integration::{Integration, IntegrationKind, IntegrationService},
+    job::JobInfo,
     repository::{ProvidedRepository, Repository, RepositoryProvider, ThirdPartyRepositoryService},
     AsID, AsRowid, DbEnum, Result,
 };
@@ -293,6 +294,11 @@ fn to_provided_repository(value: ProvidedRepositoryDAO) -> ProvidedRepository {
         refs: tabby_git::list_refs(&RepositoryConfig::new(&value.git_url).dir())
             .unwrap_or_default(),
         git_url: value.git_url,
+
+        job_info: JobInfo {
+            last_job_run: None,
+            command: "FIXME".to_string(),
+        },
     }
 }