Refactor viewer state model

Signed-off-by: Andrew Stein <steinlink@gmail.com>

Author: texodus

examples/blocks/src/fractal/index.js

@@ -56,6 +56,7 @@ c`;
 function generate_layout(params) {
     return {
         plugin: "Heatmap",
+        table: "raw_data",
         settings: true,
         group_by: [`floor("index" / ${params.resolution})`],
         split_by: [`"index" % ${params.resolution}`],
@@ -116,10 +117,16 @@ const make_run_click_callback = (worker, state) => async () => {
 
     window.run.disabled = true;
     if (!state.table) {
-        state.table = await worker.table({
-            index: "integer",
-        });
-        window.viewer.load(Promise.resolve(state.table));
+        state.table = await worker.table(
+            {
+                index: "integer",
+            },
+            {
+                name: "raw_data",
+            },
+        );
+
+        window.viewer.load(worker);
     }
 
     const run = document.getElementById("run");
@@ -154,4 +161,5 @@ run.addEventListener(
     "click",
     make_run_click_callback(await perspective.worker(), {}),
 );
+
 run.dispatchEvent(new Event("click"));

packages/viewer-datagrid/src/ts/style_handlers/body.ts

@@ -65,18 +65,20 @@ export function applyBodyCellStyles(
 
         // Calculate aggregate depth visibility
         // @ts-ignore
-        metadata._is_hidden_by_aggregate_depth = ((x?: number) =>
-            x === 0 || x === undefined
-                ? false
-                : x - 1 <
-                  Math.min(
-                      this._config.group_by.length,
-                      plugin?.aggregate_depth || 0,
-                  ))(
-            (metadata.row_header as unknown[] | undefined)?.filter(
-                (x) => x !== undefined,
-            )?.length,
-        );
+        metadata._is_hidden_by_aggregate_depth =
+            this._config.group_rollup_mode === "rollup" &&
+            ((x?: number) =>
+                x === 0 || x === undefined
+                    ? false
+                    : x - 1 <
+                      Math.min(
+                          this._config.group_by.length,
+                          plugin?.aggregate_depth || 0,
+                      ))(
+                (metadata.row_header as unknown[] | undefined)?.filter(
+                    (x) => x !== undefined,
+                )?.length,
+            );
 
         // Apply type-specific cell styling
         if (is_numeric) {

rust/perspective-client/src/rust/client.rs

@@ -88,7 +88,7 @@ impl<U: Copy + 'static> SystemInfo<U> {
 
 /// Metadata about what features are supported by the `Server` to which this
 /// [`Client`] connects.
-#[derive(Clone, Debug, Default)]
+#[derive(Clone, Debug, Default, PartialEq)]
 pub struct Features(Arc<GetFeaturesResp>);
 
 impl Features {

rust/perspective-client/src/rust/table.rs

@@ -152,7 +152,7 @@ pub struct UpdateOptions {
 
 /// Result of a call to [`Table::validate_expressions`], containing a schema
 /// for valid expressions and error messages for invalid ones.
-#[derive(Clone, Debug, Serialize, Deserialize)]
+#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
 pub struct ExprValidationResult {
     pub expression_schema: Schema,
     pub errors: HashMap<String, table_validate_expr_resp::ExprValidationError>,

rust/perspective-client/src/rust/virtual_server/features.rs

@@ -24,7 +24,7 @@ use crate::proto::{ColumnType, GetFeaturesResp};
 /// This struct is returned by
 /// [`VirtualServerHandler::get_features`](super::VirtualServerHandler::get_features)
 /// to inform clients about which operations are available.
-#[derive(Debug, Default, Deserialize, Serialize)]
+#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
 pub struct Features<'a> {
     /// Whether group-by aggregation is supported.
     #[serde(default)]
@@ -63,7 +63,7 @@ pub struct Features<'a> {
 ///
 /// Aggregates can either take no additional arguments ([`AggSpec::Single`])
 /// or require column type arguments ([`AggSpec::Multiple`]).
-#[derive(Clone, Debug, Deserialize, Serialize)]
+#[derive(Clone, Debug, Deserialize, PartialEq, Serialize)]
 #[serde(untagged)]
 pub enum AggSpec<'a> {
     /// An aggregate function with no additional arguments.

rust/perspective-js/src/rust/utils/futures.rs

@@ -64,6 +64,10 @@ where
     pub fn spawn<U: Future<Output = ApiResult<T>> + 'static>(x: U) {
         drop(js_sys::Promise::from(Self::new(x)))
     }
+
+    pub fn spawn_throttled<U: Future<Output = ApiResult<T>> + 'static>(x: U) {
+        drop(js_sys::Promise::from(Self::new_throttled(x)))
+    }
 }
 
 impl<T> Default for ApiFuture<T>