INNER CODE UNIT · Python
room_users
leonh/redis-streams-fastapi-chat · chat.py:273
async def room_users(chat_info: dict, pool):
#users = await pool.smembers(chat_info['room']+":users")
users = await pool.smembers(cvar_tenant.get()+":users")
print(len(users))
return users
async def announce(pool, chat_info: dict, action: str):
"""
add an announcement event onto the redis chat stream
"""
users = await room_users(chat_info, pool)
fields = {
'msg': f"{chat_info['username']} {action}",
'action': action,
'type': 'announcement',
'users': ", ".join(users),
'room': chat_info['room']