interop proxy with multi ups extended IT

.github/workflows/mg.yaml

@@ -16,14 +16,6 @@ jobs:
       - name: Run interop-proxy-with-multi-ups
         run: sh ./test/message-generator/test/interop-proxy-with-multi-ups/interop-proxy-with-multi-ups.sh
 
-  interop-proxy-with-multi-ups-extended:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v4
-      - name: Run interop-proxy-with-multi-ups-extended
-        run: sh ./test/message-generator/test/interop-proxy-with-multi-ups-extended/interop-proxy-with-multi-ups-extended.sh
-
   jds-do-not-fail-on-wrong-tsdatasucc:
     runs-on: ubuntu-latest
     steps:
@@ -73,7 +65,6 @@ jobs:
     if: always()
     needs: [
       interop-proxy-with-multi-ups,
-      interop-proxy-with-multi-ups-extended,
       jds-do-not-fail-on-wrong-tsdatasucc,
       jds-receive-solution-while-processing-declared-job,
       pool-sri-test-close-channel,
@@ -84,7 +75,6 @@ jobs:
       - name: Aggregate Results
         run: |
           if [ "${{ needs.interop-proxy-with-multi-ups.result }}" != "success" ] ||
-          [ "${{ needs.interop-proxy-with-multi-ups-extended.result }}" != "success" ] ||
           [ "${{ needs.jds-do-not-fail-on-wrong-tsdatasucc.result }}" != "success" ] ||
           [ "${{ needs.jds-receive-solution-while-processing-declared-job.result }}" != "success" ] ||
           [ "${{ needs.pool-sri-test-close-channel.result }}" != "success" ] ||

test/integration-tests/lib/mod.rs

@@ -341,17 +341,20 @@ pub async fn start_mining_device_sv2(
     tokio::time::sleep(std::time::Duration::from_secs(2)).await;
 }
 
-pub async fn start_mining_sv2_proxy(upstream: SocketAddr) -> SocketAddr {
+pub async fn start_mining_sv2_proxy(upstreams: &[SocketAddr]) -> SocketAddr {
     use mining_proxy_sv2::{ChannelKind, UpstreamMiningValues};
-    let upstreams = vec![UpstreamMiningValues {
-        address: upstream.ip().to_string(),
-        port: upstream.port(),
-        pub_key: Secp256k1PublicKey::from_str(
-            "9auqWEzQDVyd2oe1JVGFLMLHZtCo2FFqZwtKA5gd9xbuEu7PH72",
-        )
-        .unwrap(),
-        channel_kind: ChannelKind::Extended,
-    }];
+    let upstreams = upstreams
+        .iter()
+        .map(|upstream| UpstreamMiningValues {
+            address: upstream.ip().to_string(),
+            port: upstream.port(),
+            pub_key: Secp256k1PublicKey::from_str(
+                "9auqWEzQDVyd2oe1JVGFLMLHZtCo2FFqZwtKA5gd9xbuEu7PH72",
+            )
+            .unwrap(),
+            channel_kind: ChannelKind::Extended,
+        })
+        .collect();
     let mining_proxy_listening_address = get_available_address();
     let config = mining_proxy_sv2::Configuration {
         upstreams,

test/integration-tests/tests/interop_proxy_with_multi_ups_extended.rs

@@ -0,0 +1,14 @@
+use integration_tests_sv2::*;
+
+#[tokio::test]
+async fn test_interop_proxy_with_multi_ups_extended() {
+    start_tracing();
+    let (_, tp_addr) = start_template_provider(None);
+    let (_pool_1, pool_addr_1) = start_pool(Some(tp_addr)).await;
+    let (_pool_2, pool_addr_2) = start_pool(Some(tp_addr)).await;
+    let mining_proxy_sv2_addr = start_mining_sv2_proxy(&[pool_addr_1, pool_addr_2]).await;
+    let _ = start_mining_device_sv1(mining_proxy_sv2_addr, false, None).await;
+
+    // Need a way to kill pool. And then test if mining_proxy_sv2_addr still binds or not.
+    // Need a way to kill MD. And then test if mining_proxy_sv2_addr still binds or not.
+}