view py/configwaiter.py @ 253:0a1b642e3086

long polling config updates
author Matt Johnston <matt@ucc.asn.au>
date Mon, 08 Jun 2015 22:29:46 +0800
parents
children 26eee8591f61
line wrap: on
line source

class ConfigWaiter(object):
	""" Waits for config updates from the server. http long polling """

	def __init__(self, server):
		self.server = server
		self.epoch_tag = None
		self.http_session = aiohttp.ClientSession()

	@asyncio.coroutine
	def run(self):
		# wait until someting has been uploaded (the uploader itself waits 5 seconds)
		yield from asyncio.sleep(10)
		while True:
			yield from self.do()

			# avoid spinning too fast
			yield from server.sleep(1)

	@asyncio.coroutine
	def do(self):
		try:
			if self.epoch_tag:
				headers = {'etag': self.epoch_tag}
			else:
				headers = None

	        r = yield from asyncio.wait_for(
	        	self.http_session.get(config.SETTINGS_URL, headers=headers), 
	        	300)
	        if r.status == 200:
		        resp = yield from asyncio.wait_for(r.json(), 300)

		        self.epoch_tag = resp['epoch_tag']
		        epoch = self.epoch_tag.split('-')[0]
		        if self.server.params.receive(resp['params'], epoch):
		        	self.server.reload_signal(True)

		 except Exception as e:
		 	E("Error watching config: %s" % str(e))