feat: add aggregated daily active users table (#8026)

* feat: add aggregated daily active users table

* refactor: add comments

Author: darcyYe

packages/schemas/alterations/next-1764580589-create-aggregated-daily-active-users-table.ts

@@ -0,0 +1,51 @@
+import { sql } from '@silverhand/slonik';
+
+import type { AlterationScript } from '../lib/types/alteration.js';
+
+import { applyTableRls, dropTableRls } from './utils/1704934999-tables.js';
+
+/**
+ * Create aggregated_daily_active_users table for MAU-based billing system.
+ * This table consolidates daily user activities for efficient billing calculations.
+ */
+
+const alteration: AlterationScript = {
+  up: async (pool) => {
+    // Create the aggregated daily active users table
+    await pool.query(sql`
+      create table aggregated_daily_active_users (
+        tenant_id varchar(21) not null,
+        activity_date date not null,
+        user_id varchar(21) not null,
+        activity_count integer not null,
+        primary key (tenant_id, activity_date, user_id)
+      );
+    `);
+
+    // Index for billing cycle range queries
+    await pool.query(sql`
+      create index aggregated_daily_active_users__tenant_date
+        on aggregated_daily_active_users (tenant_id, activity_date);
+    `);
+
+    // Index for tenant-specific user activity queries
+    await pool.query(sql`
+      create index aggregated_daily_active_users__tenant_user_date
+        on aggregated_daily_active_users (tenant_id, user_id, activity_date desc);
+    `);
+
+    await applyTableRls(pool, 'aggregated_daily_active_users');
+  },
+
+  down: async (pool) => {
+    // Drop RLS policies first
+    await dropTableRls(pool, 'aggregated_daily_active_users');
+
+    // Drop the table and all its indexes
+    await pool.query(sql`
+      drop table aggregated_daily_active_users;
+    `);
+  },
+};
+
+export default alteration;

packages/schemas/src/gen/utils.ts

@@ -145,6 +145,7 @@ export const getType = (
     case 'int2':
     case 'int4':
     case 'int8':
+    case 'integer':
     case 'bigint':
     case 'float4':
     case 'float8':

packages/schemas/tables/aggregated_daily_active_users.sql

@@ -0,0 +1,18 @@
+-- This table is used to store aggregated data of daily active users for each tenant.
+-- A daily job summarizes data from the daily active users table and inserts it into this table, or removes expired data.
+-- Therefore, we should not directly manipulate this table, except for "read" operations.
+create table aggregated_daily_active_users (
+  tenant_id varchar(21) not null,
+  activity_date date not null,
+  user_id varchar(21) not null,
+  activity_count integer not null,
+  primary key (tenant_id, activity_date, user_id)
+);
+
+-- Index for billing cycle range queries
+create index aggregated_daily_active_users__tenant_date
+  on aggregated_daily_active_users (tenant_id, activity_date);
+
+-- Index for tenant-specific user activity queries
+create index aggregated_daily_active_users__tenant_user_date
+  on aggregated_daily_active_users (tenant_id, user_id, activity_date desc);