retoor/snek
1
0
Fork 1
Code Issues 10 Pull Requests Actions Packages Projects Releases Wiki Activity

Updated online users.

Browse Source
This commit is contained in:
retoor
2025-05-27 22:16:41 +02:00
parent 2fd01a5ab7
commit 03f699e448
4 changed files with 3 additions and 2854 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/snek/service/channel.py
+1 -1
View File
@@ -68,7 +68,7 @@ class ChannelService(BaseService):
return channel
async def get_recent_users(self, channel_uid):
async for user in self.query("SELECT user.uid, user.username,user.color,user.last_ping,user.nick FROM channel_member INNER JOIN user ON user.uid = channel_member.user_uid WHERE channel_uid=:channel_uid ORDER BY last_ping DESC LIMIT 30", {"channel_uid": channel_uid}):
async for user in self.query("SELECT user.uid, user.username,user.color,user.last_ping,user.nick FROM channel_member INNER JOIN user ON user.uid = channel_member.user_uid WHERE channel_uid=:channel_uid AND user.last_ping >= datetime('now', '-3 minutes') ORDER BY last_ping DESC LIMIT 30", {"channel_uid": channel_uid}):
yield user
async def get_users(self, channel_uid):
src/snek/view/rpc.py
+2 -6
View File
@@ -314,13 +314,9 @@ class RPCView(BaseView):
self._require_login()
results = [
record.record async for record in self.services.channel.get_online_users(channel_uid)
record async for record in self.services.channel.get_recent_users(channel_uid)
]
for result in results:
del result['email']
del result['password']
del result['deleted_at']
del result['updated_at']
sorted(results, key=lambda x: x["nick"])
return results
async def echo(self, obj):