aboutsummaryrefslogtreecommitdiffstats
path: root/catalog/packages/biz/nsdm_subscription.py
diff options
context:
space:
mode:
authorhongyuzhao <zhao.hongyu@zte.com.cn>2020-04-08 11:50:53 +0800
committerhongyuzhao <zhao.hongyu@zte.com.cn>2020-04-08 15:28:34 +0800
commit3fcd9e6adf5833688b0007983aab00db312e433e (patch)
tree8276ad08790b71ee3bad427713875b7cbb2bff57 /catalog/packages/biz/nsdm_subscription.py
parent613fed546242f8d7f50e9322ef58617402c075bc (diff)
fix bug for ETSI Catalog Manager needs to raise 303 exception for the same callback_uri and the same filter
Change-Id: Ie577540d2c4bb25299059869ce967422610f5785 Issue-ID: MODELING-353 Signed-off-by: hongyu zhao <zhao.hongyu@zte.com.cn>
Diffstat (limited to 'catalog/packages/biz/nsdm_subscription.py')
-rw-r--r--catalog/packages/biz/nsdm_subscription.py11
1 files changed, 7 insertions, 4 deletions
diff --git a/catalog/packages/biz/nsdm_subscription.py b/catalog/packages/biz/nsdm_subscription.py
index d111bc2..84bacde 100644
--- a/catalog/packages/biz/nsdm_subscription.py
+++ b/catalog/packages/biz/nsdm_subscription.py
@@ -26,6 +26,7 @@ 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_SERVICE_IP, MSB_SERVICE_PORT
logger = logging.getLogger(__name__)
@@ -185,13 +186,15 @@ class NsdmSubscription:
subscriptions = \
NsdmSubscriptionModel.objects.filter(
callback_uri=self.callback_uri)
- if not subscriptions.exists():
- return
+
for subscription in subscriptions:
if self.check_filter_exists(subscription):
- raise NsdmDuplicateSubscriptionException(
+ links = json.loads(subscription.links)
+ logger.error(
"Subscription has already existed with the "
- "same callbackUri and filter")
+ "same callbackUri and filter:%s" % links)
+ raise NsdmDuplicateSubscriptionException(
+ "https://%s:%s/%s" % (MSB_SERVICE_IP, MSB_SERVICE_PORT, links["self"]["href"]))
def save_db(self):
logger.debug("Create Subscription --> Saving the subscription "