aboutsummaryrefslogtreecommitdiffstats
path: root/catalog/packages
diff options
context:
space:
mode:
authordyh <dengyuanhong@chinamobile.com>2020-08-06 09:20:55 +0800
committerdyh <dengyuanhong@chinamobile.com>2020-08-07 15:37:08 +0800
commit46bd3041d522ddce28ae3450e98c9c49b44b02cc (patch)
tree765a04f0a0bc4531d8bb6a0b4aba2304e894a34c /catalog/packages
parent824413f6f354330f868b38a2ec8cb93b3c8d2808 (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.py13
-rw-r--r--catalog/packages/biz/nsdm_subscription.py3
-rw-r--r--catalog/packages/biz/vnf_package.py4
-rw-r--r--catalog/packages/biz/vnf_pkg_subscription.py10
-rw-r--r--catalog/packages/tests/test_nsdm_subscription.py35
-rw-r--r--catalog/packages/tests/test_vnf_package.py25
-rw-r--r--catalog/packages/tests/test_vnf_pkg_subscription.py22
-rw-r--r--catalog/packages/tests/test_vnfpackage.py25
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,