Function listLogs

apps/sim/lib/logs/list-logs.ts:68–454

(params: ListLogsParams, userId: string)

 * workspace permission via the `permissions` join.
 */
export async function listLogs(params: ListLogsParams, userId: string): Promise<ListLogsResponse> {
  const access = await checkWorkspaceAccess(params.workspaceId, userId)
  if (!access.hasAccess) {
    return { data: [], nextCursor: null }
  }

  const sortBy = params.sortBy as SortBy
  const sortOrder = params.sortOrder as SortOrder
  const cursor = params.cursor ? decodeCursor(params.cursor) : null

  // Expand selected folders to include descendants (matches the route behavior),
  // without mutating the caller's params object.
  const folderIds = params.folderIds
    ? await expandFolderIdsWithDescendants(params.workspaceId, params.folderIds)
    : params.folderIds
  const p: ListLogsParams = { ...params, folderIds }

  const workflowSortExpr: SQL<unknown> = (() => {
    switch (sortBy) {
      case 'duration':
        return sql`${workflowExecutionLogs.totalDurationMs}`
      case 'cost':
        // Indexed projection of the usage_log ledger (dollars); no live aggregation.
        return sql`${workflowExecutionLogs.costTotal}`
      case 'status':
        return sql`${workflowExecutionLogs.status}`
      default:
        return sql`${workflowExecutionLogs.startedAt}`
    }
  })()

  const jobSortExpr: SQL<unknown> = (() => {
    switch (sortBy) {
      case 'duration':
        return sql`${jobExecutionLogs.totalDurationMs}`
      case 'cost':
        return sql`(${jobExecutionLogs.cost}->>'total')::numeric`
      case 'status':
        return sql`${jobExecutionLogs.status}`
      default:
        return sql`${jobExecutionLogs.startedAt}`
    }
  })()

  const dir = sortOrder === 'asc' ? asc : desc
  const nullsLast = sql`NULLS LAST`
  const orderByClause = (expr: SQL): SQL => sql`${dir(expr)} ${nullsLast}`

  const buildCursorCondition = (sortExpr: unknown, idCol: unknown): SQL | undefined => {
    if (!cursor) return undefined
    const v = cursor.v
    const id = cursor.id
    const cmp = sortOrder === 'asc' ? sql`>` : sql`<`
    if (v === null) {
      return sql`(${sortExpr} IS NULL AND ${idCol} ${cmp} ${id})`
    }
    return sql`((${sortExpr} IS NOT NULL AND ${sortExpr} ${cmp} ${v}) OR (${sortExpr} = ${v} AND ${idCol} ${cmp} ${id}) OR ${sortExpr} IS NULL)`
  }