summaryrefslogtreecommitdiffstats
path: root/windriver/titanium_cloud/registration
diff options
context:
space:
mode:
Diffstat (limited to 'windriver/titanium_cloud/registration')
-rw-r--r--windriver/titanium_cloud/registration/tests/test_registration.py18
-rw-r--r--windriver/titanium_cloud/registration/views/registration.py139
2 files changed, 114 insertions, 43 deletions
diff --git a/windriver/titanium_cloud/registration/tests/test_registration.py b/windriver/titanium_cloud/registration/tests/test_registration.py
index cc4bdd6c..5c31c4e8 100644
--- a/windriver/titanium_cloud/registration/tests/test_registration.py
+++ b/windriver/titanium_cloud/registration/tests/test_registration.py
@@ -234,7 +234,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -247,7 +247,7 @@ class TestRegistration(test_base.TestRequest):
mock_delete_vim_info.return_value = 0
response = self.client.delete((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), "{}", content_type="application/json",
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -261,7 +261,7 @@ class TestRegistration(test_base.TestRequest):
mock_delete_vim_info.return_value = 1
response = self.client.delete((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), "{}", content_type="application/json",
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -291,7 +291,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -321,7 +321,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -352,7 +352,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -382,7 +382,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -412,7 +412,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
@@ -442,7 +442,7 @@ class TestRegistration(test_base.TestRequest):
})
response = self.client.post((
- "/api/multicloud-titaniumcloud/v0/windriver-hudson-dc_RegionOne/"
+ "/api/multicloud-titanium_cloud/v0/windriver-hudson-dc_RegionOne/"
"registry"), TEST_REGISTER_ENDPOINT_REQUEST,
HTTP_X_AUTH_TOKEN=mock_info.MOCK_TOKEN_ID)
diff --git a/windriver/titanium_cloud/registration/views/registration.py b/windriver/titanium_cloud/registration/views/registration.py
index 22ee55aa..584b263f 100644
--- a/windriver/titanium_cloud/registration/views/registration.py
+++ b/windriver/titanium_cloud/registration/views/registration.py
@@ -21,6 +21,8 @@ from django.conf import settings
from newton_base.registration import registration as newton_registration
from common.exceptions import VimDriverNewtonException
+from rest_framework import status
+from rest_framework.response import Response
from common.msapi import extsys
from keystoneauth1.exceptions import HttpError
from newton_base.util import VimDriverUtils
@@ -38,6 +40,7 @@ class Registry(newton_registration.Registry):
self.aai_base_url = settings.AAI_BASE_URL
# self._logger = logger
+
def _get_ovsdpdk_capabilities(self, extra_specs, viminfo):
instruction_capability = {}
feature_uuid = uuid.uuid4()
@@ -54,7 +57,8 @@ class Registry(newton_registration.Registry):
})
return instruction_capability
-class APIv1Registry(Registry):
+
+class APIv1Registry(newton_registration.Registry):
def __init__(self):
super(APIv1Registry, self).__init__()
@@ -62,6 +66,21 @@ class APIv1Registry(Registry):
self.aai_base_url = settings.AAI_BASE_URL
# self._logger = logger
+ def _get_ovsdpdk_capabilities(self, extra_specs, viminfo):
+ instruction_capability = {}
+ feature_uuid = uuid.uuid4()
+
+ instruction_capability['hpa-capability-id'] = str(feature_uuid)
+ instruction_capability['hpa-feature'] = 'ovsDpdk'
+ instruction_capability['architecture'] = 'Intel64'
+ instruction_capability['hpa-version'] = 'v1'
+
+ instruction_capability['hpa-feature-attributes'] = []
+ instruction_capability['hpa-feature-attributes'].append({'hpa-attribute-key': 'dataProcessingAccelerationLibrary',
+ 'hpa-attribute-value':
+ '{{\"value\":\"{0}\"}}'.format("v17.02")
+ })
+ return instruction_capability
def _update_cloud_region(self, cloud_owner, cloud_region_id, openstack_region_id, viminfo, session=None):
if cloud_owner and cloud_region_id:
@@ -144,17 +163,27 @@ class APIv1Registry(Registry):
try:
regions = []
vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
- for region in self._get_list_resources(
+ isDistributedCloud = False;
+ openstackregions = self._get_list_resources(
"/regions", "identity", session, viminfo, vimid,
- "regions"):
+ "regions")
+
+ for region in openstackregions:
if (region['id'] == 'SystemController'):
+ isDistributedCloud = True;
+ break;
+ else:
continue
- elif (region['id'] == 'RegionOne'):
+
+ for region in openstackregions:
+ if (region['id'] == 'SystemController'):
+ continue
+ elif (region['id'] == 'RegionOne' and isDistributedCloud == True):
continue
else:
regions.append(region['id'])
-
+ self._logger.info("Discovered Regions :%s" % regions)
return regions
except HttpError as e:
@@ -167,38 +196,58 @@ class APIv1Registry(Registry):
def post(self, request, cloud_owner="", cloud_region_id=""):
self._logger.info("registration with : %s, %s" % (cloud_owner, cloud_region_id))
- vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
+ try:
+ vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
- viminfo = VimDriverUtils.get_vim_info(vimid)
- cloud_extra_info = viminfo['cloud_extra_info']
- region_specified = cloud_extra_info["openstack-region-id"] if cloud_extra_info else None
- multi_region_discovery = cloud_extra_info["multi-region-discovery"] if cloud_extra_info else None
-
- # discover the regions
- region_ids = self._discover_regions(cloud_owner, cloud_region_id, None, viminfo)
-
- # compare the regions with region_specified and then cloud_region_id
- if (region_specified in region_ids):
- pass
- elif (cloud_region_id in region_ids):
- region_specified = cloud_region_id
- pass
- else:
- # assume the first region be the primary region since we have no other way to determine it.
- region_specified = region_ids[0]
-
- # update cloud region and discover/register resource
- if (multi_region_discovery and multi_region_discovery.upper() == "TRUE"):
- # no input for specified cloud region, so discover all cloud region?
- for regionid in region_ids:
- #create cloud region with composed AAI cloud_region_id except for the one onboarded externally (e.g. ESR)
- gen_cloud_region_id = cloud_region_id + "." + regionid if region_specified != regionid else cloud_region_id
- self._update_cloud_region(cloud_owner, gen_cloud_region_id, regionid, viminfo)
+ viminfo = VimDriverUtils.get_vim_info(vimid)
+ cloud_extra_info = viminfo['cloud_extra_info']
+ region_specified = cloud_extra_info["openstack-region-id"] if cloud_extra_info else None
+ multi_region_discovery = cloud_extra_info["multi-region-discovery"] if cloud_extra_info else None
+
+ # set the default tenant since there is no tenant info in the VIM yet
+ sess = VimDriverUtils.get_session(
+ viminfo, tenant_name=viminfo['tenant'])
+
+ # discover the regions
+ region_ids = self._discover_regions(cloud_owner, cloud_region_id, sess, viminfo)
+
+ if (len(region_ids) == 0):
+ self._logger.error("_discover_regions, return regions:%s" % (region_ids))
+ return Response(
+ data={'error': "no region found for cloud region: %s,%s" % (cloud_owner, cloud_region_id)},
+ status=status.HTTP_500_INTERNAL_SERVER_ERROR)
+
+
+ # compare the regions with region_specified and then cloud_region_id
+ if (region_specified in region_ids):
+ pass
+ elif (cloud_region_id in region_ids):
+ region_specified = cloud_region_id
+ pass
+ else:
+ # assume the first region be the primary region since we have no other way to determine it.
+ region_specified = region_ids.pop();
+
+ # update cloud region and discover/register resource
+ if (multi_region_discovery and multi_region_discovery.upper() == "TRUE"):
+ # no input for specified cloud region, so discover all cloud region?
+ for regionid in region_ids:
+ #create cloud region with composed AAI cloud_region_id except for the one onboarded externally (e.g. ESR)
+ gen_cloud_region_id = cloud_region_id + "." + regionid if region_specified != regionid else cloud_region_id
+ self._update_cloud_region(cloud_owner, gen_cloud_region_id, regionid, viminfo)
+ return super(APIv1Registry, self).post(request, vimid)
+ else:
+ self._update_cloud_region(cloud_owner, cloud_region_id, region_specified, viminfo)
return super(APIv1Registry, self).post(request, vimid)
- else:
- self._update_cloud_region(cloud_owner, cloud_region_id, region_specified, viminfo)
- return super(APIv1Registry, self).post(request, vimid)
+ except HttpError as e:
+ self._logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json()))
+ return Response(data=e.response.json(), status=e.http_status)
+ except Exception as e:
+ self._logger.error(traceback.format_exc())
+ return Response(
+ data={'error': str(e)},
+ status=status.HTTP_500_INTERNAL_SERVER_ERROR)
@@ -207,3 +256,25 @@ class APIv1Registry(Registry):
vimid = extsys.encode_vim_id(cloud_owner, cloud_region_id)
return super(APIv1Registry, self).delete(request, vimid)
+
+
+### APIv0 handler upgrading: leverage APIv1 handler
+class APIv0Registry(APIv1Registry):
+
+ def __init__(self):
+ super(APIv0Registry, self).__init__()
+ self.proxy_prefix = settings.MULTICLOUD_PREFIX
+ self.aai_base_url = settings.AAI_BASE_URL
+ # self._logger = logger
+
+ def post(self, request, vimid=""):
+ self._logger.info("registration with : %s" % (vimid))
+
+ cloud_owner, cloud_region_id = extsys.decode_vim_id(vimid)
+ return super(APIv0Registry, self).post(request, cloud_owner, cloud_region_id)
+
+ def delete(self, request, vimid=""):
+ self._logger.debug("unregister cloud region: %s" % (vimid))
+
+ cloud_owner, cloud_region_id = extsys.decode_vim_id(vimid)
+ return super(APIv0Registry, self).delete(request, cloud_owner, cloud_region_id)