@@ -66,7 +66,7 @@ export class DDPStreamer extends ServiceClass {
6666
6767 // update connections count every 30 seconds
6868 updateConnections = throttle ( ( ) => {
69- InstanceStatus . updateConnections ( this . wss ?. clients . size ?? 0 ) ;
69+ void InstanceStatus . updateConnections ( this . wss ?. clients . size ?? 0 ) ;
7070 } , 30000 ) ;
7171
7272 override async created ( ) : Promise < void > {
@@ -182,37 +182,37 @@ export class DDPStreamer extends ServiceClass {
182182
183183 server . emit ( 'presence' , { userId, connection } ) ;
184184
185- this . api ?. broadcast ( 'accounts.login' , { userId, connection } ) ;
185+ void this . api ?. broadcast ( 'accounts.login' , { userId, connection } ) ;
186186 } ) ;
187187
188188 server . on ( DDP_EVENTS . LOGGEDOUT , ( info ) => {
189189 const { userId, connection } = info ;
190190
191- this . api ?. broadcast ( 'accounts.logout' , { userId, connection } ) ;
191+ void this . api ?. broadcast ( 'accounts.logout' , { userId, connection } ) ;
192192
193- this . updateConnections ( ) ;
193+ void this . updateConnections ( ) ;
194194
195195 if ( ! userId ) {
196196 return ;
197197 }
198- Presence . removeConnection ( userId , connection . id , nodeID ) ;
198+ void Presence . removeConnection ( userId , connection . id , nodeID ) ;
199199 } ) ;
200200
201201 server . on ( DDP_EVENTS . DISCONNECTED , ( info ) => {
202202 const { userId, connection } = info ;
203203
204- this . api ?. broadcast ( 'socket.disconnected' , connection ) ;
204+ void this . api ?. broadcast ( 'socket.disconnected' , connection ) ;
205205
206206 this . updateConnections ( ) ;
207207
208208 if ( ! userId ) {
209209 return ;
210210 }
211- Presence . removeConnection ( userId , connection . id , nodeID ) ;
211+ void Presence . removeConnection ( userId , connection . id , nodeID ) ;
212212 } ) ;
213213
214214 server . on ( DDP_EVENTS . CONNECTED , ( { connection } ) => {
215- this . api ?. broadcast ( 'socket.connected' , connection ) ;
215+ void this . api ?. broadcast ( 'socket.connected' , connection ) ;
216216 } ) ;
217217 }
218218
@@ -258,7 +258,7 @@ export class DDPStreamer extends ServiceClass {
258258
259259 this . wss . on ( 'connection' , ( ws , req ) => new Client ( ws , req . url !== '/websocket' , req ) ) ;
260260
261- InstanceStatus . registerInstance ( 'ddp-streamer' , { } ) ;
261+ void InstanceStatus . registerInstance ( 'ddp-streamer' , { } ) ;
262262 } catch ( err ) {
263263 console . error ( 'DDPStreamer did not start correctly' , err ) ;
264264 }
0 commit comments