logos-blockchain/lssa
1
0
Fork 0
mirror of https://github.com/logos-blockchain/lssa.git synced 2026-03-03 10:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: http retries

Browse Source
This commit is contained in:
Pravdyvy 2026-02-27 19:11:26 +02:00
parent bdeca0185f
commit 9dc6025537
3 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Cargo.lock generated
View File

@ -1765,6 +1765,7 @@ dependencies = [
"serde_with",
"sha2",
"thiserror 2.0.18",
"tokio-retry",
"url",
]

1
common/Cargo.toml
View File

@ -22,3 +22,4 @@ bytesize.workspace = true
base64.workspace = true
url.workspace = true
logos-blockchain-common-http-client.workspace = true
tokio-retry.workspace = true

21
common/src/sequencer_client.rs
View File

@ -67,15 +67,24 @@ impl SequencerClient {
"Calling method {method} with payload {request:?} to sequencer at {}",
self.sequencer_addr
);
let mut call_builder = self.client.post(self.sequencer_addr.clone());
if let Some(BasicAuth { username, password }) = &self.basic_auth {
call_builder = call_builder.basic_auth(username, password.as_deref());
}
let strategy = tokio_retry::strategy::FixedInterval::from_millis(10000).take(60);
let call_res = call_builder.json(&request).send().await?;
let response_vall = tokio_retry::Retry::spawn(strategy, || async {
let mut call_builder = self.client.post(self.sequencer_addr.clone());
let response_vall = call_res.json::<Value>().await?;
if let Some(BasicAuth { username, password }) = &self.basic_auth {
call_builder = call_builder.basic_auth(username, password.as_deref());
}
let call_res_res = call_builder.json(&request).send().await;
match call_res_res {
Err(err) => Err(err),
Ok(call_res) => call_res.json::<Value>().await,
}
})
.await?;
#[derive(Debug, Clone, Deserialize)]
#[allow(dead_code)]