improvement(workflow): seed start block on server side

Author: icecrasher321

apps/sim/app/api/workflows/route.ts

@@ -8,6 +8,8 @@ import { AuditAction, AuditResourceType, recordAudit } from '@/lib/audit/log'
 import { checkSessionOrInternalAuth } from '@/lib/auth/hybrid'
 import { generateRequestId } from '@/lib/core/utils/request'
 import { getNextWorkflowColor } from '@/lib/workflows/colors'
+import { buildDefaultWorkflowArtifacts } from '@/lib/workflows/defaults'
+import { saveWorkflowToNormalizedTables } from '@/lib/workflows/persistence/utils'
 import { deduplicateWorkflowName, listWorkflows, type WorkflowScope } from '@/lib/workflows/utils'
 import { getUserEntityPermissions, workspaceExists } from '@/lib/workspaces/permissions/utils'
 import { verifyWorkspaceMembership } from '@/app/api/workflows/utils'
@@ -247,6 +249,8 @@ export async function POST(req: NextRequest) {
         // Silently fail
       })
 
+    const { workflowState, subBlockValues, startBlockId } = buildDefaultWorkflowArtifacts()
+
     await db.insert(workflow).values({
       id: workflowId,
       userId,
@@ -264,7 +268,14 @@ export async function POST(req: NextRequest) {
       variables: {},
     })
 
-    logger.info(`[${requestId}] Successfully created empty workflow ${workflowId}`)
+    const saveResult = await saveWorkflowToNormalizedTables(workflowId, workflowState)
+    if (!saveResult.success) {
+      logger.error(
+        `[${requestId}] Failed to persist default blocks for workflow ${workflowId}: ${saveResult.error}`
+      )
+    }
+
+    logger.info(`[${requestId}] Successfully created workflow ${workflowId} with default blocks`)
 
     recordAudit({
       workspaceId,
@@ -290,6 +301,8 @@ export async function POST(req: NextRequest) {
       sortOrder,
       createdAt: now,
       updatedAt: now,
+      startBlockId,
+      subBlockValues,
     })
   } catch (error) {
     if (error instanceof z.ZodError) {

apps/sim/hooks/queries/workflows.ts

@@ -11,7 +11,6 @@ import {
   useQueryClient,
 } from '@tanstack/react-query'
 import { getNextWorkflowColor } from '@/lib/workflows/colors'
-import { buildDefaultWorkflowArtifacts } from '@/lib/workflows/defaults'
 import { deploymentKeys } from '@/hooks/queries/deployments'
 import { fetchDeploymentVersionState } from '@/hooks/queries/utils/fetch-deployment-version-state'
 import { getFolderMap } from '@/hooks/queries/utils/folder-cache'
@@ -105,6 +104,8 @@ interface CreateWorkflowResult {
   workspaceId: string
   folderId?: string | null
   sortOrder: number
+  startBlockId?: string
+  subBlockValues?: Record<string, Record<string, unknown>>
 }
 
 export function useCreateWorkflow() {
@@ -144,19 +145,6 @@ export function useCreateWorkflow() {
 
       logger.info(`Successfully created workflow ${workflowId}`)
 
-      const { workflowState } = buildDefaultWorkflowArtifacts()
-
-      const stateResponse = await fetch(`/api/workflows/${workflowId}/state`, {
-        method: 'PUT',
-        headers: { 'Content-Type': 'application/json' },
-        body: JSON.stringify(workflowState),
-      })
-
-      if (!stateResponse.ok) {
-        const text = await stateResponse.text()
-        logger.error('Failed to persist default workflow state:', text)
-      }
-
       return {
         id: workflowId,
         name: createdWorkflow.name,
@@ -165,6 +153,8 @@ export function useCreateWorkflow() {
         workspaceId,
         folderId: createdWorkflow.folderId,
         sortOrder: createdWorkflow.sortOrder ?? 0,
+        startBlockId: createdWorkflow.startBlockId,
+        subBlockValues: createdWorkflow.subBlockValues,
       }
     },
     onMutate: async (variables) => {
@@ -247,13 +237,14 @@ export function useCreateWorkflow() {
         })
       }
 
-      const { subBlockValues } = buildDefaultWorkflowArtifacts()
-      useSubBlockStore.setState((state) => ({
-        workflowValues: {
-          ...state.workflowValues,
-          [data.id]: subBlockValues,
-        },
-      }))
+      if (data.subBlockValues) {
+        useSubBlockStore.setState((state) => ({
+          workflowValues: {
+            ...state.workflowValues,
+            [data.id]: data.subBlockValues!,
+          },
+        }))
+      }
 
       logger.info(`[CreateWorkflow] Success, replaced temp entry ${tempId}`)
     },