chore: update Mosaic to 0.19.1

packages/backend/src/anywidget/index.ts

@@ -28,7 +28,7 @@ function makeDatabaseConnector(model: AnyModel<Model>): Connector {
     } else {
       switch (msg.type) {
         case "arrow": {
-          const table = decodeIPC(buffers[0].buffer as any);
+          const table = decodeIPC(buffers[0].buffer);
           query.resolve(table);
           break;
         }

packages/component/package.json

@@ -26,8 +26,8 @@
     }
   },
   "peerDependencies": {
-    "@uwdata/mosaic-core": ">=0.15.0",
-    "@uwdata/mosaic-sql": ">=0.15.0",
+    "@uwdata/mosaic-core": ">=0.19.0",
+    "@uwdata/mosaic-sql": ">=0.19.0",
     "svelte": ">=5.0.0"
   },
   "peerDependenciesMeta": {
@@ -39,9 +39,9 @@
     "@sveltejs/vite-plugin-svelte": "^6.1.0",
     "@tsconfig/svelte": "^5.0.4",
     "@types/d3-color": "^3.1.3",
-    "@uwdata/mosaic-core": ">=0.18.0",
-    "@uwdata/mosaic-sql": ">=0.18.0",
-    "@uwdata/vgplot": ">=0.18.0",
+    "@uwdata/mosaic-core": ">=0.19.0",
+    "@uwdata/mosaic-sql": ">=0.19.0",
+    "@uwdata/vgplot": ">=0.19.0",
     "@webgpu/types": "^0.1.64",
     "d3-color": "^3.1.0",
     "fast-kde": "0.2.2",

packages/component/src/demo/EmbeddingViewMosaicDemo.svelte

@@ -46,7 +46,7 @@
     await db.registerFileText("rows.json", JSON.stringify(dataset));
     await (await db.connect()).insertJSONFromPath("rows.json", { name: "data_table" });
 
-    let r: any = await coordinator().query("SELECT COUNT(*) AS count FROM data_table");
+    let r = await coordinator().query("SELECT COUNT(*) AS count FROM data_table");
     pointCount = r.get(0).count;
 
     brush = vg.Selection.crossfilter();

packages/component/src/lib/embedding_view/EmbeddingViewMosaic.svelte

@@ -1,6 +1,6 @@
 <!-- Copyright (c) 2025 Apple Inc. Licensed under MIT License. -->
 <script lang="ts">
-  import { coordinator as defaultCoordinator, isSelection, type MosaicClient } from "@uwdata/mosaic-core";
+  import { coordinator as defaultCoordinator, isSelection, makeClient, type MosaicClient } from "@uwdata/mosaic-core";
   import * as SQL from "@uwdata/mosaic-sql";
   import { untrack } from "svelte";
 
@@ -14,7 +14,6 @@
     predicateForRangeSelection,
     queryApproximateDensity,
   } from "./mosaic_client.js";
-  import { makeClient } from "./mosaic_helper.js";
   import type { DataPoint, DataPointID } from "./types.js";
   import {
     textSummarizerAdd,
@@ -90,7 +89,7 @@
       // A client is a thing that queries data from a selection with user-defined query
       client = makeClient({
         coordinator: deps.coordinator,
-        selection: filter,
+        selection: filter ?? undefined,
         query: (predicate) => {
           return SQL.Query.from(source.table)
             .select({
@@ -100,7 +99,7 @@
             })
             .where(predicate);
         },
-        queryResult: (data) => {
+        queryResult: (data: any) => {
           let xArray = data.getChild("x").toArray();
           let yArray = data.getChild("y").toArray();
           let categoryArray = data.getChild("c")?.toArray() ?? null;
@@ -346,7 +345,7 @@
     let chunkSize = 10000;
     let lastAdd: Promise<unknown> | null = null;
     while (true) {
-      let r: any = await coordinator.query(
+      let r = await coordinator.query(
         SQL.Query.from(table)
           .select({ x: SQL.column(x), y: SQL.column(y), text: SQL.column(text) })
           .offset(start)

packages/component/src/lib/embedding_view/mosaic_client.ts

@@ -1,6 +1,5 @@
 // Copyright (c) 2025 Apple Inc. Licensed under MIT License.
 
-import type { Table } from "@uwdata/flechette";
 import type { Coordinator } from "@uwdata/mosaic-core";
 import * as SQL from "@uwdata/mosaic-sql";
 
@@ -108,7 +107,7 @@ export async function queryApproximateDensity(
 }> {
   let { x, y, table } = source;
   // Find the view transform that fits all data points in a square view.
-  let r = (await coordinator.query(
+  let r = await coordinator.query(
     SQL.Query.from(table).select({
       centerX: SQL.sql`MEDIAN(${SQL.column(x)})`,
       centerY: SQL.sql`MEDIAN(${SQL.column(y)})`,
@@ -120,7 +119,7 @@ export async function queryApproximateDensity(
           }
         : {}),
     }),
-  )) as Table;
+  );
   let { centerX, centerY, stdX, stdY, maxCategory } = r.get(0);
   let scaler = 1.0 / (Math.max(stdX, stdY, 1e-3) * 3);
 
@@ -140,7 +139,7 @@ export async function queryApproximateDensity(
     maxCount: SQL.sql`MAX(count)::INT`,
   });
 
-  r = (await coordinator.query(q)) as Table;
+  r = await coordinator.query(q);
   let { maxCount, totalCount } = r.get(0);
   let maxDensity = maxCount / (binWidth * binWidth);
 
@@ -233,7 +232,7 @@ export class DataPointQuery {
         q = q.where(predicate);
       }
       q = q.orderby(SQL.sql`(x - (${px}))**2 + (y - (${py}))**2`).limit(1);
-      let result = (await this.coordinator.query(q)) as Table;
+      let result = await this.coordinator.query(q);
       let point = result.get(0);
       if (point) {
         this.lastDistance = Math.max(Math.abs(point.x - px), Math.abs(point.y - py)) * 4;
@@ -255,7 +254,7 @@ export class DataPointQuery {
         identifiers.map((x) => SQL.literal(x)),
       ),
     );
-    let result = Array.from((await this.coordinator.query(q)) as Table);
+    let result = Array.from(await this.coordinator.query(q));
     return result.map((row) => this._convertToDataPoint(row));
   }
 }

packages/embedding-atlas/package.json

@@ -59,10 +59,10 @@
   },
   "dependencies": {},
   "peerDependencies": {
-    "@uwdata/mosaic-core": ">=0.15.0",
-    "@uwdata/mosaic-spec": ">=0.15.0",
-    "@uwdata/mosaic-sql": ">=0.15.0",
-    "@uwdata/vgplot": ">=0.15.0",
+    "@uwdata/mosaic-core": ">=0.19.0",
+    "@uwdata/mosaic-spec": ">=0.19.0",
+    "@uwdata/mosaic-sql": ">=0.19.0",
+    "@uwdata/vgplot": ">=0.19.0",
     "react": ">=17.0.0",
     "svelte": ">=5.0.0"
   },

packages/examples/package.json

@@ -17,10 +17,10 @@
     "@tsconfig/svelte": "^5.0.4",
     "@types/react": "^19.1.12",
     "@types/react-dom": "^19.1.9",
-    "@uwdata/mosaic-core": ">=0.18.0",
-    "@uwdata/mosaic-spec": ">=0.18.0",
-    "@uwdata/mosaic-sql": ">=0.18.0",
-    "@uwdata/vgplot": ">=0.18.0",
+    "@uwdata/mosaic-core": ">=0.19.0",
+    "@uwdata/mosaic-spec": ">=0.19.0",
+    "@uwdata/mosaic-sql": ">=0.19.0",
+    "@uwdata/vgplot": ">=0.19.0",
     "postcss": "^8.5.6",
     "react": "^19.1.1",
     "react-dom": "^19.1.1",

packages/examples/src/svelte/EmbeddingViewMosaicExample.svelte

@@ -47,7 +47,7 @@
     await db.registerFileText("rows.json", JSON.stringify(dataset));
     await (await db.connect()).insertJSONFromPath("rows.json", { name: "data_table" });
 
-    let r: any = await coordinator.query("SELECT COUNT(*) AS count FROM data_table");
+    let r = await coordinator.query("SELECT COUNT(*) AS count FROM data_table");
     pointCount = r.get(0).count;
 
     brush = vg.Selection.crossfilter();

packages/examples/src/svelte/TableExample.svelte

@@ -13,7 +13,7 @@
     const wasm = await wasmConnector();
     coordinator.databaseConnector(wasm);
     await createSampleDataTable(coordinator, "dataset", 100000);
-    let describe: any = await coordinator.query("DESCRIBE dataset");
+    let describe = await coordinator.query("DESCRIBE dataset");
     columns = Array.from(describe.getChild("column_name"));
   })();
 </script>

packages/table/package.json

@@ -28,8 +28,8 @@
     }
   },
   "peerDependencies": {
-    "@uwdata/mosaic-core": ">=0.15.0",
-    "@uwdata/mosaic-sql": ">=0.15.0",
+    "@uwdata/mosaic-core": ">=0.19.0",
+    "@uwdata/mosaic-sql": ">=0.19.0",
     "svelte": "^5.0.0"
   },
   "devDependencies": {

packages/table/src/lib/controllers/TableController.svelte.ts

@@ -350,7 +350,7 @@ export class TableController {
       .from("original")
       .where(eq(column(this.rowKeyColumn!), literal(rowKey)));
 
-    const result: any = await this.coordinator.query(query);
+    const result = await this.coordinator.query(query);
     const arr = result.toArray();
     if (arr.length > 0) {
       const offset = arr[0][OID] - 1;
@@ -431,7 +431,7 @@ export class TableController {
     }, {});
 
     const query = Query.from(tableName).select(select).offset(0).limit(10);
-    const sample: any = await this.coordinator.query(query);
+    const sample = await this.coordinator.query(query);
     const arr = sample.toArray();
     for (const row of arr) {
       for (const col of cols) {

packages/viewer/package.json

@@ -20,10 +20,10 @@
     }
   },
   "peerDependencies": {
-    "@uwdata/mosaic-core": ">=0.15.0",
-    "@uwdata/mosaic-spec": ">=0.15.0",
-    "@uwdata/mosaic-sql": ">=0.15.0",
-    "@uwdata/vgplot": ">=0.15.0"
+    "@uwdata/mosaic-core": ">=0.19.0",
+    "@uwdata/mosaic-spec": ">=0.19.0",
+    "@uwdata/mosaic-sql": ">=0.19.0",
+    "@uwdata/vgplot": ">=0.19.0"
   },
   "devDependencies": {
     "@embedding-atlas/component": "*",

packages/viewer/src/AdhocViewer.svelte

@@ -43,8 +43,8 @@
       let db = await (coordinator.databaseConnector()! as DuckDBWASMConnector).getDuckDB();
       await db.registerFileBuffer(file.name, new Uint8Array(await file.arrayBuffer()));
       await coordinator.exec(`CREATE TABLE dataset AS SELECT * FROM ${literal(file.name)}`);
-      let describeResult: any = await coordinator.query(`DESCRIBE TABLE dataset`);
-      describe = Array.from(describeResult);
+      let describeResult = await coordinator.query(`DESCRIBE TABLE dataset`);
+      describe = Array.from(describeResult) as typeof describe;
       await coordinator.exec(`
         ALTER TABLE dataset DROP COLUMN IF EXISTS __row_index__;
         ALTER TABLE dataset ADD COLUMN __row_index__ INTEGER;

packages/viewer/src/embedding/index.ts

@@ -21,7 +21,7 @@ async function* inputBatches(
   valueColumn: string,
   batchSize: number,
 ): AsyncGenerator<any> {
-  let r: any = await coordinator.query(SQL.Query.from(table).select({ count: SQL.count() }));
+  let r = await coordinator.query(SQL.Query.from(table).select({ count: SQL.count() }));
   let count = r.get(0).count;
   let start = 0;
   while (start < count) {

packages/viewer/src/lib/EmbeddingAtlas.svelte

@@ -41,7 +41,7 @@
   import { Context } from "./contexts.js";
   import { CustomOverlay, CustomTooltip } from "./custom_components.js";
   import { makeDarkModeStore } from "./dark_mode_store.js";
-  import { TableInfo, type ColumnDesc, type EmbeddingLegend } from "./database_utils.js";
+  import { predicateToString, TableInfo, type ColumnDesc, type EmbeddingLegend } from "./database_utils.js";
   import type { Plot } from "./plots/plot.js";
   import { PlotStateStoreManager } from "./plots/plot_state_store.js";
   import { getRenderer, type ColumnStyle } from "./renderers/index.js";
@@ -112,15 +112,7 @@
   const crossFilter = vg.Selection.crossfilter();
 
   function currentPredicate(): string | null {
-    let predicate: any = crossFilter.predicate(null as any);
-    if (predicate == null || predicate.length == 0) {
-      return null;
-    }
-    if (typeof predicate == "string") {
-      return predicate;
-    }
-    let joined = predicate.map((x: any) => x.toString()).join(" AND ");
-    return joined;
+    return predicateToString(crossFilter.predicate(null));
   }
 
   let columns: ColumnDesc[] = $state.raw([]);
@@ -338,15 +330,15 @@
       if (data.projection == null) {
         return;
       }
-      let result: any = await coordinator.query(
+      let result = await coordinator.query(
         SQL.Query.from(data.table)
           .select({
             x: SQL.column(data.projection.x),
             y: SQL.column(data.projection.y),
           })
           .where(SQL.eq(SQL.column(data.id), SQL.literal(identifier))),
       );
-      let item: { x: number; y: number } = result.get(0);
+      let item = result.get(0) as { x: number; y: number };
       x = item.x;
       y = item.y;
     }