Function createWorkflowRecord

apps/sim/lib/workflows/utils.ts:378–459

(params: CreateWorkflowInput)

}

export async function createWorkflowRecord(params: CreateWorkflowInput) {
  const { userId, workspaceId, name, description = null, folderId = null } = params
  const workflowId = generateId()
  const now = new Date()

  const duplicateConditions = [
    eq(workflowTable.workspaceId, workspaceId),
    isNull(workflowTable.archivedAt),
    eq(workflowTable.name, name),
    ...(folderId ? [eq(workflowTable.folderId, folderId)] : [isNull(workflowTable.folderId)]),
  ]
  const [duplicateWorkflow] = await db
    .select({ id: workflowTable.id })
    .from(workflowTable)
    .where(and(...duplicateConditions))
    .limit(1)
  if (duplicateWorkflow) {
    throw new Error(
      `A workflow named "${name}" already exists in this folder. Use a different name.`
    )
  }

  const workflowParentCondition = folderId
    ? eq(workflowTable.folderId, folderId)
    : isNull(workflowTable.folderId)
  const folderParentCondition = folderId
    ? eq(workflowFolder.parentId, folderId)
    : isNull(workflowFolder.parentId)

  const [[workflowMinResult], [folderMinResult]] = await Promise.all([
    db
      .select({ minOrder: min(workflowTable.sortOrder) })
      .from(workflowTable)
      .where(
        and(
          eq(workflowTable.workspaceId, workspaceId),
          workflowParentCondition,
          isNull(workflowTable.archivedAt)
        )
      ),
    db
      .select({ minOrder: min(workflowFolder.sortOrder) })
      .from(workflowFolder)
      .where(and(eq(workflowFolder.workspaceId, workspaceId), folderParentCondition)),
  ])

  const minSortOrder = [workflowMinResult?.minOrder, folderMinResult?.minOrder].reduce<
    number | null
  >((currentMin, candidate) => {
    if (candidate == null) return currentMin
    if (currentMin == null) return candidate
    return Math.min(currentMin, candidate)
  }, null)

  const sortOrder = minSortOrder != null ? minSortOrder - 1 : 0

  await db.insert(workflowTable).values({
    id: workflowId,