From 1f1d6392fa26b4c68c8fe87fb5c737ffe2feb158 Mon Sep 17 00:00:00 2001
From: Acbox <acbox0328@gmail.com>
Date: Mon, 12 Jan 2026 20:33:20 +0800
Subject: [PATCH] feat: platform connection error handle

---
 packages/api/src/modules/platform/index.ts | 23 ++++++++++++----------
 packages/api/src/modules/schedule/index.ts |  6 +++++-
 2 files changed, 18 insertions(+), 11 deletions(-)

diff --git a/packages/api/src/modules/platform/index.ts b/packages/api/src/modules/platform/index.ts
index aeeb4b63..39f177cd 100644
--- a/packages/api/src/modules/platform/index.ts
+++ b/packages/api/src/modules/platform/index.ts
@@ -28,17 +28,20 @@ export const platformModule = new Elysia({
   .use(optionalAuthMiddleware)
   // Get all platforms
   .onStart(async () => {
-    const platforms = await getActivePlatforms()
-    for (const platform of platforms) {
-      await activePlatform({
-        id: platform.id,
-        name: platform.name,
-        endpoint: platform.endpoint,
-        config: platform.config as Record<string, unknown>,
-        active: platform.active,
-      })
+    try {
+      const platforms = await getActivePlatforms()
+      for (const platform of platforms) {
+        await activePlatform({
+          id: platform.id,
+          name: platform.name,
+          endpoint: platform.endpoint,
+          config: platform.config as Record<string, unknown>,
+          active: platform.active,
+        })
+      }
+    } catch (error) {
+      console.error('Failed to start platform', error)
     }
-    console.log('platforms', platforms)
   })
   .get('/', async ({ query }) => {
     try {
diff --git a/packages/api/src/modules/schedule/index.ts b/packages/api/src/modules/schedule/index.ts
index e20404ce..a7c60bc4 100644
--- a/packages/api/src/modules/schedule/index.ts
+++ b/packages/api/src/modules/schedule/index.ts
@@ -22,7 +22,11 @@ export const scheduleModule = new Elysia({ prefix: '/schedule' })
   .use(authMiddleware)
   // Get all schedules for current user
   .onStart(async () => {
-    await resume()
+    try {
+      await resume()
+    } catch (error) {
+      console.error('Failed to resume schedule', error)
+    }
   })
   .get('/', async ({ user, query }) => {
     try {