Merge pull request #156 from plebhash/2025-12-18-adapt-group-channels

add Group Channel adaptations on apps

Author: plebhash

integration-tests/Cargo.lock

@@ -28,6 +28,7 @@ tokio = { version="1.44.1", default-features = false,  features = ["tracing"] }
 tokio-util = { version = "0.7", default-features = false }
 tracing = { version = "0.1.41", default-features = false }
 tracing-subscriber = { version = "0.3.19", default-features = false }
+hex = "0.4.3"
 
 [lib]
 path = "lib/mod.rs"

integration-tests/Cargo.toml

@@ -30,7 +30,10 @@ impl MockDownstream {
             match TcpStream::connect(upstream_address).await {
                 Ok(stream) => break stream,
                 Err(_) => {
-                    println!("MockDownstream: unable to connect to upstream, retrying");
+                    tracing::warn!(
+                        "MockDownstream: unable to connect to upstream, retrying after 1 second"
+                    );
+                    tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                 }
             }
         })

integration-tests/lib/mock_roles.rs

@@ -37,7 +37,7 @@ pub mod sv1_minerd;
 pub mod sv1_sniffer;
 pub mod template_provider;
 pub mod types;
-pub(crate) mod utils;
+pub mod utils;
 
 const SHARES_PER_MINUTE: f32 = 120.0;
 

integration-tests/lib/mod.rs

@@ -95,10 +95,12 @@ impl<'a> Sniffer<'a> {
                 match TcpStream::connect(upstream_address).await {
                     Ok(stream) => break stream,
                     Err(_) => {
-                        println!(
-                            "Sniffer {}: unable to connect to upstream {}, retrying",
-                            identifier, upstream_address
+                        tracing::warn!(
+                            "Sniffer {}: unable to connect to upstream {}, retrying after 1 second",
+                            identifier,
+                            upstream_address
                         );
+                        tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                     }
                 }
             })

integration-tests/lib/sniffer.rs

@@ -59,6 +59,10 @@ impl SnifferSV1 {
                 match TcpStream::connect(upstream_address).await {
                     Ok(s) => break s,
                     Err(_) => {
+                        tracing::warn!(
+                            "SnifferSV1: unable to connect to upstream, retrying after 1 second"
+                        );
+                        tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                         continue;
                     }
                 }