diff options
author | 2020-08-06 09:20:55 +0800 | |
---|---|---|
committer | 2020-08-07 15:37:08 +0800 | |
commit | 46bd3041d522ddce28ae3450e98c9c49b44b02cc (patch) | |
tree | 765a04f0a0bc4531d8bb6a0b4aba2304e894a34c /catalog/packages | |
parent | 824413f6f354330f868b38a2ec8cb93b3c8d2808 (diff) |
1. Remove the mandatory dependency on MSB
2. Refactor config file
Change-Id: I8317ee0e1440e177a54e5510c6393529b6a3a5fe
Issue-ID: MODELING-411
Signed-off-by: dyh <dengyuanhong@chinamobile.com>
Diffstat (limited to 'catalog/packages')
-rw-r--r-- | catalog/packages/biz/notificationsutil.py | 13 | ||||
-rw-r--r-- | catalog/packages/biz/nsdm_subscription.py | 3 | ||||
-rw-r--r-- | catalog/packages/biz/vnf_package.py | 4 | ||||
-rw-r--r-- | catalog/packages/biz/vnf_pkg_subscription.py | 10 | ||||
-rw-r--r-- | catalog/packages/tests/test_nsdm_subscription.py | 35 | ||||
-rw-r--r-- | catalog/packages/tests/test_vnf_package.py | 25 | ||||
-rw-r--r-- | catalog/packages/tests/test_vnf_pkg_subscription.py | 22 | ||||
-rw-r--r-- | catalog/packages/tests/test_vnfpackage.py | 25 |
8 files changed, 67 insertions, 70 deletions
diff --git a/catalog/packages/biz/notificationsutil.py b/catalog/packages/biz/notificationsutil.py index 31760cc..93c26c7 100644 --- a/catalog/packages/biz/notificationsutil.py +++ b/catalog/packages/biz/notificationsutil.py @@ -26,7 +26,6 @@ import catalog.pub.utils.timeutil from catalog.packages import const from catalog.packages.serializers.vnf_pkg_notifications import PkgChangeNotificationSerializer, \ PkgOnboardingNotificationSerializer -from catalog.pub.config import config as pub_config from catalog.pub.database.models import VnfPackageModel, VnfPkgSubscriptionModel, NsdmSubscriptionModel from catalog.pub.utils.values import remove_none_key @@ -61,7 +60,7 @@ class NotificationsUtil(object): # set subscription id notification["subscriptionId"] = sub.get_subscription_id() notification['_links']['subscription'] = { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, self.subscription_root_uri, notification["subscriptionId"]) + 'href': '/%s%s' % (self.subscription_root_uri, notification["subscriptionId"]) } callbackuri = sub.callback_uri """ @@ -149,7 +148,7 @@ class PkgNotifications(NotificationsUtil): 'vnfdId': vnfd_id, '_links': { 'vnfPackage': { - 'href': '%s/%s/vnf_packages/%s' % (pub_config.MSB_BASE_URL, const.PKG_URL_PREFIX, self.vnf_pkg_id) + 'href': '/%s/vnf_packages/%s' % (const.PKG_URL_PREFIX, self.vnf_pkg_id) } } } @@ -192,7 +191,8 @@ class NsdNotifications(NotificationsUtil): 'nsdId': self.nsd_id, '_links': { 'nsdInfo': { - 'href': '%s/%s/ns_descriptors/%s' % (pub_config.MSB_BASE_URL, const.NSD_URL_PREFIX, self.nsd_info_id) + 'href': '/%s/ns_descriptors/%s' % ( + const.NSD_URL_PREFIX, self.nsd_info_id) } } } @@ -232,9 +232,8 @@ class PnfNotifications(NotificationsUtil): 'pnfdId': self.pnfd_id, '_links': { 'pnfdInfo': { - 'href': '%s/%s/pnf_descriptors/%s' % (pub_config.MSB_BASE_URL, - const.NSD_URL_PREFIX, - self.pnfd_info_id) + 'href': '/%s/pnf_descriptors/%s' % (const.NSD_URL_PREFIX, + self.pnfd_info_id) } } } diff --git a/catalog/packages/biz/nsdm_subscription.py b/catalog/packages/biz/nsdm_subscription.py index a551c2c..564e936 100644 --- a/catalog/packages/biz/nsdm_subscription.py +++ b/catalog/packages/biz/nsdm_subscription.py @@ -26,7 +26,6 @@ from catalog.pub.database.models import NsdmSubscriptionModel from catalog.pub.exceptions import CatalogException, \ NsdmBadRequestException, NsdmDuplicateSubscriptionException, SubscriptionDoesNotExistsException from catalog.pub.utils.values import ignore_case_get -from catalog.pub.config.config import MSB_BASE_URL logger = logging.getLogger(__name__) @@ -194,7 +193,7 @@ class NsdmSubscription: "Subscription has already existed with the " "same callbackUri and filter:%s" % links) raise NsdmDuplicateSubscriptionException( - "%s/%s" % (MSB_BASE_URL, links["self"]["href"])) + "/%s" % (links["self"]["href"])) def save_db(self): logger.debug("Create Subscription --> Saving the subscription " diff --git a/catalog/packages/biz/vnf_package.py b/catalog/packages/biz/vnf_package.py index e202674..a906cb9 100644 --- a/catalog/packages/biz/vnf_package.py +++ b/catalog/packages/biz/vnf_package.py @@ -24,7 +24,7 @@ import zipfile from catalog.packages import const from catalog.packages.biz.common import parse_file_range, read, save from catalog.packages.biz.notificationsutil import PkgNotifications -from catalog.pub.config.config import CATALOG_ROOT_PATH, MSB_BASE_URL +from catalog.pub.config.config import CATALOG_ROOT_PATH from catalog.pub.database.models import VnfPackageModel, NSPackageModel from catalog.pub.exceptions import CatalogException, ResourceNotFoundException from catalog.pub.utils import fileutil, toscaparser @@ -279,7 +279,7 @@ def fill_artifacts_data(vnf_pkg_id): def fill_links(pkg_id, is_onboarded=False): - self_href = "%s/api/vnfpkgm/v1/vnf_packages/%s" % (MSB_BASE_URL, pkg_id) + self_href = "/api/vnfpkgm/v1/vnf_packages/%s" % (pkg_id) links = { "self": {"href": self_href}, "vnfd": {"href": "%s/%s" % (self_href, "vnfd")}, diff --git a/catalog/packages/biz/vnf_pkg_subscription.py b/catalog/packages/biz/vnf_pkg_subscription.py index 2b2e245..5609403 100644 --- a/catalog/packages/biz/vnf_pkg_subscription.py +++ b/catalog/packages/biz/vnf_pkg_subscription.py @@ -16,18 +16,18 @@ import ast import json import logging import os -import requests import uuid - from collections import Counter -from rest_framework import status + +import requests from requests.auth import HTTPBasicAuth +from rest_framework import status + from catalog.packages import const from catalog.pub.database.models import VnfPkgSubscriptionModel from catalog.pub.exceptions import VnfPkgSubscriptionException, \ VnfPkgDuplicateSubscriptionException, SubscriptionDoesNotExistsException from catalog.pub.utils.values import ignore_case_get -from catalog.pub.config.config import MSB_BASE_URL logger = logging.getLogger(__name__) @@ -133,7 +133,7 @@ class CreateSubscription(object): links = json.loads(subscription.links) logger.error("Subscriptions has already exists with the same callbackUri and filter:%s" % links) raise VnfPkgDuplicateSubscriptionException( - "%s/%s" % (MSB_BASE_URL, links["self"]["href"])) + "/%s" % (links["self"]["href"])) return True diff --git a/catalog/packages/tests/test_nsdm_subscription.py b/catalog/packages/tests/test_nsdm_subscription.py index 61c8ce6..41c8648 100644 --- a/catalog/packages/tests/test_nsdm_subscription.py +++ b/catalog/packages/tests/test_nsdm_subscription.py @@ -13,23 +13,23 @@ # limitations under the License. import json -import mock -import uuid import os +import uuid + +import mock from django.test import TestCase -from rest_framework.test import APIClient -from rest_framework import status from requests.auth import HTTPBasicAuth +from rest_framework import status +from rest_framework.test import APIClient -from catalog.packages.biz.nsdm_subscription import NsdmSubscription -from catalog.pub.database.models import NsdmSubscriptionModel -from catalog.packages.biz.notificationsutil import NsdNotifications, PnfNotifications -from catalog.packages import const -from catalog.pub.config import config as pub_config import catalog.pub.utils.timeutil +from catalog.packages import const +from catalog.packages.biz.notificationsutil import NsdNotifications, PnfNotifications +from catalog.packages.biz.nsdm_subscription import NsdmSubscription from catalog.packages.tests.const import nsd_data +from catalog.pub.config.config import CATALOG_ROOT_PATH from catalog.pub.database.models import NSPackageModel, VnfPackageModel, PnfPackageModel -from catalog.pub.config.config import CATALOG_ROOT_PATH, MSB_BASE_URL +from catalog.pub.database.models import NsdmSubscriptionModel from catalog.pub.utils import toscaparser @@ -180,7 +180,7 @@ class TestNsdmSubscription(TestCase): response = self.client.post("/api/nsd/v1/subscriptions", data=self.subscription, format='json') self.assertEqual(303, response.status_code) - redirect_addr = "%s/%s" % (MSB_BASE_URL, os.path.join(const.NSDM_SUBSCRIPTION_ROOT_URI, subscriptionid)) + redirect_addr = "/%s" % (os.path.join(const.NSDM_SUBSCRIPTION_ROOT_URI, subscriptionid)) self.assertEqual(redirect_addr, response["Location"]) @mock.patch("requests.get") @@ -626,9 +626,10 @@ class TestNsdmSubscription(TestCase): 'nsdId': "b632bddc-bccd-4180-bd8d-4e8a9578eff7", '_links': { 'nsdInfo': { - 'href': '%s/%s/ns_descriptors/%s' % (pub_config.MSB_BASE_URL, const.NSD_URL_PREFIX, "d0ea5ec3-0b98-438a-9bea-488230cff174")}, + 'href': '/%s/ns_descriptors/%s' % ( + const.NSD_URL_PREFIX, "d0ea5ec3-0b98-438a-9bea-488230cff174")}, 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.NSDM_SUBSCRIPTION_ROOT_URI, "1111")} + 'href': '/%s%s' % (const.NSDM_SUBSCRIPTION_ROOT_URI, "1111")} }, "subscriptionId": "1111" @@ -675,10 +676,10 @@ class NotificationTest(TestCase): 'nsdId': "nsdid1", '_links': { 'nsdInfo': { - 'href': '%s/%s/ns_descriptors/%s' % (pub_config.MSB_BASE_URL, const.NSD_URL_PREFIX, "nsdinfoid1") + 'href': '/%s/ns_descriptors/%s' % (const.NSD_URL_PREFIX, "nsdinfoid1") }, 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.NSDM_SUBSCRIPTION_ROOT_URI, "1")} + 'href': '/%s%s' % (const.NSDM_SUBSCRIPTION_ROOT_URI, "1")} }, 'onboardingFailureDetails': "NSD(nsdid1) already exists.", "subscriptionId": "1" @@ -711,10 +712,10 @@ class NotificationTest(TestCase): 'pnfdId': "pnfdId1", '_links': { 'pnfdInfo': { - 'href': '%s/%s/pnf_descriptors/%s' % (pub_config.MSB_BASE_URL, const.NSD_URL_PREFIX, "pnfdInfoIds1") + 'href': '/%s/pnf_descriptors/%s' % (const.NSD_URL_PREFIX, "pnfdInfoIds1") }, 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.NSDM_SUBSCRIPTION_ROOT_URI, "1")}, + 'href': '/%s%s' % (const.NSDM_SUBSCRIPTION_ROOT_URI, "1")}, }, "subscriptionId": "1", } diff --git a/catalog/packages/tests/test_vnf_package.py b/catalog/packages/tests/test_vnf_package.py index 289b600..b2675a8 100644 --- a/catalog/packages/tests/test_vnf_package.py +++ b/catalog/packages/tests/test_vnf_package.py @@ -26,7 +26,6 @@ from rest_framework.test import APIClient from catalog.packages.biz.vnf_package import VnfPackage, VnfPkgUploadThread from catalog.packages.const import PKG_STATUS from catalog.packages.tests.const import vnfd_data -from catalog.pub.config import config from catalog.pub.config.config import CATALOG_ROOT_PATH from catalog.pub.database.models import VnfPackageModel from catalog.pub.utils import toscaparser @@ -151,11 +150,11 @@ class TestVnfPackage(TestCase): "operationalState": "DISABLED", "usageState": "NOT_IN_USE", "userDefinedData": {"a": "A"}, - "_links": {'self': {'href': config.MSB_BASE_URL + '/api/vnfpkgm/v1/vnf_packages/222'}, + "_links": {'self': {'href': '/api/vnfpkgm/v1/vnf_packages/222'}, 'vnfd': { - 'href': config.MSB_BASE_URL + '/api/vnfpkgm/v1/vnf_packages/222/vnfd'}, + 'href': '/api/vnfpkgm/v1/vnf_packages/222/vnfd'}, 'packageContent': { - 'href': config.MSB_BASE_URL + '/api/vnfpkgm/v1/vnf_packages/222/package_content'} + 'href': '/api/vnfpkgm/v1/vnf_packages/222/package_content'} } } self.assertEqual(response.data, expect_data) @@ -209,13 +208,13 @@ class TestVnfPackage(TestCase): "userDefinedData": {"a": "A"}, "_links": { "self": { - "href": config.MSB_BASE_URL + "/api/vnfpkgm/v1/vnf_packages/111" + "href": "/api/vnfpkgm/v1/vnf_packages/111" }, "vnfd": { - "href": config.MSB_BASE_URL + "/api/vnfpkgm/v1/vnf_packages/111/vnfd" + "href": "/api/vnfpkgm/v1/vnf_packages/111/vnfd" }, "packageContent": { - "href": config.MSB_BASE_URL + "/api/vnfpkgm/v1/vnf_packages/111/package_content" + "href": "/api/vnfpkgm/v1/vnf_packages/111/package_content" } } }, @@ -232,10 +231,10 @@ class TestVnfPackage(TestCase): "operationalState": "DISABLED", "usageState": "NOT_IN_USE", "userDefinedData": {"a": "A"}, - "_links": {'self': {'href': config.MSB_BASE_URL + '/api/vnfpkgm/v1/vnf_packages/222'}, - 'vnfd': {'href': config.MSB_BASE_URL + '/api/vnfpkgm/v1/vnf_packages/222/vnfd'}, + "_links": {'self': {'href': '/api/vnfpkgm/v1/vnf_packages/222'}, + 'vnfd': {'href': '/api/vnfpkgm/v1/vnf_packages/222/vnfd'}, 'packageContent': { - 'href': config.MSB_BASE_URL + '/api/vnfpkgm/v1/vnf_packages/222/package_content'}} + 'href': '/api/vnfpkgm/v1/vnf_packages/222/package_content'}} } ] self.assertEqual(response.data, expect_data) @@ -477,13 +476,13 @@ class TestVnfPackage(TestCase): "usageState": "NOT_IN_USE", "_links": { "self": { - "href": config.MSB_BASE_URL + "/api/vnfpkgm/v1/vnf_packages/222" + "href": "/api/vnfpkgm/v1/vnf_packages/222" }, "vnfd": { - "href": config.MSB_BASE_URL + "/api/vnfpkgm/v1/vnf_packages/222/vnfd" + "href": "/api/vnfpkgm/v1/vnf_packages/222/vnfd" }, "packageContent": { - "href": config.MSB_BASE_URL + "/api/vnfpkgm/v1/vnf_packages/222/package_content" + "href": "/api/vnfpkgm/v1/vnf_packages/222/package_content" } } } diff --git a/catalog/packages/tests/test_vnf_pkg_subscription.py b/catalog/packages/tests/test_vnf_pkg_subscription.py index f9f6ff2..f989b17 100644 --- a/catalog/packages/tests/test_vnf_pkg_subscription.py +++ b/catalog/packages/tests/test_vnf_pkg_subscription.py @@ -18,21 +18,20 @@ import uuid import mock from django.test import TestCase +from requests.auth import HTTPBasicAuth from rest_framework import status from rest_framework.test import APIClient -from requests.auth import HTTPBasicAuth import catalog.pub.utils.timeutil from catalog.packages import const from catalog.packages.biz.notificationsutil import PkgNotifications from catalog.packages.biz.vnf_pkg_subscription import QuerySubscription, TerminateSubscription -from catalog.pub.config import config as pub_config -from catalog.pub.config.config import CATALOG_ROOT_PATH, MSB_BASE_URL +from catalog.packages.tests.const import vnfd_data +from catalog.pub.config.config import CATALOG_ROOT_PATH from catalog.pub.database.models import VnfPkgSubscriptionModel, VnfPackageModel from catalog.pub.exceptions import SubscriptionDoesNotExistsException -from .const import vnf_subscription_data from catalog.pub.utils import toscaparser -from catalog.packages.tests.const import vnfd_data +from .const import vnf_subscription_data class TestNfPackageSubscription(TestCase): @@ -92,7 +91,7 @@ class TestNfPackageSubscription(TestCase): format='json' ) self.assertEqual(303, response.status_code) - redirect_addr = "%s/%s" % (MSB_BASE_URL, os.path.join(const.VNFPKG_SUBSCRIPTION_ROOT_URI, temp_uuid)) + redirect_addr = "/%s" % (os.path.join(const.VNFPKG_SUBSCRIPTION_ROOT_URI, temp_uuid)) self.assertEqual(redirect_addr, response["Location"]) @mock.patch("requests.get") @@ -259,14 +258,15 @@ class TestNfPackageSubscription(TestCase): 'vnfdId': uuid_vnfdid, '_links': { 'vnfPackage': { - 'href': '%s/%s/vnf_packages/%s' % (pub_config.MSB_BASE_URL, const.PKG_URL_PREFIX, uuid_vnfPackageId) + 'href': '/%s/vnf_packages/%s' % (const.PKG_URL_PREFIX, uuid_vnfPackageId) }, 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.VNFPKG_SUBSCRIPTION_ROOT_URI, uuid_subscriptid)} + 'href': '/%s%s' % (const.VNFPKG_SUBSCRIPTION_ROOT_URI, uuid_subscriptid)} }, "subscriptionId": uuid_subscriptid } - mock_requests_post.assert_called_with(vnf_subscription_data["callbackUri"], data=json.dumps(expect_notification), + mock_requests_post.assert_called_with(vnf_subscription_data["callbackUri"], + data=json.dumps(expect_notification), headers={'Connection': 'close', 'content-type': 'application/json', 'accept': 'application/json'}, @@ -326,10 +326,10 @@ class NotificationTest(TestCase): 'vnfdId': "vnfdid1", '_links': { 'vnfPackage': { - 'href': '%s/%s/vnf_packages/%s' % (pub_config.MSB_BASE_URL, const.PKG_URL_PREFIX, "vnfpkgid1") + 'href': '/%s/vnf_packages/%s' % (const.PKG_URL_PREFIX, "vnfpkgid1") }, 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.VNFPKG_SUBSCRIPTION_ROOT_URI, "1")} + 'href': '/%s%s' % (const.VNFPKG_SUBSCRIPTION_ROOT_URI, "1")} }, 'changeType': const.PKG_CHANGE_TYPE.OP_STATE_CHANGE, 'operationalState': None, diff --git a/catalog/packages/tests/test_vnfpackage.py b/catalog/packages/tests/test_vnfpackage.py index e4f292c..2478dca 100644 --- a/catalog/packages/tests/test_vnfpackage.py +++ b/catalog/packages/tests/test_vnfpackage.py @@ -13,24 +13,23 @@ # limitations under the License. import json -import mock import os -import catalog.pub.utils.timeutil -from requests.auth import HTTPBasicAuth +import mock from django.test import TestCase +from requests.auth import HTTPBasicAuth from rest_framework import status from rest_framework.test import APIClient +import catalog.pub.utils.timeutil +from catalog.packages import const from catalog.packages.biz.sdc_vnf_package import NfDistributeThread, NfPkgDeleteThread +from catalog.pub.config.config import CATALOG_ROOT_PATH from catalog.pub.database.models import JobStatusModel, JobModel from catalog.pub.database.models import VnfPackageModel from catalog.pub.msapi import sdc from catalog.pub.utils import restcall, toscaparser from .const import vnfd_data -from catalog.pub.config.config import CATALOG_ROOT_PATH -from catalog.packages import const -from catalog.pub.config import config as pub_config class TestNfPackage(TestCase): @@ -326,9 +325,9 @@ class TestNfPackage(TestCase): 'vnfdId': "b1bb0ce7-2222-4fa7-95ed-4840d70a1177", '_links': { 'vnfPackage': { - 'href': '%s/%s/vnf_packages/%s' % (pub_config.MSB_BASE_URL, const.PKG_URL_PREFIX, uuid_csarid)}, + 'href': '/%s/vnf_packages/%s' % (const.PKG_URL_PREFIX, uuid_csarid)}, 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.VNFPKG_SUBSCRIPTION_ROOT_URI, uuid_subscriptid)} + 'href': '/%s%s' % (const.VNFPKG_SUBSCRIPTION_ROOT_URI, uuid_subscriptid)} }, "subscriptionId": uuid_subscriptid @@ -350,11 +349,11 @@ class TestNfPackage(TestCase): 'vnfdId': "b1bb0ce7-2222-4fa7-95ed-4840d70a1177", '_links': { 'vnfPackage': { - 'href': '%s/%s/vnf_packages/%s' % (pub_config.MSB_BASE_URL, const.PKG_URL_PREFIX, - uuid_csarid)}, - 'subscription': { - 'href': '%s/%s%s' % (pub_config.MSB_BASE_URL, const.VNFPKG_SUBSCRIPTION_ROOT_URI, - uuid_subscriptid)} + 'href': '/%s/vnf_packages/%s' % (const.PKG_URL_PREFIX, + uuid_csarid)}, + 'subscription': { + 'href': '/%s%s' % (const.VNFPKG_SUBSCRIPTION_ROOT_URI, + uuid_subscriptid)} }, 'changeType': const.PKG_CHANGE_TYPE.PKG_DELETE, |