"""Tests for the Opensearch connector."""

from unittest.mock import patch

from opensearchpy import RequestsHttpConnection


@patch("src.connectors.opensearch.OpenSearch", autospec=True)
def test_opensearch_get_client(mocked_os_client, monkeypatch):
    """Test opensearch client is created using expected configuration."""
    from src.connectors import opensearch

    os_client = mocked_os_client.return_value

    os_client_instance = opensearch.get_client()
    assert mocked_os_client.call_args
    call_kwargs = mocked_os_client.call_args[1]
    assert len(call_kwargs) == 5
    assert call_kwargs["hosts"][0]["host"] == "test-host"
    assert call_kwargs["hosts"][0]["port"] == 443
    assert call_kwargs["use_ssl"]
    assert call_kwargs["hosts"][0]["timeout"] == 60
    assert call_kwargs["connection_class"] is RequestsHttpConnection
    assert call_kwargs["http_auth"] == ("testuser", "testpass")
    assert os_client_instance is os_client