fix build

Author: TheodoreSpeaks

apps/sim/app/api/mcp/servers/[id]/refresh/route.ts

@@ -155,103 +155,107 @@ async function syncToolSchemasToWorkflows(
   }
 }
 
-export const POST =
-  withRouteHandler(withMcpAuth < { id: string }) >
-  'read'(async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
-    const { id: serverId } = await params
-
-    try {
-      logger.info(`[${requestId}] Refreshing MCP server: ${serverId}`)
-
-      const [server] = await db
-        .select()
-        .from(mcpServers)
-        .where(
-          and(
-            eq(mcpServers.id, serverId),
-            eq(mcpServers.workspaceId, workspaceId),
-            isNull(mcpServers.deletedAt)
+export const POST = withRouteHandler(
+  withMcpAuth<{ id: string }>('read')(
+    async (request: NextRequest, { userId, workspaceId, requestId }, { params }) => {
+      const { id: serverId } = await params
+
+      try {
+        logger.info(`[${requestId}] Refreshing MCP server: ${serverId}`)
+
+        const [server] = await db
+          .select()
+          .from(mcpServers)
+          .where(
+            and(
+              eq(mcpServers.id, serverId),
+              eq(mcpServers.workspaceId, workspaceId),
+              isNull(mcpServers.deletedAt)
+            )
           )
-        )
-        .limit(1)
-
-      if (!server) {
-        return createMcpErrorResponse(
-          new Error('Server not found or access denied'),
-          'Server not found',
-          404
-        )
-      }
+          .limit(1)
+
+        if (!server) {
+          return createMcpErrorResponse(
+            new Error('Server not found or access denied'),
+            'Server not found',
+            404
+          )
+        }
 
-      let connectionStatus: 'connected' | 'disconnected' | 'error' = 'error'
-      let toolCount = 0
-      let lastError: string | null = null
-      let syncResult: SyncResult = { updatedCount: 0, updatedWorkflowIds: [] }
-      let discoveredTools: McpTool[] = []
+        let connectionStatus: 'connected' | 'disconnected' | 'error' = 'error'
+        let toolCount = 0
+        let lastError: string | null = null
+        let syncResult: SyncResult = { updatedCount: 0, updatedWorkflowIds: [] }
+        let discoveredTools: McpTool[] = []
+
+        const currentStatusConfig: McpServerStatusConfig =
+          (server.statusConfig as McpServerStatusConfig | null) ?? {
+            consecutiveFailures: 0,
+            lastSuccessfulDiscovery: null,
+          }
 
-      const currentStatusConfig: McpServerStatusConfig =
-        (server.statusConfig as McpServerStatusConfig | null) ?? {
-          consecutiveFailures: 0,
-          lastSuccessfulDiscovery: null,
+        try {
+          discoveredTools = await mcpService.discoverServerTools(userId, serverId, workspaceId)
+          connectionStatus = 'connected'
+          toolCount = discoveredTools.length
+          logger.info(`[${requestId}] Discovered ${toolCount} tools from server ${serverId}`)
+
+          syncResult = await syncToolSchemasToWorkflows(
+            workspaceId,
+            serverId,
+            discoveredTools,
+            requestId,
+            { url: server.url ?? undefined, name: server.name ?? undefined }
+          )
+        } catch (error) {
+          connectionStatus = 'error'
+          lastError =
+            error instanceof Error
+              ? error.message.split('\n')[0].slice(0, 200)
+              : 'Connection failed'
+          logger.warn(`[${requestId}] Failed to connect to server ${serverId}:`, error)
         }
 
-      try {
-        discoveredTools = await mcpService.discoverServerTools(userId, serverId, workspaceId)
-        connectionStatus = 'connected'
-        toolCount = discoveredTools.length
-        logger.info(`[${requestId}] Discovered ${toolCount} tools from server ${serverId}`)
-
-        syncResult = await syncToolSchemasToWorkflows(
-          workspaceId,
-          serverId,
-          discoveredTools,
-          requestId,
-          { url: server.url ?? undefined, name: server.name ?? undefined }
-        )
-      } catch (error) {
-        connectionStatus = 'error'
-        lastError =
-          error instanceof Error ? error.message.split('\n')[0].slice(0, 200) : 'Connection failed'
-        logger.warn(`[${requestId}] Failed to connect to server ${serverId}:`, error)
-      }
+        const now = new Date()
+        const newStatusConfig =
+          connectionStatus === 'connected'
+            ? { consecutiveFailures: 0, lastSuccessfulDiscovery: now.toISOString() }
+            : {
+                consecutiveFailures: currentStatusConfig.consecutiveFailures + 1,
+                lastSuccessfulDiscovery: currentStatusConfig.lastSuccessfulDiscovery,
+              }
+
+        const [refreshedServer] = await db
+          .update(mcpServers)
+          .set({
+            lastToolsRefresh: now,
+            connectionStatus,
+            lastError,
+            lastConnected: connectionStatus === 'connected' ? now : server.lastConnected,
+            toolCount,
+            statusConfig: newStatusConfig,
+            updatedAt: now,
+          })
+          .where(eq(mcpServers.id, serverId))
+          .returning()
+
+        if (connectionStatus === 'connected') {
+          await mcpService.clearCache(workspaceId)
+        }
 
-      const now = new Date()
-      const newStatusConfig =
-        connectionStatus === 'connected'
-          ? { consecutiveFailures: 0, lastSuccessfulDiscovery: now.toISOString() }
-          : {
-              consecutiveFailures: currentStatusConfig.consecutiveFailures + 1,
-              lastSuccessfulDiscovery: currentStatusConfig.lastSuccessfulDiscovery,
-            }
-
-      const [refreshedServer] = await db
-        .update(mcpServers)
-        .set({
-          lastToolsRefresh: now,
-          connectionStatus,
-          lastError,
-          lastConnected: connectionStatus === 'connected' ? now : server.lastConnected,
+        return createMcpSuccessResponse({
+          status: connectionStatus,
           toolCount,
-          statusConfig: newStatusConfig,
-          updatedAt: now,
+          lastConnected: refreshedServer?.lastConnected?.toISOString() || null,
+          error: lastError,
+          workflowsUpdated: syncResult.updatedCount,
+          updatedWorkflowIds: syncResult.updatedWorkflowIds,
         })
-        .where(eq(mcpServers.id, serverId))
-        .returning()
-
-      if (connectionStatus === 'connected') {
-        await mcpService.clearCache(workspaceId)
+      } catch (error) {
+        logger.error(`[${requestId}] Error refreshing MCP server:`, error)
+        return createMcpErrorResponse(toError(error), 'Failed to refresh MCP server', 500)
       }
-
-      return createMcpSuccessResponse({
-        status: connectionStatus,
-        toolCount,
-        lastConnected: refreshedServer?.lastConnected?.toISOString() || null,
-        error: lastError,
-        workflowsUpdated: syncResult.updatedCount,
-        updatedWorkflowIds: syncResult.updatedWorkflowIds,
-      })
-    } catch (error) {
-      logger.error(`[${requestId}] Error refreshing MCP server:`, error)
-      return createMcpErrorResponse(toError(error), 'Failed to refresh MCP server', 500)
     }
-  })
+  )
+)

apps/sim/app/api/mcp/servers/[id]/route.ts

@@ -24,9 +24,8 @@ export const dynamic = 'force-dynamic'
 /**
  * PATCH - Update an MCP server in the workspace (requires write or admin permission)
  */
-export const PATCH =
-  withRouteHandler(withMcpAuth < { id: string }) >
-  'write'(
+export const PATCH = withRouteHandler(
+  withMcpAuth<{ id: string }>('write')(
     async (
       request: NextRequest,
       { userId, userName, userEmail, workspaceId, requestId },
@@ -149,3 +148,4 @@ export const PATCH =
       }
     }
   )
+)