feat(meerkat-core): add join filter condition support for links

meerkat-browser/src/browser-cube-to-sql/browser-cube-to-sql.ts

@@ -54,7 +54,8 @@ export const cubeQueryToSQL = async ({
 
   const updatedTableSchema = await getCombinedTableSchema(
     updatedTableSchemas,
-    query
+    query,
+    (q) => getQueryOutput(q, connection)
   );
 
   const ast = cubeToDuckdbAST(query, updatedTableSchema, {

meerkat-core/src/joins/index.spec.ts

@@ -41,7 +41,7 @@ const withArrayCols = (
 });
 
 describe('joins router', () => {
-  it('routes to v2 when joinPathsV2 is set', () => {
+  it('routes to v2 when joinPathsV2 is set', async () => {
     const schemas = [
       withArrayCols('issues', ['id'], ['owned_by_ids']),
       scalar('users'),
@@ -58,12 +58,12 @@ describe('joins router', () => {
         ],
       ],
     };
-    const result = getCombinedTableSchema(schemas, cubeQuery);
+    const result = await getCombinedTableSchema(schemas, cubeQuery);
     expect(result.sql).toContain('UNNEST(owned_by_ids)');
     expect(result.sql).not.toMatch(/CONTAINS/i);
   });
 
-  it('routes to v1 when joinPathsV2 is absent', () => {
+  it('routes to v1 when joinPathsV2 is absent', async () => {
     const schemas = [
       {
         ...scalar('orders', ['id', 'customer_id']),
@@ -76,7 +76,7 @@ describe('joins router', () => {
       dimensions: ['customers.id'],
       joinPaths: [[{ left: 'orders', right: 'customers', on: 'customer_id' }]],
     };
-    const result = getCombinedTableSchema(schemas, cubeQuery);
+    const result = await getCombinedTableSchema(schemas, cubeQuery);
     expect(result.sql).toContain('orders.customer_id = customers.id');
     expect(result.sql).not.toMatch(/UNNEST/);
   });

meerkat-core/src/joins/index.ts

@@ -1,16 +1,18 @@
 import type { Query } from '../types/cube-types';
+import type { GetQueryOutput } from '../utils/duckdb-ast-parse-serialize';
 import { hasJoinPathsV2 } from './accessors';
 import { getCombinedTableSchemaV2 } from './v2/joins';
 import { getCombinedTableSchema as getCombinedTableSchemaV1 } from './v1/joins';
 
 export { hasAnyJoinPaths, hasJoinPathsV2 } from './accessors';
 
-export const getCombinedTableSchema = (
+export const getCombinedTableSchema = async (
   tableSchema: Parameters<typeof getCombinedTableSchemaV1>[0],
-  cubeQuery: Query
+  cubeQuery: Query,
+  getQueryOutput?: GetQueryOutput
 ) => {
   if (hasJoinPathsV2(cubeQuery)) {
-    return getCombinedTableSchemaV2(tableSchema, cubeQuery);
+    return getCombinedTableSchemaV2(tableSchema, cubeQuery, getQueryOutput);
   }
   return getCombinedTableSchemaV1(tableSchema, cubeQuery);
 };