Update.
This commit is contained in:
parent
27c0abea31
commit
b365afc910
@ -13,12 +13,15 @@ class ChannelModel(BaseModel):
|
||||
last_message_on = ModelField(name="last_message_on", required=False, kind=str)
|
||||
|
||||
async def get_last_message(self) -> ChannelMessageModel:
|
||||
async for model in self.app.services.channel_message.query(
|
||||
"SELECT uid FROM channel_message WHERE channel_uid=:channel_uid ORDER BY created_at DESC LIMIT 1",
|
||||
{"channel_uid": self["uid"]},
|
||||
):
|
||||
try:
|
||||
async for model in self.app.services.channel_message.query(
|
||||
"SELECT uid FROM channel_message WHERE channel_uid=:channel_uid ORDER BY created_at DESC LIMIT 1",
|
||||
{"channel_uid": self["uid"]},
|
||||
):
|
||||
|
||||
return await self.app.services.channel_message.get(uid=model["uid"])
|
||||
return await self.app.services.channel_message.get(uid=model["uid"])
|
||||
except:
|
||||
pass
|
||||
return None
|
||||
|
||||
async def get_members(self):
|
||||
|
Loading…
Reference in New Issue
Block a user