fix(core): socket pushes not working

libraries/grpc-sdk/src/classes/Routing/RoutingManager.ts

@@ -108,6 +108,7 @@ export class RoutingManager {
     for (let option in routeObject.options) {
       if (!routeObject.options.hasOwnProperty(option)) continue;
       if (option === 'middlewares') continue;
+      if (option === 'path') continue;
       routeObject.options[option] = JSON.stringify(routeObject.options[option]);
     }
     let primary: string;

libraries/grpc-sdk/src/types/index.ts

@@ -56,7 +56,7 @@ export type SocketRequest = GrpcRequest<{
 export type ParsedSocketRequest = GrpcRequest<{
   event: string;
   socketId: string;
-  params: { [key: string]: any };
+  params: string[];
   context: { [key: string]: any };
 }>;
 export type UnparsedSocketResponse =

modules/chat/src/routes/routes.ts

@@ -7,6 +7,7 @@ import ConduitGrpcSdk, {
   ParsedRouterRequest,
   RoutingManager,
   TYPE,
+  ParsedSocketRequest,
   UnparsedRouterResponse,
   UnparsedSocketResponse,
 } from '@conduitplatform/grpc-sdk';
@@ -289,14 +290,14 @@ export class ChatRoutes {
     return 'Message updated successfully';
   }
 
-  async connect(call: ParsedRouterRequest): Promise<UnparsedSocketResponse> {
+  async connect(call: ParsedSocketRequest): Promise<UnparsedSocketResponse> {
     const { user } = call.request.context;
     const rooms = await ChatRoom.getInstance()
       .findMany({ participants: user._id });
     return { rooms: (rooms as ChatRoom[]).map((room: any) => room._id) };
   }
 
-  async onMessage(call: ParsedRouterRequest): Promise<UnparsedSocketResponse> {
+  async onMessage(call: ParsedSocketRequest): Promise<UnparsedSocketResponse> {
     const { user } = call.request.context;
     const { roomId, message } = call.request.params;
     const room = await ChatRoom.getInstance().findOne({ _id: roomId });
@@ -320,7 +321,7 @@ export class ChatRoutes {
     };
   }
 
-  async onMessagesRead(call: ParsedRouterRequest): Promise<UnparsedSocketResponse> {
+  async onMessagesRead(call: ParsedSocketRequest): Promise<UnparsedSocketResponse> {
     const { user } = call.request.context;
     const { roomId } = call.request.params;
     const room = await ChatRoom.getInstance()

packages/router/src/controllers/Socket/Socket.ts

@@ -149,9 +149,15 @@ export class SocketController extends ConduitRouter {
   handleSocketPush(push: SocketPush) {
     if (isInstanceOfEventResponse(push)) {
       if (isNil(push.receivers) || push.receivers!.length === 0) {
-        this.io.emit(push.event, push.data);
+        this.io.of(push.namespace).emit(push.event, push.data);
       } else {
-        this.io.to(push.receivers).emit(push.event, push.data);
+        this.io.of(push.namespace).adapter.fetchSockets({
+          rooms: new Set(push.receivers)
+        }).then(sockets=>{
+          sockets.forEach(r=>{
+            r.to(push.receivers).emit(push.event, push.data)
+          })
+        })
       }
     } else {
       throw new Error('Cannot join room in this context');

packages/router/src/index.ts

@@ -184,7 +184,7 @@ export class ConduitDefaultRouter implements IConduitRouter {
         );
         this.registerRouteMiddleware(r);
       } else if (r instanceof ConduitSocket) {
-        console.log('New socker registered: ' + r.input.path + ' handler url: ' + url);
+        console.log('New socket registered: ' + r.input.path + ' handler url: ' + url);
         this.registerSocket(r);
       } else {
         console.log(
@@ -209,6 +209,7 @@ export class ConduitDefaultRouter implements IConduitRouter {
         data: JSON.parse(call.request.data),
         receivers: call.request.receivers,
         rooms: call.request.rooms,
+        namespace: `/${(call as any).metadata.get('module-name')[0]}/`
       };
       await this._internalRouter.socketPush(socketData);
     } catch (err) {

packages/router/src/models/SocketPush.model.ts

@@ -3,4 +3,5 @@ export interface SocketPush {
   data: any;
   receivers: string[];
   rooms: string[];
+  namespace: string;
 }