first version of CubeJoinsResolver

Author: KSDaemon

packages/cubejs-schema-compiler/src/compiler/CubeJoinsResolver.ts

@@ -0,0 +1,58 @@
+import { CompilerInterface } from './PrepareCompiler';
+import { CubeDefinitionExtended, CubeSymbols, JoinDefinition } from './CubeSymbols';
+import type { ErrorReporter } from './ErrorReporter';
+
+export class CubeJoinsResolver extends CubeSymbols implements CompilerInterface {
+  // key: cubeName with joins defined
+  private cubeJoins: Record<string, JoinDefinition[]>;
+
+  // key: cubeName with joins defined
+  // 1st level value: join alias
+  // 2nd level value: join definition
+  private cubeJoinAliases: Record<string, Record<string, JoinDefinition>>;
+
+  // key: cubeName with joins defined
+  // 1st level value: target cube name
+  // 2nd level value: join definition
+  private cubeJoinTargets: Record<string, Record<string, JoinDefinition>>;
+
+  public constructor() {
+    super(false); // It seems that we don't need to evaluate views
+    this.cubeJoins = {};
+    this.cubeJoinAliases = {};
+    this.cubeJoinTargets = {};
+  }
+
+  public compile(cubes: CubeDefinitionExtended[], errorReporter: ErrorReporter) {
+    super.compile(cubes, errorReporter);
+
+    this.cubeList.forEach(cube => {
+      if (!cube.joins) {
+        return;
+      }
+
+      this.cubeJoins[cube.name] = this.cubeJoins[cube.name] || [];
+      this.cubeJoinAliases[cube.name] = this.cubeJoinAliases[cube.name] || {};
+      this.cubeJoinTargets[cube.name] = this.cubeJoinTargets[cube.name] || {};
+
+      const er = errorReporter.inContext(`${cube.name} cube`);
+
+      cube.joins.forEach(join => {
+        this.cubeJoins[cube.name].push(join);
+        this.cubeJoinTargets[cube.name][join.name] = join;
+
+        if (join.alias) {
+          if (this.cubeJoinAliases[cube.name][join.alias]) {
+            er.error(
+              `Join alias "${join.alias}" is already defined in cube "${cube.name}".`,
+              cube.fileName
+            );
+
+            return;
+          }
+          this.cubeJoinAliases[cube.name][join.alias] = join;
+        }
+      });
+    });
+  }
+}

packages/cubejs-schema-compiler/src/compiler/CubeSymbols.ts

@@ -116,9 +116,10 @@ export type PreAggregationDefinitionRollup = BasePreAggregationDefinition & {
 export type PreAggregationDefinition = PreAggregationDefinitionRollup;
 
 export type JoinDefinition = {
-  name: string,
-  relationship: string,
-  sql: (...args: any[]) => string,
+  name: string;
+  relationship: string;
+  sql: (...args: any[]) => string;
+  alias?: string;
 };
 
 export type Filter =