add max participant capacity feature to conference room

ant-media · Oct 24, 2023 · 8597d17 · 8597d17
1 parent 343d8b4
commit 8597d17
Show file tree

Hide file tree

Showing 3 changed files with 31 additions and 3 deletions.
diff --git a/src/main/java/io/antmedia/datastore/db/types/ConferenceRoom.java b/src/main/java/io/antmedia/datastore/db/types/ConferenceRoom.java
@@ -22,6 +22,8 @@
 public class ConferenceRoom {
 	public static final String MULTI_TRACK_MODE = "multitrack";
 
+	public static final int UNLIMITED_PARTICIPANT_CAPACITY = -1;
+
 	public static final String LEGACY_MODE = "legacy";
 
 	@JsonIgnore
@@ -43,7 +45,10 @@ public class ConferenceRoom {
 
 	@ApiModelProperty(value = "Conference Room Mode: legacy | mcu | multi-track")
 	private String mode = "legacy";
-
+
+	@ApiModelProperty(value = "Maximum number of participants/streams that can participate in conference room. Default is unlimited.")
+	private int maxParticipantCapacity = UNLIMITED_PARTICIPANT_CAPACITY;
+
 	@JsonIgnore
 	private boolean zombi;
 
@@ -109,5 +114,20 @@ public void setOriginAdress(String originAdress) {
 		this.originAdress = originAdress;
 	}
 
+	public boolean isCapacityFull(){
+		if(maxParticipantCapacity == UNLIMITED_PARTICIPANT_CAPACITY){
+			return false;
+		}
+		return roomStreamList.size() >= maxParticipantCapacity;
+	}
+
+	public int getMaxParticipantCapacity() {
+		return maxParticipantCapacity;
+	}
+
+	public void setMaxParticipantCapacity(int maxParticipantCapacity) {
+		this.maxParticipantCapacity = maxParticipantCapacity;
+	}
+
 }
 
diff --git a/src/main/java/io/antmedia/rest/RestServiceBase.java b/src/main/java/io/antmedia/rest/RestServiceBase.java
@@ -1782,6 +1782,10 @@ public static boolean addStreamToConferenceRoom(String roomId, String streamId,
 			return false;
 		}
 
+		if(conferenceRoom.isCapacityFull()){
+			return false;
+		}
+
 		List<String> roomStreamList = conferenceRoom.getRoomStreamList();
 		if (roomStreamList.contains(streamId)) {
 			return false;

diff --git a/src/main/java/io/antmedia/websocket/WebSocketConstants.java b/src/main/java/io/antmedia/websocket/WebSocketConstants.java
@@ -168,8 +168,12 @@ private WebSocketConstants() {
 	 * joining the video conference
 	 */
 	public static final String ROOM_TIME_INVALID = "room_not_active_or_expired";
-
-
+
+	/**
+	 * This is sent back to the user when conference room participant capacity is full.
+	 */
+	public static final String ROOM_CAPACITY_FULL = "room_capacity_full";
+
 	/**
 	 * This is sent back to the user when stream plannedStartDate and plannedEndDate 
 	 * values are in interval or not.