Congegni
/
libretime
mirror of https://github.com/libretime/libretime.git
7
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

CC-2830: airtime-playout not working after reboot on Debian squeeze 

-fixed
This commit is contained in:
Martin Konecny 2011-09-19 12:44:43 -04:00
parent 09df72862d
commit 2152ae5b3a
1 changed files with 28 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
python_apps/api_clients/api_client.py
View File

@ -156,6 +156,26 @@ class AirTimeApiClient(ApiClientInterface):
logger = logging.getLogger() logger = logging.getLogger()
logger.error('Error loading config file: %s', e) logger.error('Error loading config file: %s', e)
sys.exit(1) sys.exit(1)
def get_response_from_server(self, url):
logger = logging.getLogger()
successful_response = False
while not successful_response:
try:
response = urllib.urlopen(url)
data = response.read()
successful_response = True
except IOError, e:
logger.error('Error Authenticating with remote server: %s', e)
except Exception, e:
logger.error('Couldn\'t connect to remote server. Is it running?')
logger.error("%s" % e)
if not successful_response:
time.sleep(5)
return data
def __get_airtime_version(self, verbose = True): def __get_airtime_version(self, verbose = True):
logger = logging.getLogger() logger = logging.getLogger()
@ -166,30 +186,13 @@ class AirTimeApiClient(ApiClientInterface):
version = -1 version = -1
response = None response = None
try: try:
response = urllib.urlopen(url) data = self.get_response_from_server(url)
data = response.read()
logger.debug("Data: %s", data) logger.debug("Data: %s", data)
response_json = json.loads(data) response_json = json.loads(data)
version = response_json['version'] version = response_json['version']
logger.debug("Airtime Version %s detected", version) logger.debug("Airtime Version %s detected", version)
except IOError, e:
logger.error("Unable to detect Airtime Version - %s, Response: %s", e, data)
if e[1] == 401:
if (verbose):
logger.info('#####################################')
logger.info('# YOUR API KEY SEEMS TO BE INVALID:')
logger.info('# ' + self.config["api_key"])
logger.info('#####################################')
if e[1] == 404:
if (verbose):
logger.info('#####################################')
logger.info('# Unable to contact the Airtime-API')
logger.info('# ' + url)
logger.info('#####################################')
return -1
except Exception, e: except Exception, e:
logger.error("Unable to detect Airtime Version - %s, Response: %s", e, data) logger.error("Unable to detect Airtime Version - %s", e)
return -1 return -1
return version return version
@ -241,7 +244,7 @@ class AirTimeApiClient(ApiClientInterface):
response = "" response = ""
status = 0 status = 0
try: try:
response_json = urllib.urlopen(export_url).read() response_json = self.get_response_from_server(export_url)
response = json.loads(response_json) response = json.loads(response_json)
status = response['check'] status = response['check']
except Exception, e: except Exception, e:
@ -331,9 +334,10 @@ class AirTimeApiClient(ApiClientInterface):
url = "http://%s:%s/%s/%s" % (self.config["base_url"], str(self.config["base_port"]), self.config["api_base"], self.config["show_schedule_url"]) url = "http://%s:%s/%s/%s" % (self.config["base_url"], str(self.config["base_port"]), self.config["api_base"], self.config["show_schedule_url"])
logger.debug(url) logger.debug(url)
url = url.replace("%%api_key%%", self.config["api_key"]) url = url.replace("%%api_key%%", self.config["api_key"])
response = self.get_response_from_server(url)
response = urllib.urlopen(url) response = json.loads(response)
response = json.loads(response.read())
logger.info("shows %s", response) logger.info("shows %s", response)
except Exception, e: except Exception, e:
@ -385,14 +389,9 @@ class AirTimeApiClient(ApiClientInterface):
url = "http://%s:%s/%s/%s" % (self.config["base_url"], str(self.config["base_port"]), self.config["api_base"], self.config["media_setup_url"]) url = "http://%s:%s/%s/%s" % (self.config["base_url"], str(self.config["base_port"]), self.config["api_base"], self.config["media_setup_url"])
url = url.replace("%%api_key%%", self.config["api_key"]) url = url.replace("%%api_key%%", self.config["api_key"])
response = urllib.urlopen(url) response = self.get_response_from_server(url)
response = json.loads(response.read()) response = json.loads(response)
logger.info("Connected to Airtime Server. Json Media Storage Dir: %s", response) logger.info("Connected to Airtime Server. Json Media Storage Dir: %s", response)
except IOError:
#this should be a common exception when media-monitor daemon
#has started before apache on bootup and apache isn't accepting
#connections yet.
response = None
except Exception, e: except Exception, e:
response = None response = None
logger.error("Exception: %s", e) logger.error("Exception: %s", e)