Function performFullDeploy

apps/sim/lib/workflows/orchestration/deploy.ts:102–215

(
  params: PerformFullDeployParams
)

 * deploy tools must use this single function so behaviour stays consistent.
 */
export async function performFullDeploy(
  params: PerformFullDeployParams
): Promise<PerformFullDeployResult> {
  const { workflowId, userId, workflowName } = params
  const actorId = params.actorId ?? userId
  const requestId = params.requestId ?? generateRequestId()

  const [workflowRecord] = await db
    .select()
    .from(workflowTable)
    .where(eq(workflowTable.id, workflowId))
    .limit(1)

  if (!workflowRecord) {
    return { success: false, error: 'Workflow not found', errorCode: 'not_found' }
  }

  const workflowData = workflowRecord as Record<string, unknown>
  let outboxEventId: string | undefined

  const deployResult = await deployWorkflow({
    workflowId,
    deployedBy: actorId,
    workflowName: workflowName || workflowRecord.name || undefined,
    description: params.versionDescription,
    name: params.versionName,
    validateWorkflowState: async (workflowState, executor) => {
      const scheduleValidation = validateWorkflowSchedules(workflowState.blocks)
      if (!scheduleValidation.isValid) {
        return {
          success: false,
          error: `Invalid schedule configuration: ${scheduleValidation.error}`,
          errorCode: 'validation',
        }
      }
      const triggerValidation = await validateTriggerWebhookConfigForDeploy(
        workflowState.blocks,
        executor
      )
      if (!triggerValidation.success) {
        return {
          success: false,
          error: triggerValidation.error?.message || 'Invalid trigger configuration',
          errorCode: 'validation',
        }
      }
      return { success: true }
    },
    onDeployTransaction: async (tx, result) => {
      outboxEventId = await enqueueWorkflowDeploymentSideEffects(tx, {
        workflowId,
        deploymentVersionId: result.deploymentVersionId,
        userId,
        requestId,
      })
    },
  })