@@ -61,12 +61,6 @@ async function setHandlers(
61
61
isInitialNode = false ,
62
62
retryCount = 0 ,
63
63
) : Promise < void > {
64
- // log.info(
65
- // `Initiated Websocket connection for: ${ws_url} on ${
66
- // networks ?? 'unknown network'
67
- // }`,
68
- // )
69
-
70
64
const ledger_hashes : string [ ] = [ ]
71
65
return new Promise ( function setHandlersPromise ( resolve , _reject ) {
72
66
ws . on ( 'open' , ( ) => {
@@ -124,21 +118,21 @@ async function setHandlers(
124
118
)
125
119
}
126
120
} )
127
- ws . on ( 'close' , async ( code ) => {
128
- // log.error(
129
- // `Websocket closed for ${ws.url} on ${
130
- // networks ?? 'unknown network'
131
- // } with code ${code} and reason ${reason.toString('utf-8')}.`,
132
- // )
121
+ ws . on ( 'close' , async ( code , reason ) => {
122
+ log . error (
123
+ `Websocket closed for ${ ws . url } on ${
124
+ networks ?? 'unknown network'
125
+ } with code ${ code } and reason ${ reason . toString ( 'utf-8' ) } .`,
126
+ )
133
127
134
128
const delay = BASE_RETRY_DELAY * 2 ** retryCount
135
129
136
130
if ( CLOSING_CODES . includes ( code ) && delay <= MAX_RETRY_DELAY ) {
137
- // log.info(
138
- // `Reconnecting to ${ws.url} on ${
139
- // networks ?? 'unknown network'
140
- // } after ${delay}ms...`,
141
- // )
131
+ log . info (
132
+ `Reconnecting to ${ ws . url } on ${
133
+ networks ?? 'unknown network'
134
+ } after ${ delay } ms...`,
135
+ )
142
136
// Clean up the old Websocket connection
143
137
connections . delete ( ws . url )
144
138
ws . terminate ( )
@@ -168,12 +162,12 @@ async function setHandlers(
168
162
ws . terminate ( )
169
163
resolve ( )
170
164
} )
171
- ws . on ( 'error' , ( ) => {
172
- // log.error(
173
- // `Websocket connection error for ${ws.url} on ${
174
- // networks ?? 'unknown network'
175
- // } - ${err.message}`,
176
- // )
165
+ ws . on ( 'error' , ( err ) => {
166
+ log . error (
167
+ `Websocket connection error for ${ ws . url } on ${
168
+ networks ?? 'unknown network'
169
+ } - ${ err . message } `,
170
+ )
177
171
178
172
if ( connections . get ( ws . url ) ?. url === ws . url ) {
179
173
connections . delete ( ws . url )
0 commit comments