X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FNBI.git;a=blobdiff_plain;f=osm_nbi%2Fosm_vnfm%2Fvnf_subscription.py;fp=osm_nbi%2Fosm_vnfm%2Fvnf_subscription.py;h=c04fbdece616763fe98b9a3680b3ab58b8be4e75;hp=5371a44ee9f1e94f2a99d984d629b13838dd714d;hb=f2af4a100d308e07f355d61b94fb27d1ccc97aa2;hpb=838e4fb65f485469934a4dd895ca910470fa8beb diff --git a/osm_nbi/osm_vnfm/vnf_subscription.py b/osm_nbi/osm_vnfm/vnf_subscription.py index 5371a44..c04fbde 100644 --- a/osm_nbi/osm_vnfm/vnf_subscription.py +++ b/osm_nbi/osm_vnfm/vnf_subscription.py @@ -18,8 +18,10 @@ __author__ = "Selvi Jayaraman " from osm_nbi.subscription_topics import CommonSubscriptions from osm_nbi.validation import vnf_subscription + class VnflcmSubscriptionsTopic(CommonSubscriptions): schema_new = vnf_subscription + def _subscription_mapper(self, _id, data, table): """ Performs data transformation on subscription request @@ -30,7 +32,7 @@ class VnflcmSubscriptionsTopic(CommonSubscriptions): formatted_data = [] formed_data = { "reference": data.get("_id"), - "CallbackUri": data.get("CallbackUri") + "CallbackUri": data.get("CallbackUri"), } if data.get("authentication"): formed_data.update({"authentication": data.get("authentication")}) @@ -53,11 +55,15 @@ class VnflcmSubscriptionsTopic(CommonSubscriptions): formatted_data.append(update_dict) elif elem == "VnfLcmOperationOccurrenceNotification": if "operationTypes" in data["filter"].keys(): - update_dict["operationTypes"] = data["filter"]["operationTypes"] + update_dict["operationTypes"] = data["filter"][ + "operationTypes" + ] else: update_dict["operationTypes"] = "ANY" if "operationStates" in data["filter"].keys(): - update_dict["operationStates"] = data["filter"]["operationStates"] + update_dict["operationStates"] = data["filter"][ + "operationStates" + ] else: update_dict["operationStates"] = "ANY" formatted_data.append(update_dict)