feat: insights

novuhq · scopsy · Dec 4, 2024 · Dec 4, 2024 · Dec 4, 2024 · Dec 4, 2024
commit 9f7b9dc8485c899ae393be70e01a8ce730a586e7
diff --git a/apps/api/src/app/insights/insights.module.ts b/apps/api/src/app/insights/insights.module.ts
@@ -0,0 +1,10 @@
+import { Module } from '@nestjs/common';
+import { USE_CASES } from './usecases';
+import { SharedModule } from '../shared/shared.module';
+
+@Module({
+  imports: [SharedModule],
+  providers: [...USE_CASES],
+  exports: [...USE_CASES],
+})
+export class InsightsModule {}
diff --git a/apps/api/src/app/insights/usecases/index.ts b/apps/api/src/app/insights/usecases/index.ts
@@ -0,0 +1,3 @@
+import { UsageInsights } from './usage-insights/usage-insights.usecase';
+
+export const USE_CASES = [UsageInsights];
diff --git a/apps/api/src/app/insights/usecases/usage-insights/usage-insights.command.ts b/apps/api/src/app/insights/usecases/usage-insights/usage-insights.command.ts
@@ -0,0 +1,7 @@
+import { IsString } from 'class-validator';
+import { EnvironmentCommand } from '@novu/application-generic';
+
+export class UsageInsightsCommand extends EnvironmentCommand {
+  @IsString()
+  organizationId: string;
+}
diff --git a/apps/api/src/app/insights/usecases/usage-insights/usage-insights.usecase.ts b/apps/api/src/app/insights/usecases/usage-insights/usage-insights.usecase.ts
@@ -0,0 +1,36 @@
+import { Injectable } from '@nestjs/common';
+import { MessageRepository, NotificationRepository } from '@novu/dal';
+import { InstrumentUsecase } from '@novu/application-generic';
+
+import { UsageInsightsCommand } from './usage-insights.command';
+
+interface IUsageInsightsResponse {
+  totalNotifications: number;
+  totalMessages: number;
+}
+
+@Injectable()
+export class UsageInsights {
+  constructor(
+    private notificationRepository: NotificationRepository,
+    private messageRepository: MessageRepository
+  ) {}
+
+  @InstrumentUsecase()
+  async execute(command: UsageInsightsCommand): Promise<IUsageInsightsResponse> {
+    const query = {
+      _environmentId: command.environmentId,
+      _organizationId: command.organizationId,
+    };
+
+    const [totalNotifications, totalMessages] = await Promise.all([
+      this.notificationRepository.count(query),
+      this.messageRepository.count(query),
+    ]);
+
+    return {
+      totalNotifications,
+      totalMessages,
+    };
+  }
+}
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		import { UsageInsights } from './usage-insights/usage-insights.usecase';

		export const USE_CASES = [UsageInsights];