xos/synchronizers/onboarding/steps/sync_servicecontroller.py

import os
import sys
import base64
from django.db.models import F, Q
from xos.config import Config
from synchronizers.base.syncstep import SyncStep, DeferredException
from core.models import XOS, ServiceController
from xos.logger import Logger, logging
from synchronizers.base.ansible_helper import run_template

# xosbuilder will be in steps/..
parentdir = os.path.join(os.path.dirname(__file__),"..")
sys.path.insert(0,parentdir)

from xosbuilder import XOSBuilder

logger = Logger(level=logging.INFO)

class SyncServiceController(SyncStep, XOSBuilder):
    provides=[ServiceController]
    observes=ServiceController
    requested_interval=0
    playbook = "sync_servicecontroller.yaml"

    def __init__(self, **args):
        SyncStep.__init__(self, **args)
        XOSBuilder.__init__(self)

    def sync_record(self, sc):
        logger.info("Sync'ing ServiceController %s" % sc)

        if sc.xos and (not sc.xos.enable_build):
            raise DeferredException("XOS build is currently disabled")

        unready = self.check_controller_unready(sc)
        if unready:
            raise Exception("Controller %s has unready resources: %s" % (str(sc), ",".join([str(x) for x in unready])))

        if sc.no_build:
            # nothing to do for a no-build ServiceController
            return

        dockerfile = self.create_synchronizer_dockerfile(sc)
        if dockerfile:
            dockerfiles=[dockerfile]
        else:
            dockerfiles=[]

        tenant_fields = {"dockerfiles": dockerfiles,
                         "build_dir": self.build_dir,
                         "ansible_tag": sc.__class__.__name__ + "_" + str(sc.id)}

        path="servicecontroller"
        res = run_template(self.playbook, tenant_fields, path=path, object=sc)

    def delete_record(self, m):
        pass

    def fetch_pending(self, deleted=False):
        pend = super(SyncServiceController, self).fetch_pending(deleted)
        return pend