chore: add hourly request stats to subscription request history

- Updated version in package.json to 2.1.64.
- Added hourlyRequestStats to GetSubscriptionRequestHistoryStatsCommand and GetSubscriptionRequestHistoryStatsResponseModel.
- Implemented getHourlyRequestStats method in UserSubscriptionRequestHistoryRepository to retrieve hourly request statistics.

Author: kastov

libs/contract/commands/subscription-request-history/get-subscription-request-history-stats.command.ts

@@ -21,6 +21,15 @@ export namespace GetSubscriptionRequestHistoryStatsCommand {
                     count: z.number(),
                 }),
             ),
+            hourlyRequestStats: z.array(
+                z.object({
+                    dateTime: z
+                        .string()
+                        .datetime()
+                        .transform((str) => new Date(str)),
+                    requestCount: z.number(),
+                }),
+            ),
         }),
     });
 

libs/contract/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@remnawave/backend-contract",
-  "version": "2.1.62",
+  "version": "2.1.64",
   "public": true,
   "license": "AGPL-3.0-only",
   "description": "A contract library for Remnawave Backend. It can be used in backend and frontend.",

src/modules/user-subscription-request-history/models/get-subscription-request-history-stats.response.model.ts

@@ -1,7 +1,9 @@
 export class GetSubscriptionRequestHistoryStatsResponseModel {
     public readonly byParsedApp: { app: string; count: number }[];
+    public readonly hourlyRequestStats: { dateTime: Date; requestCount: number }[];
 
     constructor(data: GetSubscriptionRequestHistoryStatsResponseModel) {
         this.byParsedApp = data.byParsedApp;
+        this.hourlyRequestStats = data.hourlyRequestStats;
     }
 }

src/modules/user-subscription-request-history/repositories/user-subscription-request-history.repository.ts

@@ -254,4 +254,22 @@ export class UserSubscriptionRequestHistoryRepository
 
         return result.length;
     }
+
+    public async getHourlyRequestStats(): Promise<{ dateTime: Date; requestCount: number }[]> {
+        const result = await this.qb.kysely
+            .selectFrom('userSubscriptionRequestHistory')
+            .select([
+                sql<Date>`date_trunc('hour', request_at)`.as('hour'),
+                (eb) => eb.fn.count('id').as('requestCount'),
+            ])
+            .where('requestAt', '>=', sql<Date>`NOW() - INTERVAL '48 hours'`)
+            .groupBy(sql`date_trunc('hour', request_at)`)
+            .orderBy('hour')
+            .execute();
+
+        return result.map((row) => ({
+            dateTime: row.hour,
+            requestCount: Number(row.requestCount),
+        }));
+    }
 }

src/modules/user-subscription-request-history/user-subscription-request-history.service.ts

@@ -52,10 +52,14 @@ export class UserSubscriptionRequestHistoryService {
             const stats =
                 await this.userSubscriptionRequestHistoryRepository.getSubscriptionRequestHistoryStats();
 
+            const hourlyRequestStats =
+                await this.userSubscriptionRequestHistoryRepository.getHourlyRequestStats();
+
             return {
                 isOk: true,
                 response: new GetSubscriptionRequestHistoryStatsResponseModel({
                     byParsedApp: stats.byParsedApp,
+                    hourlyRequestStats: hourlyRequestStats,
                 }),
             };
         } catch (error) {