diff options
Diffstat (limited to 'lcm/lcm/nf/biz')
-rw-r--r-- | lcm/lcm/nf/biz/delete_subscription.py | 31 | ||||
-rw-r--r-- | lcm/lcm/nf/biz/query_subscription.py | 6 |
2 files changed, 37 insertions, 0 deletions
diff --git a/lcm/lcm/nf/biz/delete_subscription.py b/lcm/lcm/nf/biz/delete_subscription.py new file mode 100644 index 00000000..387aa5d9 --- /dev/null +++ b/lcm/lcm/nf/biz/delete_subscription.py @@ -0,0 +1,31 @@ +# Copyright (C) 2019 ZTE. All Rights Reserved +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +import logging + +from lcm.pub.database.models import SubscriptionModel +from lcm.pub.exceptions import NFLCMException + +logger = logging.getLogger(__name__) + + +class DeleteSubscription: + def __init__(self, subscription_id): + self.subscription_id = subscription_id + + def delete_single_subscription(self): + subscription = SubscriptionModel.objects.filter(subscription_id=self.subscription_id) + if not subscription.exists(): + raise NFLCMException('Subscription(%s) does not exist' % self.subscription_id) + subscription.delete() diff --git a/lcm/lcm/nf/biz/query_subscription.py b/lcm/lcm/nf/biz/query_subscription.py index f2270d0a..7702f60b 100644 --- a/lcm/lcm/nf/biz/query_subscription.py +++ b/lcm/lcm/nf/biz/query_subscription.py @@ -35,6 +35,12 @@ class QuerySubscription: self.subscription_id = subscription_id self.params = data + def query_single_subscription(self): + subscription = SubscriptionModel.objects.filter(subscription_id=self.subscription_id) + if not subscription.exists(): + raise NFLCMException('Subscription(%s) does not exist' % self.subscription_id) + return self.fill_resp_data(subscription) + def query_multi_subscriptions(self): query_data = {} logger.debug("QueryMultiSubscriptions--get--biz::> Check for filters in query params" % self.params) |