Support for ELAN, ETREE, and VNoD Global Service
Change-Id: Iea1ee5b5b9224404a16bc9b88bc082719f75d10f
diff --git a/xos/synchronizer/invokers/vnodglobalserviceinvoker.py b/xos/synchronizer/invokers/vnodglobalserviceinvoker.py
new file mode 100644
index 0000000..a313171
--- /dev/null
+++ b/xos/synchronizer/invokers/vnodglobalserviceinvoker.py
@@ -0,0 +1,50 @@
+import json
+from synchronizers.metronetwork.invokers.invoker import Invoker
+from services.metronetwork.models import ServiceSpoke
+from services.metronetwork.models import BandwidthProfile
+from services.metronetwork.models import NetworkEdgeToEdgePointConnection
+
+class VnodGlobalServiceInvoker(Invoker):
+
+ def __init__(self, **args):
+ pass
+
+ # Method for handline pre save semantics
+ # content here would be model specific but could include handling Many-to-Many relationship
+ # creation - which must occur post save
+ #
+ # obj - Whatever obj was just saved
+ # returns - None - this is a pure invoke() call, return type is None
+ #
+ def presave(self, obj):
+
+ if hasattr(obj, 'bwpname'):
+ bwprofile = BandwidthProfile.objects.get(name=obj.bwpname)
+ obj.bandwidthProfile = bwprofile
+
+ if hasattr(obj, 'pointtopointsid'):
+ connection = NetworkEdgeToEdgePointConnection.objects.get(sid=obj.pointtopointsid)
+ obj.metronetworkpointtopoint = connection
+
+ # Method for handline post save semantics
+ # content here would be model specific but could include handling Many-to-Many relationship
+ # creation - which must occur post save
+ #
+ # obj - Whatever obj was just saved
+ # returns - N/A - this is a pure invoke() call
+ #
+ def postsave(self, obj):
+ #
+ # Ok - we need to handle the multipoint many-to-many relationships in here
+ #
+ # By design convnetion we will look for them in the 'backend_register' object field
+ # this is a json field that is general purpose - we will expect to find a JSON array
+ # called 'eps' that just containts a reference to a bunch of NetworkEdgePorts
+ #
+ if hasattr(obj, 'spokes_createbuffer'):
+ scratchpad = json.loads(obj.spokes_createbuffer)
+ spokes = scratchpad['spokes']
+
+ for spokeid in spokes:
+ spoke = ServiceSpoke.objects.get(name=spokeid)
+ obj.spokes.add(spoke)