fix(oxlint): keep unsafe type assertions on a single line

oxlint-tsgolint 7.0.2004 reports a multi-line type assertion at its first
line, so the disable comment above its last line no longer applied.

- Bridge Dexie's liveQuery to rxjs Observable in a liveObservable helper
- Move the WidgetHandle cast to an asWidgetHandle helper
- Await the WebSocket client before casting it to RpcClient

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

Author: BotellaA

app/composables/clipping_planes_widget_entries.ts

@@ -47,6 +47,11 @@ function asWidgetFactory(widget: PlaneWidget): vtkAbstractWidgetFactory<vtkAbstr
   return widget as unknown as vtkAbstractWidgetFactory<vtkAbstractWidget>;
 }
 
+function asWidgetHandle(widget: unknown): WidgetHandle {
+  // oxlint-disable-next-line no-unsafe-type-assertion -- vtk.js WidgetManager.addWidget is untyped for our custom WidgetHandle shape; narrowed here.
+  return widget as WidgetHandle;
+}
+
 interface WidgetEntryManagerParams {
   planes: Ref<ClippingPlane[]>;
   debouncedApply: (...args: readonly unknown[]) => void;
@@ -136,10 +141,7 @@ function useWidgetEntryManager({ planes, debouncedApply }: WidgetEntryManagerPar
     if (!widgetEntries[idx]) {
       // oxlint-disable-next-line no-unsafe-call no-unsafe-type-assertion -- vtk.js has no types for ImplicitPlaneWidget's factory; narrowed here.
       const planeWidget = vtkImplicitPlaneWidget() as PlaneWidget;
-      const widgetHandle = widgetManager.addWidget(
-        asWidgetFactory(planeWidget),
-        // oxlint-disable-next-line no-unsafe-type-assertion -- vtk.js WidgetManager.addWidget is untyped for our custom WidgetHandle shape; narrowed here.
-      ) as unknown as WidgetHandle;
+      const widgetHandle = asWidgetHandle(widgetManager.addWidget(asWidgetFactory(planeWidget)));
       widgetEntries.push(createWidgetEntry(planeWidget, widgetHandle, idx));
     }
     const entry = widgetEntries[idx];

app/stores/camera_manager.ts

@@ -1,10 +1,10 @@
-import { type Table, liveQuery } from "dexie";
-import type { Observable } from "rxjs";
+import type { Table } from "dexie";
 import { useObservable } from "@vueuse/rxjs";
 
 // Local imports
 import type { CameraOptions } from "@ogw_internal/stores/hybrid_viewer/vtk_types.js";
 import { database } from "@ogw_internal/database/database.js";
+import { liveObservable } from "@ogw_front/utils/live_observable";
 import { useViewerStore } from "@ogw_front/stores/viewer";
 import viewer_schemas from "@geode/opengeodeweb-viewer/opengeodeweb_viewer_typed_schemas.js";
 
@@ -26,16 +26,11 @@ export const useCameraManagerStore = defineStore("camera_manager", () => {
   >;
 
   function refAllCameraPositions(): Ref<CameraPositionRecord[]> {
-    // Dexie's liveQuery() returns Dexie's own minimal Observable shape, not an
-    // Actual rxjs Observable instance (useObservable's declared parameter type);
-    // The two are structurally close enough at runtime (vueuse only calls
-    // `.subscribe`) but not identical, hence the cast.
     return useObservable(
-      liveQuery(async () => {
+      liveObservable(async () => {
         const positions = await camera_positions_db.toArray();
         return positions;
-        // oxlint-disable-next-line no-unsafe-type-assertion -- trusted vueuse/Dexie Observable boundary; see comment above.
-      }) as unknown as Observable<CameraPositionRecord[]>,
+      }),
       { initialValue: [] as CameraPositionRecord[] },
     );
   }

app/stores/data.ts

@@ -1,13 +1,13 @@
 // oxlint-disable eslint/max-lines
 // Third party imports
-import { type Table, liveQuery } from "dexie";
-import type { Observable } from "rxjs";
+import type { Table } from "dexie";
 import { useObservable } from "@vueuse/rxjs";
 import viewer_schemas from "@geode/opengeodeweb-viewer/opengeodeweb_viewer_typed_schemas.js";
 
 // Local imports
 import { type ModelComponentRecord, useDataMesh } from "./data_helpers/mesh.js";
 import { database } from "@ogw_internal/database/database.js";
+import { liveObservable } from "@ogw_front/utils/live_observable";
 import { useDataCollections } from "./data_helpers/collections.js";
 import { useViewerStore } from "@ogw_front/stores/viewer";
 
@@ -137,16 +137,11 @@ export const useDataStore = defineStore("data", () => {
     return items;
   }
   function refItem(id: string): Ref<DataItem | undefined> {
-    // Dexie's liveQuery() returns Dexie's own minimal Observable shape, not an
-    // Actual rxjs Observable instance (useObservable's declared parameter type);
-    // The two are structurally close enough at runtime (vueuse only calls
-    // `.subscribe`) but not identical, hence the cast.
     return useObservable(
-      liveQuery(async () => {
+      liveObservable(async () => {
         const data_item = await data_db.get(id);
         return data_item;
-        // oxlint-disable-next-line no-unsafe-type-assertion -- trusted vueuse/Dexie Observable boundary; see comment above.
-      }) as unknown as Observable<DataItem | undefined>,
+      }),
       {
         // oxlint-disable-next-line no-unsafe-type-assertion -- placeholder until the live query resolves; consumers must treat this as possibly incomplete.
         initialValue: {} as DataItem,
@@ -155,11 +150,10 @@ export const useDataStore = defineStore("data", () => {
   }
   function refAllItems(): Ref<DataItem[]> {
     return useObservable(
-      liveQuery(async () => {
+      liveObservable(async () => {
         const items = await data_db.toArray();
         return items;
-        // oxlint-disable-next-line no-unsafe-type-assertion -- trusted vueuse/Dexie Observable boundary; see comment above.
-      }) as unknown as Observable<DataItem[]>,
+      }),
       {
         initialValue: [] as DataItem[],
       },

app/stores/data_helpers/collections.ts

@@ -1,9 +1,8 @@
 import { type FormattedComponent, type ModelComponentRecord, useDataMesh } from "./mesh.js";
 import { MESH_COMPONENT_TYPES } from "@ogw_front/utils/default_styles";
-import type { Observable } from "rxjs";
 import type { Ref } from "vue";
 import { getTable } from "@ogw_internal/database/database.js";
-import { liveQuery } from "dexie";
+import { liveObservable } from "@ogw_front/utils/live_observable";
 import { useObservable } from "@vueuse/rxjs";
 
 interface ModelComponentRelationRecord {
@@ -115,12 +114,10 @@ export function useDataCollections(): {
     modelId: string,
   ): Ref<CollectionComponentGroup[] | undefined> {
     return useObservable(
-      // Dexie's liveQuery returns its own Observable-like type, not rxjs's Observable, so bridging needs a cast.
-      liveQuery(async () => {
+      liveObservable(async () => {
         const groups = await formatedCollectionComponents(modelId);
         return groups;
-        // oxlint-disable-next-line no-unsafe-type-assertion
-      }) as unknown as Observable<CollectionComponentGroup[]>,
+      }),
       {
         initialValue: undefined,
       },

app/stores/data_helpers/mesh.ts

@@ -1,6 +1,6 @@
-import { type Table, liveQuery } from "dexie";
-import type { Observable } from "rxjs";
+import type { Table } from "dexie";
 import { database } from "@ogw_internal/database/database.js";
+import { liveObservable } from "@ogw_front/utils/live_observable";
 import { useObservable } from "@vueuse/rxjs";
 
 interface ModelComponentRecord {
@@ -87,11 +87,10 @@ export function useDataMesh(): {
 
   function refFormatedMeshComponents(modelId: string): Ref<FormattedComponentGroup[] | undefined> {
     return useObservable(
-      liveQuery(async () => {
+      liveObservable(async () => {
         const components = await formatedMeshComponents(modelId);
         return components;
-        // oxlint-disable-next-line no-unsafe-type-assertion
-      }) as unknown as Observable<FormattedComponentGroup[]>,
+      }),
       {
         initialValue: undefined,
       },

app/stores/viewer.ts

@@ -142,12 +142,13 @@ export const useViewerStore = defineStore(
         }
         try {
           status.value = Status.CONNECTING;
-          client.value = (await initWebSocketClient(base_url.value, client.value, {
+          const wsClient = await initWebSocketClient(base_url.value, client.value, {
             onConnectionClose: () => {
               status.value = Status.NOT_CONNECTED;
             },
-            // oxlint-disable-next-line no-unsafe-type-assertion -- initWebSocketClient's return is not typed as RpcClient.
-          })) as unknown as RpcClient;
+          });
+          // oxlint-disable-next-line no-unsafe-type-assertion -- initWebSocketClient's return is not typed as RpcClient.
+          client.value = wsClient as unknown as RpcClient;
           connectImageStream(client.value.getConnection().getSession());
           // oxlint-disable-next-line no-unsafe-type-assertion -- endBusy is not part of the RpcClient type.
           (client.value as unknown as { endBusy: () => void }).endBusy();

app/utils/live_observable.ts

@@ -0,0 +1,14 @@
+// Third party imports
+import type { Observable } from "rxjs";
+import { liveQuery } from "dexie";
+
+// Dexie's liveQuery() returns Dexie's own minimal Observable shape, not an
+// Actual rxjs Observable instance (useObservable's declared parameter type);
+// The two are structurally close enough at runtime (vueuse only calls
+// `.subscribe`) but not identical, hence the cast.
+function liveObservable<Value>(query: () => Promise<Value>): Observable<Value> {
+  // oxlint-disable-next-line no-unsafe-type-assertion -- trusted vueuse/Dexie Observable boundary; see comment above.
+  return liveQuery(query) as unknown as Observable<Value>;
+}
+
+export { liveObservable };