BigBlueButton/bigbluebutton-Github
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove unused EndAndKickAllSysMsg

Browse Source
This commit is contained in:
Gustavo Trott 2024-07-30 11:36:53 -03:00
parent aba8f3eff2
commit df6b86cd72
4 changed files with 3 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
akka-bbb-apps/src/main/scala/org/bigbluebutton/core2/message/handlers/meeting/DestroyMeetingSysCmdMsgHdlr.scala
View File

@ -26,7 +26,7 @@ trait DestroyMeetingSysCmdMsgHdlr {
}
// Eject all users using the client.
outGW.send(MsgBuilder.buildEndAndKickAllSysMsg(liveMeeting.props.meetingProp.intId, "not-used"))
//TODO check if it should remove Graphql connections at this moment
// Force stopping of voice recording if voice conf is being recorded.
VoiceApp.stopRecordingVoiceConference(liveMeeting, outGW)

10
akka-bbb-apps/src/main/scala/org/bigbluebutton/core2/message/senders/MsgBuilder.scala
View File

@ -216,16 +216,6 @@ object MsgBuilder {
BbbCommonEnvCoreMsg(envelope, event)
}
def buildEndAndKickAllSysMsg(meetingId: String, userId: String): BbbCommonEnvCoreMsg = {
val routing = Routing.addMsgToClientRouting(MessageTypes.SYSTEM, meetingId, userId)
val envelope = BbbCoreEnvelope(EndAndKickAllSysMsg.NAME, routing)
val body = EndAndKickAllSysMsgBody(meetingId)
val header = BbbCoreHeaderWithMeetingId(EndAndKickAllSysMsg.NAME, meetingId)
val event = EndAndKickAllSysMsg(header, body)
BbbCommonEnvCoreMsg(envelope, event)
}
def buildRecordStatusResetSysMsg(meetingId: String, recording: Boolean, setBy: String): BbbCommonEnvCoreMsg = {
val routing = Routing.addMsgToClientRouting(MessageTypes.SYSTEM, meetingId, setBy)
val envelope = BbbCoreEnvelope(RecordStatusResetSysMsg.NAME, routing)

4
akka-bbb-apps/src/main/scala/org/bigbluebutton/endpoint/redis/RedisRecorderActor.scala
View File

@ -115,7 +115,7 @@ class RedisRecorderActor(
case m: RecordingStatusChangedEvtMsg => handleRecordingStatusChangedEvtMsg(m)
case m: RecordStatusResetSysMsg => handleRecordStatusResetSysMsg(m)
case m: WebcamsOnlyForModeratorChangedEvtMsg => handleWebcamsOnlyForModeratorChangedEvtMsg(m)
case m: MeetingEndingEvtMsg => handleEndAndKickAllSysMsg(m)
case m: MeetingEndingEvtMsg => handleMeetingEndingEvtMsg(m)
case m: MeetingCreatedEvtMsg => handleStarterConfigurations(m)
// Recording
@ -637,7 +637,7 @@ class RedisRecorderActor(
record(msg.header.meetingId, ev.toMap.asJava)
}
private def handleEndAndKickAllSysMsg(msg: MeetingEndingEvtMsg): Unit = {
private def handleMeetingEndingEvtMsg(msg: MeetingEndingEvtMsg): Unit = {
val ev = new EndAndKickAllRecordEvent()
ev.setMeetingId(msg.header.meetingId)
ev.setReason(msg.body.reason)

7
bbb-common-message/src/main/scala/org/bigbluebutton/common2/msgs/SystemMsgs.scala
View File

@ -141,13 +141,6 @@ case class DisconnectAllClientsSysMsg(
) extends BbbCoreMsg
case class DisconnectAllClientsSysMsgBody(meetingId: String, reason: String)
object EndAndKickAllSysMsg { val NAME = "EndAndKickAllSysMsg" }
case class EndAndKickAllSysMsg(
header: BbbCoreHeaderWithMeetingId,
body: EndAndKickAllSysMsgBody
) extends BbbCoreMsg
case class EndAndKickAllSysMsgBody(meetingId: String)
object RecordStatusResetSysMsg { val NAME = "RecordStatusResetSysMsg" }
case class RecordStatusResetSysMsg(
header: BbbCoreHeaderWithMeetingId,