diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py index 7d73db3..ef19c3c 100644 --- a/src/snek/view/rpc.py +++ b/src/snek/view/rpc.py @@ -64,7 +64,7 @@ class RPCView(BaseView): return await self.services.socket.broadcast( channel_uid, { - "channel_uid": "293ecf12-08c9-494b-b423-48ba1a2d12c2", + "channel_uid": channel_uid, "event": "set_typing", "data": { "event": "set_typing", @@ -95,9 +95,9 @@ class RPCView(BaseView): self.user_uid, table_name, record, keys ) - async def db_query(self, table_name, args): + async def db_query(self, sql, args): self._require_login() - return await self.services.db.query(self.user_uid, table_name, sql, args) + return await self.services.db.query(self.user_uid, sql, args) @property def user_uid(self): @@ -457,7 +457,7 @@ class RPCView(BaseView): channel = await self.services.channel.get(uid=channel_uid) if not channel: raise Exception("Channel not found") - channel['history_start'] = datetime.now() + channel['history_start'] = now() await self.services.channel.save(channel) return await self.services.channel_message.clear(channel_uid)