@@ -157,8 +157,8 @@ impl RelayerSessionTask {
157
157
158
158
failure_count += 1 ;
159
159
let next_backoff = backoff. next_backoff ( ) . unwrap_or ( max_interval) ;
160
- tracing:: error !(
161
- "relayer session failed with error: {:?}, failure_count: {}; retrying in {:?}" ,
160
+ tracing:: warn !(
161
+ "relayer session ended with error: {:?}, failure_count: {}; retrying in {:?}" ,
162
162
e,
163
163
failure_count,
164
164
next_backoff
@@ -211,7 +211,7 @@ impl RelayerSessionTask {
211
211
tracing:: error!( "Error receiving message from at relayer: {e:?}" ) ;
212
212
}
213
213
None => {
214
- tracing:: error !( "relayer connection closed" ) ;
214
+ tracing:: warn !( "relayer connection closed" ) ;
215
215
bail!( "relayer connection closed" ) ;
216
216
}
217
217
}
@@ -290,14 +290,16 @@ pub fn lazer_exporter(config: Config, state: Arc<state::State>) -> Vec<JoinHandl
290
290
panic ! ( "failed to get Lazer signing key" )
291
291
}
292
292
} ;
293
+ let pubkey_base64 = BASE64_STANDARD . encode ( signing_key. verifying_key ( ) . to_bytes ( ) ) ;
294
+ tracing:: info!( "Loaded Lazer signing key; pubkey in base64: {pubkey_base64}" ) ;
293
295
294
296
// can safely drop first receiver for ease of iteration
295
297
let ( relayer_sender, _) = broadcast:: channel ( RELAYER_CHANNEL_CAPACITY ) ;
296
298
297
299
for url in config. relayer_urls . iter ( ) {
298
300
let mut task = RelayerSessionTask {
299
301
url : url. clone ( ) ,
300
- token : BASE64_STANDARD . encode ( signing_key . verifying_key ( ) . to_bytes ( ) ) ,
302
+ token : pubkey_base64 . clone ( ) ,
301
303
receiver : relayer_sender. subscribe ( ) ,
302
304
} ;
303
305
handles. push ( tokio:: spawn ( async move { task. run ( ) . await } ) ) ;
0 commit comments