Function duplicateWorkflow

apps/sim/lib/workflows/persistence/duplicate.ts:100–521

(
  options: DuplicateWorkflowOptions
)

 * This is a shared helper used by both the workflow duplicate API and folder duplicate API
 */
export async function duplicateWorkflow(
  options: DuplicateWorkflowOptions
): Promise<DuplicateWorkflowResult> {
  const {
    sourceWorkflowId,
    userId,
    name,
    description,
    workspaceId,
    folderId,
    requestId = 'unknown',
    newWorkflowId: clientNewWorkflowId,
    tx: providedTx,
    workflowIdMap,
  } = options

  const newWorkflowId = clientNewWorkflowId || workflowIdMap?.get(sourceWorkflowId) || generateId()
  const now = new Date()

  // Authorization runs before the transaction opens so its global-pool
  // queries never execute while a pooled connection is held. Callers that
  // pass `tx` authorize the workspace themselves (see DuplicateWorkflowOptions).
  if (!providedTx) {
    const sourceAuthorization = await authorizeWorkflowByWorkspacePermission({
      workflowId: sourceWorkflowId,
      userId,
      action: 'read',
    })
    if (!sourceAuthorization.allowed || !sourceAuthorization.workflow) {
      throw new Error('Source workflow not found or access denied')
    }

    const sourceWorkspaceId = sourceAuthorization.workflow.workspaceId
    if (!sourceWorkspaceId) {
      throw new Error(
        'This workflow is not attached to a workspace. Personal workflows are deprecated and cannot be duplicated.'
      )
    }

    const targetWorkspaceId = workspaceId || sourceWorkspaceId
    if (targetWorkspaceId !== sourceWorkspaceId) {
      throw new Error('Cross-workspace workflow duplication is not supported')
    }

    // The target workspace equals the source workspace, so the permission
    // resolved by the authorization above is the target permission.
    if (
      sourceAuthorization.workspacePermission !== 'admin' &&
      sourceAuthorization.workspacePermission !== 'write'
    ) {
      throw new Error('Write or admin access required for target workspace')
    }
  }

  const duplicateWithinTransaction = async (tx: DbOrTx) => {
    // First verify the source workflow exists
    const sourceWorkflowRow = await tx
      .select()