()
| 1312 | |
| 1313 | #[tokio::test] |
| 1314 | async fn test_count_connected_agents() { |
| 1315 | use serde_json::json; |
| 1316 | |
| 1317 | let mock_client = Arc::new(TrackedDockerClient { |
| 1318 | inspect_container_response: json!({ |
| 1319 | "NetworkSettings": { |
| 1320 | "Networks": { |
| 1321 | "tsk-external": {}, |
| 1322 | "tsk-agent-task1": {}, |
| 1323 | "tsk-agent-task2": {}, |
| 1324 | "tsk-agent-task3": {} |
| 1325 | } |
| 1326 | } |
| 1327 | }) |
| 1328 | .to_string(), |
| 1329 | ..Default::default() |
| 1330 | }); |
| 1331 | |
| 1332 | let ctx = AppContext::builder().build(); |
| 1333 | |
| 1334 | let manager = ProxyManager::new(mock_client, ctx.tsk_env(), ContainerEngine::Docker, None); |
| 1335 | let result = manager.count_connected_agents("tsk-proxy-test").await; |
| 1336 | |
| 1337 | assert!(result.is_ok()); |
| 1338 | assert_eq!(result.unwrap(), 3); |
| 1339 | } |
| 1340 | |
| 1341 | #[tokio::test] |
| 1342 | async fn test_force_stop_proxy_no_agents() { |
nothing calls this directly
no test coverage detected