4 from django.db.models import F, Q
5 from planetstack.config import Config
6 from observer.syncstep import SyncStep
7 from core.models import Service
8 from hpc.models import ServiceProvider
9 from requestrouter.models import RequestRouterService
10 from util.logger import Logger, logging
12 # hpclibrary will be in steps/..
13 parentdir = os.path.join(os.path.dirname(__file__),"..")
14 sys.path.insert(0,parentdir)
\r
16 from hpclib import HpcLibrary
18 logger = Logger(level=logging.INFO)
20 class SyncServiceProvider(SyncStep, HpcLibrary):
21 provides=[ServiceProvider]
24 def __init__(self, **args):
25 SyncStep.__init__(self, **args)
26 HpcLibrary.__init__(self)
28 def fetch_pending(self):
29 return ServiceProvider.objects.filter(Q(enacted__lt=F('updated')) | Q(enacted=None))
31 def sync_record(self, sp):
32 logger.info("sync'ing service provider %s" % str(sp))
33 account_name = self.make_account_name(sp.name)
34 print "XXX", sp.name, account_name
35 if not sp.service_provider_id:
36 id = self.client.onev.Create("ServiceProvider", {"account": account_name, "name": sp.name, "enabled": sp.enabled})
37 sp.service_provider_id = id
39 self.client.onev.Update("ServiceProvider", {"account": account_name, "name": sp.name, "enabled": sp.enabled})