Merge branch 'main' into fix/job-fetching-and-pagination

Author: digitalnomad91

.vscode/settings.json

@@ -0,0 +1,18 @@
+{
+  "sqltools.connections": [
+    {
+      "mysqlOptions": {
+        "authProtocol": "default",
+        "enableSsl": "Disabled"
+      },
+      "previewLimit": 50,
+      "server": "localhost",
+      "port": 3306,
+      "driver": "MariaDB",
+      "name": "MySQL",
+      "database": "codebuilder_main",
+      "username": "codebuilder",
+      "password": "joker123"
+    }
+  ]
+}

src/events/events.gateway.ts

@@ -41,14 +41,16 @@ export class EventsGateway implements OnGatewayConnection, OnGatewayDisconnect {
 
   public handleConnection(client: Socket) {
     const { user_id } = this.getClientQuery(client);
-
+    
+    console.log('WssGateway: handleConnection', { user_id });
 
     return this.broadcastAll('event', { connected: user_id });
   }
 
   public handleDisconnect(client: Socket) {
     const { user_id } = this.getClientQuery(client);
 
+    console.log('WssGateway: handleDisconnect', { user_id });
 
     return this.broadcastAll('event', { disconnected: user_id });
   }
@@ -66,7 +68,6 @@ export class EventsGateway implements OnGatewayConnection, OnGatewayDisconnect {
 
   @SubscribeMessage('identity')
   identity(@MessageBody() data: number): number {
-
     return data;
   }
 }

src/wss/wss.gateway.ts

@@ -42,9 +42,7 @@ export class WssGateway implements OnGatewayConnection, OnGatewayDisconnect {
     this.server.emit(event_name, message);
   }
 
-  handleConnection(client: io.Socket) {
-    
-    client.join('msgRoom');
+  handleConnection(client: io.Socket) {        client.join('msgRoom');
     const { user_id } = this.getClientQuery(client);
 
     this.logService.info(`WssGateway: handleConnection ${user_id}`);