Fixed a few bugs.

This commit is contained in:
retoor 2025-12-15 00:10:50 +01:00
parent 0ad8f6cb31
commit 0e083268c6

View File

@ -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)