Fix flushing

Author: Sg312

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/components/panel-new/components/editor/components/sub-block/components/trigger-save/trigger-save.tsx

@@ -442,7 +442,7 @@ export function TriggerSave({
             />
           ) : (
             <p className='text-muted-foreground text-xs'>
-              Generate a temporary URL that executes this webhook against the live (un-deployed)
+              Generate a temporary URL that executes this webhook against the live (undeployed)
               workflow state.
             </p>
           )}

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/components/panel-new/components/editor/components/sub-block/components/webhook/components/webhook-modal.tsx

@@ -897,7 +897,7 @@ export function WebhookModal({
                 ) : (
                   <p className='text-muted-foreground text-xs'>
                     Generate a temporary URL that executes this webhook against the live
-                    (un-deployed) workflow state.
+                    (undeployed) workflow state.
                   </p>
                 )}
                 {testUrlExpiresAt && (

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

@@ -1,6 +1,7 @@
 import crypto from 'crypto'
 import {
   db,
+  webhook,
   workflow,
   workflowBlocks,
   workflowDeploymentVersion,
@@ -249,6 +250,11 @@ export async function saveWorkflowToNormalizedTables(
   try {
     // Start a transaction
     await db.transaction(async (tx) => {
+      const existingWebhooks = await tx
+        .select()
+        .from(webhook)
+        .where(eq(webhook.workflowId, workflowId))
+
       // Clear existing data for this workflow
       await Promise.all([
         tx.delete(workflowBlocks).where(eq(workflowBlocks.workflowId, workflowId)),
@@ -320,6 +326,26 @@ export async function saveWorkflowToNormalizedTables(
       if (subflowInserts.length > 0) {
         await tx.insert(workflowSubflows).values(subflowInserts)
       }
+
+      if (existingWebhooks.length > 0) {
+        const webhookInserts = existingWebhooks
+          .filter((wh) => !!state.blocks?.[wh.blockId ?? ''])
+          .map((wh) => ({
+            id: wh.id,
+            workflowId: wh.workflowId,
+            blockId: wh.blockId,
+            path: wh.path,
+            provider: wh.provider,
+            providerConfig: wh.providerConfig,
+            isActive: wh.isActive,
+            createdAt: wh.createdAt,
+            updatedAt: new Date(),
+          }))
+
+        if (webhookInserts.length > 0) {
+          await tx.insert(webhook).values(webhookInserts)
+        }
+      }
     })
 
     return { success: true }