()
| 944 | |
| 945 | #[tokio::test] |
| 946 | async fn test_deployment_manager_executing_task() { |
| 947 | //use tracing_subscriber::EnvFilter; |
| 948 | //tracing_subscriber::fmt() |
| 949 | // .with_env_filter( |
| 950 | // EnvFilter::builder() |
| 951 | // .with_default_directive(tracing::Level::INFO.into()) |
| 952 | // .from_env_lossy(), |
| 953 | // ) |
| 954 | // .with_ansi(true) |
| 955 | // .init(); |
| 956 | |
| 957 | let (client, server) = tokio::io::duplex(1024); |
| 958 | |
| 959 | let engine_gateway = MyEngineGtwTest { |
| 960 | deployments: Mutex::new(vec![Ok(Response::new(DeploymentInfo { |
| 961 | organization_id: "".to_string(), |
| 962 | cluster_id: "".to_string(), |
| 963 | execution_id: Uuid::new_v4().to_string(), |
| 964 | request_id: "".to_string(), |
| 965 | r#type: 0, |
| 966 | last_message_id: "".to_string(), |
| 967 | execution_start_deadline: None, |
| 968 | }))]), |
| 969 | msgs: vec![Ok(EngineMessageRx { |
| 970 | message_id: "".to_string(), |
| 971 | request: Some(engine_message_rx::Request::DeploymentRequest("".to_string())), |
| 972 | })], |
| 973 | }; |
| 974 | |
| 975 | tokio::spawn(async move { |
| 976 | Server::builder() |
| 977 | .add_service(EngineServer::new(engine_gateway)) |
| 978 | .serve_with_incoming(tokio_stream::iter(vec![Ok::<_, std::io::Error>(server)])) |
| 979 | .await |
| 980 | }); |
| 981 | |
| 982 | let client = new_engine_client_test(Some(client)).await; |
| 983 | |
| 984 | let should_shutdown = Arc::new(AtomicBool::new(false)); |
| 985 | let is_connected_to_gtw = Arc::new(AtomicBool::new(false)); |
| 986 | let task = EngineTaskTest::new(); |
| 987 | let task_is_running = task.is_running.clone(); |
| 988 | let task_cancel = task.should_shutdown.clone(); |
| 989 | |
| 990 | let mk_engine_task = move |_, _: &_, _: &_, _, _, _| { |
| 991 | let task: Arc<dyn Task> = Arc::new(task.clone()); |
| 992 | Ok::<_, Box<EngineEvent>>(task) |
| 993 | }; |
| 994 | |
| 995 | let task = TaskSelector::Environment; |
| 996 | let mut deployment_mngr = DeploymentManager::new( |
| 997 | &task, |
| 998 | client, |
| 999 | should_shutdown.clone(), |
| 1000 | is_connected_to_gtw.clone(), |
| 1001 | Box::new(mk_engine_task), |
| 1002 | Default::default(), |
| 1003 | DeploymentManagerRunMode::Daemon, |
nothing calls this directly
no test coverage detected