add SubmissionScanCompleteHandler

Author: kkartunov

src/shared/modules/kafka/handlers/submission-scan-complete.handler.ts

@@ -0,0 +1,55 @@
+import { Injectable, OnModuleInit } from '@nestjs/common';
+import { BaseEventHandler } from '../base-event.handler';
+import { KafkaHandlerRegistry } from '../kafka-handler.registry';
+import { LoggerService } from '../../global/logger.service';
+
+@Injectable()
+export class SubmissionScanCompleteHandler
+  extends BaseEventHandler
+  implements OnModuleInit
+{
+  private readonly topic = 'submission.scan.complete';
+
+  constructor(private readonly handlerRegistry: KafkaHandlerRegistry) {
+    super(LoggerService.forRoot('SubmissionScanCompleteHandler'));
+  }
+
+  onModuleInit() {
+    this.handlerRegistry.registerHandler(this.topic, this);
+    this.logger.log(`Registered handler for topic: ${this.topic}`);
+  }
+
+  getTopic(): string {
+    return this.topic;
+  }
+
+  async handle(message: any): Promise<void> {
+    try {
+      this.logger.log({
+        message: 'Processing Submission Scan Complete event',
+        topic: this.topic,
+        payload: message,
+      });
+
+      if (!this.validateMessage(message)) {
+        this.logger.warn('Invalid message received');
+        return;
+      }
+
+      this.logger.log('=== Submission Scan Complete Event ===');
+      this.logger.log('Topic:', this.topic);
+      this.logger.log('Payload:', JSON.stringify(message, null, 2));
+      this.logger.log('==============================');
+
+      await Promise.resolve(); // Add await to satisfy linter
+
+      this.logger.log('Submission Scan Complete event processed successfully');
+    } catch (error) {
+      this.logger.error(
+        'Error processing Submission Scan Complete event',
+        error,
+      );
+      throw error;
+    }
+  }
+}

src/shared/modules/kafka/kafka.module.ts

@@ -5,6 +5,7 @@ import {
 } from './kafka-consumer.service';
 import { KafkaHandlerRegistry } from './kafka-handler.registry';
 import { AVScanActionScanHandler } from './handlers/avscan-action-scan.handler';
+import { SubmissionScanCompleteHandler } from './handlers/submission-scan-complete.handler';
 
 @Module({})
 export class KafkaModule {
@@ -25,6 +26,7 @@ export class KafkaModule {
           inject: [KafkaHandlerRegistry],
         },
         AVScanActionScanHandler,
+        SubmissionScanCompleteHandler,
       ],
       exports: [KafkaConsumerService, KafkaHandlerRegistry],
     };