Conditional execution of transfer tests based on framework-test feature

Cargo.toml

@@ -16,7 +16,7 @@ dummy-driver = ['ya-dummy-driver']
 erc20-driver = ['ya-erc20-driver']
 erc20next-driver = ['ya-erc20next-driver']
 tos = []
-framework-test = []
+framework-test = ['ya-exe-unit/framework-test']
 # Temporary to make goth integration tests work
 central-net = ['ya-net/central-net']
 packet-trace-enable = [
@@ -65,6 +65,7 @@ ya-client-model = "0.5"
 
 gftp = { version = "0.3.1", optional = true }      # just to enable gftp build for cargo-deb
 ya-provider = { version = "0.3", optional = true } # just to enable conditionally running some tests
+ya-exe-unit = { version = "0.4", optional = true }       # just to enable conditionally running some tests
 
 actix-rt = "2.7"
 actix-service = "2"
@@ -91,6 +92,7 @@ libsqlite3-sys = { workspace = true }
 
 [dev-dependencies]
 ya-test-framework = "0.1"
+ya-exe-unit = { version = "0.4" }
 
 [package.metadata.deb]
 name = "golem-requestor"

exe-unit/Cargo.toml

@@ -25,6 +25,7 @@ sgx = [
     'ya-transfer/sgx',
 ]
 packet-trace-enable = ["ya-packet-trace/enable"]
+framework-test = ["ya-transfer/framework-test"]
 
 [target.'cfg(target_family = "unix")'.dependencies]
 nix = "0.22.0"

exe-unit/components/transfer/tests/test_transfer_abort.rs

@@ -67,15 +67,15 @@ async fn interrupted_transfer(
     Ok(())
 }
 
-// #[cfg_attr(not(feature = "framework-test"), ignore)]
+#[cfg_attr(not(feature = "framework-test"), ignore)]
 #[test_context(DroppableTestContext)]
 #[serial_test::serial]
 async fn test_transfer_abort(ctx: &mut DroppableTestContext) -> anyhow::Result<()> {
     env::set_var(
         "RUST_LOG",
         env::var("RUST_LOG").unwrap_or_else(|_| "debug".into()),
     );
-    env_logger::try_init().ok();
+    //env_logger::try_init().ok();
 
     let temp_dir = temp_dir!("transfer-abort")?;
     let temp_dir = temp_dir.path();

exe-unit/components/transfer/tests/test_transfer_service.rs

@@ -36,15 +36,15 @@ async fn transfer_with_args(
     Ok(())
 }
 
-// #[cfg_attr(not(feature = "framework-test"), ignore)]
+#[cfg_attr(not(feature = "framework-test"), ignore)]
 #[test_context(DroppableTestContext)]
 #[serial_test::serial]
 async fn test_transfer_scenarios(ctx: &mut DroppableTestContext) -> anyhow::Result<()> {
     env::set_var(
         "RUST_LOG",
         env::var("RUST_LOG").unwrap_or_else(|_| "debug".into()),
     );
-    env_logger::try_init().ok();
+    //env_logger::try_init().ok();
 
     let dir = temp_dir!("transfer")?;
     let temp_dir = dir.path();
@@ -164,15 +164,15 @@ async fn test_transfer_scenarios(ctx: &mut DroppableTestContext) -> anyhow::Resu
     Ok(())
 }
 
-// #[cfg_attr(not(feature = "framework-test"), ignore)]
+#[cfg_attr(not(feature = "framework-test"), ignore)]
 #[test_context(DroppableTestContext)]
 #[serial_test::serial]
 async fn test_transfer_archived(ctx: &mut DroppableTestContext) -> anyhow::Result<()> {
     env::set_var(
         "RUST_LOG",
         env::var("RUST_LOG").unwrap_or_else(|_| "debug".into()),
     );
-    env_logger::try_init().ok();
+    //env_logger::try_init().ok();
 
     let dir = temp_dir!("transfer-archive")?;
     let temp_dir = dir.path();