fix(deployed-version-check): check deployed version existence pre-queuing (#1508)

* fix(deployed-version-check): check deployed version existence pre-queuing

* fix tests

* fix edge case

Author: icecrasher321

apps/sim/app/api/webhooks/trigger/[path]/route.test.ts

@@ -133,6 +133,7 @@ describe('Webhook Trigger API Route', () => {
         parallels: {},
         isFromNormalizedTables: true,
       }),
+      blockExistsInDeployment: vi.fn().mockResolvedValue(true),
     }))
 
     hasProcessedMessageMock.mockResolvedValue(false)

apps/sim/app/api/webhooks/trigger/[path]/route.ts

@@ -10,6 +10,7 @@ import {
   queueWebhookExecution,
   verifyProviderAuth,
 } from '@/lib/webhooks/processor'
+import { blockExistsInDeployment } from '@/lib/workflows/db-helpers'
 
 const logger = createLogger('WebhookTriggerAPI')
 
@@ -62,6 +63,16 @@ export async function POST(
     return usageLimitError
   }
 
+  if (foundWebhook.blockId) {
+    const blockExists = await blockExistsInDeployment(foundWorkflow.id, foundWebhook.blockId)
+    if (!blockExists) {
+      logger.warn(
+        `[${requestId}] Trigger block ${foundWebhook.blockId} not found in deployment for workflow ${foundWorkflow.id}`
+      )
+      return new NextResponse('Trigger block not deployed', { status: 404 })
+    }
+  }
+
   return queueWebhookExecution(foundWebhook, foundWorkflow, body, request, {
     requestId,
     path,

apps/sim/lib/workflows/db-helpers.ts

@@ -36,10 +36,34 @@ export interface NormalizedWorkflowData {
   isFromNormalizedTables: boolean // Flag to indicate source (true = normalized tables, false = deployed state)
 }
 
-/**
- * Load deployed workflow state for execution
- * Returns deployed state if available, otherwise throws error
- */
+export async function blockExistsInDeployment(
+  workflowId: string,
+  blockId: string
+): Promise<boolean> {
+  try {
+    const [result] = await db
+      .select({ state: workflowDeploymentVersion.state })
+      .from(workflowDeploymentVersion)
+      .where(
+        and(
+          eq(workflowDeploymentVersion.workflowId, workflowId),
+          eq(workflowDeploymentVersion.isActive, true)
+        )
+      )
+      .limit(1)
+
+    if (!result?.state) {
+      return false
+    }
+
+    const state = result.state as WorkflowState
+    return !!state.blocks?.[blockId]
+  } catch (error) {
+    logger.error(`Error checking block ${blockId} in deployment for workflow ${workflowId}:`, error)
+    return false
+  }
+}
+
 export async function loadDeployedWorkflowState(
   workflowId: string
 ): Promise<NormalizedWorkflowData> {