# Copyright 2025 Collate # Licensed under the Collate Community License, Version 1.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # https://github.com/open-metadata/OpenMetadata/blob/main/ingestion/LICENSE # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """Unit tests for REST API connection handling.""" from unittest.mock import MagicMock, patch from metadata.ingestion.connections.connection import BaseConnection from metadata.ingestion.source.api.rest.connection import RestConnection CONNECTION_MODULE = "metadata.ingestion.source.api.rest.connection" def test_rest_connection_is_base_connection(): assert issubclass(RestConnection, BaseConnection) def test_get_client_delegates_to_get_connection(): with patch(f"{CONNECTION_MODULE}.get_connection") as mock_get: conn = RestConnection(MagicMock()) client = conn.client assert client is mock_get.return_value mock_get.assert_called_once_with(conn.service_connection) def test_test_connection_runs_steps(): conn = RestConnection(MagicMock()) conn._client = MagicMock() with patch(f"{CONNECTION_MODULE}.test_connection_steps") as mock_step: result = conn.test_connection(metadata=MagicMock()) assert result is mock_step.return_value