Add quest analytics rollup job

- Create QuestAnalytics entity for daily quest aggregation
- Add QuestAnalyticsRollupJob scheduled at 00:30 UTC
- Aggregate daily quest assignment/completion counts
- Create migration for quest_analytics table
- Register job and entities in analytics module

Author: Nemenwq

backend/src/analytics/analytics.module.ts

@@ -3,6 +3,8 @@ import { TypeOrmModule } from '@nestjs/typeorm';
 import { AnalyticsEvent } from './entities/analytics-event.entity';
 import { RetentionCohort } from './entities/retention-cohort.entity';
 import { DailyActiveUser } from './entities/daily-active-user.entity';
+import { QuestAnalytics } from './entities/quest-analytics.entity';
+import { DailyQuest } from '../quests/entities/daily-quest.entity';
 import { UsersAnalyticsListener } from './listeners/users-analytics.listener';
 import { BlockchainAnalyticsListener } from './listeners/blockchain-analytics.listener';
 import { AnalyticsController } from './controllers/analytics.controller';
@@ -13,13 +15,17 @@ import { GetRetentionCurveProvider } from './providers/get-retention-curve.provi
 import { GetChurnRiskProvider } from './providers/get-churn-risk.provider';
 import { PuzzleAnalyticsProvider } from './providers/puzzle-analytics.provider';
 import { ExportCsvProvider } from './providers/export-csv.provider';
+import { DailyActiveUsersRollupJob } from './jobs/daily-active-users-rollup.job';
+import { QuestAnalyticsRollupJob } from './jobs/quest-analytics-rollup.job';
 
 @Module({
   imports: [
     TypeOrmModule.forFeature([
       AnalyticsEvent,
       RetentionCohort,
       DailyActiveUser,
+      QuestAnalytics,
+      DailyQuest,
     ]),
   ],
   controllers: [AnalyticsController],
@@ -33,6 +39,8 @@ import { ExportCsvProvider } from './providers/export-csv.provider';
     GetChurnRiskProvider,
     PuzzleAnalyticsProvider,
     ExportCsvProvider,
+    DailyActiveUsersRollupJob,
+    QuestAnalyticsRollupJob,
   ],
   exports: [
     AnalyticsService,

backend/src/analytics/entities/quest-analytics.entity.ts

@@ -0,0 +1,31 @@
+import {
+  Column,
+  CreateDateColumn,
+  Entity,
+  Index,
+  PrimaryGeneratedColumn,
+} from 'typeorm';
+
+/**
+ * Aggregated daily quest analytics.
+ * One row per day containing assignment and completion counts.
+ * Materialized by QuestAnalyticsRollupJob to avoid joining raw quest tables.
+ */
+@Entity('quest_analytics')
+@Index(['date'], { unique: true })
+export class QuestAnalytics {
+  @PrimaryGeneratedColumn()
+  id: number;
+
+  @Column('date')
+  date: string;
+
+  @Column('int', { default: 0 })
+  assignedCount: number;
+
+  @Column('int', { default: 0 })
+  completedCount: number;
+
+  @CreateDateColumn({ type: 'timestamptz' })
+  createdAt: Date;
+}

backend/src/analytics/jobs/quest-analytics-rollup.job.ts

@@ -0,0 +1,70 @@
+import { Injectable, Logger } from '@nestjs/common';
+import { Cron } from '@nestjs/schedule';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { DailyQuest } from '../../quests/entities/daily-quest.entity';
+import { QuestAnalytics } from '../entities/quest-analytics.entity';
+
+/**
+ * Nightly rollup that materializes `QuestAnalytics` rows from raw
+ * `DailyQuest` data for the previous day, so quest completion rates can be
+ * read cheaply without joining quest tables on every request.
+ *
+ * Scheduled to run at 00:30 UTC to ensure it runs after quest reset time.
+ */
+@Injectable()
+export class QuestAnalyticsRollupJob {
+  private readonly logger = new Logger(QuestAnalyticsRollupJob.name);
+
+  constructor(
+    @InjectRepository(DailyQuest)
+    private readonly dailyQuestRepository: Repository<DailyQuest>,
+    @InjectRepository(QuestAnalytics)
+    private readonly questAnalyticsRepository: Repository<QuestAnalytics>,
+  ) {}
+
+  @Cron('30 0 * * *') // Runs at 00:30 UTC daily (after quest reset)
+  async handleCron(): Promise<void> {
+    const yesterday = new Date();
+    yesterday.setDate(yesterday.getDate() - 1);
+    await this.rollupForDate(yesterday);
+  }
+
+  /**
+   * Recomputes the `QuestAnalytics` row for `targetDate`. Safe to re-run
+   * for the same day: existing row for that date is replaced rather than
+   * appended to.
+   */
+  async rollupForDate(
+    targetDate: Date,
+  ): Promise<{ date: string; assignedCount: number; completedCount: number }> {
+    const dateStr = targetDate.toISOString().split('T')[0];
+
+    // Count total quests assigned for this date
+    const assignedCount = await this.dailyQuestRepository.count({
+      where: { questDate: dateStr },
+    });
+
+    // Count quests completed for this date
+    const completedCount = await this.dailyQuestRepository.count({
+      where: { questDate: dateStr, isCompleted: true },
+    });
+
+    // Delete existing row for this date (if any)
+    await this.questAnalyticsRepository.delete({ date: dateStr });
+
+    // Insert new aggregated row
+    const questAnalytics = this.questAnalyticsRepository.create({
+      date: dateStr,
+      assignedCount,
+      completedCount,
+    });
+    await this.questAnalyticsRepository.save(questAnalytics);
+
+    this.logger.log(
+      `Quest analytics rollup for ${dateStr}: ${assignedCount} assigned, ${completedCount} completed`,
+    );
+
+    return { date: dateStr, assignedCount, completedCount };
+  }
+}

backend/src/database/migrations/20260727000000-AddQuestAnalyticsTable.ts

@@ -0,0 +1,33 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddQuestAnalyticsTable20260727000000 implements MigrationInterface {
+  name = 'AddQuestAnalyticsTable20260727000000';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+      -- Create quest_analytics table
+      CREATE TABLE IF NOT EXISTS "quest_analytics" (
+        "id" SERIAL NOT NULL,
+        "date" date NOT NULL,
+        "assignedCount" integer NOT NULL DEFAULT 0,
+        "completedCount" integer NOT NULL DEFAULT 0,
+        "createdAt" TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT now(),
+        CONSTRAINT "PK_quest_analytics_id" PRIMARY KEY ("id"),
+        CONSTRAINT "UQ_quest_analytics_date" UNIQUE ("date")
+      );
+
+      -- Create indexes for quest_analytics
+      CREATE INDEX "IDX_quest_analytics_date" ON "quest_analytics" ("date");
+    `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+      -- Drop indexes
+      DROP INDEX IF EXISTS "IDX_quest_analytics_date";
+
+      -- Drop table
+      DROP TABLE IF EXISTS "quest_analytics";
+    `);
+  }
+}