@@ -39,7 +39,7 @@ export class ConnectionManager
39
39
private currentActiveParallelDialCount = 0 ;
40
40
private pendingPeerDialQueue : Array < PeerId > = [ ] ;
41
41
42
- private isConnectedToNetwork : boolean = window . navigator . onLine ;
42
+ private isConnectedToNetwork : boolean = false ;
43
43
private isConnectedToWakuNetwork : boolean = false ;
44
44
45
45
public static create (
@@ -107,21 +107,26 @@ export class ConnectionManager
107
107
}
108
108
109
109
public stop ( ) : void {
110
- this . keepAliveManager . stopAll ( ) ;
111
- this . libp2p . removeEventListener (
112
- "peer:connect" ,
113
- this . onEventHandlers [ "peer:connect" ]
114
- ) ;
115
- this . libp2p . removeEventListener (
116
- "peer:disconnect" ,
117
- this . onEventHandlers [ "peer:disconnect" ]
118
- ) ;
119
- this . libp2p . removeEventListener (
120
- "peer:discovery" ,
121
- this . onEventHandlers [ "peer:discovery" ]
122
- ) ;
123
- window . removeEventListener ( "online" , this . onEventHandlers [ "online" ] ) ;
124
- window . removeEventListener ( "offline" , this . onEventHandlers [ "offline" ] ) ;
110
+ try {
111
+ this . keepAliveManager . stopAll ( ) ;
112
+ this . libp2p . removeEventListener (
113
+ "peer:connect" ,
114
+ this . onEventHandlers [ "peer:connect" ]
115
+ ) ;
116
+ this . libp2p . removeEventListener (
117
+ "peer:disconnect" ,
118
+ this . onEventHandlers [ "peer:disconnect" ]
119
+ ) ;
120
+ this . libp2p . removeEventListener (
121
+ "peer:discovery" ,
122
+ this . onEventHandlers [ "peer:discovery" ]
123
+ ) ;
124
+
125
+ window . removeEventListener ( "online" , this . onEventHandlers [ "online" ] ) ;
126
+ window . removeEventListener ( "offline" , this . onEventHandlers [ "offline" ] ) ;
127
+ } catch ( err ) {
128
+ log . error ( `Failed to stop: ${ err } ` ) ;
129
+ }
125
130
}
126
131
127
132
public async dropConnection ( peerId : PeerId ) : Promise < void > {
@@ -345,8 +350,12 @@ export class ConnectionManager
345
350
}
346
351
347
352
private startBrowserNetworkStatusListener ( ) : void {
348
- window . addEventListener ( "online" , this . onEventHandlers [ "online" ] ) ;
349
- window . addEventListener ( "offline" , this . onEventHandlers [ "offline" ] ) ;
353
+ try {
354
+ window . addEventListener ( "online" , this . onEventHandlers [ "online" ] ) ;
355
+ window . addEventListener ( "offline" , this . onEventHandlers [ "offline" ] ) ;
356
+ } catch ( err ) {
357
+ log . error ( `Failed to add event listener to window: ${ err } ` ) ;
358
+ }
350
359
}
351
360
352
361
private onEventHandlers = {
0 commit comments