Initial prototype of synchronizer
Change-Id: I45de04debd89e7007d7985728d51aa5d03178675
diff --git a/xos/synchronizer/steps/sync_controller_slices.py b/xos/synchronizer/steps/sync_controller_slices.py
new file mode 100644
index 0000000..58a0896
--- /dev/null
+++ b/xos/synchronizer/steps/sync_controller_slices.py
@@ -0,0 +1,76 @@
+import os
+import base64
+from collections import defaultdict
+from netaddr import IPAddress, IPNetwork
+from django.db.models import F, Q
+from xos.config import Config
+from synchronizers.base.syncstep import *
+from core.models import *
+from synchronizers.base.ansible import *
+from xos.logger import observer_logger as logger
+import json
+
+class SyncControllerSlices(SyncStep):
+ provides=[Slice]
+ requested_interval=0
+ observes=ControllerSlice
+ playbook='sync_controller_slices.yaml'
+
+ def map_sync_inputs(self, controller_slice):
+ logger.info("sync'ing slice controller %s" % controller_slice)
+
+ if not controller_slice.controller.admin_user:
+ logger.info("controller %r has no admin_user, skipping" % controller_slice.controller)
+ return
+
+ controller_users = ControllerUser.objects.filter(user=controller_slice.slice.creator,
+ controller=controller_slice.controller)
+ if not controller_users:
+ raise Exception("slice creator %s has not account at controller %s" % (controller_slice.slice.creator, controller_slice.controller.name))
+ else:
+ controller_user = controller_users[0]
+
+ max_instances=int(controller_slice.slice.max_instances)
+ slice_fields = {
+ 'endpoint': controller_slice.controller.auth_url,
+ 'admin_user': controller_slice.controller.admin_user,
+ 'admin_password': controller_slice.controller.admin_password,
+ 'slice_name': controller_slice.slice.name,
+ 'slice_description': controller_slice.slice.description,
+ 'name': controller_user.user.email,
+ 'ansible_tag': '%s@%s'%(controller_slice.slice.name,controller_slice.controller.name),
+ 'image': controller_slice.slice.default_image.name,
+ 'addresses': '10.168.2.0/24', # FIXME
+ 'gateway_ip': '10.168.2.1', # FIXME
+ 'gateway_mac': '02:42:0a:a8:02:01', # FIXME
+ 'max_instances': max_instances
+ }
+
+ return slice_fields
+
+ def map_sync_outputs(self, controller_slice, res):
+ if (not controller_slice.tenant_id):
+ controller_slice.tenant_id = "Not implemented"
+ controller_slice.backend_status = '1 - OK'
+ controller_slice.save()
+
+
+ def map_delete_inputs(self, controller_slice):
+ controller_users = ControllerUser.objects.filter(user=controller_slice.slice.creator,
+ controller=controller_slice.controller)
+ if not controller_users:
+ raise Exception("slice creator %s has not account at controller %s" % (controller_slice.slice.creator, controller_slice.controller.name))
+ else:
+ controller_user = controller_users[0]
+
+ slice_fields = {
+ 'endpoint': controller_slice.controller.auth_url,
+ 'admin_user': controller_slice.controller.admin_user,
+ 'admin_password': controller_slice.controller.admin_password,
+ 'slice': controller_slice.slice.name,
+ 'slice_description': controller_slice.slice.description,
+ 'name': controller_user.user.email,
+ 'ansible_tag': '%s@%s'%(controller_slice.slice.name,controller_slice.controller.name),
+ 'delete': True
+ }
+ return slice_fields