From e0c46060ddc528b799adc1370f31da6488476fcb Mon Sep 17 00:00:00 2001 From: yanpliu Date: Thu, 7 Mar 2024 01:19:54 -0500 Subject: [PATCH] codecoverage bug2173870 --- robottelo/utils/virtwho.py | 72 ++++++++++++++++++ tests/foreman/virtwho/cli/test_esx_sca.py | 90 +++++++++++++++++++++++ 2 files changed, 162 insertions(+) diff --git a/robottelo/utils/virtwho.py b/robottelo/utils/virtwho.py index 5e0f3a4657a..27968c4d37a 100644 --- a/robottelo/utils/virtwho.py +++ b/robottelo/utils/virtwho.py @@ -473,6 +473,33 @@ def hypervisor_json_create(hypervisors, guests): return mapping +def hypervisor_fake_json_create(hypervisors, guests): + """ + Create a hypervisor guest json data for fake config usages. For example: + {'hypervisors': [{'uuid': '820b5143-3885-4dba-9358-4ce8c30d934e', + 'guests': [{'guestId': 'afb91b1f-8438-46f5-bc67-d7ab328ef782', 'state': 1, + 'attributes': {'active': 1, 'virtWhoType': 'esx'}}]}]} + :param hypervisors: how many hypervisors will be created + :param guests: how many guests will be created + """ + hypervisors_list = [] + for _ in range(hypervisors): + guest_list = [] + for _ in range(guests): + guest_list.append( + { + "guestId": str(uuid.uuid4()), + "state": 1, + "attributes": {"active": 1, "virtWhoType": "esx"}, + } + ) + name = str(uuid.uuid4()) + hypervisor = {"guests": guest_list, "name": name, "uuid": name} + hypervisors_list.append(hypervisor) + mapping = {"hypervisors": hypervisors_list} + return mapping + + def create_fake_hypervisor_content(org_label, hypervisors, guests): """ Post the fake hypervisor content to satellite server @@ -541,3 +568,48 @@ def get_configure_command_option(deploy_type, args, org=DEFAULT_ORG): return f"hammer -u {username} -p {password} virt-who-config deploy --id {args['id']} --organization-title '{args['organization-title']}' " elif deploy_type == 'name': return f"hammer -u {username} -p {password} virt-who-config deploy --name {args['name']} --organization '{org}' " + + +def vw_fake_conf_create( + owner, + rhsm_hostname, + rhsm_username, + rhsm_encrypted_password, + fake_conf_file, + json_file, + is_hypervisor=True, +): + conf_name = fake_conf_file.split("/")[-1].split(".")[0] + file = f'{fake_conf_file}\n' + title = f'[{conf_name}]\n' + type = 'type=fake\n' + json = f'file={json_file}\n' + is_hypervisor = f'is_hypervisor={is_hypervisor}\n' + owner = f'owner={owner}\n' + env = 'env = Library\n' + rhsm_hostname = f'rhsm_hostname={rhsm_hostname}\n' + rhsm_username = f'rhsm_username={rhsm_username}\n' + rhsm_encrypted_password = f'rhsm_encrypted_password={rhsm_encrypted_password}\n' + rhsm_prefix = 'rhsm_prefix=/rhsm\n' + rhsm_port = 'rhsm_port=443\n' + cmd = ('cat < {}' '{}' '{}' '{}' '{}' '{}' '{}' '{}' '{}' '{}' '{}' '{}' 'EOF').format( + file, + title, + type, + json, + is_hypervisor, + owner, + env, + rhsm_hostname, + rhsm_username, + rhsm_encrypted_password, + rhsm_prefix, + rhsm_port, + ) + runcmd(cmd) + + +def vw_run_option(option): + runcmd("systemctl stop virt-who") + runcmd("pkill -9 virt-who") + runcmd(f"virt-who -{option}") diff --git a/tests/foreman/virtwho/cli/test_esx_sca.py b/tests/foreman/virtwho/cli/test_esx_sca.py index 6b15b6803f9..9f3fabe2033 100644 --- a/tests/foreman/virtwho/cli/test_esx_sca.py +++ b/tests/foreman/virtwho/cli/test_esx_sca.py @@ -9,6 +9,8 @@ :Team: Phoenix """ +import json +from pathlib import Path import re from fauxfactory import gen_string @@ -18,14 +20,18 @@ from robottelo.config import settings from robottelo.utils.virtwho import ( ETC_VIRTWHO_CONFIG, + check_message_in_rhsm_log, create_http_proxy, deploy_configure_by_command, deploy_configure_by_command_check, get_configure_command, get_configure_file, get_configure_option, + hypervisor_fake_json_create, hypervisor_json_create, virtwho_package_locked, + vw_fake_conf_create, + vw_run_option, ) @@ -502,3 +508,87 @@ def test_positive_remove_env_option( env_warning = f"Ignoring unknown configuration option \"{option}\"" result = target_sat.execute(f'grep "{env_warning}" /var/log/messages') assert result.status == 1 + + @pytest.mark.tier2 + def test_positive_post_hypervisors_with_fake_different_org_simultaneous( + self, module_sca_manifest_org, form_data_cli, target_sat + ): + """create many fake conf files in two orgs with specific service account rhsm_username=virt_who_reporter_X post to satellite without task errors" + + :id: ee2ec178-01e0-48b9-8c2f-5c3279eef796 + + :expectedresults: + hypervisor/guest json can be posted and the task is success status + + :customerscenario: true + + :CaseImportance: Medium + + :BZ: 2173870 + """ + + # create 3 hypersiors and each have 3 guests json file + json_file = Path("/tmp/fake.json") + data = hypervisor_fake_json_create(hypervisors=1, guests=1) + json_file.write_text(json.dumps(data)) + # create 10 fake files in module_sca_manifest_org + virtwho_config_cli = target_sat.cli.VirtWhoConfig.create(form_data_cli)[ + 'general-information' + ] + command = get_configure_command(virtwho_config_cli['id'], module_sca_manifest_org.name) + deploy_configure_by_command( + command, form_data_cli['hypervisor-type'], org=module_sca_manifest_org.label + ) + config_file_1 = get_configure_file(virtwho_config_cli['id']) + owner_1 = get_configure_option('owner', config_file_1) + rhsm_hostname_1 = get_configure_option('rhsm_hostname', config_file_1) + rhsm_username_1 = get_configure_option('rhsm_username', config_file_1) + rhsm_encrypted_password_1 = get_configure_option('rhsm_encrypted_password', config_file_1) + # create another org and create fake conf files in this org + ORG_DATA = {'name': f'virtwho_fake_{gen_string("alpha")}'} + org = target_sat.api.Organization(name=ORG_DATA['name']).create() + target_sat.api.Location(organization=[org]).create() + form_data_cli['organization-id'] = org.id + virtwho_config_cli = target_sat.cli.VirtWhoConfig.create(form_data_cli)[ + 'general-information' + ] + command = get_configure_command(virtwho_config_cli['id'], org.name) + deploy_configure_by_command( + command, form_data_cli['hypervisor-type'], debug=True, org=org.label + ) + config_file_2 = get_configure_file(virtwho_config_cli['id']) + owner_2 = get_configure_option('owner', config_file_2) + rhsm_hostname_2 = get_configure_option('rhsm_hostname', config_file_2) + rhsm_username_2 = get_configure_option('rhsm_username', config_file_2) + rhsm_encrypted_password_2 = get_configure_option('rhsm_encrypted_password', config_file_2) + for i in range(5): + fake_conf_file = f"/etc/virt-who.d/virt-who-config-fake{i}.conf" + vw_fake_conf_create( + owner_1, + rhsm_hostname_1, + rhsm_username_1, + rhsm_encrypted_password_1, + fake_conf_file, + json_file, + ) + for i in range(5, 10): + fake_conf_file = f"/etc/virt-who.d/virt-who-config-fake{i}.conf" + vw_fake_conf_create( + owner_2, + rhsm_hostname_2, + rhsm_username_2, + rhsm_encrypted_password_2, + fake_conf_file, + json_file, + ) + vw_run_option("od") + for i in range(10): + fake_conf_file = f"/etc/virt-who.d/virt-who-config-fake{i}.conf" + conf_name = fake_conf_file.split("/")[-1].split(".")[0] + config_str = f'Using configuration "{conf_name}" ("fake" mode)' + check_message_in_rhsm_log(config_str) + check_message_in_rhsm_log(f"Host-to-guest mapping being sent to '{org}'") + task = target_sat.cli.Task.list_tasks({'search': 'label ~ Hyper'}) + for item in task: + assert "Job blocked by the following existing jobs" not in item['task-errors'] + assert "success" in item['result']