()
| 1458 | |
| 1459 | #[tokio::test] |
| 1460 | async fn test_resolve_proxy_ip() { |
| 1461 | use serde_json::json; |
| 1462 | |
| 1463 | let agent_network = "tsk-agent-test-task"; |
| 1464 | |
| 1465 | let mock_client = Arc::new(TrackedDockerClient { |
| 1466 | inspect_container_response: json!({ |
| 1467 | "State": { |
| 1468 | "Running": true |
| 1469 | }, |
| 1470 | "NetworkSettings": { |
| 1471 | "Networks": { |
| 1472 | agent_network: { |
| 1473 | "IPAddress": "172.18.0.2" |
| 1474 | } |
| 1475 | } |
| 1476 | } |
| 1477 | }) |
| 1478 | .to_string(), |
| 1479 | ..Default::default() |
| 1480 | }); |
| 1481 | let ctx = AppContext::builder().build(); |
| 1482 | |
| 1483 | let manager = ProxyManager::new(mock_client, ctx.tsk_env(), ContainerEngine::Docker, None); |
| 1484 | let result = manager |
| 1485 | .resolve_proxy_ip("tsk-proxy-test", agent_network) |
| 1486 | .await; |
| 1487 | |
| 1488 | assert!(result.is_ok()); |
| 1489 | assert_eq!(result.unwrap(), "172.18.0.2"); |
| 1490 | } |
| 1491 | |
| 1492 | #[tokio::test] |
| 1493 | async fn test_acquire_proxy_creates_network_and_connects() { |
nothing calls this directly
no test coverage detected