fix: fixed dangling window object

Author: mbret

src/lib/queries/client/focusManager.ts

@@ -1,9 +1,19 @@
-import { filter, fromEvent, map, merge, skip, tap, BehaviorSubject } from "rxjs"
+import {
+  filter,
+  fromEvent,
+  map,
+  merge,
+  skip,
+  tap,
+  BehaviorSubject,
+  EMPTY
+} from "rxjs"
+import { isServer } from "../../utils"
 
 export class FocusManager {
   readonly #visibility$ = merge(
     fromEvent(document, "visibilitychange"),
-    fromEvent(window, "visibilitychange")
+    isServer ? EMPTY : fromEvent(window, "visibilitychange")
   ).pipe(map(() => document.visibilityState))
 
   readonly #focusedSubject = new BehaviorSubject(

src/lib/queries/client/onlineManager.ts

@@ -1,5 +1,6 @@
 import {
   BehaviorSubject,
+  EMPTY,
   distinctUntilChanged,
   filter,
   first,
@@ -8,6 +9,7 @@ import {
   merge
 } from "rxjs"
 import { emitToSubject } from "../../utils/operators/emitToSubject"
+import { isServer } from "../../utils"
 
 export class OnlineManager {
   protected isOnlineSubject = new BehaviorSubject(true)
@@ -21,8 +23,8 @@ export class OnlineManager {
 
   constructor() {
     merge(
-      fromEvent(window, "offline").pipe(map(() => false)),
-      fromEvent(window, "online").pipe(map(() => true))
+      isServer ? EMPTY : fromEvent(window, "offline").pipe(map(() => false)),
+      isServer ? EMPTY : fromEvent(window, "online").pipe(map(() => true))
     )
       .pipe(emitToSubject(this.isOnlineSubject))
       .subscribe()

src/lib/queries/client/queries/query/query.rq.test.ts

@@ -399,7 +399,6 @@ describe("query", () => {
     expect(queryFn).toHaveBeenCalledTimes(1)
     expect(isCancelledError(query.state.error)).toBe(true)
     const result = await query.fetch()
-
     expect(result).toBe("data")
     expect(query.state.error).toBe(null)
     expect(queryFn).toHaveBeenCalledTimes(2)
@@ -524,7 +523,7 @@ describe("query", () => {
     // unsubscribe should not remove even though gcTime has elapsed b/c query is still fetching
     expect(queryCache.find({ queryKey: key })).toBeDefined()
     await sleep(10)
-    // // should be removed after an additional staleTime wait
+    // should be removed after an additional staleTime wait
     await waitFor(() => {
       expect(queryCache.find({ queryKey: key })).toBeUndefined()
     })