feat: measure validator (#119)

* add: dimension validator

* add: typegiards

* update: test

* more: test

* update: package

* fix: build

* update: export

* remove: log

* resolve: comments

* update: types

* update: export

* address: comments

Author: vpbs2

meerkat-browser/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@devrev/meerkat-browser",
-  "version": "0.0.84",
+  "version": "0.0.85",
   "dependencies": {
     "@swc/helpers": "~0.5.0",
     "@devrev/meerkat-core": "*",

meerkat-browser/src/ast/index.ts

@@ -1,2 +1,3 @@
 export * from './dimension';
+export * from './measure';
 export * from './query-to-ast';

meerkat-browser/src/ast/measure.ts

@@ -0,0 +1,41 @@
+import { validateMeasure } from '@devrev/meerkat-core';
+import { AsyncDuckDBConnection } from '@duckdb/duckdb-wasm';
+import { parseQueryToAST } from './query-to-ast';
+import { getAvailableFunctions, isParseError } from './utils';
+
+/**
+ * Validates the query can be used as a measure by parsing it to an AST and checking its structure
+ * @param connection - DuckDB connection instance
+ * @param query - The query string to validate
+ * @returns Promise<boolean> - Whether the measure is valid
+ */
+export const validateMeasureQuery = async ({
+  connection,
+  query,
+  validFunctions,
+}: {
+  connection: AsyncDuckDBConnection;
+  query: string;
+  validFunctions?: string[];
+}): Promise<boolean> => {
+  const parsedSerialization = await parseQueryToAST(query, connection);
+
+  if (isParseError(parsedSerialization)) {
+    throw new Error(parsedSerialization.error_message ?? 'Unknown error');
+  }
+
+  // Only fetch valid functions if not provided
+  const availableFunctions =
+    validFunctions ?? (await getAvailableFunctions(connection, 'aggregate'));
+
+  const validScalarFunctions = await getAvailableFunctions(
+    connection,
+    'scalar'
+  );
+
+  return validateMeasure(
+    parsedSerialization,
+    availableFunctions,
+    validScalarFunctions
+  );
+};

meerkat-browser/src/index.ts

@@ -1,4 +1,8 @@
 export * from './browser-cube-to-sql/browser-cube-to-sql';
 export { convertCubeStringToTableSchema };
 import { convertCubeStringToTableSchema } from '@devrev/meerkat-core';
-export { validateDimensionQuery } from './ast';
+export {
+  parseQueryToAST,
+  validateDimensionQuery,
+  validateMeasureQuery,
+} from './ast';

meerkat-core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@devrev/meerkat-core",
-  "version": "0.0.84",
+  "version": "0.0.85",
   "dependencies": {
     "@swc/helpers": "~0.5.0"
   },