Sync refactored into abstract steps

[plstackapi.git] / planetstack / observer / syncstep.py

diff --git a/planetstack/observer/syncstep.py b/planetstack/observer/syncstep.py
new file mode 100644 (file)
index 0000000..b206106
--- /dev/null
+++ b/planetstack/observer/syncstep.py
@@ -0,0 +1,41 @@
+import os
+import base64
+from planetstack.config import Config
+
+class SyncStep:
+       """ A PlanetStack Sync step. 
+
+       Attributes:
+               psmodel         Model name the step synchronizes 
+               dependencies    list of names of models that must be synchronized first if the current model depends on them
+       """ 
+       slow=False
+       def get_prop(prop):
+               try:
+                       sync_config_dir = Config().sync_config_dir
+               except:
+                       sync_config_dir = '/etc/planetstack/sync'
+               prop_config_path = '/'.join(sync_config_dir,self.name,prop)
+               return open(prop_config_path).read().rstrip()
+
+       def __init__(self, **args):
+               """Initialize a sync step
+                  Keyword arguments:
+                               name -- Name of the step
+                               provides -- PlanetStack models sync'd by this step
+               """
+               try:
+                       self.soft_deadline = int(self.get_prop('soft_deadline_seconds'))
+               except:
+                       self.soft_deadline = 5 # 5 seconds
+
+               return
+
+       def fetch_pending(self):
+               return Sliver.objects.filter(ip=None)
+
+       def call(self):
+               return True
+
+       def __call__(self):
+               return self.call()