Function resolveWorkflowIdForUser

apps/sim/lib/workflows/utils.ts:132–249

(
  userId: string,
  workflowId?: string,
  workflowName?: string,
  workspaceId?: string
)

    }

export async function resolveWorkflowIdForUser(
  userId: string,
  workflowId?: string,
  workflowName?: string,
  workspaceId?: string
): Promise<WorkflowResolutionResult> {
  if (workflowId) {
    const authorization = await authorizeWorkflowByWorkspacePermission({
      workflowId,
      userId,
      action: 'read',
    })
    if (!authorization.allowed) {
      return {
        status: 'not_found',
        message: 'No workflows found. Create a workflow first or provide a valid workflowId.',
      }
    }
    const wf = await getWorkflowById(workflowId)
    if (!wf?.workspaceId) {
      return {
        status: 'not_found',
        message: 'No workflows found. Create a workflow first or provide a valid workflowId.',
      }
    }
    return {
      status: 'resolved',
      workflowId,
      workspaceId: wf.workspaceId,
      workflowName: wf.name || undefined,
    }
  }

  const accessibleRows = await listAccessibleWorkspaceRowsForUser(userId, 'all')
  const workspaceIdList = accessibleRows.map((row) => row.workspace.id)
  const allowedWorkspaceIds = workspaceId
    ? workspaceIdList.filter((candidateWorkspaceId) => candidateWorkspaceId === workspaceId)
    : workspaceIdList
  if (allowedWorkspaceIds.length === 0) {
    return {
      status: 'not_found',
      message: 'No workflows found. Create a workflow first or provide a valid workflowId.',
    }
  }

  const workflowRows = await db
    .select()
    .from(workflowTable)
    .where(
      and(inArray(workflowTable.workspaceId, allowedWorkspaceIds), isNull(workflowTable.archivedAt))
    )
    .orderBy(asc(workflowTable.sortOrder), asc(workflowTable.createdAt), asc(workflowTable.id))

  const workflows = workflowRows.filter(
    (workflow): workflow is (typeof workflowRows)[number] & { workspaceId: string } =>
      workflow.workspaceId !== null
  )