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

update lss-connector dep rev

Browse Source
This commit is contained in:
Evan Feenstra
2023-05-31 15:00:08 -07:00
parent b84c3d6d54
commit ea88db3df6
3 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
broker/Cargo.lock generated
View File

@@ -1713,7 +1713,7 @@ dependencies = [
[[package]] [[package]]
name = "lss-connector" name = "lss-connector"
version = "0.1.0" version = "0.1.0"
source = "git+https://github.com/stakwork/sphinx-rs#2f25ab4dcb70c1372dce866d028158c7a346e679" source = "git+https://github.com/stakwork/sphinx-rs#7242f58f734281111c1d3597cc4d47e9a26b6499"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"lightning-storage-server", "lightning-storage-server",
@@ -3173,7 +3173,7 @@ dependencies = [
[[package]] [[package]]
name = "sphinx-auther" name = "sphinx-auther"
version = "0.1.12" version = "0.1.12"
source = "git+https://github.com/stakwork/sphinx-rs#2f25ab4dcb70c1372dce866d028158c7a346e679" source = "git+https://github.com/stakwork/sphinx-rs#7242f58f734281111c1d3597cc4d47e9a26b6499"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"base64 0.13.1", "base64 0.13.1",
@@ -3185,7 +3185,7 @@ dependencies = [
[[package]] [[package]]
name = "sphinx-glyph" name = "sphinx-glyph"
version = "0.1.2" version = "0.1.2"
source = "git+https://github.com/stakwork/sphinx-rs#2f25ab4dcb70c1372dce866d028158c7a346e679" source = "git+https://github.com/stakwork/sphinx-rs#7242f58f734281111c1d3597cc4d47e9a26b6499"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"hex", "hex",
@@ -3231,7 +3231,7 @@ dependencies = [
[[package]] [[package]]
name = "sphinx-signer" name = "sphinx-signer"
version = "0.1.0" version = "0.1.0"
source = "git+https://github.com/stakwork/sphinx-rs#2f25ab4dcb70c1372dce866d028158c7a346e679" source = "git+https://github.com/stakwork/sphinx-rs#7242f58f734281111c1d3597cc4d47e9a26b6499"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"bip39", "bip39",

1
broker/src/looper.rs
View File

@@ -143,6 +143,7 @@ impl<C: 'static + Client> SignerLoop<C> {
// send reply to LSS to store muts // send reply to LSS to store muts
log::info!("GOT ON {}", _res_topic); log::info!("GOT ON {}", _res_topic);
let lss_reply = self.send_lss_and_get_reply(res)?; let lss_reply = self.send_lss_and_get_reply(res)?;
log::info!("LSS REPLY LEN {}", &lss_reply.len());
// send to signer for HMAC validation, and get final reply // send to signer for HMAC validation, and get final reply
log::info!("SEND ON {}", topics::LSS_MSG); log::info!("SEND ON {}", topics::LSS_MSG);
let (_res_topic, res2) = self.send_request_and_get_reply(topics::LSS_MSG, lss_reply)?; let (_res_topic, res2) = self.send_request_and_get_reply(topics::LSS_MSG, lss_reply)?;

1
broker/src/main.rs
View File

@@ -149,6 +149,7 @@ pub async fn lss_setup(uri: &str, mut lss_rx: mpsc::Receiver<LssReq>, mqtt_tx: m
while let Some(req) = lss_rx.recv().await { while let Some(req) = lss_rx.recv().await {
match lss_handle(&persister, &req.message).await { match lss_handle(&persister, &req.message).await {
Ok(msg) => { Ok(msg) => {
log::info!("payload to send {:?}", &msg);
let _ = req.reply_tx.send(msg); let _ = req.reply_tx.send(msg);
}, },
Err(e) => { Err(e) => {