From c3cfdc40967dc8bd7121ed83565d79658809be76 Mon Sep 17 00:00:00 2001
From: Acbox <acbox0328@gmail.com>
Date: Fri, 6 Feb 2026 22:12:13 +0800
Subject: [PATCH] feat(agent): add trigger-schedule api

---
 agent/src/modules/chat.ts | 30 ++++++++++++++++++++++++++----
 1 file changed, 26 insertions(+), 4 deletions(-)

diff --git a/agent/src/modules/chat.ts b/agent/src/modules/chat.ts
index 00b7a21a..290c1a5b 100644
--- a/agent/src/modules/chat.ts
+++ b/agent/src/modules/chat.ts
@@ -4,7 +4,7 @@ import { createAgent } from '../agent'
 import { createAuthFetcher } from '../index'
 import { ModelConfig } from '../types'
 import { bearerMiddleware } from '../middlewares/bearer'
-import { AllowedActionModel, AttachmentModel, IdentityContextModel, MCPConnectionModel, ModelConfigModel } from '../models'
+import { AllowedActionModel, AttachmentModel, IdentityContextModel, MCPConnectionModel, ModelConfigModel, ScheduleModel } from '../models'
 import { allActions } from '../types'
 
 const AgentModel = z.object({
@@ -15,7 +15,6 @@ const AgentModel = z.object({
   allowedActions: z.array(AllowedActionModel).optional().default(allActions),
   messages: z.array(z.any()),
   skills: z.array(z.string()),
-  query: z.string(),
   identity: IdentityContextModel,
   attachments: z.array(AttachmentModel).optional().default([]),
   mcpConnections: z.array(MCPConnectionModel).optional().default([]),
@@ -41,7 +40,9 @@ export const chatModule = new Elysia({ prefix: '/chat' })
       attachments: body.attachments,
     })
   }, {
-    body: AgentModel,
+    body: AgentModel.extend({
+      query: z.string(),
+    }),
   })
   .post('/stream', async function* ({ body, bearer }) {
     try {
@@ -71,5 +72,26 @@ export const chatModule = new Elysia({ prefix: '/chat' })
       }))
     }
   }, {
-    body: AgentModel,
+    body: AgentModel.extend({
+      query: z.string(),
+    }),
+  })
+  .post('/trigger-schedule', async ({ body, bearer }) => {
+    const authFetcher = createAuthFetcher(bearer)
+    const { triggerSchedule } = createAgent({
+      model: body.model as ModelConfig,
+      activeContextTime: body.activeContextTime,
+      channels: body.channels,
+      currentChannel: body.currentChannel,
+      identity: body.identity,
+      mcpConnections: body.mcpConnections,
+    }, authFetcher)
+    return triggerSchedule({
+      schedule: body.schedule,
+      messages: body.messages,
+    })
+  }, {
+    body: AgentModel.extend({
+      schedule: ScheduleModel,
+    }),
   })