fix(backend): stabilize websocket gateway CI integration

Author: Brite

apps/backend/src/gateways/escrow.gateway.spec.ts

@@ -1,14 +1,14 @@
-import { EventsGateway } from './escrow.gateway';
+import { EscrowGateway } from './escrow.gateway';
 
 describe('EventsGateway', () => {
-  let gateway: EventsGateway;
+  let gateway: EscrowGateway;
   let jwtService: { verify: jest.Mock };
 
   beforeEach(() => {
     jwtService = {
       verify: jest.fn().mockReturnValue({ sub: 'user-1' }),
     };
-    gateway = new EventsGateway(jwtService as any);
+    gateway = new EscrowGateway(jwtService as any);
   });
 
   it('authenticates a socket and emits a connected event', async () => {

apps/backend/src/gateways/escrow.gateway.ts

@@ -31,11 +31,11 @@ interface ClientAuthPayload {
     credentials: true,
   },
 })
-export class EventsGateway implements OnGatewayConnection, OnGatewayDisconnect {
+export class EscrowGateway implements OnGatewayConnection, OnGatewayDisconnect {
   @WebSocketServer()
   server!: Server;
 
-  private readonly logger = new Logger(EventsGateway.name);
+  private readonly logger = new Logger(EscrowGateway.name);
   private readonly userSocketMap = new Map<string, Set<string>>();
   private readonly socketUserMap = new Map<string, string>();
   private readonly socketEscrowMap = new Map<string, Set<string>>();
@@ -44,9 +44,7 @@ export class EventsGateway implements OnGatewayConnection, OnGatewayDisconnect {
 
   private extractToken(client: Socket): string | undefined {
     const authPayload = client.handshake.auth as ClientAuthPayload | undefined;
-    const authorizationHeader = client.handshake.headers.authorization as
-      | string
-      | undefined;
+    const authorizationHeader = client.handshake.headers.authorization;
 
     if (authPayload?.token) {
       return authPayload.token;
@@ -254,7 +252,4 @@ export class EventsGateway implements OnGatewayConnection, OnGatewayDisconnect {
       timestamp: new Date().toISOString(),
     });
   }
-  isHealthy(): boolean {
-    return this.server !== undefined;
-  }
 }

apps/backend/src/gateways/events.module.ts

@@ -1,7 +1,7 @@
 import { Module } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
 import { JwtModule } from '@nestjs/jwt';
-import { EventsGateway } from './escrow.gateway';
+import { EscrowGateway } from './escrow.gateway';
 
 @Module({
   imports: [
@@ -17,7 +17,7 @@ import { EventsGateway } from './escrow.gateway';
       inject: [ConfigService],
     }),
   ],
-  providers: [EventsGateway],
-  exports: [EventsGateway],
+  providers: [EscrowGateway],
+  exports: [EscrowGateway],
 })
 export class EventsModule {}

apps/backend/src/gateways/gateways.module.ts

@@ -1,10 +1,8 @@
 import { Module } from '@nestjs/common';
-import { JwtModule } from '@nestjs/jwt';
-import { EscrowGateway } from './escrow.gateway';
+import { EventsModule } from './events.module';
 
 @Module({
-  imports: [JwtModule],
-  providers: [EscrowGateway],
-  exports: [EscrowGateway],
+  imports: [EventsModule],
+  exports: [EventsModule],
 })
 export class GatewaysModule {}

apps/backend/src/modules/escrow/services/escrow-evidence.service.ts

@@ -16,13 +16,6 @@ import {
   UploadEvidenceResponseDto,
 } from '../dto/upload-evidence.dto';
 
-interface FileWithMetadata extends Express.Multer.File {
-  buffer: Buffer;
-  originalname: string;
-  mimetype: string;
-  size: number;
-}
-
 @Injectable()
 export class EscrowEvidenceService {
   private readonly logger = new Logger(EscrowEvidenceService.name);
@@ -57,7 +50,7 @@ export class EscrowEvidenceService {
    */
   async uploadEvidence(
     escrowId: string,
-    files: FileWithMetadata[],
+    files: Express.Multer.File[],
     userId: string,
   ): Promise<UploadEvidenceResponseDto> {
     this.logger.log(
@@ -230,7 +223,7 @@ export class EscrowEvidenceService {
    * - Check MIME type against allowlist
    * - Check file size (max 10MB)
    */
-  private validateFile(file: FileWithMetadata): void {
+  private validateFile(file: Express.Multer.File): void {
     // Validate MIME type
     if (!this.ALLOWED_MIME_TYPES.includes(file.mimetype)) {
       throw new BadRequestException(

apps/backend/src/modules/escrow/services/escrow.service.ts

@@ -45,7 +45,7 @@ import { IpfsService } from '../../ipfs/ipfs.service';
 import { AllowedAsset } from '../../assets/entities/allowed-asset.entity';
 import { NotificationService } from '../../../notifications/notifications.service';
 import { NotificationEventType } from '../../../notifications/enums/notification-event.enum';
-import { EventsGateway } from '../../../gateways/escrow.gateway';
+import { EscrowGateway } from '../../../gateways/escrow.gateway';
 
 @Injectable()
 export class EscrowService {
@@ -69,7 +69,7 @@ export class EscrowService {
     private readonly webhookService: WebhookService,
     private readonly ipfsService: IpfsService,
     private readonly notificationService: NotificationService,
-    @Optional() private readonly eventsGateway?: EventsGateway,
+    @Optional() private readonly eventsGateway?: EscrowGateway,
   ) {}
 
   async create(

apps/backend/src/modules/health/health.controller.ts

@@ -52,6 +52,8 @@ export class HealthController {
       () => this.checkDatabase(),
       () => this.checkStellar(),
       () => this.checkWebSocket(),
+      () => this.checkMemory(),
+      () => this.checkDisk(),
     ]);
   }
 

apps/backend/src/notifications/notifications.service.ts

@@ -12,7 +12,7 @@ import { WebhookSender } from './senders/webhook.sender';
 import { Repository, IsNull } from 'typeorm';
 import { EmailSender } from './senders/email.sender';
 import { PreferenceService } from './preference.service';
-import { EventsGateway } from '../gateways/escrow.gateway';
+import { EscrowGateway } from '../gateways/escrow.gateway';
 
 @Injectable()
 export class NotificationService {
@@ -25,7 +25,7 @@ export class NotificationService {
     private preferenceService: PreferenceService,
     emailSender: EmailSender,
     webhookSender: WebhookSender,
-    @Optional() private readonly eventsGateway?: EventsGateway,
+    @Optional() private readonly eventsGateway?: EscrowGateway,
   ) {
     this.senders = new Map([
       [NotificationChannel.EMAIL, emailSender],

apps/backend/tsconfig.json

@@ -20,7 +20,7 @@
     "noImplicitAny": false,
     "strictBindCallApply": false,
     "noFallthroughCasesInSwitch": false,
-    "types": ["node"],
+    "types": ["node", "multer"],
     "lib": ["es2021"]
   }
 }