Added randomized backoff/retry scheme to try to help with failed requests, since the CT50 doesn't seem to handle requests in quick succession very well.

Also set the default API to CT50 for now, since it is the only one at the moment and it saves a request to not check the thermostat version.

Author: Paul Jennings

TStat.py

@@ -49,6 +49,8 @@
 import httplib
 import urllib
 import logging
+import random
+import time
 
 # For Python < 2.6, this json module:
 # http://pypi.python.org/pypi/python-json
@@ -86,6 +88,7 @@ def __init__(self, address, cacheExpiry=5, api=None, logger=None, logLevel=None)
 		if api is None:
 			self.api = API()
 			self.api = getAPI(self.getModel())
+			time.sleep(2)
 		else:
 			self.api = api
 
@@ -135,9 +138,15 @@ def _post(self, key, value):
 			l.debug("Will send params: %s" % params)
 
 			headers = {"Content-type": "application/x-www-form-urlencoded", "Accept": "text/plain"}
-			conn = self._getConn()
-			conn.request("POST", location, params, headers)
-			response = conn.getresponse()
+			response = None
+			count = 0
+			while response is None and count < 5:
+				conn = self._getConn()
+				conn.request("POST", location, params, headers)
+				response = conn.getresponse()
+				if response is None:
+					time.sleep(count*random.randint(0, 3))
+				count = count + 1
 			if response.status != 200:
 				l.error("Error %s while trying to set '%s' with '%s'" % (response.status, location, params))
 				continue
@@ -199,9 +208,15 @@ def _get(self, key, raw=False):
 		else:
 			for getter in entry.getters:
 				# Either data was not cached or cache was expired
-				conn = self._getConn()
-				conn.request("GET", getter[0])
-				response = conn.getresponse()
+				response = None
+				count = 0
+				while response is None and count < 5:
+					conn = self._getConn()
+					conn.request("GET", getter[0])
+					response = conn.getresponse()
+					if response is None:
+						time.sleep(count*random.randint(0, 10))
+					count = count + 1
 				if response.status != 200:
 					l.warning("Request for '%s' failed (error %s)" % (getter[0], response.status))
 					response = None
@@ -357,7 +372,7 @@ def setCloudMode(self, value):
 def main():
 	import sys
 	addr = sys.argv[1]
-	t = TStat(addr)
+	t = TStat(addr, api=API_CT50v109())
 	for cmd in sys.argv[2:]:
 		result = eval("t.%s(raw=True)" % cmd)
 		#print "%s: %s" % (cmd, result)