Function performRevertToVersion

apps/sim/lib/workflows/orchestration/deploy.ts:503–651

(
  params: PerformRevertToVersionParams
)

 * by both the HTTP route and the mothership tool handler.
 */
export async function performRevertToVersion(
  params: PerformRevertToVersionParams
): Promise<PerformRevertToVersionResult> {
  const { workflowId, version, userId, workflow } = params
  const actorId = params.actorId ?? userId
  const versionLabel = String(version)

  const lastSaved = Date.now()
  let saveResult: { success: boolean; error?: string; errorCode?: OrchestrationErrorCode }
  try {
    await assertWorkflowMutable(workflowId)
    saveResult = await db.transaction(async (tx) => {
      await tx
        .select({ id: workflowTable.id })
        .from(workflowTable)
        .where(eq(workflowTable.id, workflowId))
        .limit(1)
        .for('update')

      const [stateRow] =
        version === 'active'
          ? await tx
              .select({ state: workflowDeploymentVersion.state })
              .from(workflowDeploymentVersion)
              .where(
                and(
                  eq(workflowDeploymentVersion.workflowId, workflowId),
                  eq(workflowDeploymentVersion.isActive, true)
                )
              )
              .limit(1)
          : await tx
              .select({ state: workflowDeploymentVersion.state })
              .from(workflowDeploymentVersion)
              .where(
                and(
                  eq(workflowDeploymentVersion.workflowId, workflowId),
                  eq(workflowDeploymentVersion.version, version)
                )
              )
              .limit(1)

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

      const deployedState = stateRow.state as {
        blocks?: Record<string, unknown>
        edges?: unknown[]
        loops?: Record<string, unknown>
        parallels?: Record<string, unknown>
        variables?: WorkflowState['variables']
      }
      if (!deployedState.blocks || !deployedState.edges) {
        return { success: false, error: 'Invalid deployed state structure' }
      }

      const hasDeploymentVariables = Object.hasOwn(deployedState, 'variables')