Add integration test for PoolSv2

.github/workflows/test.yaml

@@ -40,6 +40,10 @@ jobs:
  cargo build --manifest-path=roles/Cargo.toml
  cargo build --manifest-path=utils/Cargo.toml
 
+ - name: Roles Integration Tests
+ run: |
+ cargo test --manifest-path=roles/Cargo.toml --verbose --test '*' -- --nocapture
+
  - name: Run sv1-client-and-server example
  run: |
  cargo run --manifest-path=examples/sv1-client-and-server/Cargo.toml --bin client_and_server -- 60

roles/tests-integration/tests/pool_integration.rs

@@ -0,0 +1,31 @@
+use std::str::FromStr;
+
+mod common;
+
+#[tokio::test]
+async fn success_pool_template_provider_connection() {
+ assert!(common::start_template_provider_and_pool().await.is_ok());
+}
+
+#[tokio::test]
+async fn pool_bad_coinbase_output() {
+ let (template_provider, template_provider_port) = common::start_template_provider().await;
+ let invalid_coinbase_output = vec![pool_sv2::mining_pool::CoinbaseOutput::new(
+ "P2PK".to_string(),
+ "04466d7fcae563e5cb09a0d1870bb580344804617879a14949cf22285f1bae3f276728176c3c6431f8eeda4538dc37c865e2784f3a9e77d044f33e407797e1278".to_string(),
+ )];
+ let template_provider_address =
+ std::net::SocketAddr::from_str(&format!("127.0.0.1:{}", template_provider_port)).unwrap();
+ let test_pool = common::TestPoolSv2::new(
+ None,
+ Some(invalid_coinbase_output),
+ Some(template_provider_address),
+ );
+ let pool = test_pool.pool.clone();
+ let state = pool.state().await.safe_lock(|s| s.clone()).unwrap();
+ assert_eq!(state, pool_sv2::PoolState::Initial);
+ assert!(pool.start().await.is_err());
+ let state = pool.state().await.safe_lock(|s| s.clone()).unwrap();
+ assert_eq!(state, pool_sv2::PoolState::Initial);
+ template_provider.stop();
+}