alemi/aioappsrv
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

feat: less crude but still raw, also for join

Browse source
This commit is contained in:
əlemi 2024-01-29 20:06:36 +01:00
parent d039f313c6
commit 870a4faa9b
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 13 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/aioappsrv/app.py
View file

@ -86,8 +86,11 @@ class AppService:
},
params={"user_id": mxid} if mxid else {},
) as res:
doc = await res.json()
self.logger.debug("joined room %s with %s : %s", room, mxid, doc)
if res.ok:
self.logger.debug("joined room %s with %s : %s", room, mxid, await res.json())
else:
self.logger.error("failed sending message: %s", await res.text())
raise ValueError()
async def leave_room(self):
raise NotImplementedError
@ -103,13 +106,14 @@ class AppService:
params={"user_id": mxid} if mxid else {},
json=mx_message(text),
) as res:
if res.ok:
doc = await res.json()
if "event_id" in doc:
self.logger.debug("sent message %s to %s as %s : %s", text, room, mxid, doc)
return doc["event_id"]
else:
self.logger.error("failed sending message: %s", doc)
raise ValueError(doc)
text = await res.text()
self.logger.error("failed sending message: %s", text)
raise ValueError()
async def redact_message(self):
raise NotImplementedError