diff --git a/broker/README.md b/broker/README.md index 32ab145..b36730b 100644 --- a/broker/README.md +++ b/broker/README.md @@ -18,13 +18,13 @@ docker rm -v $cid ### c-lightning -##### get the version +##### get the version `git describe --tags --long --always --match='v*.*'` and only take the last 8 chars of the last string -or +or `docker run -it --entrypoint "/bin/bash" sphinx-cln` @@ -40,4 +40,8 @@ docker push sphinxlightning/sphinx-cln-vls:0.1.4 ##### testing -cargo run --bin sphinx-key-tester -- --log \ No newline at end of file +cargo run --bin sphinx-key-tester -- --log + +##### find pid + +ps aux | grep -i sphinx-key-broker diff --git a/broker/src/run_test.rs b/broker/src/run_test.rs index e3c19a4..867f263 100644 --- a/broker/src/run_test.rs +++ b/broker/src/run_test.rs @@ -18,7 +18,7 @@ pub async fn run_test() -> rocket::Rocket { let settings = Settings::default(); let (tx, rx) = mpsc::channel(1000); - let (status_tx, _status_rx) = mpsc::channel(1000); + let (status_tx, mut status_rx) = mpsc::channel(1000); let (error_tx, error_rx) = broadcast::channel(1000); crate::error_log::log_errors(error_rx); @@ -27,6 +27,11 @@ pub async fn run_test() -> rocket::Rocket { log::info!("BROKER started!"); // let mut connected = false; // let tx_ = tx.clone(); + tokio::spawn(async move { + while let Some(status) = status_rx.recv().await { + log::info!("========> CONNECTED! {}", status); + } + }); // tokio::spawn(async move { // loop { // tokio::select! {