openstack/tacker
Code Issues Proposed changes

Merge "Fix db-migration-tool issues"

Browse Source
This commit is contained in:
Zuul
2024-03-05 09:53:57 +00:00
committed by Gerrit Code Review
parent b885f93d64 aa73583b50
commit a38c1736b6
2 changed files with 19 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
tacker/db/migration/migrate_to_v2.py
View File

@@ -55,6 +55,13 @@ def env(*_vars, **kwargs):
return kwargs.get('default', '') return kwargs.get('default', '')
DEFAULT_OPTS = [
cfg.BoolOpt('use_credential_encryption', default=False,
help=_("Enable to encrypt the credential"))
]
CONF.register_opts(DEFAULT_OPTS)
OPTS = [cfg.StrOpt('user_domain_id', OPTS = [cfg.StrOpt('user_domain_id',
default=env("OS_USER_DOMAIN_ID", default='default'), default=env("OS_USER_DOMAIN_ID", default='default'),
help='User Domain Id'), help='User Domain Id'),
@@ -264,7 +271,7 @@ def _to_vim_connection_info(vim_con_infos, vim_infos):
"accessInfo": _info.get("access_info"), "accessInfo": _info.get("access_info"),
"extra": _info.get("extra")} "extra": _info.get("extra")}
vim_info_obj = objects_v2.VimConnectionInfo(**fields) vim_info_obj = objects_v2.VimConnectionInfo(**fields)
dict_info["vim{}".format(i)] = vim_info_obj dict_info["vim_{}".format(i)] = vim_info_obj
return dict_info return dict_info
@@ -720,7 +727,7 @@ def _get_vim(context, vim_con_info):
def _set_stack_id(inst_v2, vnf): def _set_stack_id(inst_v2, vnf):
heat_client = heat_utils.HeatClient(inst_v2.vimConnectionInfo["vim0"]) heat_client = heat_utils.HeatClient(inst_v2.vimConnectionInfo["vim_0"])
stack_names = [] stack_names = []
stack_names.append(f"vnflcm_{inst_v2.id}") stack_names.append(f"vnflcm_{inst_v2.id}")
stack_names.append(f"{inst_v2.vnfInstanceName}_{inst_v2.id}") stack_names.append(f"{inst_v2.vnfInstanceName}_{inst_v2.id}")
@@ -779,7 +786,7 @@ def create_vnf_instance_v2(context, vnf_id):
metadata=_vnf_instance.vnf_metadata,) metadata=_vnf_instance.vnf_metadata,)
if inst_v2.instantiatedVnfInfo: if inst_v2.instantiatedVnfInfo:
_set_cp_instance_type(inst_v2) _set_cp_instance_type(inst_v2)
if inst_v2.vimConnectionInfo["vim0"].accessInfo.get("project"): if inst_v2.vimConnectionInfo["vim_0"].accessInfo.get("project"):
_set_stack_id(inst_v2, _vnf) _set_stack_id(inst_v2, _vnf)
inst_v2.create(context) inst_v2.create(context)
return inst_v2 return inst_v2
@@ -853,7 +860,7 @@ def _create_resource_changes_v2(dict_resource_changes,
affected_vnfc["removed_storage_resource_ids"], affected_vnfc["removed_storage_resource_ids"],
# v1 -> v2 # v1 -> v2
'computeResource': 'computeResource':
objects_v2.ResourceHandle(**affected_vnfc["compute_resource"]), _to_resource_handle(affected_vnfc["compute_resource"]),
'vnfdId': None, 'vnfdId': None,
'resourceDefinitionId': None, 'resourceDefinitionId': None,
'zoneId': None, 'zoneId': None,
@@ -875,8 +882,7 @@ def _create_resource_changes_v2(dict_resource_changes,
# v1 -> v2 # v1 -> v2
'vnfdId': None, 'vnfdId': None,
'networkResource': 'networkResource':
objects_v2.ResourceHandle( _to_resource_handle(affected_vl["network_resource"]),
**affected_vl["network_resource"]),
'vnfLinkPortIds': None, 'vnfLinkPortIds': None,
'resourceDefinitionId': None, 'resourceDefinitionId': None,
'zoneId': None, 'zoneId': None,
@@ -898,8 +904,8 @@ def _create_resource_changes_v2(dict_resource_changes,
affected_vstorage["virtual_storage_desc_id"], affected_vstorage["virtual_storage_desc_id"],
'changeType': affected_vstorage["change_type"], 'changeType': affected_vstorage["change_type"],
# v1 -> v2 # v1 -> v2
'storageResource': objects_v2.ResourceHandle( 'storageResource':
**affected_vstorage["storage_resource"]), _to_resource_handle(affected_vstorage["storage_resource"]),
'vnfdId': None, 'vnfdId': None,
'resourceDefinitionId': None, 'resourceDefinitionId': None,
'zoneId': None, 'zoneId': None,

10
tacker/tests/unit/db/test_db_migration_to_v2.py
View File

@@ -1026,15 +1026,15 @@ class TestDbMigrationToV2(SqlTestCase):
# vimConnectionInfo # vimConnectionInfo
vim_conn_info_v2 = vnf_instance_v2.vimConnectionInfo vim_conn_info_v2 = vnf_instance_v2.vimConnectionInfo
vim_conn_info_v1 = vnf_instance_v1.vim_connection_info vim_conn_info_v1 = vnf_instance_v1.vim_connection_info
self.assertEqual(vim_conn_info_v2["vim0"].vimId, self.assertEqual(vim_conn_info_v2["vim_0"].vimId,
vim_conn_info_v1[0].vim_id) vim_conn_info_v1[0].vim_id)
self.assertEqual(vim_conn_info_v2["vim0"].vimType, self.assertEqual(vim_conn_info_v2["vim_0"].vimType,
vim_conn_info_v1[0].vim_type) vim_conn_info_v1[0].vim_type)
self.assertEqual(vim_conn_info_v2["vim0"].interfaceInfo, self.assertEqual(vim_conn_info_v2["vim_0"].interfaceInfo,
vim_conn_info_v1[0].interface_info) vim_conn_info_v1[0].interface_info)
self.assertEqual(vim_conn_info_v2["vim0"].accessInfo, self.assertEqual(vim_conn_info_v2["vim_0"].accessInfo,
vim_conn_info_v1[0].access_info) vim_conn_info_v1[0].access_info)
self.assertEqual(vim_conn_info_v2["vim0"].extra, self.assertEqual(vim_conn_info_v2["vim_0"].extra,
vim_conn_info_v1[0].extra) vim_conn_info_v1[0].extra)
self.assertEqual(vnf_instance_v2.instantiationState, self.assertEqual(vnf_instance_v2.instantiationState,