diff --git a/src/snek/system/service.py b/src/snek/system/service.py index baf2086..a088854 100644 --- a/src/snek/system/service.py +++ b/src/snek/system/service.py @@ -59,7 +59,7 @@ class BaseService: async def find(self, **kwargs): if not "_limit" in kwargs or int(kwargs.get("_limit")) > 30: - kwargs["_limit"] = 30 + kwargs["_limit"] = 60 async for model in self.mapper.find(**kwargs): yield model diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py index d4ed660..97d58f4 100644 --- a/src/snek/view/rpc.py +++ b/src/snek/view/rpc.py @@ -25,7 +25,7 @@ class RPCView(BaseView): return record async def get_messages(self, channel_uid,offset=0): messages = [] - async for message in self.services.channel_message.query("SELECT * FROM channel_message ORDER BY created_at DESC LIMIT 30"): #"SELECT uid, channel_uid, user_uid, message, created_at FROM channel_message WHERE channel_uid = :channel_uid ORDER BY created_at DESC LIMIT 30 OFFSET :offset",{"channel_uid":channel_uid,"offset":int(offset)}): + async for message in self.services.channel_message.query("SELECT * FROM channel_message ORDER BY created_at DESC LIMIT 60"): #"SELECT uid, channel_uid, user_uid, message, created_at FROM channel_message WHERE channel_uid = :channel_uid ORDER BY created_at DESC LIMIT 30 OFFSET :offset",{"channel_uid":channel_uid,"offset":int(offset)}): user = await self.services.user.get(uid=message["user_uid"]) if not user: