Limit video senders

src/main/java/org/jitsi/impl/protocol/xmpp/ChatRoomImpl.java

@@ -589,12 +589,22 @@ public void addVideoSender()
     {
         ++numVideoSenders;
         logger.debug(() -> "The number of video senders has increased to " + numVideoSenders + ".");
+
+        eventEmitter.fireEvent(handler -> {
+            handler.numVideoSendersChanged(numVideoSenders);
+            return Unit.INSTANCE;
+        });
     }
 
     public void removeVideoSender()
     {
         --numVideoSenders;
         logger.debug(() -> "The number of video senders has decreased to " + numVideoSenders + ".");
+
+        eventEmitter.fireEvent(handler -> {
+            handler.numVideoSendersChanged(numVideoSenders);
+            return Unit.INSTANCE;
+        });
     }
 
     /**

src/main/java/org/jitsi/jicofo/conference/JitsiMeetConferenceImpl.java

@@ -115,7 +115,7 @@ public class JitsiMeetConferenceImpl
     @NotNull
     private final JitsiMeetConfig config;
 
-    private final ChatRoomListener chatRoomListener = new ChatRoomListenerImpl();
+    private final ChatRoomListener chatRoomListener = new ChatRoomListenerImpl(this);
 
     /**
      * Conference room chat instance.
@@ -228,6 +228,11 @@ public class JitsiMeetConferenceImpl
      */
     private final ValidatingConferenceSourceMap conferenceSources = new ValidatingConferenceSourceMap();
 
+    /**
+     * Whether the limit on the number of video senders is currently hit.
+     */
+    private boolean videoLimitReached = false;
+
     /**
      * Creates new instance of {@link JitsiMeetConferenceImpl}.
      *
@@ -526,6 +531,19 @@ private void setConferenceProperty(String key, String value, boolean updatePrese
         }
     }
 
+    /**
+     * Process the new number of video senders reported by the chat room.
+     */
+    private void numVideoSendersChanged(int numVideoSenders)
+    {
+        boolean newValue = numVideoSenders >= ConferenceConfig.config.getMaxVideoSenders();
+        if (videoLimitReached != newValue)
+        {
+            videoLimitReached = newValue;
+            setConferenceProperty("video-limit-reached", String.valueOf(videoLimitReached));
+        }
+    }
+
     /**
      * Leaves the conference room.
      */
@@ -2425,6 +2443,12 @@ public void bridgeAdded(Bridge bridge)
 
     private class ChatRoomListenerImpl implements ChatRoomListener
     {
+        private final JitsiMeetConferenceImpl conference;
+        private ChatRoomListenerImpl(JitsiMeetConferenceImpl conference)
+        {
+            this.conference = conference;
+        }
+
         @Override
         public void roomDestroyed(@NotNull String reason)
         {
@@ -2471,5 +2495,11 @@ public void localRoleChanged(@NotNull MemberRole newRole, @Nullable MemberRole o
         public void memberPresenceChanged(@NotNull ChatRoomMember member)
         {
         }
+
+        @Override
+        public void numVideoSendersChanged(int numVideoSenders)
+        {
+            conference.numVideoSendersChanged(numVideoSenders);
+        }
     }
 }

src/main/kotlin/org/jitsi/jicofo/xmpp/muc/ChatRoomListener.kt

@@ -29,6 +29,7 @@ interface ChatRoomListener {
     fun roomDestroyed(reason: String) {}
     fun startMutedChanged(startAudioMuted: Boolean, startVideoMuted: Boolean) {}
     fun localRoleChanged(newRole: MemberRole, oldRole: MemberRole? = null) {}
+    fun numVideoSendersChanged(numVideoSenders: Int) {}
 }
 
 /** A class with the default kotlin method implementations (to avoid using @JvmDefault) **/