File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
backend/matching/src/workers Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -12,9 +12,13 @@ export const initWorker = (name: string, io: Server) => {
12
12
const worker = fork ( path . join ( __dirname , `${ lCaseName } .js` ) , { signal : controller . signal } ) ;
13
13
const upperCaseName = name . replace ( / ^ [ A - Z a - z ] / , ( c ) => c . toUpperCase ( ) ) ;
14
14
worker . on ( 'message' , ( message ) => {
15
- logger . info ( `Received message from '${ upperCaseName } ': ${ JSON . stringify ( message ) } ` ) ;
16
-
17
- const { rooms, event, message : payload } = message as IChildProcessMessage ;
15
+ if ( typeof message . valueOf ( ) === 'string' ) {
16
+ logger . info ( `[${ upperCaseName } ]: ${ message } ` ) ;
17
+ return ;
18
+ }
19
+ const messagePayload = message . valueOf ( ) ;
20
+ logger . info ( `[${ upperCaseName } ] WS Payload: ${ JSON . stringify ( messagePayload ) } ` ) ;
21
+ const { rooms, event, message : payload } = messagePayload as IChildProcessMessage ;
18
22
if ( event === MATCH_SVC_EVENT . DISCONNECT ) {
19
23
io . sockets . in ( rooms ) . disconnectSockets ( ) ;
20
24
return ;
You can’t perform that action at this time.
0 commit comments