chore: added logging for dts

swrlab · Dec 12, 2023 · c75f9b9 · c75f9b9
1 parent 213a6f9
commit c75f9b9
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
 	"name": "ard-eventhub",
-	"version": "1.7.0",
+	"version": "1.7.1",
 	"description": "ARD system to distribute real-time (live) metadata for primarily radio broadcasts.",
 	"main": "./src/ingest/index.js",
 	"engines": {

diff --git a/src/ingest/events/post.js b/src/ingest/events/post.js
@@ -131,7 +131,10 @@ module.exports = async (req, res) => {
 		// add opt-out plugins
 		const isDtsPluginSet = message.plugins?.find((plugin) => plugin.type === 'dts')
 		const isMusic = req.body.type === 'music'
-		if (!isDtsPluginSet && isMusic && DTS_INSTITUTION_ALLOW_LIST.includes(req.user.institutionId)) {
+		const isInDtsAllowList = DTS_INSTITUTION_ALLOW_LIST.includes(req.user.institutionId)
+		const institutionId = req.user.institutionId || 'unknown'
+
+		if (!isDtsPluginSet && isMusic && isInDtsAllowList) {
 			message.plugins.push({
 				type: 'dts',
 				isDeactivated: false,
@@ -182,7 +185,7 @@ module.exports = async (req, res) => {
 		// log success
 		logger.log({
 			level: 'info',
-			message: `event processed > ${eventName} > ${message.services.length}x services (${message.services[0]?.publisherId})`,
+			message: `event processed > ${eventName} > institution ${institutionId} > isInDtsAllowList ${isInDtsAllowList} > ${message.services.length}x services (${message.services[0]?.publisherId})`,
 			source,
 			data: { ...data, body: req.body, isDtsPluginSet },
 		})