- implement voice messages

bigbluebutton · Jun 1, 2015 · 04b5e4f · 04b5e4f
1 parent 855ab96
commit 04b5e4f
Show file tree

Hide file tree

Showing 63 changed files with 2,267 additions and 236 deletions.
diff --git a/...main/java/org/bigbluebutton/common/messages/EjectAllUsersFromVoiceConfRequestMessage.java b/...main/java/org/bigbluebutton/common/messages/EjectAllUsersFromVoiceConfRequestMessage.java
@@ -0,0 +1,56 @@
+package org.bigbluebutton.common.messages;
+
+import java.util.HashMap;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+
+public class EjectAllUsersFromVoiceConfRequestMessage {
+	public static final String EJECT_ALL_VOICE_USERS_REQUEST  = "eject_all_users_from_voice_conf_request_message";
+	public static final String VERSION = "0.0.1";
+
+	public static final String MEETING_ID = "meeting_id";
+	public static final String VOICE_CONF_ID = "voice_conf_id";
+
+	public final String meetingId;
+	public final String voiceConfId;
+
+	public EjectAllUsersFromVoiceConfRequestMessage(String meetingId, String voiceConfId) {
+		this.meetingId = meetingId;
+		this.voiceConfId = voiceConfId;
+	}
+
+	public String toJson() {
+		HashMap<String, Object> payload = new HashMap<String, Object>();
+		payload.put(MEETING_ID, meetingId); 
+		payload.put(VOICE_CONF_ID, voiceConfId);
+
+		java.util.HashMap<String, Object> header = MessageBuilder.buildHeader(EJECT_ALL_VOICE_USERS_REQUEST, VERSION, null);
+
+		return MessageBuilder.buildJson(header, payload);				
+	}
+
+	public static EjectAllUsersFromVoiceConfRequestMessage fromJson(String message) {
+		JsonParser parser = new JsonParser();
+		JsonObject obj = (JsonObject) parser.parse(message);
+
+		if (obj.has("header") && obj.has("payload")) {
+			JsonObject header = (JsonObject) obj.get("header");
+			JsonObject payload = (JsonObject) obj.get("payload");
+
+			if (header.has("name")) {
+				String messageName = header.get("name").getAsString();
+				if (EJECT_ALL_VOICE_USERS_REQUEST.equals(messageName)) {
+					if (payload.has(MEETING_ID) 
+							&& payload.has(VOICE_CONF_ID)) {
+						String id = payload.get(MEETING_ID).getAsString();
+						String voiceConfId = payload.get(VOICE_CONF_ID).getAsString();
+						return new EjectAllUsersFromVoiceConfRequestMessage(id, voiceConfId);					
+					}
+				} 
+			}
+		}
+		return null;
+
+	}
+}
diff --git a/...src/main/java/org/bigbluebutton/common/messages/EjectUserFromVoiceConfRequestMessage.java b/...src/main/java/org/bigbluebutton/common/messages/EjectUserFromVoiceConfRequestMessage.java
@@ -0,0 +1,62 @@
+package org.bigbluebutton.common.messages;
+
+import java.util.HashMap;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+
+public class EjectUserFromVoiceConfRequestMessage {
+	public static final String EJECT_VOICE_USER_REQUEST  = "eject_user_from_voice_conf_request_message";
+	public static final String VERSION = "0.0.1";
+
+	public static final String MEETING_ID = "meeting_id";
+	public static final String VOICE_CONF_ID = "voice_conf_id";
+	public static final String VOICE_USER_ID = "voice_user_id";
+
+	public final String meetingId;
+	public final String voiceConfId;
+	public final String voiceUserId;
+
+	public EjectUserFromVoiceConfRequestMessage(String meetingId, String voiceConfId, String voiceUserId) {
+		this.meetingId = meetingId;
+		this.voiceConfId = voiceConfId;
+		this.voiceUserId = voiceUserId;
+	}
+
+	public String toJson() {
+		HashMap<String, Object> payload = new HashMap<String, Object>();
+		payload.put(MEETING_ID, meetingId); 
+		payload.put(VOICE_CONF_ID, voiceConfId);
+		payload.put(VOICE_USER_ID, voiceUserId);
+
+		java.util.HashMap<String, Object> header = MessageBuilder.buildHeader(EJECT_VOICE_USER_REQUEST, VERSION, null);
+
+		return MessageBuilder.buildJson(header, payload);				
+	}
+
+	public static EjectUserFromVoiceConfRequestMessage fromJson(String message) {
+		JsonParser parser = new JsonParser();
+		JsonObject obj = (JsonObject) parser.parse(message);
+
+		if (obj.has("header") && obj.has("payload")) {
+			JsonObject header = (JsonObject) obj.get("header");
+			JsonObject payload = (JsonObject) obj.get("payload");
+
+			if (header.has("name")) {
+				String messageName = header.get("name").getAsString();
+				if (EJECT_VOICE_USER_REQUEST.equals(messageName)) {
+					if (payload.has(MEETING_ID) 
+							&& payload.has(VOICE_CONF_ID)
+							&& payload.has(VOICE_USER_ID)) {
+						String id = payload.get(MEETING_ID).getAsString();
+						String voiceConfId = payload.get(VOICE_CONF_ID).getAsString();
+						String voiceUserId = payload.get(VOICE_USER_ID).getAsString();
+						return new EjectUserFromVoiceConfRequestMessage(id, voiceConfId, voiceUserId);					
+					}
+				} 
+			}
+		}
+		return null;
+
+	}
+}
diff --git a/.../src/main/java/org/bigbluebutton/common/messages/GetUsersFromVoiceConfRequestMessage.java b/.../src/main/java/org/bigbluebutton/common/messages/GetUsersFromVoiceConfRequestMessage.java
@@ -0,0 +1,56 @@
+package org.bigbluebutton.common.messages;
+
+import java.util.HashMap;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+
+public class GetUsersFromVoiceConfRequestMessage {
+	public static final String GET_VOICE_USERS_REQUEST  = "get_users_from_voice_conf_request_message";
+	public static final String VERSION = "0.0.1";
+
+	public static final String MEETING_ID = "meeting_id";
+	public static final String VOICE_CONF_ID = "voice_conf_id";
+
+	public final String meetingId;
+	public final String voiceConfId;
+
+	public GetUsersFromVoiceConfRequestMessage(String meetingId, String voiceConfId) {
+		this.meetingId = meetingId;
+		this.voiceConfId = voiceConfId;
+	}
+
+	public String toJson() {
+		HashMap<String, Object> payload = new HashMap<String, Object>();
+		payload.put(MEETING_ID, meetingId); 
+		payload.put(VOICE_CONF_ID, voiceConfId);
+
+		java.util.HashMap<String, Object> header = MessageBuilder.buildHeader(GET_VOICE_USERS_REQUEST, VERSION, null);
+
+		return MessageBuilder.buildJson(header, payload);				
+	}
+
+	public static GetUsersFromVoiceConfRequestMessage fromJson(String message) {
+		JsonParser parser = new JsonParser();
+		JsonObject obj = (JsonObject) parser.parse(message);
+
+		if (obj.has("header") && obj.has("payload")) {
+			JsonObject header = (JsonObject) obj.get("header");
+			JsonObject payload = (JsonObject) obj.get("payload");
+
+			if (header.has("name")) {
+				String messageName = header.get("name").getAsString();
+				if (GET_VOICE_USERS_REQUEST.equals(messageName)) {
+					if (payload.has(MEETING_ID) 
+							&& payload.has(VOICE_CONF_ID)) {
+						String id = payload.get(MEETING_ID).getAsString();
+						String voiceConfId = payload.get(VOICE_CONF_ID).getAsString();
+						return new GetUsersFromVoiceConfRequestMessage(id, voiceConfId);					
+					}
+				} 
+			}
+		}
+		return null;
+
+	}
+}
diff --git a/labs/akka-bbb-apps/src/main/java/org/bigbluebutton/common/messages/MessagingConstants.java b/labs/akka-bbb-apps/src/main/java/org/bigbluebutton/common/messages/MessagingConstants.java
@@ -41,6 +41,13 @@ public class MessagingConstants {
 	public static final String TO_VOICE_CHANNEL = TO_BBB_APPS_CHANNEL + ":voice";
 	public static final String TO_WHITEBOARD_CHANNEL = TO_BBB_APPS_CHANNEL + ":whiteboard";
 
+	public static final String TO_VOICE_CONF_CHANNEL = "bigbluebutton:to-voice-conf";	
+	public static final String TO_VOICE_CONF_PATTERN = TO_VOICE_CONF_CHANNEL + ":*";
+	public static final String TO_VOICE_CONF_SYSTEM_CHAN = TO_VOICE_CONF_CHANNEL + ":system";
+	public static final String FROM_VOICE_CONF_CHANNEL = "bigbluebutton:from-voice-conf";	
+	public static final String FROM_VOICE_CONF_PATTERN = FROM_VOICE_CONF_CHANNEL + ":*";
+	public static final String FROM_VOICE_CONF_SYSTEM_CHAN = FROM_VOICE_CONF_CHANNEL + ":system";
+
 	public static final String DESTROY_MEETING_REQUEST_EVENT = "DestroyMeetingRequestEvent";
 	public static final String CREATE_MEETING_REQUEST_EVENT = "CreateMeetingRequestEvent";	
 	public static final String END_MEETING_REQUEST_EVENT = "EndMeetingRequestEvent";

diff --git a/...ps/src/main/java/org/bigbluebutton/common/messages/MuteUserInVoiceConfRequestMessage.java b/...ps/src/main/java/org/bigbluebutton/common/messages/MuteUserInVoiceConfRequestMessage.java
@@ -0,0 +1,68 @@
+package org.bigbluebutton.common.messages;
+
+import java.util.HashMap;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+
+public class MuteUserInVoiceConfRequestMessage {
+	public static final String MUTE_VOICE_USER_REQUEST  = "mute_user_in_voice_conf_request_message";
+	public static final String VERSION = "0.0.1";
+
+	public static final String MEETING_ID = "meeting_id";
+	public static final String VOICE_CONF_ID = "voice_conf_id";
+	public static final String VOICE_USER_ID = "voice_user_id";
+	public static final String MUTE = "mute";
+
+	public final String meetingId;
+	public final String voiceConfId;
+	public final String voiceUserId;
+	public final Boolean mute;
+
+	public MuteUserInVoiceConfRequestMessage(String meetingId, String voiceConfId, String voiceUserId, Boolean mute) {
+		this.meetingId = meetingId;
+		this.voiceConfId = voiceConfId;
+		this.voiceUserId = voiceUserId;
+		this.mute = mute;
+	}
+
+	public String toJson() {
+		HashMap<String, Object> payload = new HashMap<String, Object>();
+		payload.put(MEETING_ID, meetingId); 
+		payload.put(VOICE_CONF_ID, voiceConfId);
+		payload.put(VOICE_USER_ID, voiceUserId);
+		payload.put(MUTE, mute);
+
+		java.util.HashMap<String, Object> header = MessageBuilder.buildHeader(MUTE_VOICE_USER_REQUEST, VERSION, null);
+
+		return MessageBuilder.buildJson(header, payload);				
+	}
+
+	public static MuteUserInVoiceConfRequestMessage fromJson(String message) {
+		JsonParser parser = new JsonParser();
+		JsonObject obj = (JsonObject) parser.parse(message);
+
+		if (obj.has("header") && obj.has("payload")) {
+			JsonObject header = (JsonObject) obj.get("header");
+			JsonObject payload = (JsonObject) obj.get("payload");
+
+			if (header.has("name")) {
+				String messageName = header.get("name").getAsString();
+				if (MUTE_VOICE_USER_REQUEST.equals(messageName)) {
+					if (payload.has(MEETING_ID) 
+							&& payload.has(VOICE_CONF_ID)
+							&& payload.has(VOICE_USER_ID)
+							&& payload.has(MUTE)) {
+						String id = payload.get(MEETING_ID).getAsString();
+						String voiceConfId = payload.get(VOICE_CONF_ID).getAsString();
+						String voiceUserId = payload.get(VOICE_USER_ID).getAsString();
+						Boolean mute = payload.get(MUTE).getAsBoolean();
+						return new MuteUserInVoiceConfRequestMessage(id, voiceConfId, voiceUserId, mute);					
+					}
+				} 
+			}
+		}
+		return null;
+
+	}
+}
diff --git a/...b-apps/src/main/java/org/bigbluebutton/common/messages/RecordVoiceConfRequestMessage.java b/...b-apps/src/main/java/org/bigbluebutton/common/messages/RecordVoiceConfRequestMessage.java
@@ -0,0 +1,62 @@
+package org.bigbluebutton.common.messages;
+
+import java.util.HashMap;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+
+public class RecordVoiceConfRequestMessage {
+	public static final String RECORD_VOICE_CONF_REQUEST  = "record_voice_conf_request_message";
+	public static final String VERSION = "0.0.1";
+
+	public static final String MEETING_ID = "meeting_id";
+	public static final String VOICE_CONF_ID = "voice_conf_id";
+	public static final String RECORD = "record";
+
+	public final String meetingId;
+	public final String voiceConfId;
+	public final Boolean record;
+
+	public RecordVoiceConfRequestMessage(String meetingId, String voiceConfId, Boolean record) {
+		this.meetingId = meetingId;
+		this.voiceConfId = voiceConfId;
+		this.record = record;
+	}
+
+	public String toJson() {
+		HashMap<String, Object> payload = new HashMap<String, Object>();
+		payload.put(MEETING_ID, meetingId); 
+		payload.put(VOICE_CONF_ID, voiceConfId);
+		payload.put(RECORD, record);
+
+		java.util.HashMap<String, Object> header = MessageBuilder.buildHeader(RECORD_VOICE_CONF_REQUEST, VERSION, null);
+
+		return MessageBuilder.buildJson(header, payload);				
+	}
+
+	public static RecordVoiceConfRequestMessage fromJson(String message) {
+		JsonParser parser = new JsonParser();
+		JsonObject obj = (JsonObject) parser.parse(message);
+
+		if (obj.has("header") && obj.has("payload")) {
+			JsonObject header = (JsonObject) obj.get("header");
+			JsonObject payload = (JsonObject) obj.get("payload");
+
+			if (header.has("name")) {
+				String messageName = header.get("name").getAsString();
+				if (RECORD_VOICE_CONF_REQUEST.equals(messageName)) {
+					if (payload.has(MEETING_ID) 
+							&& payload.has(VOICE_CONF_ID)
+							&& payload.has(RECORD)) {
+						String id = payload.get(MEETING_ID).getAsString();
+						String voiceConfId = payload.get(VOICE_CONF_ID).getAsString();
+						Boolean record = payload.get(RECORD).getAsBoolean();
+						return new RecordVoiceConfRequestMessage(id, voiceConfId, record);					
+					}
+				} 
+			}
+		}
+		return null;
+
+	}
+}
diff --git a/...rc/main/java/org/bigbluebutton/common/messages/StartRecordingVoiceConfRequestMessage.java b/...rc/main/java/org/bigbluebutton/common/messages/StartRecordingVoiceConfRequestMessage.java
@@ -0,0 +1,56 @@
+package org.bigbluebutton.common.messages;
+
+import java.util.HashMap;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+
+
+public class StartRecordingVoiceConfRequestMessage {
+	public static final String START_RECORD_VOICE_CONF_REQUEST  = "start_recording__voice_conf_request_message";
+	public static final String VERSION = "0.0.1";
+
+	public static final String MEETING_ID = "meeting_id";
+	public static final String VOICE_CONF_ID = "voice_conf_id";
+
+	public final String meetingId;
+	public final String voiceConfId;
+
+	public StartRecordingVoiceConfRequestMessage(String meetingId, String voiceConfId) {
+		this.meetingId = meetingId;
+		this.voiceConfId = voiceConfId;
+	}
+
+	public String toJson() {
+		HashMap<String, Object> payload = new HashMap<String, Object>();
+		payload.put(MEETING_ID, meetingId); 
+		payload.put(VOICE_CONF_ID, voiceConfId);
+
+		java.util.HashMap<String, Object> header = MessageBuilder.buildHeader(START_RECORD_VOICE_CONF_REQUEST, VERSION, null);
+
+		return MessageBuilder.buildJson(header, payload);				
+	}
+
+	public static StartRecordingVoiceConfRequestMessage fromJson(String message) {
+		JsonParser parser = new JsonParser();
+		JsonObject obj = (JsonObject) parser.parse(message);
+
+		if (obj.has("header") && obj.has("payload")) {
+			JsonObject header = (JsonObject) obj.get("header");
+			JsonObject payload = (JsonObject) obj.get("payload");
+
+			if (header.has("name")) {
+				String messageName = header.get("name").getAsString();
+				if (START_RECORD_VOICE_CONF_REQUEST.equals(messageName)) {
+					if (payload.has(MEETING_ID) 
+							&& payload.has(VOICE_CONF_ID)) {
+						String id = payload.get(MEETING_ID).getAsString();
+						String voiceConfId = payload.get(VOICE_CONF_ID).getAsString();
+						return new StartRecordingVoiceConfRequestMessage(id, voiceConfId);					
+					}
+				} 
+			}
+		}
+		return null;
+
+	}
+}