feat: First async proptest, for Gateway::run

node/narwhal/Cargo.toml

@@ -109,6 +109,5 @@ version = "0.3"
 features = [ "env-filter" ]
 
 [dev-dependencies]
-test-strategy = "0.3.0"
-proptest = "1.0.0"
-rand_xorshift = "0.3.0"
+test-strategy = { git = "https://github.com/frozenlib/test-strategy/", branch = "master"}
+proptest = "1.0.0"

node/narwhal/src/gateway.rs

@@ -802,11 +802,12 @@ mod tests {
         MAX_COMMITTEE_SIZE,
         MEMORY_POOL_PORT,
     };
+    use indexmap::IndexMap;
     use parking_lot::RwLock;
     use snarkos_node_tcp::P2P;
     use snarkvm::prelude::Testnet3;
     use std::{
-        net::{IpAddr, Ipv4Addr},
+        net::{IpAddr, Ipv4Addr, SocketAddr},
         sync::Arc,
     };
     use test_strategy::{proptest, Arbitrary};
@@ -858,4 +859,26 @@ mod tests {
         assert_eq!(tcp_config.max_connections, MAX_COMMITTEE_SIZE);
         assert_eq!(gateway.account().address(), address);
     }
+
+    #[proptest(async = "tokio")]
+    async fn gateway_start(#[filter(|x| x.dev.is_some())] input: GatewayInput) {
+        let Some(dev) = input.dev else { unreachable!() };
+        let mut gateway = input.to_gateway();
+        let tcp_config = gateway.tcp().config();
+        assert_eq!(tcp_config.listener_ip, Some(IpAddr::V4(Ipv4Addr::LOCALHOST)));
+        assert_eq!(tcp_config.desired_listening_port, Some(MEMORY_POOL_PORT + (dev as u16)));
+
+        match gateway.run(IndexMap::new()).await {
+            Ok(_) => {
+                assert_eq!(
+                    gateway.local_ip(),
+                    SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), MEMORY_POOL_PORT + (dev as u16))
+                );
+                assert_eq!(gateway.num_workers(), 0);
+            }
+            Err(err) => {
+                panic!("Shouldn't fail because of {err}");
+            }
+        }
+    }
 }