ci: apply automated fixes

Author: autofix-ci[bot]

packages/db/src/query/live/ordered-source-loader.ts

@@ -489,10 +489,7 @@ export class OrderedSourceLoader {
     // Register each request separately. The operation tracker observes the
     // next request before this promise settles, so the logical chain remains
     // pending without retaining every ancestor promise until the final page.
-    this.onResult(
-      tracked,
-      isFullSource && this.needsFullSourceRecovery,
-    )
+    this.onResult(tracked, isFullSource && this.needsFullSourceRecovery)
     return tracked
   }
 

packages/db/tests/live-query-window-controller.test.ts

@@ -79,9 +79,7 @@ describe(`createLiveQueryWindowController`, () => {
   )(
     `handles $action during initial loading with $rowCount rows`,
     async ({ rowCount, action }) => {
-      const { source, resolveLoad } = makePendingSource(
-        ROWS.slice(0, rowCount),
-      )
+      const { source, resolveLoad } = makePendingSource(ROWS.slice(0, rowCount))
       const lq = makeOrderedLiveQuery(source, 2)
       const controller = createLiveQueryWindowController(lq, {
         pageSize: 2,

packages/db/tests/query/live-query-collection.test.ts

@@ -4092,8 +4092,8 @@ describe(`createLiveQueryCollection`, () => {
             markReady()
 
             return {
-                loadSubset: (options) => {
-                  loadSubsetCallCount++
+              loadSubset: (options) => {
+                loadSubsetCallCount++
                 if (!initialPreloadComplete || moveStarted) return true
                 moveStarted = true
                 return gate.promise.then(() => {
@@ -4112,9 +4112,9 @@ describe(`createLiveQueryCollection`, () => {
       const liveQuery = createLiveQueryCollection({
         query: (q) =>
           q
-              .from({ item: sourceCollection })
-              .orderBy(({ item }) => item.value, `asc`)
-              .limit(1)
+            .from({ item: sourceCollection })
+            .orderBy(({ item }) => item.value, `asc`)
+            .limit(1)
             .offset(0),
         startSync: true,
       })

packages/db/tests/query/ordered-source-loader.test.ts

@@ -247,10 +247,7 @@ describe(`OrderedSourceLoader`, () => {
     `settles a fully synchronous $route acquisition before start returns`,
     (route) => {
       const requests: Array<string> = []
-      const request = (
-        method: string,
-        options: RequestOptions,
-      ): void => {
+      const request = (method: string, options: RequestOptions): void => {
         requests.push(method)
         options.onLoadSubsetResult?.(true, options, () => {})
       }

packages/react-db/src/useLiveQuery.ts

@@ -47,10 +47,7 @@ type SuspenseCollectionEntry = {
   removeStatusListeners: () => void
 }
 
-const unscopedSuspenseCollections = new Map<
-  string,
-  SuspenseCollectionEntry
->()
+const unscopedSuspenseCollections = new Map<string, SuspenseCollectionEntry>()
 const suspenseCollectionsByClient = new WeakMap<
   DbClient,
   Map<string, SuspenseCollectionEntry>
@@ -197,12 +194,14 @@ function getCurrentTime(): number {
 function getWarningCallsite(stackIndex: number): string {
   const stack = new Error().stack ?? `unknown`
   const lines = stack.split(`\n`)
-  const userFrame = lines.slice(1).find(
-    (line) =>
-      !line.includes(`useLiveQuery.ts`) &&
-      !line.includes(`useLiveSuspenseQuery.ts`) &&
-      !line.includes(`useLiveInfiniteQuery.ts`),
-  )
+  const userFrame = lines
+    .slice(1)
+    .find(
+      (line) =>
+        !line.includes(`useLiveQuery.ts`) &&
+        !line.includes(`useLiveSuspenseQuery.ts`) &&
+        !line.includes(`useLiveInfiniteQuery.ts`),
+    )
   return userFrame?.trim() ?? lines[stackIndex]?.trim() ?? stack
 }
 
@@ -873,7 +872,8 @@ function useLiveQueryImpl(
   const suspenseEntry = suspenseKey
     ? suspenseCollections?.get(suspenseKey)
     : undefined
-  if (suspenseConsumerId) suspenseEntry?.pendingConsumers.add(suspenseConsumerId)
+  if (suspenseConsumerId)
+    suspenseEntry?.pendingConsumers.add(suspenseConsumerId)
   const suspenseCollection = suspenseEntry?.collection
 
   const identityChanged =
@@ -936,14 +936,12 @@ function useLiveQueryImpl(
         ) as SuspenseCollection
         if (suspenseCollections && suspenseKey && suspenseConsumerId) {
           const collection = collectionRef.current
-          const removeCleanupListener = collection.on(
-            `status:cleaned-up`,
-            () =>
-              releaseSuspenseCollection(
-                suspenseCollections,
-                suspenseKey,
-                collection,
-              ),
+          const removeCleanupListener = collection.on(`status:cleaned-up`, () =>
+            releaseSuspenseCollection(
+              suspenseCollections,
+              suspenseKey,
+              collection,
+            ),
           )
           const removeErrorListener = collection.on(`status:error`, () => {
             // Keep the failed collection through React's immediate retry so

packages/react-db/tests/useLiveQuery.uncommitted-render.test.tsx

@@ -226,9 +226,7 @@ describe(`live queries across uncommitted renders`, () => {
     const People = () => {
       const { data } = useLiveSuspenseQuery({
         query: (q) =>
-          q
-            .from({ person: source })
-            .where(({ person }) => eq(person.id, `1`)),
+          q.from({ person: source }).where(({ person }) => eq(person.id, `1`)),
       })
       return <div>{data.map((person) => person.name).join(`, `)}</div>
     }
@@ -291,9 +289,7 @@ describe(`live queries across uncommitted renders`, () => {
     collections.push(source)
     const config = {
       query: (q: InitialQueryBuilder) =>
-        q
-          .from({ person: source })
-          .where(({ person }) => eq(person.id, `1`)),
+        q.from({ person: source }).where(({ person }) => eq(person.id, `1`)),
     }
     const First = () => {
       const { data } = useLiveSuspenseQuery(config)