@@ -32,49 +32,40 @@ export class EventsGateway implements OnGatewayConnection, OnGatewayDisconnect {
3232 server : Server ;
3333
3434 private getClientQuery ( client : Socket ) : Record < string , unknown > {
35- console . log ( 'wtf121212' ) ;
3635 return client . handshake . query ;
3736 }
3837
3938 public broadcastAll ( event_name : string , message : Record < string , unknown > ) {
40- console . log ( 'assdasda' ) ;
4139 this . server . emit ( event_name , message ) ;
4240 }
4341
4442 public handleConnection ( client : Socket ) {
45- console . log ( 'whaaaat' ) ;
4643 const { user_id } = this . getClientQuery ( client ) ;
4744
48- console . log ( 'WssGateway: handleConnection' , { user_id } ) ;
4945
5046 return this . broadcastAll ( 'event' , { connected : user_id } ) ;
5147 }
5248
5349 public handleDisconnect ( client : Socket ) {
54- console . log ( 'hwathwat' ) ;
5550 const { user_id } = this . getClientQuery ( client ) ;
5651
57- console . log ( 'WssGateway: handleDisconnect' , { user_id } ) ;
5852
5953 return this . broadcastAll ( 'event' , { disconnected : user_id } ) ;
6054 }
6155
6256 @SubscribeMessage ( 'tick' )
6357 handleEvent ( @MessageBody ( ) data : unknown , @ConnectedSocket ( ) client : Socket ) : WsResponse < unknown > {
64- console . log ( 'wtf111' ) ;
6558 const event = 'events' ;
6659 return { event, data } ;
6760 }
6861
6962 @SubscribeMessage ( 'tick' )
7063 findAll ( @MessageBody ( ) data : any ) : Observable < WsResponse < number > > {
71- console . log ( 'wtf222");' ) ;
7264 return from ( [ 1 , 2 , 3 ] ) . pipe ( map ( ( item ) => ( { event : 'events' , data : item } ) ) ) ;
7365 }
7466
7567 @SubscribeMessage ( 'identity' )
7668 identity ( @MessageBody ( ) data : number ) : number {
77- console . log ( 'wtf23232' ) ;
7869
7970 return data ;
8071 }
0 commit comments