Function activateWorkflowVersionById

apps/sim/lib/workflows/persistence/utils.ts:1101–1194

(params: {
  workflowId: string
  deploymentVersionId: string
})

}

async function activateWorkflowVersionById(params: {
  workflowId: string
  deploymentVersionId: string
}): Promise<{
  success: boolean
  deployedAt?: Date
  state?: unknown
  previousVersionId?: string
  error?: string
}> {
  const { workflowId, deploymentVersionId } = 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.id, deploymentVersionId)
          )
        )
        .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(eq(workflowDeploymentVersion.workflowId, workflowId))

      await tx
        .update(workflowDeploymentVersion)
        .set({ isActive: true })
        .where(
          and(