"""Tests for EKSDescribeAddonTool (function-based, @tool decorated).""" from __future__ import annotations from unittest.mock import MagicMock, patch from botocore.exceptions import ClientError from integrations.eks.tools import describe_eks_addon from tests.tools.conftest import BaseToolContract, mock_agent_state class TestEKSDescribeAddonToolContract(BaseToolContract): def get_tool_under_test(self): return describe_eks_addon.__opensre_registered_tool__ def test_is_available_requires_cluster_name() -> None: rt = describe_eks_addon.__opensre_registered_tool__ assert rt.is_available({"eks": {"connection_verified": True, "cluster_name": "c1"}}) is True assert rt.is_available({"eks": {"connection_verified": True}}) is False assert rt.is_available({}) is False def test_extract_params_maps_fields() -> None: rt = describe_eks_addon.__opensre_registered_tool__ sources = mock_agent_state() params = rt.extract_params(sources) assert params["cluster_name"] == "my-cluster" def test_run_happy_path() -> None: mock_client = MagicMock() mock_client.describe_addon.return_value = { "status": "ACTIVE", "addonVersion": "v1.9.3-eksbuild.7", "health": {}, "marketplaceVersion": None, } with patch("integrations.eks.tools.EKSClient", return_value=mock_client): result = describe_eks_addon( cluster_name="c1", addon_name="coredns", role_arn="arn:aws:iam::123:role/r" ) assert result["available"] is True assert result["status"] == "ACTIVE" assert result["addon_name"] == "coredns" def test_run_handles_client_error() -> None: mock_client = MagicMock() error = ClientError( {"Error": {"Code": "NotFoundException", "Message": "Addon not found"}}, "DescribeAddon" ) mock_client.describe_addon.side_effect = error with patch("integrations.eks.tools.EKSClient", return_value=mock_client): result = describe_eks_addon( cluster_name="c1", addon_name="coredns", role_arn="arn:aws:iam::123:role/r" ) assert result["available"] is False assert "error" in result