Function assertNoPushdownViolation

packages/db-collection-e2e/src/utils/assertions.ts:140–157

(
  collection: Collection<T>,
  expectedMaxIds: Array<string>,
  message?: string,
)

 * This checks that the collection didn't load more data than necessary
 */
export function assertNoPushdownViolation<T extends { id: string }>(
  collection: Collection<T>,
  expectedMaxIds: Array<string>,
  message?: string,
) {
  const loadedIds = getLoadedIds(collection)
  const expectedSet = new Set(expectedMaxIds)

  // Check if any loaded IDs are not in expected set
  const extraIds = loadedIds.filter((id) => !expectedSet.has(id))

  if (extraIds.length > 0) {
    throw new Error(
      message ??
        `Predicate pushdown violation: Collection loaded ${extraIds.length} extra item(s) that don't match the predicate`,
    )
  }
}

/**
 * Assert that deduplication occurred