diff --git a/bbb-webhooks/messageMapping.js b/bbb-webhooks/messageMapping.js index a18badce776842d5d6252c86a012c8dad79a4023..7ea2062c8a022894279ad9f4f15c20f82a4aac7e 100644 --- a/bbb-webhooks/messageMapping.js +++ b/bbb-webhooks/messageMapping.js @@ -147,31 +147,36 @@ module.exports = class MessageMapping { } rapTemplate(messageObj) { - data = messageObj.payload + const data = messageObj.payload; this.mappedObject.data = { "type": "event", "id": this.mapInternalMessage(messageObj.header.name), "attributes": { "meeting": { "internal-meeting-id": data.meeting_id, - "external-meeting-id": IDMapping.getExternalMeetingID(data.meeting_id) + "external-meeting-id": data.external_meeting_id }, - "recording": { - "name": data.metadata.meetingName, - "isBreakout": data.metadata.isBreakout, - "startTime": data.startTime, - "endTime": data.endTime, - "size": data.playback.size, - "rawSize": data.rawSize, - "metadata": data.metadata, - "playback": data.playback, - "download": data.download - } + "success": data.success, + "step-time": data.step_time }, "event": { "ts": messageObj.header.current_time } }; + + if (this.mappedObject.data["id"] == "rap-publish-ended") { + this.mappedObject.data["attributes"]["recording"] = { + "name": data.metadata.meetingName, + "isBreakout": data.metadata.isBreakout, + "startTime": data.startTime, + "endTime": data.endTime, + "size": data.playback.size, + "rawSize": data.rawSize, + "metadata": data.metadata, + "playback": data.playback, + "download": data.download + } + } this.mappedMessage = JSON.stringify(this.mappedObject); Logger.info("[MessageMapping] Mapped message:", this.mappedMessage); } diff --git a/bbb-webhooks/web_hooks.js b/bbb-webhooks/web_hooks.js index a91718f1e889e6724f1ec35b095f7011f5c4919c..c00a2cf0b14c5eb2af40d16eeeb399fdd089c266 100644 --- a/bbb-webhooks/web_hooks.js +++ b/bbb-webhooks/web_hooks.js @@ -69,7 +69,7 @@ module.exports = class WebHooks { } } } catch (e) { - Logger.error("[WebHooks] error processing the message:", JSON.stringify(raw), ":", e); + Logger.error("[WebHooks] error processing the message:", JSON.stringify(raw), ":", e.message); } });