feat(monitoring): implement ongoing monitoring state update functionality

- Add route for updating ongoing monitoring state using Patch method
- Introduce OngoingMonitoringPatchDto with updated status options
- Refactor related business logic and metadata handling in the controller

Author: tomer-shvadron

services/workflows-service/prisma/data-migrations

@@ -42,6 +42,7 @@ import {
 import { BusinessReportMetricsDto } from './dtos/business-report-metrics-dto';
 import { BusinessReportStatusUpdateRequestParamsDto } from '@/business-report/dtos/business-report-status-update.dto';
 import { UserData } from '@/user/user-data.decorator';
+import { OngoingMonitoringPatchDto } from './dtos/ongoing-monitoring.patch.dto';
 
 @ApiBearerAuth()
 @swagger.ApiTags('Business Reports')
@@ -442,4 +443,22 @@ export class BusinessReportControllerExternal {
     res.setHeader('content-type', 'application/json');
     res.send(result);
   }
+
+  @common.Patch('/websites/:websiteId/monitoring')
+  @swagger.ApiForbiddenResponse()
+  @swagger.ApiOkResponse()
+  @swagger.ApiNotFoundResponse({ type: errors.NotFoundException })
+  async updateOngoingMonitoringState(
+    @common.Param('websiteId') websiteId: string,
+    @common.Body() data: OngoingMonitoringPatchDto,
+    @CurrentProject() currentProjectId: TProjectId,
+  ) {
+    const { id: customerId } = await this.customerService.getByProjectId(currentProjectId);
+
+    await this.merchantMonitoringClient.updateOngoingMonitoring({
+      customerId,
+      websiteId,
+      status: data.status,
+    });
+  }
 }

services/workflows-service/src/business-report/business-report.controller.external.ts

@@ -1,9 +1,9 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { IsIn, IsString } from 'class-validator';
 
-export class BusinessMonitoringPatchDto {
+export class OngoingMonitoringPatchDto {
   @ApiProperty({ type: String, required: true })
   @IsString()
-  @IsIn(['on', 'off'])
-  state!: 'on' | 'off';
+  @IsIn(['active', 'inactive'])
+  status!: 'active' | 'inactive';
 }

…ss/dtos/business-monitoring.patch.dto.ts …ort/dtos/ongoing-monitoring.patch.dto.tsservices/workflows-service/src/business/dtos/business-monitoring.patch.dto.ts renamed to services/workflows-service/src/business-report/dtos/ongoing-monitoring.patch.dto.ts services/workflows-service/src/business/dtos/business-monitoring.patch.dto.ts renamed to services/workflows-service/src/business-report/dtos/ongoing-monitoring.patch.dto.ts

@@ -5,7 +5,6 @@ import * as swagger from '@nestjs/swagger';
 import { ApiBearerAuth, ApiExcludeEndpoint } from '@nestjs/swagger';
 import { plainToClass } from 'class-transformer';
 import type { Request } from 'express';
-import _ from 'lodash';
 
 import { BusinessInformation } from '@/business/dtos/business-information';
 import { BusinessDto } from '@/business/dtos/business.dto';
@@ -15,7 +14,6 @@ import { CurrentProject } from '@/common/decorators/current-project.decorator';
 import { ProjectIds } from '@/common/decorators/project-ids.decorator';
 import { UseCustomerAuthGuard } from '@/common/decorators/use-customer-auth-guard.decorator';
 import { UseKeyAuthOrSessionGuard } from '@/common/decorators/use-key-auth-or-session-guard.decorator';
-import { FEATURE_LIST, TCustomerWithFeatures } from '@/customer/types';
 import { PrismaService } from '@/prisma/prisma.service';
 import { isRecordNotFoundError } from '@/prisma/prisma.util';
 import type { TProjectId, TProjectIds } from '@/types';
@@ -29,7 +27,6 @@ import { BusinessModel } from './business.model';
 import { BusinessService } from './business.service';
 import { BusinessCreateDto } from './dtos/business-create';
 import { BusinessFindManyArgs } from './dtos/business-find-many-args';
-import { BusinessMonitoringPatchDto } from './dtos/business-monitoring.patch.dto';
 import { BusinessWhereUniqueInput } from './dtos/business-where-unique-input';
 
 @ApiBearerAuth()
@@ -134,42 +131,6 @@ export class BusinessControllerExternal {
     });
   }
 
-  @common.Patch('/:id/monitoring')
-  @swagger.ApiForbiddenResponse()
-  @swagger.ApiOkResponse({ type: BusinessDto })
-  @swagger.ApiNotFoundResponse({ type: errors.NotFoundException })
-  async updateOngoingMonitoringState(
-    @common.Param('id') businessId: string,
-    @common.Body() data: BusinessMonitoringPatchDto,
-    @CurrentProject() currentProjectId: TProjectId,
-  ) {
-    const business = await this.businessService.getById(
-      businessId,
-      { select: { metadata: true } },
-      [currentProjectId],
-    );
-
-    const metadata = business?.metadata as {
-      featureConfig?: TCustomerWithFeatures['features'];
-    };
-
-    const isEnabled = data.state === 'on';
-    const updatedMetadata = _.merge({}, metadata, {
-      featureConfig: {
-        [FEATURE_LIST.ONGOING_MERCHANT_REPORT]: {
-          enabled: isEnabled,
-          disabledAt: isEnabled ? null : new Date().getTime(),
-        },
-      },
-    });
-
-    await this.businessService.updateById(businessId, {
-      data: {
-        metadata: updatedMetadata,
-      },
-    });
-  }
-
   @common.Patch(':id')
   @UseCustomerAuthGuard()
   @swagger.ApiForbiddenResponse()

services/workflows-service/src/business/business.controller.external.ts

@@ -165,24 +165,11 @@ export class UnifiedApiClient {
   }
 
   public formatBusiness(business: BusinessPayload) {
-    const metadata = business.metadata as unknown as {
-      featureConfig: TCustomerWithFeatures['features'];
-      lastOngoingReportInvokedAt: number;
-    } | null;
-
-    const unsubscribedMonitoringAt = metadata?.featureConfig?.[FEATURE_LIST.ONGOING_MERCHANT_REPORT]
-      ?.disabledAt
-      ? new Date(metadata.featureConfig[FEATURE_LIST.ONGOING_MERCHANT_REPORT]!.disabledAt!)
-      : metadata?.featureConfig?.[FEATURE_LIST.ONGOING_MERCHANT_REPORT]?.enabled === false
-      ? new Date()
-      : null;
-
     return {
       id: business.id,
       correlationId: business.correlationId,
       companyName: business.companyName,
       customerId: business.project.customer.id,
-      unsubscribedMonitoringAt: unsubscribedMonitoringAt?.toISOString() ?? null,
       createdAt: business.createdAt.toISOString(),
       updatedAt: business.updatedAt.toISOString(),
     };

services/workflows-service/src/common/utils/unified-api-client/unified-api-client.ts

@@ -273,6 +273,20 @@ export class MerchantMonitoringClient {
     });
   }
 
+  public async updateOngoingMonitoring({
+    customerId,
+    websiteId,
+    status,
+  }: {
+    customerId: string;
+    websiteId: string;
+    status: 'active' | 'inactive';
+  }) {
+    await this.axios.put(`customers/${customerId}/websites/${websiteId}`, {
+      unsubscribedMonitoringAt: status === 'active' ? null : new Date().toISOString(),
+    });
+  }
+
   public async getMetrics({
     customerId,
     from,