aljaz/sphinx-key
1
1
Fork 0
mirror of https://github.com/stakwork/sphinx-key.git synced 2025-12-19 00:04:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

handle lss_handle errs, lss-connector master

Browse Source
This commit is contained in:
Evan Feenstra
2023-05-31 13:08:28 -07:00
parent 5a63a08182
commit b84c3d6d54
2 changed files with 20 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
broker/src/main.rs
View File

@@ -82,7 +82,13 @@ async fn run_main(parent_fd: i32) -> rocket::Rocket<rocket::Build> {
let (lss_tx, lss_rx) = mpsc::channel(10000);
let _lss_broker = if let Ok(lss_uri) = env::var("VLS_LSS") {
// waits until LSS confirmation from signer
let lss_broker = lss_setup(&lss_uri, lss_rx, mqtt_tx.clone()).await.unwrap();
let lss_broker = match lss_setup(&lss_uri, lss_rx, mqtt_tx.clone()).await{
Ok(l) => l,
Err(e) => {
let _ = error_tx.send(e.to_string().as_bytes().to_vec());
panic!("{:?}", e);
}
};
log::info!("=> lss broker connection created!");
Some(lss_broker)
} else {
@@ -141,8 +147,14 @@ pub async fn lss_setup(uri: &str, mut lss_rx: mpsc::Receiver<LssReq>, mqtt_tx: m
let persister = lss_conn.persister();
tokio::task::spawn(async move{
while let Some(req) = lss_rx.recv().await {
let msg = lss_handle(&persister, &req.message).await.unwrap();
let _ = req.reply_tx.send(msg);
match lss_handle(&persister, &req.message).await {
Ok(msg) => {
let _ = req.reply_tx.send(msg);
},
Err(e) => {
log::error!("failed lss_handle {:?}", e);
}
}
}
});