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

add published/unpublished/deleted events on webhooks

Browse Source
This commit is contained in:
Felipe Cecagno 2019-02-01 00:06:42 -03:00
parent 8f6a9dd388
commit 4bb7262958
2 changed files with 43 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bbb-webhooks/config.js
View File

@ -20,11 +20,12 @@ if (!config.hooks) { config.hooks = {}; }
if (!config.hooks.channels) {
config.hooks.channels = {
mainChannel: 'from-akka-apps-redis-channel',
rapChannel: 'bigbluebutton:from-rap',
rapChannel: 'from-bbb-web-redis-channel',
chatChannel: 'from-akka-apps-chat-redis-channel',
compMeetingChannel: 'bigbluebutton:from-bbb-apps:meeting',
compUserChannel: 'bigbluebutton:from-bbb-apps:users',
compChatChannel: 'bigbluebutton:from-bbb-apps:chat'
compChatChannel: 'bigbluebutton:from-bbb-apps:chat',
compRapChannel: 'bigbluebutton:from-rap'
}
}
// IP where permanent hook will post data (more than 1 URL means more than 1 permanent hook)

46
bbb-webhooks/messageMapping.js
View File

@ -10,10 +10,10 @@ module.exports = class MessageMapping {
this.meetingEvents = ["MeetingCreatedEvtMsg","MeetingDestroyedEvtMsg", "ScreenshareRtmpBroadcastStartedEvtMsg", "ScreenshareRtmpBroadcastStoppedEvtMsg", "SetCurrentPresentationEvtMsg", "RecordingStatusChangedEvtMsg"];
this.userEvents = ["UserJoinedMeetingEvtMsg","UserLeftMeetingEvtMsg","UserJoinedVoiceConfToClientEvtMsg","UserLeftVoiceConfToClientEvtMsg","PresenterAssignedEvtMsg", "PresenterUnassignedEvtMsg", "UserBroadcastCamStartedEvtMsg", "UserBroadcastCamStoppedEvtMsg", "UserEmojiChangedEvtMsg"];
this.chatEvents = ["SendPublicMessageEvtMsg","SendPrivateMessageEvtMsg"];
this.rapEvents = ["archive_started","archive_ended","sanity_started","sanity_ended","post_archive_started","post_archive_ended","process_started","process_ended","post_process_started","post_process_ended","publish_started","publish_ended","post_publish_started","post_publish_ended"];
this.rapEvents = ["PublishedRecordingSysMsg","UnpublishedRecordingSysMsg","DeletedRecordingSysMsg"];
this.compMeetingEvents = ["meeting_created_message","meeting_destroyed_event"];
this.compUserEvents = ["user_joined_message","user_left_message","user_listening_only","user_joined_voice_message","user_left_voice_message","user_shared_webcam_message","user_unshared_webcam_message","user_status_changed_message"];
this.compRapEvents = ["archive_started","archive_ended","sanity_started","sanity_ended","post_archive_started","post_archive_ended","process_started","process_ended","post_process_started","post_process_ended","publish_started","publish_ended","post_publish_started","post_publish_ended","published","unpublished","deleted"];
}
// Map internal message based on it's type
@ -30,6 +30,8 @@ module.exports = class MessageMapping {
this.compMeetingTemplate(messageObj);
} else if (this.mappedEvent(messageObj,this.compUserEvents)) {
this.compUserTemplate(messageObj);
} else if (this.mappedEvent(messageObj,this.compRapEvents)) {
this.compRapTemplate(messageObj);
}
}
@ -256,6 +258,25 @@ module.exports = class MessageMapping {
}
rapTemplate(messageObj) {
const data = messageObj.core.body;
this.mappedObject.data = {
"type": "event",
"id": this.mapInternalMessage(messageObj),
"attributes": {
"meeting": {
"internal-meeting-id": data.recordId,
"external-meeting-id": IDMapping.getExternalMeetingID(data.recordId)
}
},
"event": {
"ts": Date.now()
}
};
this.mappedMessage = JSON.stringify(this.mappedObject);
Logger.info("[MessageMapping] Mapped message:", this.mappedMessage);
}
compRapTemplate(messageObj) {
const data = messageObj.payload;
this.mappedObject.data = {
"type": "event",
@ -264,16 +285,23 @@ module.exports = class MessageMapping {
"meeting": {
"internal-meeting-id": data.meeting_id,
"external-meeting-id": data.external_meeting_id || IDMapping.getExternalMeetingID(data.meeting_id)
},
"record-id": data.record_id,
"success": data.success,
"step-time": data.step_time
}
},
"event": {
"ts": messageObj.header.current_time
}
};
if (this.mappedObject.data.id === "published" ||
this.mappedObject.data.id === "unpublished" ||
this.mappedObject.data.id === "deleted") {
this.mappedObject.data.attributes["format"] = data.format;
} else {
this.mappedObject.data.attributes["record-id"] = data.record_id;
this.mappedObject.data.attributes["success"] = data.success;
this.mappedObject.data.attributes["step-time"] = data.step_time;
}
if (data.workflow) {
this.mappedObject.data.attributes.workflow = data.workflow;
}
@ -334,6 +362,12 @@ module.exports = class MessageMapping {
case "post_process_ended": return "rap-post-process-ended";
case "publish_started": return "rap-publish-started";
case "publish_ended": return "rap-publish-ended";
case "published": return "rap-published";
case "unpublished": return "rap-unpublished";
case "deleted": return "rap-deleted";
case "PublishedRecordingSysMsg": return "rap-published";
case "UnpublishedRecordingSysMsg": return "rap-unpublished";
case "DeletedRecordingSysMsg": return "rap-deleted";
case "post_publish_started": return "rap-post-publish-started";
case "post_publish_ended": return "rap-post-publish-ended";
case "meeting_created_message": return "meeting-created";