tfa/rte
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Ajout gestion d'erreur

Browse Source
This commit is contained in:
tfa
2022-12-06 12:44:03 +01:00
parent 933a45f2a8
commit 60dd02bf63
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
rte.py
View File

@@ -25,11 +25,17 @@ class Rte(Plugin):
await evt.mark_read() await evt.mark_read()
resp = await self.http.post(self.config["auth_url"], headers={'Authorization' : 'Basic ' + self.config["token"]}) resp = await self.http.post(self.config["auth_url"], headers={'Authorization' : 'Basic ' + self.config["token"]})
ans = await resp.text() ans = await resp.text()
objet = json.loads(ans) objet = json.loads(ans)
bearer = objet["access_token"] bearer = objet["access_token"]
resp = await self.http.get(self.config["ecowatt_url"], headers={'Authorization' : 'Bearer ' + bearer}) resp = await self.http.get(self.config["ecowatt_url"], headers={'Authorization' : 'Bearer ' + bearer})
ans = await resp.text() ans = await resp.text()
try:
resp.raise_for_status()
except aiohttp.ClientError as error:
await evt.respond(str(error))
return
objet = json.loads(ans) objet = json.loads(ans)
signals = objet["signals"] signals = objet["signals"]
for signal in signals: for signal in signals: