aboutsummaryrefslogtreecommitdiffstats
path: root/catalog/packages/biz
diff options
context:
space:
mode:
authordyh <dengyuanhong@chinamobile.com>2020-02-18 15:18:13 +0800
committerdyh <dengyuanhong@chinamobile.com>2020-02-18 16:20:47 +0800
commit9812671ef6df484b944355bf5101732d5cf9ea03 (patch)
treee0edb28f6ebeed891116a99eb5b3cdfb28074242 /catalog/packages/biz
parent14eb438e920a9905e7254bf3aeb6bc4cc423e6b3 (diff)
modify filters to filter
Change-Id: If18419663f2c5154f1a461429916025cf6c684e0 Issue-ID: MODELING-311 Signed-off-by: dyh <dengyuanhong@chinamobile.com>
Diffstat (limited to 'catalog/packages/biz')
-rw-r--r--catalog/packages/biz/notificationsutil.py10
-rw-r--r--catalog/packages/biz/nsdm_subscription.py2
-rw-r--r--catalog/packages/biz/vnf_pkg_subscription.py8
3 files changed, 10 insertions, 10 deletions
diff --git a/catalog/packages/biz/notificationsutil.py b/catalog/packages/biz/notificationsutil.py
index 8cdfd80..114f922 100644
--- a/catalog/packages/biz/notificationsutil.py
+++ b/catalog/packages/biz/notificationsutil.py
@@ -41,7 +41,7 @@ class NotificationsUtil(object):
def send_notification(self):
notification = self.prepare_notification()
- subscriptions_filter = {v + "__contains": notification[k] for k, v in self.filters.items()}
+ subscriptions_filter = {v + "__contains": notification[k] for k, v in self.filter.items()}
subscriptions_filter = remove_none_key(subscriptions_filter)
logger.debug('send_notification subscriptions_filter = %s' % subscriptions_filter)
q1 = Q()
@@ -51,7 +51,7 @@ class NotificationsUtil(object):
subscriptions = self.SubscriptionModel.objects.filter(q1)
if not subscriptions.exists():
- logger.info("No subscriptions created for the filters %s" % notification)
+ logger.info("No subscriptions created for the filter %s" % notification)
return
logger.info("Start sending notifications")
for sub in subscriptions:
@@ -102,7 +102,7 @@ class NotificationsUtil(object):
class PkgNotifications(NotificationsUtil):
def __init__(self, notification_type, vnf_pkg_id, change_type=None, operational_state=None):
super(PkgNotifications, self).__init__(notification_type)
- self.filters = {
+ self.filter = {
'vnfdId': 'vnfd_id',
'vnfPkgId': 'vnf_pkg_id'
}
@@ -150,7 +150,7 @@ class PkgNotifications(NotificationsUtil):
class NsdNotifications(NotificationsUtil):
def __init__(self, notification_type, nsd_info_id, nsd_id, failure_details=None, operational_state=None):
super(NsdNotifications, self).__init__(notification_type)
- self.filters = {
+ self.filter = {
'nsdInfoId': 'nsdInfoId',
'nsdId': 'nsdId',
}
@@ -195,7 +195,7 @@ class NsdNotifications(NotificationsUtil):
class PnfNotifications(NotificationsUtil):
def __init__(self, notification_type, pnfd_info_id, pnfd_id, failure_details=None):
super(PnfNotifications, self).__init__(notification_type)
- self.filters = {
+ self.filter = {
'pnfdId': 'pnfdId',
'pnfdInfoIds': 'pnfdInfoIds',
}
diff --git a/catalog/packages/biz/nsdm_subscription.py b/catalog/packages/biz/nsdm_subscription.py
index e2af6e4..652e9a7 100644
--- a/catalog/packages/biz/nsdm_subscription.py
+++ b/catalog/packages/biz/nsdm_subscription.py
@@ -76,7 +76,7 @@ class NsdmSubscription:
for query, value in list(self.params.items()):
if query in const.NSDM_NOTIFICATION_FILTERS and value:
query_data[query + '__icontains'] = json.dumps(list(set(value)))
- # Query the database with filters if the request
+ # Query the database with filter if the request
# has fields in request params, else fetch all records
if query_data:
subscriptions = NsdmSubscriptionModel.objects.filter(**query_data)
diff --git a/catalog/packages/biz/vnf_pkg_subscription.py b/catalog/packages/biz/vnf_pkg_subscription.py
index 69ce2e8..6abe10e 100644
--- a/catalog/packages/biz/vnf_pkg_subscription.py
+++ b/catalog/packages/biz/vnf_pkg_subscription.py
@@ -48,7 +48,7 @@ class CreateSubscription(object):
def __init__(self, data):
self.data = data
- self.filter = ignore_case_get(self.data, "filters", {})
+ self.filter = ignore_case_get(self.data, "filter", {})
self.callback_uri = ignore_case_get(self.data, "callbackUri")
self.authentication = ignore_case_get(self.data, "authentication", {})
self.notification_types = ignore_case_get(self.filter, "notificationTypes", [])
@@ -104,7 +104,7 @@ class CreateSubscription(object):
if not is_filter_type_equal(getattr(self, filter_type),
ast.literal_eval(getattr(sub, filter_type))):
return False
- # If all the above types are same then check id filters
+ # If all the above types are same then check id filter
for id_filter in ["vnfd_id", "vnf_pkg_id"]:
if not is_filter_type_equal(getattr(self, id_filter),
ast.literal_eval(getattr(sub, id_filter))):
@@ -151,11 +151,11 @@ class QuerySubscription(object):
def query_multi_subscriptions(self, params):
query_data = {}
logger.debug("QuerySubscription--get--multi--subscriptions--biz::> Check "
- "for filters in query params %s" % params)
+ "for filter in query params %s" % params)
for query, value in list(params.items()):
if query in ROOT_FILTERS:
query_data[ROOT_FILTERS[query] + '__icontains'] = value
- # Query the database with filters if the request has fields in request params, else fetch all records
+ # Query the database with filter if the request has fields in request params, else fetch all records
if query_data:
subscriptions = VnfPkgSubscriptionModel.objects.filter(**query_data)
else: