Fix: delete if from allow_speaker

#30
Files changed (1) hide show
  1. seamless_server/app_pubsub.py +7 -0
seamless_server/app_pubsub.py CHANGED
@@ -558,6 +558,13 @@ async def join_room(sid, client_id, room_id_from_client, config_dict):
558
 
559
  return {"roomsJoined": sio.rooms(sid), "roomID": room_id}
560
 
 
 
 
 
 
 
 
561
  def check_and_lock_single_user(client_id, member):
562
  global server_lock
563
 
 
558
 
559
  return {"roomsJoined": sio.rooms(sid), "roomID": room_id}
560
 
561
+ def allow_speaker(room, client_id):
562
+ if MAX_SPEAKERS is not None and client_id in room.speakers:
563
+ room_statuses = {room_id: room.get_room_status_dict() for room_id, room in rooms.items()}
564
+ speakers = sum(room_status["activeTranscoders"] for room_status in room_statuses.values())
565
+ return speakers < int(MAX_SPEAKERS)
566
+ return True
567
+
568
  def check_and_lock_single_user(client_id, member):
569
  global server_lock
570