jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-13 08:17:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing Client connection error (#7991)

Browse Source
This commit is contained in:
sander76 2017-06-12 06:42:35 +02:00 committed by Paulus Schoutsen
parent e7de1fb9ae
commit 1c06b51968
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
homeassistant/components/telegram_bot/polling.py
View File

@ -79,7 +79,7 @@ class TelegramPoll(BaseTelegramBotEntity):
def get_updates(self, offset): def get_updates(self, offset):
"""Bypass the default long polling method to enable asyncio.""" """Bypass the default long polling method to enable asyncio."""
resp = None resp = None
_json = [] # The actual value to be returned. _json = {'result': [], 'ok': True} # Empty result.
if offset: if offset:
self.post_data['offset'] = offset self.post_data['offset'] = offset
@ -89,9 +89,11 @@ class TelegramPoll(BaseTelegramBotEntity):
self.update_url, data=self.post_data, self.update_url, data=self.post_data,
headers={'connection': 'keep-alive'} headers={'connection': 'keep-alive'}
) )
if resp.status != 200: if resp.status == 200:
_json = yield from resp.json()
else:
_LOGGER.error("Error %s on %s", resp.status, self.update_url) _LOGGER.error("Error %s on %s", resp.status, self.update_url)
_json = yield from resp.json()
except ValueError: except ValueError:
_LOGGER.error("Error parsing Json message") _LOGGER.error("Error parsing Json message")
except (asyncio.TimeoutError, ClientError): except (asyncio.TimeoutError, ClientError):
@ -106,9 +108,13 @@ class TelegramPoll(BaseTelegramBotEntity):
def handle(self): def handle(self):
"""Receiving and processing incoming messages.""" """Receiving and processing incoming messages."""
_updates = yield from self.get_updates(self.update_id) _updates = yield from self.get_updates(self.update_id)
for update in _updates['result']: _updates = _updates.get('result')
self.update_id = update['update_id'] + 1 if _updates is None:
self.process_message(update) _LOGGER.error("Incorrect result received.")
else:
for update in _updates:
self.update_id = update['update_id'] + 1
self.process_message(update)
@asyncio.coroutine @asyncio.coroutine
def check_incoming(self): def check_incoming(self):