planetstack/observer/syncstep.py

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()