projects
/
osm
/
NBI.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Feature 10999: Dual-Stack IP Support for VNFs in SOL003 VNFM Interface
[osm/NBI.git]
/
osm_nbi
/
osm_vnfm
/
vnf_subscription.py
diff --git
a/osm_nbi/osm_vnfm/vnf_subscription.py
b/osm_nbi/osm_vnfm/vnf_subscription.py
index
5371a44
..
c04fbde
100644
(file)
--- a/
osm_nbi/osm_vnfm/vnf_subscription.py
+++ b/
osm_nbi/osm_vnfm/vnf_subscription.py
@@
-18,8
+18,10
@@
__author__ = "Selvi Jayaraman <selvi.j@tataelxsi.co.in>"
from osm_nbi.subscription_topics import CommonSubscriptions
from osm_nbi.validation import vnf_subscription
from osm_nbi.subscription_topics import CommonSubscriptions
from osm_nbi.validation import vnf_subscription
+
class VnflcmSubscriptionsTopic(CommonSubscriptions):
schema_new = vnf_subscription
class VnflcmSubscriptionsTopic(CommonSubscriptions):
schema_new = vnf_subscription
+
def _subscription_mapper(self, _id, data, table):
"""
Performs data transformation on subscription request
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"),
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")})
}
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():
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():
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)
else:
update_dict["operationStates"] = "ANY"
formatted_data.append(update_dict)