feat: add event name field and filter support in WarehouseInsightsSqlBuilder

Author: moonrailgun

src/server/model/insights/warehouse.spec.ts

@@ -19,6 +19,7 @@ describe('WarehouseInsightsSqlBuilder', () => {
         },
         eventParametersTable: {
           name: 'event_parameters',
+          eventNameField: 'event_name',
           paramsNameField: 'event_param_key',
           paramsValueField: 'event_param_value',
           createdAtField: 'event_timestamp',
@@ -55,4 +56,40 @@ describe('WarehouseInsightsSqlBuilder', () => {
     const sql = builder.build();
     expect(unwrapSQL(sql)).toMatchSnapshot('sql');
   });
+
+  test('with filter', () => {
+    const builder = new WarehouseInsightsSqlBuilder(
+      {
+        insightId,
+        insightType,
+        workspaceId: '',
+        metrics: [
+          {
+            name: '$all_event',
+            math: 'events',
+          },
+        ],
+        filters: [
+          {
+            name: 'name',
+            value: 'value',
+            operator: 'equals',
+            type: 'string',
+          },
+        ],
+        time: {
+          startAt: dayjs('2025-08-01').valueOf(),
+          endAt: dayjs('2025-08-02').valueOf(),
+          unit: 'day',
+        },
+        groups: [],
+      },
+      {
+        timezone: 'UTC',
+      }
+    );
+
+    const sql = builder.build();
+    expect(unwrapSQL(sql)).toMatchSnapshot('sql');
+  });
 });

src/server/model/insights/warehouse.ts

@@ -41,6 +41,7 @@ export const warehouseInsightsApplicationSchema = z.object({
   }),
   eventParametersTable: z.object({
     name: z.string(),
+    eventNameField: z.string(),
     paramsNameField: z.string(),
     paramsValueField: z.string(),
     paramsValueNumberField: z.string().optional(),
@@ -106,17 +107,6 @@ export class WarehouseInsightsSqlBuilder extends InsightsSqlBuilder {
     );
   }
 
-  private enableDateBasedOptimizedEventParametersTable() {
-    const eventParametersTable = this.getEventParametersTable();
-    const startAt = this.query.time.startAt;
-    const endAt = this.query.time.endAt;
-
-    return (
-      !!eventParametersTable.dateBasedCreatedAtField &&
-      dayjs(endAt).diff(startAt, 'day') >= 1
-    );
-  }
-
   private getEventTable() {
     return this.getApplication().eventTable;
   }
@@ -361,6 +351,43 @@ export class WarehouseInsightsSqlBuilder extends InsightsSqlBuilder {
     return groupSelectQueryArr;
   }
 
+  buildInnerJoinQuery() {
+    const { filters, groups } = this.query;
+    const eventTable = this.getEventTable();
+    const eventParametersTable = this.getEventParametersTable();
+
+    let innerJoinQuery = Prisma.empty;
+    if (filters.length > 0 || groups.length > 0) {
+      innerJoinQuery = Prisma.sql`INNER JOIN "${Prisma.raw(eventParametersTable.name)}" ON "${Prisma.raw(eventTable.name)}"."${Prisma.raw(eventTable.eventNameField)}" = "${Prisma.raw(eventParametersTable.name)}"."${Prisma.raw(eventParametersTable.eventNameField)}"`;
+
+      if (filters.length > 0) {
+        innerJoinQuery = Prisma.sql`${innerJoinQuery} AND ${Prisma.join(
+          filters.map((filter) =>
+            this.buildFilterQueryOperator(
+              filter.type,
+              filter.operator,
+              filter.value
+            )
+          ),
+          ' AND '
+        )}`;
+      }
+
+      if (groups.length > 0) {
+        const groupConditions = groups.map(
+          (g) =>
+            Prisma.sql`"${Prisma.raw(eventParametersTable.name)}"."${Prisma.raw(eventParametersTable.eventNameField)}" = ${g.value}`
+        );
+        innerJoinQuery = Prisma.sql`${innerJoinQuery} AND ${Prisma.join(
+          groupConditions,
+          ' OR '
+        )}`;
+      }
+    }
+
+    return innerJoinQuery;
+  }
+
   buildWhereQueryArr() {
     const { metrics } = this.query;
     const eventTable = this.getEventTable();