Function restoreWorkflow

apps/sim/lib/workflows/lifecycle.ts:213–286

(
  workflowId: string,
  options: RestoreWorkflowOptions
)

}

export async function restoreWorkflow(
  workflowId: string,
  options: RestoreWorkflowOptions
): Promise<{ restored: boolean; workflow: Awaited<ReturnType<typeof getWorkflowById>> | null }> {
  const existingWorkflow = await getWorkflowById(workflowId, { includeArchived: true })

  if (!existingWorkflow) {
    return { restored: false, workflow: null }
  }

  if (!existingWorkflow.archivedAt) {
    return { restored: false, workflow: existingWorkflow }
  }

  if (existingWorkflow.workspaceId) {
    const { getWorkspaceWithOwner } = await import('@/lib/workspaces/permissions/utils')
    const ws = await getWorkspaceWithOwner(existingWorkflow.workspaceId)
    if (!ws || ws.archivedAt) {
      throw new Error('Cannot restore workflow into an archived workspace')
    }
  }

  let clearFolderId = false
  if (existingWorkflow.folderId) {
    const [folder] = await db
      .select({ archivedAt: workflowFolder.archivedAt })
      .from(workflowFolder)
      .where(eq(workflowFolder.id, existingWorkflow.folderId))

    if (!folder || folder.archivedAt) {
      clearFolderId = true
    }
  }

  const now = new Date()

  await db.transaction(async (tx) => {
    await tx
      .update(workflow)
      .set({
        archivedAt: null,
        updatedAt: now,
        ...(clearFolderId && { folderId: null }),
      })
      .where(eq(workflow.id, workflowId))

    await tx
      .update(workflowSchedule)
      .set({ archivedAt: null, updatedAt: now })
      .where(eq(workflowSchedule.workflowId, workflowId))

    await tx
      .update(webhook)
      .set({ archivedAt: null, updatedAt: now })
      .where(eq(webhook.workflowId, workflowId))

    await tx
      .update(chat)