|
| 1 | +#[cfg(test)] |
| 2 | +pub mod test { |
| 3 | + use mtma_migrator_test_matching_feature_flags_criterion::GlobalFeatureCheck; |
| 4 | + use mtma_migrator_test_types::check::checked_migration; |
| 5 | + use mtma_migrator_types::migrator::{movement_migrator::Overlays, MovementMigrator}; |
| 6 | + use mtma_node_null_core::config::Config as MtmaNullConfig; |
| 7 | + use mtma_node_test_types::prelude::Prelude; |
| 8 | + |
| 9 | + #[tokio::test] |
| 10 | + #[tracing_test::traced_test] |
| 11 | + #[ignore = "activate when runtime problems are solved"] |
| 12 | + async fn test_matching_feature_flags() -> Result<(), anyhow::Error> { |
| 13 | + // Form the migrator. |
| 14 | + let mut movement_migrator = MovementMigrator::try_temp()?; |
| 15 | + // TODO: use `MovementMigrator::try_debug_home()` |
| 16 | + // let mut movement_migrator = MovementMigrator::try_debug_home()?; |
| 17 | + movement_migrator.set_overlays(Overlays::default()); |
| 18 | + |
| 19 | + // Start the migrator so that it's running in the background. |
| 20 | + // In the future, some migrators may be for already running nodes. |
| 21 | + let movement_migrator_for_task = movement_migrator.clone(); |
| 22 | + let movement_migrator_task = kestrel::task(async move { |
| 23 | + movement_migrator_for_task.run().await?; |
| 24 | + Ok::<_, anyhow::Error>(()) |
| 25 | + }); |
| 26 | + |
| 27 | + tokio::time::sleep(tokio::time::Duration::from_secs(30)).await; |
| 28 | + |
| 29 | + kestrel::end!(movement_migrator_task)?; |
| 30 | + |
| 31 | + // Form the prelude. |
| 32 | + // todo: this needs to be updated to use the prelude generator |
| 33 | + let prelude = Prelude::new_empty(); |
| 34 | + |
| 35 | + // Form the migration. |
| 36 | + let migration_config = MtmaNullConfig::default(); |
| 37 | + let migration = migration_config.build()?; |
| 38 | + |
| 39 | + // Run the checked migration. |
| 40 | + let matching_feature_flags = GlobalFeatureCheck::new(); |
| 41 | + checked_migration( |
| 42 | + &mut movement_migrator, |
| 43 | + &prelude, |
| 44 | + &migration, |
| 45 | + vec![matching_feature_flags], |
| 46 | + ) |
| 47 | + .await?; |
| 48 | + |
| 49 | + Ok(()) |
| 50 | + } |
| 51 | +} |
0 commit comments