refactor(analytic-logs): Remove InteractionCountsRepository and relat…

…ed SQL migration

- Deleted InteractionCountsRepository and its associated SQL migration for interaction counts.
- Updated use cases to utilize WorkflowActivityCountsRepository for interaction trend and total interactions data retrieval.
- Adjusted shared module to remove InteractionCountsRepository references.

apps/api/migrations/clickhouse-migrations/8_unified_workflow_activity_counts.sql

@@ -0,0 +1,40 @@
+-- Unified workflow activity counts migration
+-- Merges interaction_counts functionality into workflow_activity_counts
+-- Adds event_type column to track both message_sent and interaction events
+
+-- Drop existing materialized views
+DROP VIEW IF EXISTS workflow_activity_counts_mv;
+DROP VIEW IF EXISTS interaction_counts_mv;
+
+-- Drop existing tables
+DROP TABLE IF EXISTS workflow_activity_counts;
+DROP TABLE IF EXISTS interaction_counts;
+
+-- Create unified workflow activity counts table with event_type
+CREATE TABLE IF NOT EXISTS workflow_activity_counts (
+  date Date,
+  organization_id String,
+  environment_id String,
+  workflow_id String,
+  external_subscriber_id String DEFAULT '',
+  event_type LowCardinality(String),
+  count UInt64
+)
+ENGINE = SummingMergeTree(count)
+PARTITION BY toYYYYMM(date)
+ORDER BY (organization_id, environment_id, workflow_id, date, external_subscriber_id, event_type);
+
+-- Materialized view populates from traces table
+-- Captures both message_sent events and interaction events
+CREATE MATERIALIZED VIEW IF NOT EXISTS workflow_activity_counts_mv
+TO workflow_activity_counts
+AS SELECT
+  toDate(created_at) AS date,
+  organization_id,
+  environment_id,
+  ifNull(workflow_id, '') AS workflow_id,
+  ifNull(external_subscriber_id, '') AS external_subscriber_id,
+  event_type,
+  1 AS count
+FROM traces
+WHERE event_type IN ('message_sent', 'message_seen', 'message_read', 'message_snoozed', 'message_archived');

apps/api/src/app/activity/usecases/build-interaction-trend-chart/build-interaction-trend-chart.usecase.ts

@@ -2,9 +2,9 @@ import { Injectable } from '@nestjs/common';
 import {
   FeatureFlagsService,
   InstrumentUsecase,
-  InteractionCountsRepository,
   PinoLogger,
   TraceLogRepository,
+  WorkflowActivityCountsRepository,
 } from '@novu/application-generic';
 import { FeatureFlagsKeysEnum } from '@novu/shared';
 import { InteractionTrendDataPointDto } from '../../dtos/get-charts.response.dto';
@@ -13,7 +13,7 @@ import { BuildInteractionTrendChartCommand } from './build-interaction-trend-cha
 @Injectable()
 export class BuildInteractionTrendChart {
   constructor(
-    private interactionCountsRepository: InteractionCountsRepository,
+    private workflowActivityCountsRepository: WorkflowActivityCountsRepository,
     private traceLogRepository: TraceLogRepository,
     private featureFlagsService: FeatureFlagsService,
     private logger: PinoLogger
@@ -46,7 +46,7 @@ export class BuildInteractionTrendChart {
     const useNewQuery = isGlobalEnabled || isDedicatedEnabled;
 
     const traces = useNewQuery
-      ? await this.interactionCountsRepository.getInteractionTrendData(
+      ? await this.workflowActivityCountsRepository.getInteractionTrendData(
           environmentId,
           organizationId,
           startDate,

apps/api/src/app/activity/usecases/build-total-interactions-chart/build-total-interactions-chart.usecase.ts

@@ -2,9 +2,9 @@ import { Injectable } from '@nestjs/common';
 import {
   FeatureFlagsService,
   InstrumentUsecase,
-  InteractionCountsRepository,
   PinoLogger,
   TraceLogRepository,
+  WorkflowActivityCountsRepository,
 } from '@novu/application-generic';
 import { FeatureFlagsKeysEnum } from '@novu/shared';
 import { TotalInteractionsDataPointDto } from '../../dtos/get-charts.response.dto';
@@ -13,7 +13,7 @@ import { BuildTotalInteractionsChartCommand } from './build-total-interactions-c
 @Injectable()
 export class BuildTotalInteractionsChart {
   constructor(
-    private interactionCountsRepository: InteractionCountsRepository,
+    private workflowActivityCountsRepository: WorkflowActivityCountsRepository,
     private traceLogRepository: TraceLogRepository,
     private featureFlagsService: FeatureFlagsService,
     private logger: PinoLogger
@@ -50,7 +50,7 @@ export class BuildTotalInteractionsChart {
     const useNewQuery = isGlobalEnabled || isDedicatedEnabled;
 
     const result = useNewQuery
-      ? await this.interactionCountsRepository.getTotalInteractionsCount(
+      ? await this.workflowActivityCountsRepository.getTotalInteractionsCount(
           environmentId,
           organizationId,
           startDate,

apps/api/src/app/shared/shared.module.ts

@@ -14,7 +14,6 @@ import {
   ExecuteBridgeRequest,
   featureFlagsService,
   GetDecryptedSecretKey,
-  InteractionCountsRepository,
   InvalidateCacheService,
   LoggerModule,
   ProviderVolumeCountsRepository,
@@ -127,7 +126,6 @@ const ANALYTICS_PROVIDERS = [
   WorkflowRunRepository,
   WorkflowActivityCountsRepository,
   ProviderVolumeCountsRepository,
-  InteractionCountsRepository,
   DeliveryTrendCountsRepository,
   WorkflowVolumeCountsRepository,
 

libs/application-generic/src/services/analytic-logs/index.ts

@@ -1,7 +1,6 @@
 export { createClient as createClickHouseClient } from '@clickhouse/client';
 export * from './clickhouse.service';
 export * from './delivery-trend-counts';
-export * from './interaction-counts';
 export * from './log.repository';
 export * from './provider-volume-counts';
 export * from './request-log';