scheduler 支持手动触发

Author: linyuan.yang

packages/admin/src/i18n/en.ts

@@ -533,6 +533,8 @@ export default {
     edit_title: 'Edit Timer',
     message_required: 'Message is required',
     target_required: 'Please select a target session',
+    trigger: 'Trigger',
+    triggered: 'Triggered',
   },
   todo: {
     title: 'Todos',

packages/admin/src/i18n/zh.ts

@@ -533,6 +533,8 @@ export default {
     edit_title: '编辑计时器',
     message_required: '请填写目标消息',
     target_required: '请选择目标会话',
+    trigger: '手动触发',
+    triggered: '已触发',
   },
   todo: {
     title: '待办事项',

packages/admin/src/views/admin/SchedulerView.vue

@@ -165,6 +165,16 @@ async function remove(row: SchedulerRow) {
   }
 }
 
+async function trigger(row: SchedulerRow) {
+  try {
+    await apiFetch(`/api/schedulers/${row.id}/trigger`, 'POST')
+    show(t('scheduler.triggered'))
+    await load()
+  } catch (e: any) {
+    show(e.message, 'error')
+  }
+}
+
 onMounted(() => {
   load()
   tickHandle = setInterval(() => { now.value = Date.now() }, 30_000)
@@ -250,6 +260,7 @@ onUnmounted(() => {
         </template>
 
         <template #ops="{ row }">
+          <SButton type="outline" size="sm" @click="trigger(row)">{{ t('scheduler.trigger') }}</SButton>
           <SButton type="outline" size="sm" @click="openEdit(row)">{{ t('common.edit') }}</SButton>
           <SButton type="danger" size="sm" @click="remove(row)">{{ t('common.delete') }}</SButton>
         </template>

packages/sbot/src/Scheduler/SchedulerService.ts

@@ -217,6 +217,10 @@ class SchedulerService {
         if (scheduler) await this.schedule(scheduler);
         else this.executor.cancel(schedulerId);
     }
+
+    async triggerOnce(schedulerId: number): Promise<void> {
+        await executeScheduler(schedulerId);
+    }
 }
 
 export const schedulerService = new SchedulerService();

packages/sbot/src/Server/routes/schedulers.ts

@@ -37,6 +37,15 @@ export class SchedulerRoutes {
             if (isNaN(id)) throwBad('Invalid id');
             await schedulerService.delete(id);
         }));
+
+        app.post('/api/schedulers/:id/trigger', api(async req => {
+            const id = parseInt(req.params.id as string, 10);
+            if (isNaN(id)) throwBad('Invalid id');
+            const row = await schedulerService.findByPk(id);
+            if (!row) throwBad('Scheduler not found');
+            await schedulerService.triggerOnce(id);
+            return { triggered: true };
+        }));
     }
 }