X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=solution%2Fsmo%2Fapps%2Fflows%2Fdata%2Fflows.json;fp=solution%2Fsmo%2Fapps%2Fflows%2Fdata%2Fflows.json;h=29657bae1e94b3ca5f72dc7d0555dddc6e261f9b;hb=b50e1db7d0f2e6b18df54bda65524e8508c26c1d;hp=56c18e640e706ffc1f39d545a350d9c958dcfebc;hpb=9bdc2fb14c7c45b53632f28787ec023bead83616;p=oam.git

diff --git a/solution/smo/apps/flows/data/flows.json b/solution/smo/apps/flows/data/flows.json
index 56c18e6..29657ba 100644
--- a/solution/smo/apps/flows/data/flows.json
+++ b/solution/smo/apps/flows/data/flows.json
@@ -2541,7 +2541,7 @@
         "type": "function",
         "z": "7ba02ed596e8cde5",
         "name": "Consumer (new Data?)",
-        "func": "const topicData = global.get('topicData');\nmsg.payload = topicData.map(event => {\n    if (event.event.commonEventHeader.stndDefinedNamespace === 'o-ran-supervision:supervision-notification')\n        return event.event.commonEventHeader.sourceName;\n}).filter(element => {\n    return element !== undefined;\n});\nglobal.set('topicData', []);\nreturn msg;",
+        "func": "// read topic data from global context\nconst topicData = global.get('topicData');\n// init result as array\nlet result = [];\nif (Array.isArray(topicData)) {\n    result = topicData.filter(event => {\n        return event.event.commonEventHeader.stndDefinedNamespace === 'o-ran-supervision:supervision-notification';\n    }).map(event => {\n        return event.event.commonEventHeader.sourceName;;\n    });\n}\nmsg.payload = result;\nglobal.set('topicData', []);\nreturn msg; ",
         "outputs": 1,
         "noerr": 0,
         "initialize": "",