diff options
Diffstat (limited to 'ironic/tests/unit/drivers/test_agent_client.py')
| -rw-r--r-- | ironic/tests/unit/drivers/test_agent_client.py | 220 |
1 files changed, 220 insertions, 0 deletions
diff --git a/ironic/tests/unit/drivers/test_agent_client.py b/ironic/tests/unit/drivers/test_agent_client.py new file mode 100644 index 000000000..223844882 --- /dev/null +++ b/ironic/tests/unit/drivers/test_agent_client.py @@ -0,0 +1,220 @@ +# Copyright 2014 Rackspace, Inc. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# 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. + +import json + +import mock +import requests +import six + +from ironic.common import exception +from ironic.drivers.modules import agent_client +from ironic.tests.unit import base + + +class MockResponse(object): + status_code = 200 + + def __init__(self, text): + assert isinstance(text, six.string_types) + self.text = text + + def json(self): + return json.loads(self.text) + + +class MockNode(object): + def __init__(self): + self.uuid = 'uuid' + self.driver_info = {} + self.driver_internal_info = { + 'agent_url': "http://127.0.0.1:9999", + 'clean_version': {'generic': '1'} + } + self.instance_info = {} + + def as_dict(self): + return { + 'uuid': self.uuid, + 'driver_info': self.driver_info, + 'driver_internal_info': self.driver_internal_info, + 'instance_info': self.instance_info + } + + +class TestAgentClient(base.TestCase): + def setUp(self): + super(TestAgentClient, self).setUp() + self.client = agent_client.AgentClient() + self.client.session = mock.MagicMock(autospec=requests.Session) + self.node = MockNode() + + def test_content_type_header(self): + client = agent_client.AgentClient() + self.assertEqual('application/json', + client.session.headers['Content-Type']) + + def test__get_command_url(self): + command_url = self.client._get_command_url(self.node) + expected = self.node.driver_internal_info['agent_url'] + '/v1/commands' + self.assertEqual(expected, command_url) + + def test__get_command_url_fail(self): + del self.node.driver_internal_info['agent_url'] + self.assertRaises(exception.IronicException, + self.client._get_command_url, + self.node) + + def test__get_command_body(self): + expected = json.dumps({'name': 'prepare_image', 'params': {}}) + self.assertEqual(expected, + self.client._get_command_body('prepare_image', {})) + + def test__command(self): + response_data = {'status': 'ok'} + response_text = json.dumps(response_data) + self.client.session.post.return_value = MockResponse(response_text) + method = 'standby.run_image' + image_info = {'image_id': 'test_image'} + params = {'image_info': image_info} + + url = self.client._get_command_url(self.node) + body = self.client._get_command_body(method, params) + + response = self.client._command(self.node, method, params) + self.assertEqual(response, response_data) + self.client.session.post.assert_called_once_with( + url, + data=body, + params={'wait': 'false'}) + + def test__command_fail_json(self): + response_text = 'this be not json matey!' + self.client.session.post.return_value = MockResponse(response_text) + method = 'standby.run_image' + image_info = {'image_id': 'test_image'} + params = {'image_info': image_info} + + url = self.client._get_command_url(self.node) + body = self.client._get_command_body(method, params) + + self.assertRaises(exception.IronicException, + self.client._command, + self.node, method, params) + self.client.session.post.assert_called_once_with( + url, + data=body, + params={'wait': 'false'}) + + def test_get_commands_status(self): + with mock.patch.object(self.client.session, 'get', + autospec=True) as mock_get: + res = mock.MagicMock(spec_set=['json']) + res.json.return_value = {'commands': []} + mock_get.return_value = res + self.assertEqual([], self.client.get_commands_status(self.node)) + + @mock.patch('uuid.uuid4', mock.MagicMock(spec_set=[], return_value='uuid')) + def test_prepare_image(self): + self.client._command = mock.MagicMock(spec_set=[]) + image_info = {'image_id': 'image'} + params = {'image_info': image_info} + + self.client.prepare_image(self.node, + image_info, + wait=False) + self.client._command.assert_called_once_with( + node=self.node, method='standby.prepare_image', + params=params, wait=False) + + @mock.patch('uuid.uuid4', mock.MagicMock(spec_set=[], return_value='uuid')) + def test_prepare_image_with_configdrive(self): + self.client._command = mock.MagicMock(spec_set=[]) + configdrive_url = 'http://swift/configdrive' + self.node.instance_info['configdrive'] = configdrive_url + image_info = {'image_id': 'image'} + params = { + 'image_info': image_info, + 'configdrive': configdrive_url, + } + + self.client.prepare_image(self.node, + image_info, + wait=False) + self.client._command.assert_called_once_with( + node=self.node, method='standby.prepare_image', + params=params, wait=False) + + @mock.patch('uuid.uuid4', mock.MagicMock(spec_set=[], return_value='uuid')) + def test_start_iscsi_target(self): + self.client._command = mock.MagicMock(spec_set=[]) + iqn = 'fake-iqn' + params = {'iqn': iqn} + + self.client.start_iscsi_target(self.node, iqn) + self.client._command.assert_called_once_with( + node=self.node, method='iscsi.start_iscsi_target', + params=params, wait=True) + + @mock.patch('uuid.uuid4', mock.MagicMock(spec_set=[], return_value='uuid')) + def test_install_bootloader(self): + self.client._command = mock.MagicMock(spec_set=[]) + root_uuid = 'fake-root-uuid' + efi_system_part_uuid = 'fake-efi-system-part-uuid' + params = {'root_uuid': root_uuid, + 'efi_system_part_uuid': efi_system_part_uuid} + + self.client.install_bootloader( + self.node, root_uuid, efi_system_part_uuid=efi_system_part_uuid) + self.client._command.assert_called_once_with( + node=self.node, method='image.install_bootloader', params=params, + wait=True) + + def test_get_clean_steps(self): + self.client._command = mock.MagicMock(spec_set=[]) + ports = [] + expected_params = { + 'node': self.node.as_dict(), + 'ports': [] + } + + self.client.get_clean_steps(self.node, + ports) + self.client._command.assert_called_once_with( + node=self.node, method='clean.get_clean_steps', + params=expected_params, wait=True) + + def test_execute_clean_step(self): + self.client._command = mock.MagicMock(spec_set=[]) + ports = [] + step = {'priority': 10, 'step': 'erase_devices', 'interface': 'deploy'} + expected_params = { + 'step': step, + 'node': self.node.as_dict(), + 'ports': [], + 'clean_version': self.node.driver_internal_info.get( + 'hardware_manager_version') + } + self.client.execute_clean_step(step, + self.node, + ports) + self.client._command.assert_called_once_with( + node=self.node, method='clean.execute_clean_step', + params=expected_params, wait=False) + + def test_power_off(self): + self.client._command = mock.MagicMock(spec_set=[]) + self.client.power_off(self.node) + self.client._command.assert_called_once_with( + node=self.node, method='standby.power_off', params={}) |