Function selectRowDataPage

apps/sim/lib/table/rows/ordering.ts:542–574

(params: {
  tableId: string
  workspaceId: string
  cutoff: Date
  filterClause?: SQL
  afterId?: string
  limit: number
  excludeIfPatched?: string
})

 * would double-count progress. It also skips no-op updates of rows that already hold those values.
 */
export async function selectRowDataPage(params: {
  tableId: string
  workspaceId: string
  cutoff: Date
  filterClause?: SQL
  afterId?: string
  limit: number
  excludeIfPatched?: string
}): Promise<Array<{ id: string; data: RowData }>> {
  const { tableId, workspaceId, cutoff, filterClause, afterId, limit, excludeIfPatched } = params
  const selectPage = (executor: DbExecutor) =>
    executor
      .select({ id: userTableRows.id, data: userTableRows.data })
      .from(userTableRows)
      .where(
        and(
          eq(userTableRows.tableId, tableId),
          eq(userTableRows.workspaceId, workspaceId),
          lte(userTableRows.createdAt, cutoff),
          afterId ? gt(userTableRows.id, afterId) : undefined,
          excludeIfPatched
            ? sql`NOT (${userTableRows.data} @> ${excludeIfPatched}::jsonb)`
            : undefined,
          filterClause
        )
      )
      .orderBy(asc(userTableRows.id))
      .limit(limit)
  const rows = filterClause
    ? await withSeqscanOff(async (trx) => selectPage(trx))
    : await selectPage(db)
  return rows.map((r) => ({ id: r.id, data: r.data as RowData }))
}

/**
 * Deletes one page of rows for the async delete-job worker, committing each `DELETE_BATCH_SIZE`