Function activateWorkflowVersion

apps/sim/lib/workflows/persistence/utils.ts:995–1099

(params: {
  workflowId: string
  version: number
  onActivateTransaction?: (
    tx: DbOrTx,
    result: { deploymentVersionId: string; previousVersionId?: string }
  ) => Promise<void>
})

}

export async function activateWorkflowVersion(params: {
  workflowId: string
  version: number
  onActivateTransaction?: (
    tx: DbOrTx,
    result: { deploymentVersionId: string; previousVersionId?: string }
  ) => Promise<void>
}): Promise<{
  success: boolean
  deployedAt?: Date
  state?: unknown
  previousVersionId?: string
  error?: string
}> {
  const { workflowId, version } = params

  try {
    const now = new Date()
    let versionState: unknown

    const result = await db.transaction(async (tx) => {
      if (!(await lockWorkflowForUpdate(tx, workflowId))) {
        return { success: false as const, error: 'Workflow not found' }
      }

      const [currentActiveVersion] = await tx
        .select({ id: workflowDeploymentVersion.id })
        .from(workflowDeploymentVersion)
        .where(
          and(
            eq(workflowDeploymentVersion.workflowId, workflowId),
            eq(workflowDeploymentVersion.isActive, true)
          )
        )
        .limit(1)

      const [versionData] = await tx
        .select({ id: workflowDeploymentVersion.id, state: workflowDeploymentVersion.state })
        .from(workflowDeploymentVersion)
        .where(
          and(
            eq(workflowDeploymentVersion.workflowId, workflowId),
            eq(workflowDeploymentVersion.version, version)
          )
        )
        .limit(1)

      if (!versionData) {
        return { success: false as const, error: 'Deployment version not found' }
      }
      versionState = versionData.state

      await tx
        .update(workflowDeploymentVersion)
        .set({ isActive: false })
        .where(
          and(
            eq(workflowDeploymentVersion.workflowId, workflowId),