Function performActivateVersion

apps/sim/lib/workflows/orchestration/deploy.ts:350–463

(
  params: PerformActivateVersionParams
)

 * PATCH handler and the admin activate route must use this function.
 */
export async function performActivateVersion(
  params: PerformActivateVersionParams
): Promise<PerformActivateVersionResult> {
  const { workflowId, version, userId, workflow } = params
  const actorId = params.actorId ?? userId
  const requestId = params.requestId ?? generateRequestId()

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

  if (!versionRow?.state) {
    return { success: false, error: 'Deployment version not found', errorCode: 'not_found' }
  }

  if (versionRow.isActive) {
    const [workflowDeployment] = await db
      .select({ deployedAt: workflowTable.deployedAt })
      .from(workflowTable)
      .where(eq(workflowTable.id, workflowId))
      .limit(1)

    return { success: true, deployedAt: workflowDeployment?.deployedAt ?? new Date(), warnings: [] }
  }

  const deployedState = versionRow.state as { blocks?: Record<string, unknown> }
  const blocks = deployedState.blocks
  if (!blocks || typeof blocks !== 'object') {
    return { success: false, error: 'Invalid deployed state structure', errorCode: 'validation' }
  }

  const scheduleValidation = validateWorkflowSchedules(blocks as Record<string, BlockState>)
  if (!scheduleValidation.isValid) {
    return {
      success: false,
      error: `Invalid schedule configuration: ${scheduleValidation.error}`,
      errorCode: 'validation',
    }
  }

  const triggerValidation = await validateTriggerWebhookConfigForDeploy(
    blocks as Record<string, BlockState>
  )
  if (!triggerValidation.success) {
    return {
      success: false,
      error: triggerValidation.error?.message || 'Invalid trigger configuration',