| ''' |
| Licensed to the Apache Software Foundation (ASF) under one |
| or more contributor license agreements. See the NOTICE file |
| distributed with this work for additional information |
| regarding copyright ownership. The ASF licenses this file |
| to you 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 os |
| import platform |
| from mock.mock import patch, MagicMock, call |
| from unittest import TestCase |
| from ambari_commons.exceptions import FatalException |
| |
| os.environ["ROOT"] = "" |
| |
| from only_for_platform import get_platform, not_for_platform, only_for_platform, os_distro_value, PLATFORM_LINUX, PLATFORM_WINDOWS |
| from ambari_commons import os_utils |
| |
| import shutil |
| project_dir = os.path.join(os.path.abspath(os.path.dirname(__file__)),os.path.normpath("../../../../")) |
| shutil.copyfile(project_dir+"/ambari-server/conf/unix/ambari.properties", "/tmp/ambari.properties") |
| |
| # We have to use this import HACK because the filename contains a dash |
| _search_file = os_utils.search_file |
| os_utils.search_file = MagicMock(return_value="/tmp/ambari.properties") |
| with patch.object(platform, "linux_distribution", return_value = MagicMock(return_value=('Redhat', '6.4', 'Final'))): |
| with patch("os.path.isdir", return_value = MagicMock(return_value=True)): |
| with patch("os.access", return_value = MagicMock(return_value=True)): |
| with patch.object(os_utils, "parse_log4j_file", return_value={'ambari.log.dir': '/var/log/ambari-server'}): |
| with patch("platform.linux_distribution", return_value = os_distro_value): |
| with patch("os.symlink"): |
| with patch.object(os_utils, "is_service_exist", return_value = True): |
| with patch("glob.glob", return_value = ['/etc/init.d/postgresql-9.3']): |
| _ambari_server_ = __import__('ambari-server') |
| os_utils.search_file = _search_file |
| with patch("__builtin__.open"): |
| from ambari_commons.exceptions import FatalException, NonFatalException |
| from ambari_server import serverConfiguration |
| serverConfiguration.search_file = _search_file |
| |
| from ambari_server.setupMpacks import install_mpack, upgrade_mpack, replay_mpack_logs, \ |
| purge_stacks_and_mpacks, validate_purge, read_mpack_metadata, _uninstall_mpack, \ |
| STACK_DEFINITIONS_RESOURCE_NAME, EXTENSION_DEFINITIONS_RESOURCE_NAME, \ |
| SERVICE_DEFINITIONS_RESOURCE_NAME, MPACKS_RESOURCE_NAME, GRAFANA_DASHBOARDS_DIRNAME, \ |
| DASHBOARDS_DIRNAME, SERVICE_METRICS_DIRNAME |
| |
| with patch.object(os, "geteuid", new=MagicMock(return_value=0)): |
| from resource_management.core import sudo |
| reload(sudo) |
| |
| def get_configs(): |
| test_directory = os.path.dirname(os.path.abspath(__file__)) |
| mpacks_directory = os.path.join(test_directory, "mpacks") |
| configs = { |
| serverConfiguration.STACK_LOCATION_KEY : "/var/lib/ambari-server/resources/stacks", |
| serverConfiguration.COMMON_SERVICES_PATH_PROPERTY : "/var/lib/ambari-server/resources/common-services", |
| serverConfiguration.EXTENSION_PATH_PROPERTY : "/var/lib/ambari-server/resources/extensions", |
| serverConfiguration.RESOURCES_DIR_PROPERTY : "/var/lib/ambari-server/resources", |
| serverConfiguration.MPACKS_STAGING_PATH_PROPERTY : mpacks_directory, |
| serverConfiguration.SERVER_TMP_DIR_PROPERTY : "/tmp", |
| serverConfiguration.JDBC_DATABASE_PROPERTY: "postgres" |
| } |
| return configs |
| |
| configs = get_configs() |
| |
| |
| class TestMpacks(TestCase): |
| |
| def test_install_mpack_with_no_mpack_path(self): |
| options = self._create_empty_options_mock() |
| fail = False |
| try: |
| install_mpack(options) |
| except FatalException as e: |
| self.assertEquals("Management pack not specified!", e.reason) |
| fail = True |
| self.assertTrue(fail) |
| |
| @patch("ambari_server.setupMpacks.download_mpack") |
| def test_install_mpack_with_invalid_mpack_path(self, download_mpack_mock): |
| options = self._create_empty_options_mock() |
| options.mpack_path = "/invalid_path/mpack.tar.gz" |
| download_mpack_mock.return_value = None |
| |
| fail = False |
| try: |
| install_mpack(options) |
| except FatalException as e: |
| self.assertEquals("Management pack could not be downloaded!", e.reason) |
| fail = True |
| self.assertTrue(fail) |
| |
| @patch("os.path.exists") |
| @patch("ambari_server.setupMpacks.get_YN_input") |
| @patch("ambari_server.setupMpacks.run_mpack_install_checker") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| def test_validate_purge(self, get_ambari_properties_mock, run_mpack_install_checker_mock, get_YN_input_mock, os_path_exists_mock): |
| options = self._create_empty_options_mock() |
| options.purge = True |
| purge_list = options.purge_list.split(',') |
| mpack_staging_dir = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| mpack_dir = os.path.join(mpack_staging_dir, "mystack-ambari-mpack-1.0.0.0") |
| mpack_metadata = read_mpack_metadata(mpack_dir) |
| replay_mode = False |
| run_mpack_install_checker_mock.return_value = (0, "No errors found", "") |
| get_YN_input_mock.return_value = True |
| os_path_exists_mock.return_value = True |
| |
| fail = False |
| try: |
| validate_purge(options, purge_list, mpack_dir, mpack_metadata, replay_mode) |
| except FatalException as e: |
| # Unexpected failure |
| fail = True |
| self.assertFalse(fail) |
| |
| get_YN_input_mock.return_value = False |
| fail = False |
| try: |
| validate_purge(options, purge_list, mpack_dir, mpack_metadata, replay_mode) |
| except FatalException as e: |
| # Expected failure |
| fail = True |
| self.assertTrue(fail) |
| |
| get_YN_input_mock.return_value = True |
| fail = False |
| run_mpack_install_checker_mock.return_value = (1, "", "Mpack installation checker failed!") |
| try: |
| validate_purge(options, purge_list, mpack_dir, mpack_metadata, replay_mode) |
| except FatalException as e: |
| # Expected failure |
| fail = True |
| self.assertTrue(fail) |
| |
| fail = False |
| mpack_dir = os.path.join(mpack_staging_dir, "myservice-ambari-mpack-1.0.0.0") |
| mpack_metadata = read_mpack_metadata(mpack_dir) |
| run_mpack_install_checker_mock.return_value = (0, "No errors found", "") |
| try: |
| validate_purge(options, purge_list, mpack_dir, mpack_metadata, replay_mode) |
| except FatalException as e: |
| # Expected failure |
| fail = True |
| self.assertTrue(fail) |
| |
| @patch("os.path.exists") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| def test_purge_stacks_and_mpacks(self, get_ambari_version_mock, os_path_exists_mock): |
| options = self._create_empty_options_mock() |
| get_ambari_version_mock.return_value = configs |
| stacks_directory = configs[serverConfiguration.STACK_LOCATION_KEY] |
| extensions_directory = configs[serverConfiguration.EXTENSION_PATH_PROPERTY] |
| common_services_directory = configs[serverConfiguration.COMMON_SERVICES_PATH_PROPERTY] |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| os_path_exists_mock.side_effect = [True] |
| |
| purge_stacks_and_mpacks(None) |
| os_path_exists_calls = [ |
| call('/var/lib/ambari-server/resources'), |
| ] |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| |
| os_path_exists_mock.side_effect = [True, False, False] |
| purge_stacks_and_mpacks(options.purge_list.split(",")) |
| os_path_exists_calls = [ |
| call('/var/lib/ambari-server/resources'), |
| call(stacks_directory), |
| call(mpacks_directory) |
| ] |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| |
| options.purge_list = ",".join([STACK_DEFINITIONS_RESOURCE_NAME, SERVICE_DEFINITIONS_RESOURCE_NAME, MPACKS_RESOURCE_NAME]) |
| os_path_exists_mock.side_effect = [True, False, False, False] |
| purge_stacks_and_mpacks(options.purge_list.split(",")) |
| os_path_exists_calls = [ |
| call('/var/lib/ambari-server/resources'), |
| call(stacks_directory), |
| call(common_services_directory), |
| call(mpacks_directory) |
| ] |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| |
| options.purge_list = ",".join([STACK_DEFINITIONS_RESOURCE_NAME, EXTENSION_DEFINITIONS_RESOURCE_NAME, MPACKS_RESOURCE_NAME]) |
| os_path_exists_mock.side_effect = [True, False, False, False] |
| purge_stacks_and_mpacks(options.purge_list.split(",")) |
| os_path_exists_calls = [ |
| call('/var/lib/ambari-server/resources'), |
| call(stacks_directory), |
| call(extensions_directory), |
| call(mpacks_directory) |
| ] |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| |
| options.purge_list = ",".join([STACK_DEFINITIONS_RESOURCE_NAME, SERVICE_DEFINITIONS_RESOURCE_NAME, MPACKS_RESOURCE_NAME]) |
| options.replay_mode = True |
| os_path_exists_mock.side_effect = [True, False, False, False] |
| purge_stacks_and_mpacks(options.purge_list.split(",")) |
| os_path_exists_calls = [ |
| call('/var/lib/ambari-server/resources'), |
| call(stacks_directory), |
| call(common_services_directory), |
| call(mpacks_directory) |
| ] |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| |
| @patch("os.path.exists") |
| @patch("ambari_server.setupMpacks.untar_archive") |
| @patch("ambari_server.setupMpacks.get_archive_root_dir") |
| @patch("ambari_server.setupMpacks.download_mpack") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| def test_install_mpack_with_malformed_mpack(self, get_ambari_properties_mock, download_mpack_mock, get_archive_root_dir_mock, untar_archive_mock, os_path_exists_mock): |
| options = self._create_empty_options_mock() |
| options.mpack_path = "/path/to/mpack.tar.gz" |
| download_mpack_mock.return_value = "/tmp/mpack.tar.gz" |
| get_ambari_properties_mock.return_value = configs |
| os_path_exists_mock.return_value = True |
| get_archive_root_dir_mock.return_value = None |
| |
| fail = False |
| try: |
| install_mpack(options) |
| except FatalException as e: |
| self.assertEquals("Malformed management pack. Root directory missing!", e.reason) |
| fail = True |
| self.assertTrue(fail) |
| |
| get_archive_root_dir_mock.return_value = "mpack" |
| os_path_exists_mock.side_effect = [True, True, False, False] |
| untar_archive_mock.return_value = None |
| fail = False |
| try: |
| install_mpack(options) |
| except FatalException as e: |
| self.assertEquals("Malformed management pack. Failed to expand management pack!", e.reason) |
| fail = True |
| self.assertTrue(fail) |
| |
| get_archive_root_dir_mock.return_value = "mpack" |
| os_path_exists_mock.side_effect = [True, True, False, True, False] |
| untar_archive_mock.return_value = None |
| fail = False |
| try: |
| install_mpack(options) |
| except FatalException as e: |
| self.assertEquals("Malformed management pack {0}. Metadata file missing!".format(options.mpack_path), e.reason) |
| fail = True |
| self.assertTrue(fail) |
| |
| @patch("os.path.exists") |
| @patch("shutil.move") |
| @patch("os.mkdir") |
| @patch("ambari_server.setupMpacks.read_ambari_user") |
| @patch("ambari_server.setupMpacks.create_symlink") |
| @patch("ambari_server.setupMpacks.get_ambari_version") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| @patch("ambari_server.setupMpacks.add_replay_log") |
| @patch("ambari_server.setupMpacks.purge_stacks_and_mpacks") |
| @patch("ambari_server.setupMpacks.expand_mpack") |
| @patch("ambari_server.setupMpacks.download_mpack") |
| @patch("ambari_server.setupMpacks.run_os_command") |
| @patch("ambari_server.setupMpacks.validate_purge") |
| @patch("ambari_server.setupMpacks.set_file_permissions") |
| def test_install_stack_mpack(self, set_file_permissions_mock, validate_purge_mock, run_os_command_mock, download_mpack_mock, expand_mpack_mock, purge_stacks_and_mpacks_mock, |
| add_replay_log_mock, get_ambari_properties_mock, get_ambari_version_mock, |
| create_symlink_mock, read_ambari_user_mock, os_mkdir_mock, shutil_move_mock, os_path_exists_mock): |
| options = self._create_empty_options_mock() |
| options.mpack_path = "/path/to/mystack.tar.gz" |
| options.purge = True |
| download_mpack_mock.return_value = "/tmp/mystack.tar.gz" |
| expand_mpack_mock.return_value = "mpacks/mystack-ambari-mpack-1.0.0.0" |
| get_ambari_version_mock.return_value = "2.4.0.0" |
| run_os_command_mock.return_value = (0, "", "") |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| |
| os_path_exists_calls = [call('/tmp/mystack.tar.gz'), |
| call('mpacks/mystack-ambari-mpack-1.0.0.0/mpack.json'), |
| call('mpacks/mystack-ambari-mpack-1.0.0.0/hooks/before_install.py'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks'), |
| call('/var/lib/ambari-server/resources/extensions'), |
| call('/var/lib/ambari-server/resources/common-services'), |
| call(mpacks_directory), |
| call(mpacks_directory + '/cache'), |
| call('/var/lib/ambari-server/resources/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/common-services/SERVICEA'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/common-services/SERVICEA/1.0/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/common-services/SERVICEA/2.0/dashboards'), |
| call('/var/lib/ambari-server/resources/common-services/SERVICEB'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/common-services/SERVICEB/1.0.0/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/common-services/SERVICEB/2.0.0/dashboards'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/stacks/MYSTACK/1.0/services/SERVICEA/dashboards'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.1'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.1/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/stacks/MYSTACK/1.1/services/SERVICEA/dashboards'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/2.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/2.0/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/stacks/MYSTACK/2.0/services/SERVICEA/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/stacks/MYSTACK/2.0/services/SERVICEB/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/hooks/after_install.py')] |
| |
| os_path_exists_mock.side_effect = [True, True, True, True, False, True, False, False, False, False, |
| False, True, False, False, False, False, False, False, True, False, |
| False, False, False, False, False, False, False, False, False, False, |
| True] |
| get_ambari_properties_mock.return_value = configs |
| shutil_move_mock.return_value = True |
| |
| try: |
| install_mpack(options) |
| except Exception as e: |
| print e |
| |
| stacks_directory = configs[serverConfiguration.STACK_LOCATION_KEY] |
| common_services_directory = configs[serverConfiguration.COMMON_SERVICES_PATH_PROPERTY] |
| extensions_directory = configs[serverConfiguration.EXTENSION_PATH_PROPERTY] |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| mpacks_staging_directory = os.path.join(mpacks_directory, "mystack-ambari-mpack-1.0.0.0") |
| resources_directory = configs[serverConfiguration.RESOURCES_DIR_PROPERTY] |
| dashboards_directory = os.path.join(resources_directory, "dashboards") |
| |
| run_os_command_calls = [ |
| call([ |
| "/usr/bin/ambari-python-wrap", |
| "mpacks/mystack-ambari-mpack-1.0.0.0/hooks/before_install.py" |
| ]), |
| call([ |
| "/usr/bin/ambari-python-wrap", |
| mpacks_directory + "/mystack-ambari-mpack-1.0.0.0/hooks/after_install.py" |
| ]) |
| ] |
| |
| os_mkdir_calls = [ |
| call(stacks_directory), |
| call(common_services_directory), |
| call(mpacks_directory), |
| call(mpacks_directory + '/cache'), |
| call(dashboards_directory), |
| call(os.path.join(dashboards_directory, GRAFANA_DASHBOARDS_DIRNAME)), |
| call(os.path.join(dashboards_directory, SERVICE_METRICS_DIRNAME)), |
| call(os.path.join(common_services_directory, "SERVICEA")), |
| call(os.path.join(common_services_directory, "SERVICEB")), |
| call(os.path.join(stacks_directory, "MYSTACK")), |
| call(os.path.join(stacks_directory, "MYSTACK/1.0")), |
| call(os.path.join(stacks_directory, "MYSTACK/1.0/services")), |
| call(os.path.join(stacks_directory, "MYSTACK/1.1")), |
| call(os.path.join(stacks_directory, "MYSTACK/1.1/services")), |
| call(os.path.join(stacks_directory, "MYSTACK/2.0")), |
| call(os.path.join(stacks_directory, "MYSTACK/2.0/services")) |
| ] |
| create_symlink_calls = [ |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEA"), |
| os.path.join(common_services_directory, "SERVICEA"), |
| "1.0", None), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEA"), |
| os.path.join(common_services_directory, "SERVICEA"), |
| "2.0", None), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEB"), |
| os.path.join(common_services_directory, "SERVICEB"), |
| "1.0.0", None), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEB"), |
| os.path.join(common_services_directory, "SERVICEB"), |
| "2.0.0", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.0"), |
| os.path.join(stacks_directory, "MYSTACK/1.0"), |
| "metainfo.xml", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/1.0/services"), |
| "SERVICEA", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.1"), |
| os.path.join(stacks_directory, "MYSTACK/1.1"), |
| "metainfo.xml", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.1/services"), |
| os.path.join(stacks_directory, "MYSTACK/1.1/services"), |
| "SERVICEA", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/2.0"), |
| os.path.join(stacks_directory, "MYSTACK/2.0"), |
| "metainfo.xml", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/2.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/2.0/services"), |
| "SERVICEA", None), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/2.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/2.0/services"), |
| "SERVICEB", None) |
| ] |
| |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| self.assertTrue(purge_stacks_and_mpacks_mock.called) |
| run_os_command_mock.assert_has_calls(run_os_command_calls) |
| os_mkdir_mock.assert_has_calls(os_mkdir_calls) |
| create_symlink_mock.assert_has_calls(create_symlink_calls) |
| self.assertTrue(add_replay_log_mock.called) |
| |
| @patch("os.path.exists") |
| @patch("shutil.move") |
| @patch("os.mkdir") |
| @patch("ambari_server.setupMpacks.read_ambari_user") |
| @patch("ambari_server.setupMpacks.create_symlink") |
| @patch("ambari_server.setupMpacks.get_ambari_version") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| @patch("ambari_server.setupMpacks.purge_stacks_and_mpacks") |
| @patch("ambari_server.setupMpacks.add_replay_log") |
| @patch("ambari_server.setupMpacks.expand_mpack") |
| @patch("ambari_server.setupMpacks.download_mpack") |
| @patch("ambari_server.setupMpacks.set_file_permissions") |
| |
| def test_install_extension_mpack(self, set_file_permissions_mock, download_mpack_mock, expand_mpack_mock, add_replay_log_mock, |
| purge_stacks_and_mpacks_mock, get_ambari_properties_mock, get_ambari_version_mock, |
| create_symlink_mock, read_ambari_user_mock, os_mkdir_mock, shutil_move_mock, os_path_exists_mock): |
| options = self._create_empty_options_mock() |
| options.mpack_path = "/path/to/myextension.tar.gz" |
| options.purge = False |
| download_mpack_mock.return_value = "/tmp/myextension.tar.gz" |
| expand_mpack_mock.return_value = "mpacks/myextension-ambari-mpack-1.0.0.0" |
| get_ambari_version_mock.return_value = "2.4.0.0" |
| |
| os_path_exists_mock.side_effect = [True, True, True, True, False, True, False, False, False, |
| False, True, True, False, False, False] |
| get_ambari_properties_mock.return_value = configs |
| shutil_move_mock.return_value = True |
| |
| install_mpack(options) |
| |
| extensions_directory = configs[serverConfiguration.EXTENSION_PATH_PROPERTY] |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| mpacks_staging_directory = os.path.join(mpacks_directory, "myextension-ambari-mpack-1.0.0.0") |
| resources_directory = configs[serverConfiguration.RESOURCES_DIR_PROPERTY] |
| dashboards_directory = os.path.join(resources_directory, "dashboards") |
| |
| os_path_exists_calls = [call('/tmp/myextension.tar.gz'), |
| call('mpacks/myextension-ambari-mpack-1.0.0.0/mpack.json'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks'), |
| call('/var/lib/ambari-server/resources/extensions'), |
| call('/var/lib/ambari-server/resources/common-services'), |
| call(mpacks_directory), |
| call(mpacks_directory + '/cache'), |
| call('/var/lib/ambari-server/resources/dashboards'), |
| call(mpacks_directory + '/myextension-ambari-mpack-1.0.0.0'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/extensions'), |
| call('/var/lib/ambari-server/resources/extensions/MYEXTENSION'), |
| call(mpacks_directory + '/myextension-ambari-mpack-1.0.0.0/extensions/MYEXTENSION/1.0/services'), |
| call(mpacks_directory + '/myextension-ambari-mpack-1.0.0.0/extensions/MYEXTENSION/1.1/services')] |
| |
| os_mkdir_calls = [ |
| call(extensions_directory), |
| call(mpacks_directory), |
| call(mpacks_directory + '/cache'), |
| call(dashboards_directory), |
| call(os.path.join(dashboards_directory, GRAFANA_DASHBOARDS_DIRNAME)), |
| call(os.path.join(dashboards_directory, SERVICE_METRICS_DIRNAME)), |
| call(os.path.join(extensions_directory, "MYEXTENSION")) |
| ] |
| create_symlink_calls = [ |
| call(os.path.join(mpacks_staging_directory, "extensions/MYEXTENSION"), |
| os.path.join(extensions_directory, "MYEXTENSION"), |
| "1.0", None), |
| call(os.path.join(mpacks_staging_directory, "extensions/MYEXTENSION"), |
| os.path.join(extensions_directory, "MYEXTENSION"), |
| "1.1", None) |
| ] |
| |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| self.assertFalse(purge_stacks_and_mpacks_mock.called) |
| os_mkdir_mock.assert_has_calls(os_mkdir_calls) |
| create_symlink_mock.assert_has_calls(create_symlink_calls) |
| self.assertTrue(add_replay_log_mock.called) |
| |
| @patch("os.path.exists") |
| @patch("os.path.isdir") |
| @patch("os.symlink") |
| @patch("shutil.move") |
| @patch("os.mkdir") |
| @patch("ambari_server.setupMpacks.read_ambari_user") |
| @patch("ambari_server.setupMpacks.create_symlink") |
| @patch("ambari_server.setupMpacks.get_ambari_version") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| @patch("ambari_server.setupMpacks.add_replay_log") |
| @patch("ambari_server.setupMpacks.purge_stacks_and_mpacks") |
| @patch("ambari_server.setupMpacks.expand_mpack") |
| @patch("ambari_server.setupMpacks.download_mpack") |
| @patch("ambari_server.setupMpacks.set_file_permissions") |
| def test_install_addon_service_mpack(self, set_file_permissions_mock, download_mpack_mock, expand_mpack_mock, purge_stacks_and_mpacks_mock, |
| add_replay_log_mock, get_ambari_properties_mock, get_ambari_version_mock, |
| create_symlink_mock, read_ambari_user_mock, os_mkdir_mock, shutil_move_mock,os_symlink_mock, |
| os_path_isdir_mock, os_path_exists_mock ): |
| options = self._create_empty_options_mock() |
| options.mpack_path = "/path/to/myservice.tar.gz" |
| options.purge = False |
| download_mpack_mock.return_value = "/tmp/myservice.tar.gz" |
| expand_mpack_mock.return_value = "mpacks/myservice-ambari-mpack-1.0.0.0" |
| get_ambari_version_mock.return_value = "2.4.0.0" |
| |
| os_path_exists_mock.side_effect = [True, True, True, True, True, True, True, |
| True, True, False, False, True, False, False, |
| True, True, True, True, False, True, True, |
| True, False] |
| |
| get_ambari_properties_mock.return_value = configs |
| shutil_move_mock.return_value = True |
| os_path_isdir_mock.return_value = True |
| |
| install_mpack(options) |
| |
| stacks_directory = configs[serverConfiguration.STACK_LOCATION_KEY] |
| common_services_directory = configs[serverConfiguration.COMMON_SERVICES_PATH_PROPERTY] |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| mpacks_staging_directory = os.path.join(mpacks_directory, "myservice-ambari-mpack-1.0.0.0") |
| resources_directory = configs[serverConfiguration.RESOURCES_DIR_PROPERTY] |
| dashboards_directory = os.path.join(resources_directory, "dashboards") |
| |
| os_path_exists_calls = [call('/tmp/myservice.tar.gz'), |
| call('mpacks/myservice-ambari-mpack-1.0.0.0/mpack.json'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks'), |
| call('/var/lib/ambari-server/resources/extensions'), |
| call('/var/lib/ambari-server/resources/common-services'), |
| call(mpacks_directory), |
| call(mpacks_directory + '/cache'), |
| call('/var/lib/ambari-server/resources/dashboards'), |
| call(mpacks_directory + '/myservice-ambari-mpack-1.0.0.0'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/common-services/MYSERVICE'), |
| call(mpacks_directory + '/myservice-ambari-mpack-1.0.0.0/common-services/MYSERVICE/1.0.0/dashboards'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0/services'), |
| call(mpacks_directory + '/myservice-ambari-mpack-1.0.0.0/custom-services/MYSERVICE/1.0.0/dashboards'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/2.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/2.0/services'), |
| call(mpacks_directory + '/myservice-ambari-mpack-1.0.0.0/custom-services/MYSERVICE/2.0.0/dashboards')] |
| |
| os_mkdir_calls = [ |
| call(dashboards_directory), |
| call(os.path.join(dashboards_directory, GRAFANA_DASHBOARDS_DIRNAME)), |
| call(os.path.join(dashboards_directory, SERVICE_METRICS_DIRNAME)), |
| call(os.path.join(common_services_directory, "MYSERVICE")) |
| ] |
| create_symlink_calls = [ |
| call(os.path.join(mpacks_staging_directory, "common-services/MYSERVICE"), |
| os.path.join(common_services_directory, "MYSERVICE"), "1.0.0", None) |
| ] |
| os_symlink_calls = [ |
| call(os.path.join(mpacks_staging_directory, "custom-services/MYSERVICE/1.0.0"), |
| os.path.join(stacks_directory, "MYSTACK/1.0/services/MYSERVICE")), |
| call(os.path.join(mpacks_staging_directory, "custom-services/MYSERVICE/2.0.0"), |
| os.path.join(stacks_directory, "MYSTACK/2.0/services/MYSERVICE")) |
| ] |
| |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| self.assertFalse(purge_stacks_and_mpacks_mock.called) |
| os_mkdir_mock.assert_has_calls(os_mkdir_calls) |
| create_symlink_mock.assert_has_calls(create_symlink_calls) |
| os_symlink_mock.assert_has_calls(os_symlink_calls) |
| self.assertTrue(add_replay_log_mock.called) |
| |
| @patch("ambari_server.setupMpacks.create_symlink_using_path") |
| @patch("os.path.exists") |
| @patch("shutil.move") |
| @patch("os.mkdir") |
| @patch("ambari_server.setupMpacks.read_ambari_user") |
| @patch("ambari_server.setupMpacks.create_symlink") |
| @patch("ambari_server.setupMpacks.get_ambari_version") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| @patch("ambari_server.setupMpacks.add_replay_log") |
| @patch("ambari_server.setupMpacks._uninstall_mpack") |
| @patch("ambari_server.setupMpacks.purge_stacks_and_mpacks") |
| @patch("ambari_server.setupMpacks.expand_mpack") |
| @patch("ambari_server.setupMpacks.download_mpack") |
| @patch("ambari_server.setupMpacks.run_os_command") |
| @patch("ambari_server.setupMpacks.set_file_permissions") |
| |
| def test_upgrade_stack_mpack(self, set_file_permissions_mock, run_os_command_mock, download_mpack_mock, expand_mpack_mock, purge_stacks_and_mpacks_mock, |
| _uninstall_mpack_mock, add_replay_log_mock, get_ambari_properties_mock, |
| get_ambari_version_mock, create_symlink_mock, read_ambari_user_mock, os_mkdir_mock, shutil_move_mock, |
| os_path_exists_mock, create_symlink_using_path_mock): |
| options = self._create_empty_options_mock() |
| options.mpack_path = "/path/to/mystack-1.0.0.1.tar.gz" |
| download_mpack_mock.side_effect = ["/tmp/mystack-1.0.0.1.tar.gz", "/tmp/mystack-1.0.0.1.tar.gz"] |
| expand_mpack_mock.side_effect = ["mpacks/mystack-ambari-mpack-1.0.0.1", "mpacks/mystack-ambari-mpack-1.0.0.1"] |
| get_ambari_version_mock.return_value = "2.4.0.0" |
| run_os_command_mock.return_value = (0, "", "") |
| |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| os_path_exists_mock.side_effect = [True, True, True, True, True, True, True, True, True, True, |
| True, True, True, True, True, True, True, False, False, True, |
| True, False, False, True, False, False, False, False, False, True, |
| True, True, True, False, True, True, False, True, True, False, |
| False, False, False, False, True, True, True, True, True, True, |
| True, False, True, False, True, True, True, True, True, True, |
| True] |
| |
| get_ambari_properties_mock.return_value = configs |
| shutil_move_mock.return_value = True |
| |
| upgrade_mpack(options) |
| |
| stacks_directory = configs[serverConfiguration.STACK_LOCATION_KEY] |
| common_services_directory = configs[serverConfiguration.COMMON_SERVICES_PATH_PROPERTY] |
| mpacks_directory = configs[serverConfiguration.MPACKS_STAGING_PATH_PROPERTY] |
| mpacks_staging_directory = os.path.join(mpacks_directory, "mystack-ambari-mpack-1.0.0.1") |
| resources_directory = configs[serverConfiguration.RESOURCES_DIR_PROPERTY] |
| dashboards_directory = os.path.join(resources_directory, "dashboards") |
| |
| os_path_exists_calls = [call('/tmp/mystack-1.0.0.1.tar.gz'), |
| call('mpacks/mystack-ambari-mpack-1.0.0.1/mpack.json'), |
| call('/var/lib/ambari-server/resources'), |
| call(mpacks_directory), |
| call(mpacks_directory + '/myextension-ambari-mpack-1.0.0.0/mpack.json'), |
| call(mpacks_directory + '/myservice-ambari-mpack-1.0.0.0/mpack.json'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/mpack.json'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/mpack.json'), |
| call('/tmp/mystack-1.0.0.1.tar.gz'), |
| call('mpacks/mystack-ambari-mpack-1.0.0.1/mpack.json'), |
| call('mpacks/mystack-ambari-mpack-1.0.0.1/hooks/before_upgrade.py'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks'), |
| call('/var/lib/ambari-server/resources/extensions'), |
| call('/var/lib/ambari-server/resources/common-services'), |
| call(mpacks_directory), |
| call(mpacks_directory + '/cache'), |
| call('/var/lib/ambari-server/resources/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/common-services/SERVICEA'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/common-services/SERVICEA/1.0/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/common-services/SERVICEA/2.0/dashboards'), |
| call('/var/lib/ambari-server/resources/common-services/SERVICEB'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/common-services/SERVICEB/1.0.0/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/common-services/SERVICEB/2.0.0/dashboards'), |
| call('/var/lib/ambari-server/resources/common-services/SERVICEC'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/common-services/SERVICEC/1.0.0/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/common-services/SERVICEC/2.0.0/dashboards'), |
| call('/var/lib/ambari-server/resources'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.0/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/1.0/services/SERVICEA/dashboards'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.1'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/1.1/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/1.1/services/SERVICEA/dashboards'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/2.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/2.0/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/2.0/services/SERVICEA/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/2.0/services/SERVICEB/dashboards'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/3.0'), |
| call('/var/lib/ambari-server/resources/stacks/MYSTACK/3.0/services'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEA/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEB/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEB/dashboards/grafana-dashboards'), |
| call('/var/lib/ambari-server/resources/dashboards/grafana-dashboards/SERVICEB'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEB/dashboards/service-metrics/SERVICEB.txt'), |
| call('/var/lib/ambari-server/resources/dashboards/service-metrics/SERVICEB.txt'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEC/dashboards'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEC/dashboards/grafana-dashboards'), |
| call('/var/lib/ambari-server/resources/dashboards/grafana-dashboards/SERVICEC'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/stacks/MYSTACK/3.0/services/SERVICEC/dashboards/service-metrics/SERVICEC.txt'), |
| call('/var/lib/ambari-server/resources/dashboards/service-metrics/SERVICEC.txt'), |
| call('/var/lib/ambari-server/resources'), |
| call(mpacks_directory), |
| call(mpacks_directory + '/myextension-ambari-mpack-1.0.0.0/mpack.json'), |
| call(mpacks_directory + '/myservice-ambari-mpack-1.0.0.0/mpack.json'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.0/mpack.json'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/mpack.json'), |
| call(mpacks_directory + '/mystack-ambari-mpack-1.0.0.1/hooks/after_upgrade.py')] |
| |
| run_os_command_calls = [ |
| call([ |
| "/usr/bin/ambari-python-wrap", |
| "mpacks/mystack-ambari-mpack-1.0.0.1/hooks/before_upgrade.py" |
| ]), |
| call([ |
| "/usr/bin/ambari-python-wrap", |
| mpacks_directory + "/mystack-ambari-mpack-1.0.0.1/hooks/after_upgrade.py" |
| ]) |
| ] |
| |
| os_mkdir_calls = [ |
| call(dashboards_directory), |
| call(os.path.join(dashboards_directory, GRAFANA_DASHBOARDS_DIRNAME)), |
| call(os.path.join(dashboards_directory, SERVICE_METRICS_DIRNAME)), |
| call(os.path.join(common_services_directory, "SERVICEC")), |
| call(os.path.join(stacks_directory, "MYSTACK/3.0")), |
| call(os.path.join(stacks_directory, "MYSTACK/3.0/services")) |
| ] |
| create_symlink_calls = [ |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEA"), |
| os.path.join(common_services_directory, "SERVICEA"), |
| "1.0", True), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEA"), |
| os.path.join(common_services_directory, "SERVICEA"), |
| "2.0", True), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEB"), |
| os.path.join(common_services_directory, "SERVICEB"), |
| "1.0.0", True), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEB"), |
| os.path.join(common_services_directory, "SERVICEB"), |
| "2.0.0", True), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEC"), |
| os.path.join(common_services_directory, "SERVICEC"), |
| "1.0.0", True), |
| call(os.path.join(mpacks_staging_directory, "common-services/SERVICEC"), |
| os.path.join(common_services_directory, "SERVICEC"), |
| "2.0.0", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.0"), |
| os.path.join(stacks_directory, "MYSTACK/1.0"), |
| "metainfo.xml", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/1.0/services"), |
| "SERVICEA", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.1"), |
| os.path.join(stacks_directory, "MYSTACK/1.1"), |
| "metainfo.xml", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/1.1/services"), |
| os.path.join(stacks_directory, "MYSTACK/1.1/services"), |
| "SERVICEA", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/2.0"), |
| os.path.join(stacks_directory, "MYSTACK/2.0"), |
| "metainfo.xml", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/2.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/2.0/services"), |
| "SERVICEA", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/2.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/2.0/services"), |
| "SERVICEB", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/3.0"), |
| os.path.join(stacks_directory, "MYSTACK/3.0"), |
| "metainfo.xml", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/3.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/3.0/services"), |
| "SERVICEA", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/3.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/3.0/services"), |
| "SERVICEB", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/3.0/services"), |
| os.path.join(stacks_directory, "MYSTACK/3.0/services"), |
| "SERVICEC", True), |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/3.0/services/SERVICEC/dashboards/service-metrics"), |
| os.path.join(dashboards_directory, "service-metrics"), |
| "SERVICEC.txt", True) |
| ] |
| |
| create_symlink_using_path_calls = [ |
| call(os.path.join(mpacks_staging_directory, "stacks/MYSTACK/3.0/services/SERVICEC/dashboards/grafana-dashboards"), |
| os.path.join(dashboards_directory, "grafana-dashboards/SERVICEC"), True) |
| ] |
| |
| os_path_exists_mock.assert_has_calls(os_path_exists_calls) |
| self.assertFalse(purge_stacks_and_mpacks_mock.called) |
| run_os_command_mock.assert_has_calls(run_os_command_calls) |
| os_mkdir_mock.assert_has_calls(os_mkdir_calls) |
| create_symlink_mock.assert_has_calls(create_symlink_calls) |
| self.assertEqual(18, create_symlink_mock.call_count) |
| create_symlink_using_path_mock.assert_has_calls(create_symlink_using_path_calls) |
| self.assertEqual(1, create_symlink_using_path_mock.call_count) |
| _uninstall_mpack_mock.assert_has_calls([call("mystack-ambari-mpack", "1.0.0.0")]) |
| self.assertTrue(add_replay_log_mock.called) |
| |
| |
| @patch("os.path.exists") |
| @patch("ambari_server.setupMpacks.get_replay_log_file") |
| @patch("ambari_server.setupMpacks.upgrade_mpack") |
| @patch("ambari_server.setupMpacks.install_mpack") |
| def test_replay_mpack_logs(self, install_mpack_mock, upgrade_mpack_mock, get_replay_log_file_mock, os_path_exists_mock): |
| test_directory = os.path.dirname(os.path.abspath(__file__)) |
| resources_directory = os.path.join(test_directory, os.pardir, "resources") |
| get_replay_log_file_mock.return_value = os.path.join(resources_directory, "mpacks_replay.log") |
| os_path_exists_mock.return_value = True |
| |
| replay_mpack_logs() |
| |
| install_replay_options = { |
| 'purge' : True, |
| 'mpack_command' : 'install-mpack', |
| 'mpack_path': '/var/lib/ambari-server/resources/mpacks/cache/hdp-1.0.0.0.tar.gz', |
| 'force': False, |
| 'verbose': True |
| } |
| |
| upgrade_replay_options = { |
| 'purge' : False, |
| 'mpack_command' : 'upgrade-mpack', |
| 'mpack_path': '/var/lib/ambari-server/resources/mpacks/cache/hdp-1.0.0.1.tar.gz', |
| 'force': True, |
| 'verbose': True |
| } |
| |
| install_mpack_mock.assert_has_calls([call(install_replay_options, replay_mode=True)]) |
| upgrade_mpack_mock.assert_has_calls([call(upgrade_replay_options, replay_mode=True)]) |
| |
| @patch("resource_management.core.sudo.unlink") |
| @patch("resource_management.core.sudo.rmtree") |
| @patch("ambari_server.setupMpacks.get_ambari_version") |
| @patch("ambari_server.setupMpacks.get_ambari_properties") |
| def test_uninstall_mpack(self, get_ambari_properties_mock, get_ambari_version_mock, sudo_rmtree_mock, sudo_unlink_mock): |
| test_directory = os.path.dirname(os.path.abspath(__file__)) |
| mpacks_directory = os.path.join(test_directory, "mpacks") |
| uninstall_directory = os.path.join(test_directory, "uninstall") |
| fake_configs = { |
| serverConfiguration.STACK_LOCATION_KEY : os.path.join(uninstall_directory, "stacks"), |
| serverConfiguration.COMMON_SERVICES_PATH_PROPERTY : os.path.join(uninstall_directory, "common-services"), |
| serverConfiguration.EXTENSION_PATH_PROPERTY : os.path.join(uninstall_directory, "extensions"), |
| serverConfiguration.MPACKS_STAGING_PATH_PROPERTY : mpacks_directory, |
| serverConfiguration.RESOURCES_DIR_PROPERTY : uninstall_directory, |
| serverConfiguration.SERVER_TMP_DIR_PROPERTY : "/tmp" |
| } |
| |
| get_ambari_version_mock.return_value = "2.4.0.0" |
| get_ambari_properties_mock.return_value = fake_configs |
| stacks_directory = fake_configs[serverConfiguration.STACK_LOCATION_KEY] |
| extension_directory = fake_configs[serverConfiguration.EXTENSION_PATH_PROPERTY] |
| common_services_directory = fake_configs[serverConfiguration.COMMON_SERVICES_PATH_PROPERTY] |
| resources_directory = fake_configs[serverConfiguration.RESOURCES_DIR_PROPERTY] |
| dashboards_directory = os.path.join(resources_directory, "dashboards") |
| |
| _uninstall_mpack("mystack-ambari-mpack", "1.0.0.1") |
| |
| self.assertEqual(1, sudo_rmtree_mock.call_count) |
| # self.assertEqual(6, sudo_unlink_mock.call_count) # ToDo: fix, as os.walk is not mocked |
| sudo_unlink_mock_calls = [call(os.path.join(stacks_directory, "2.0/SERVICEB")), |
| call(os.path.join(stacks_directory, "2.0/files/metainfo2.xml")), |
| call(os.path.join(extension_directory, "SERVICEB")), |
| call(os.path.join(common_services_directory, "SERVICEB")), |
| call(os.path.join(dashboards_directory, "SERVICEB")), |
| call(os.path.join(dashboards_directory, "files/STORM.txt"))] |
| |
| def _create_empty_options_mock(self): |
| options = MagicMock() |
| options.mpack_path = None |
| options.purge = None |
| options.purge_list = ",".join([STACK_DEFINITIONS_RESOURCE_NAME, MPACKS_RESOURCE_NAME]) |
| options.force = None |
| options.verbose = None |
| options.replay_mode = False |
| return options |
