From 119a6d14bd7886714e1b7e8da9faf63cc39f4a50 Mon Sep 17 00:00:00 2001 From: Martin Skorupski Date: Thu, 13 Apr 2023 15:11:05 +0200 Subject: [PATCH] Support of WG4 OpenFronthaul Management-Plane VES - add OFHM VES flows Issue-ID: OAM-326 Change-Id: Ifbd74599c37e007e17f757d91c077f85424de446 Signed-off-by: Martin Skorupski --- solution/smo/apps/flows/data/flows.json | 1943 +++++++++++++++++++++++++++---- 1 file changed, 1719 insertions(+), 224 deletions(-) diff --git a/solution/smo/apps/flows/data/flows.json b/solution/smo/apps/flows/data/flows.json index 5e77f4f..e00bb5c 100644 --- a/solution/smo/apps/flows/data/flows.json +++ b/solution/smo/apps/flows/data/flows.json @@ -64,7 +64,7 @@ "type": "function", "z": "51e83a0892da060e", "name": "vesHeader", - "func": "const timeStamp = new Date(msg.payload);\nconst eventType = msg.topic;\nlet domain = \"stndDefined\";\n// handle domain expecption for 'pnfRegistration'\nif (eventType === 'pnfRegistration') {\n domain = eventType;\n} \nconst nfNamingCode = env.get('APP_NETWORK_FUNCTION_ID');\nconst namespaces = {\n pnfRegistration: undefined,\n o1NotifyPnfRegistration: 'o1-notify-pnf-registration',\n oRanScDuHelloWorldPmStreaming: 'o-ran-sc-du-hello-world-pm-streaming-oas3',\n notifyHeartbeat: '3GPP-Heartbeat',\n notifyFileReady: 'file-ready',\n 'o-ran-file-management:file-download-event': 'o-ran-sc-ofhm',\n 'o-ran-file-management:file-upload-notification': 'o-ran-sc-ofhm'\n};\n\nmsg.topic = \"commonEventHeader\"\nmsg.payload = {\n domain: domain,\n eventType: eventType,\n eventId:[nfNamingCode, eventType, msg._msgid].join('_'),\n eventName: [domain, eventType].join('_'),\n sequence: Number(timeStamp),\n priority: \"Low\",\n reportingEntityId: \"c2b7d6e9-ee35-459a-ab8e-717a6fc1fde6\",\n reportingEntityName: global.get('os').hostname(),\n sourceId: \"378e9904-6d39-40ea-9994-0596fe2235a3\",\n sourceName: env.get('APP_SOURCE'),\n startEpochMicrosec: timeStamp.getTime() * 1000,\n lastEpochMicrosec: timeStamp.getTime() * 1000,\n nfNamingCode: nfNamingCode,\n nfVendorName: env.get('APP_VENDOR'),\n timeZoneOffset: \"+00:00\",\n stndDefinedNamespace: namespaces[eventType],\n version: \"4.1\",\n vesEventListenerVersion: \"7.2.1\"\n}\nreturn msg;", + "func": "const timeStamp = new Date(msg.payload);\nconst eventType = msg.topic;\nlet domain = \"stndDefined\";\n// handle domain expecption for 'pnfRegistration'\nif (eventType === 'pnfRegistration') {\n domain = eventType;\n} \nconst nfNamingCode = env.get('APP_NETWORK_FUNCTION_ID');\nconst namespaces = {\n pnfRegistration: undefined,\n o1NotifyPnfRegistration: 'o1-notify-pnf-registration',\n oRanScDuHelloWorldPmStreaming: 'o-ran-sc-du-hello-world-pm-streaming-oas3',\n notifyHeartbeat: '3GPP-Heartbeat',\n notifyFileReady: 'file-ready'\n};\nconst topic = namespaces[eventType] || msg.topic;\n\nmsg.topic = \"commonEventHeader\"\nmsg.payload = {\n domain: domain,\n eventType: eventType,\n eventId:[nfNamingCode, eventType, msg._msgid].join('_'),\n eventName: [domain, eventType].join('_'),\n sequence: Number(timeStamp),\n priority: \"Low\",\n reportingEntityId: \"c2b7d6e9-ee35-459a-ab8e-717a6fc1fde6\",\n reportingEntityName: global.get('os').hostname(),\n sourceId: \"378e9904-6d39-40ea-9994-0596fe2235a3\",\n sourceName: env.get('APP_SOURCE'),\n startEpochMicrosec: timeStamp.getTime() * 1000,\n lastEpochMicrosec: timeStamp.getTime() * 1000,\n nfNamingCode: nfNamingCode,\n nfVendorName: env.get('APP_VENDOR'),\n timeZoneOffset: \"+00:00\",\n stndDefinedNamespace: topic,\n version: \"4.1\",\n vesEventListenerVersion: \"7.2.1\"\n}\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -430,16 +430,6 @@ ] ] }, - { - "id": "2d033da139fb379e", - "type": "comment", - "z": "51e83a0892da060e", - "name": "from OpenFronthaul Management-Plane", - "info": "", - "x": 820, - "y": 380, - "wires": [] - }, { "id": "456597d0477d239f", "type": "inject", @@ -461,8 +451,8 @@ "topic": "o-ran-file-management:file-download-event", "payload": "", "payloadType": "date", - "x": 840, - "y": 420, + "x": 820, + "y": 820, "wires": [ [ "f40d1d16c7044edc", @@ -481,8 +471,8 @@ "initialize": "", "finalize": "", "libs": [], - "x": 1170, - "y": 420, + "x": 1150, + "y": 820, "wires": [ [ "f65b1c13e0243ef6" @@ -510,8 +500,8 @@ "topic": "o-ran-file-management:file-upload-notification", "payload": "", "payloadType": "date", - "x": 850, - "y": 460, + "x": 830, + "y": 860, "wires": [ [ "d473bf42d8169599", @@ -530,8 +520,8 @@ "initialize": "", "finalize": "", "libs": [], - "x": 1170, - "y": 460, + "x": 1150, + "y": 860, "wires": [ [ "f65b1c13e0243ef6" @@ -539,10 +529,10 @@ ] }, { - "id": "910dfec7eb74df65", + "id": "ec85f2a64f79450d", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "pnfRegistration", + "z": "51e83a0892da060e", + "name": "o-ran-supervision:supervision-notification", "props": [ { "p": "payload" @@ -556,40 +546,53 @@ "crontab": "", "once": false, "onceDelay": 0.1, - "topic": "pnfRegistration", + "topic": "o-ran-supervision:supervision-notification", "payload": "", "payloadType": "date", - "x": 240, - "y": 80, + "x": 820, + "y": 1140, "wires": [ [ - "e5f66f4bd6777ca0" + "96ea9b3d7d4121dc", + "b5533c10604af5a6" ] ] }, { - "id": "562063a080cb99d6", - "type": "debug", - "z": "c5746e29f53f72ce", - "name": "eventData", - "active": true, - "tosidebar": true, - "console": false, - "tostatus": false, - "complete": "payload", - "targetType": "msg", - "statusVal": "", - "statusType": "auto", - "x": 990, - "y": 220, + "id": "96ea9b3d7d4121dc", + "type": "function", + "z": "51e83a0892da060e", + "name": "vesStndDefindBody", + "func": "const eventTime = new Date(msg.payload).toISOString();\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/yang/published/o-ran/ru-fh/o-ran-supervision.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-supervision:supervision-notification': {\n 'session-id': 999999\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 1150, + "y": 1140, + "wires": [ + [ + "f65b1c13e0243ef6" + ] + ] + }, + { + "id": "027098b9ba7cd1e6", + "type": "comment", + "z": "51e83a0892da060e", + "name": "from OpenFronthaul Management-Plane", + "info": "", + "x": 780, + "y": 380, "wires": [] }, { - "id": "172060688d87f510", + "id": "e80ff3c876a343e5", "type": "inject", - "z": "c5746e29f53f72ce", + "z": "51e83a0892da060e", "d": true, - "name": "notifyHeartbeat", + "name": "o-ran-ald-port:dc-enabled-status-change", "props": [ { "p": "payload" @@ -599,26 +602,25 @@ "vt": "str" } ], - "repeat": "5", + "repeat": "", "crontab": "", - "once": true, + "once": false, "onceDelay": 0.1, - "topic": "notifyHeartbeat", + "topic": "o-ran-ald-port:dc-enabled-status-change", "payload": "", "payloadType": "date", - "x": 230, + "x": 820, "y": 420, "wires": [ - [ - "e5f66f4bd6777ca0" - ] + [] ] }, { - "id": "311c3b5d3d73fc24", + "id": "c61fe1f3bdb954d5", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyFileReady", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-ald-port:overcurrent-report", "props": [ { "p": "payload" @@ -632,114 +634,21 @@ "crontab": "", "once": false, "onceDelay": 0.1, - "topic": "notifyFileReady", + "topic": "o-ran-ald-port:overcurrent-report", "payload": "", "payloadType": "date", - "x": 240, + "x": 790, "y": 460, "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "5437e3fdfca300c9", - "type": "http request", - "z": "c5746e29f53f72ce", - "name": "", - "method": "GET", - "ret": "txt", - "paytoqs": "ignore", - "url": "", - "tls": "7b2f4859e5963695", - "persist": true, - "proxy": "", - "insecureHTTPParser": true, - "authType": "", - "senderr": false, - "headers": [], - "x": 670, - "y": 220, - "wires": [ - [ - "dc576b6355478428" - ] - ] - }, - { - "id": "dc576b6355478428", - "type": "function", - "z": "c5746e29f53f72ce", - "name": "JSON", - "func": "const string = msg.payload;\nconst array = JSON.parse(string);\nif (Array.isArray(array)) {\n msg.payload = array.map( (item) => {\n if (typeof item === 'string' || item instanceof String) {\n return JSON.parse(item);\n }\n });\n} else {\n msg.payload = array;\n}\nreturn msg;", - "outputs": 1, - "noerr": 0, - "initialize": "", - "finalize": "", - "libs": [], - "x": 830, - "y": 220, - "wires": [ - [ - "562063a080cb99d6" - ] - ] - }, - { - "id": "e5f66f4bd6777ca0", - "type": "function", - "z": "c5746e29f53f72ce", - "name": "SET msg.url", - "func": "const base = 'https://messages.smo.o-ran-sc.org';\nconst path = 'events';\nconst urlMapping = {\n pnfRegistration: \"unauthenticated.VES_PNFREG_OUTPUT\",\n o1NotifyPnfRegistration: \"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\",\n oRanScDuHelloWorldPmStreaming: \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\",\n notifyHeartbeat: \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\",\n notifyFileReady: \"unauthenticated.VES_FILE_READY_OUTPUT\",\n oRanOpenfrontManagementPlane: \"unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT\"\n};\nmsg.url = [base, path, urlMapping[msg.topic], '1','1'].join('/');\nreturn msg;", - "outputs": 1, - "noerr": 0, - "initialize": "", - "finalize": "", - "libs": [], - "x": 490, - "y": 220, - "wires": [ - [ - "5437e3fdfca300c9" - ] + [] ] }, { - "id": "42275e9c12f8e52b", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from O-RAN-SC", - "info": "", - "x": 100, - "y": 140, - "wires": [] - }, - { - "id": "e07fa97ebc66dce0", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from ONAP", - "info": "", - "x": 90, - "y": 40, - "wires": [] - }, - { - "id": "44b8c2cc138777f1", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from SA5 R-18 branch", - "info": "", - "x": 120, - "y": 380, - "wires": [] - }, - { - "id": "4480e5473a65a757", + "id": "939ac153e888cc93", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "oRanScDuHelloWorldPmStreaming", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-coordinated", "props": [ { "p": "payload" @@ -753,22 +662,21 @@ "crontab": "", "once": false, "onceDelay": 0.1, - "topic": "oRanScDuHelloWorldPmStreaming", + "topic": "o-ran-antenna-calibration:antenna-calibration-coordinated", "payload": "", "payloadType": "date", - "x": 180, - "y": 220, + "x": 870, + "y": 500, "wires": [ - [ - "e5f66f4bd6777ca0" - ] + [] ] }, { - "id": "52f22ee054e5b4ac", + "id": "f7834ee33e7731fb", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "o1NotifyPnfRegistration", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params", "props": [ { "p": "payload" @@ -782,53 +690,21 @@ "crontab": "", "once": false, "onceDelay": 0.1, - "topic": "o1NotifyPnfRegistration", + "topic": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params", "payload": "", "payloadType": "date", - "x": 220, - "y": 180, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "3051f52553efaaa4", - "type": "http request", - "z": "c5746e29f53f72ce", - "name": "", - "method": "GET", - "ret": "txt", - "paytoqs": "ignore", - "url": "https://messages.smo.o-ran-sc.org/topics", - "tls": "7b2f4859e5963695", - "persist": true, - "proxy": "", - "insecureHTTPParser": true, - "authType": "", - "senderr": false, - "headers": [ - { - "keyType": "other", - "keyValue": "Accept", - "valueType": "other", - "valueValue": "application/json" - } - ], - "x": 670, - "y": 180, + "x": 930, + "y": 540, "wires": [ - [ - "dc576b6355478428" - ] + [] ] }, { - "id": "0acceacb99b7981a", + "id": "8e98d432fcaef200", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "Topics?", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-required", "props": [ { "p": "payload" @@ -842,32 +718,21 @@ "crontab": "", "once": false, "onceDelay": 0.1, - "topic": "topics", + "topic": "o-ran-antenna-calibration:antenna-calibration-required", "payload": "", "payloadType": "date", - "x": 510, - "y": 180, + "x": 860, + "y": 580, "wires": [ - [ - "3051f52553efaaa4" - ] + [] ] }, { - "id": "34b7ac222692e06d", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from OpenFronthaul Management-Plane", - "info": "", - "x": 180, - "y": 280, - "wires": [] - }, - { - "id": "efd550c650283862", + "id": "554cb2ce5934b36c", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "oRanOpenfrontManagementPlane", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-result", "props": [ { "p": "payload" @@ -881,11 +746,1641 @@ "crontab": "", "once": false, "onceDelay": 0.1, - "topic": "oRanOpenfrontManagementPlane", + "topic": "o-ran-antenna-calibration:antenna-calibration-result", "payload": "", "payloadType": "date", - "x": 180, - "y": 320, + "x": 850, + "y": 620, + "wires": [ + [] + ] + }, + { + "id": "391ce0bfa3b8003d", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-beamforming:beamforming-information-update", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-beamforming:beamforming-information-update", + "payload": "", + "payloadType": "date", + "x": 850, + "y": 660, + "wires": [ + [] + ] + }, + { + "id": "966ca15e87b419f5", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-beamforming:capability-group-beamforming-information-update", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-beamforming:capability-group-beamforming-information-update", + "payload": "", + "payloadType": "date", + "x": 900, + "y": 700, + "wires": [ + [] + ] + }, + { + "id": "243cffacec890e26", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-beamforming:predefined-beam-tilt-offset-complete", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-beamforming:predefined-beam-tilt-offset-complete", + "payload": "", + "payloadType": "date", + "x": 860, + "y": 740, + "wires": [ + [] + ] + }, + { + "id": "843c4093e2ddd914", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-externalio:external-input-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-externalio:external-input-change", + "payload": "", + "payloadType": "date", + "x": 810, + "y": 780, + "wires": [ + [] + ] + }, + { + "id": "627b31335d7e5b6f", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-fm:alarm-notif", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-fm:alarm-notif", + "payload": "", + "payloadType": "date", + "x": 750, + "y": 900, + "wires": [ + [] + ] + }, + { + "id": "87c1e3e0e87bd7c1", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-laa-operations:measurement-result", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-laa-operations:measurement-result", + "payload": "", + "payloadType": "date", + "x": 820, + "y": 940, + "wires": [ + [] + ] + }, + { + "id": "27d98684362bee02", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-performance-management:measurement-result-stats", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-performance-management:measurement-result-stats", + "payload": "", + "payloadType": "date", + "x": 870, + "y": 980, + "wires": [ + [] + ] + }, + { + "id": "03292a70960f7d50", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-software-management:activation-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-software-management:activation-event", + "payload": "", + "payloadType": "date", + "x": 830, + "y": 1020, + "wires": [ + [] + ] + }, + { + "id": "652dbf9c0ef73057", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-software-management:download-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-software-management:download-event", + "payload": "", + "payloadType": "date", + "x": 830, + "y": 1060, + "wires": [ + [] + ] + }, + { + "id": "0636add6c6d4d5e2", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-software-management:install-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-software-management:install-event", + "payload": "", + "payloadType": "date", + "x": 820, + "y": 1100, + "wires": [ + [] + ] + }, + { + "id": "4c274d02a62c7565", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-sync:gnss-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:gnss-state-change", + "payload": "", + "payloadType": "date", + "x": 780, + "y": 1180, + "wires": [ + [] + ] + }, + { + "id": "ad0e319d109512e7", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-sync:ptp-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:ptp-state-change", + "payload": "", + "payloadType": "date", + "x": 780, + "y": 1220, + "wires": [ + [] + ] + }, + { + "id": "de24c11aa05ce94e", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-sync:synce-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:synce-state-change", + "payload": "", + "payloadType": "date", + "x": 790, + "y": 1260, + "wires": [ + [] + ] + }, + { + "id": "a9b33c01b841cc78", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-sync:synchronization-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:synchronization-state-change", + "payload": "", + "payloadType": "date", + "x": 820, + "y": 1300, + "wires": [ + [] + ] + }, + { + "id": "f4a87018c664902f", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-trace:trace-log-generated", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-trace:trace-log-generated", + "payload": "", + "payloadType": "date", + "x": 790, + "y": 1340, + "wires": [ + [] + ] + }, + { + "id": "7cbe4e4faa26098b", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-uplane-conf:rx-array-carriers-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-uplane-conf:rx-array-carriers-state-change", + "payload": "", + "payloadType": "date", + "x": 840, + "y": 1420, + "wires": [ + [] + ] + }, + { + "id": "a5eeb9d399c203ca", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-troubleshooting:troubleshooting-log-generated", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-troubleshooting:troubleshooting-log-generated", + "payload": "", + "payloadType": "date", + "x": 850, + "y": 1380, + "wires": [ + [] + ] + }, + { + "id": "b9d72e03c66c78b3", + "type": "inject", + "z": "51e83a0892da060e", + "d": true, + "name": "o-ran-uplane-conf:tx-array-carriers-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-uplane-conf:tx-array-carriers-state-change", + "payload": "", + "payloadType": "date", + "x": 840, + "y": 1460, + "wires": [ + [] + ] + }, + { + "id": "910dfec7eb74df65", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "pnfRegistration", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "pnfRegistration", + "payload": "", + "payloadType": "date", + "x": 240, + "y": 80, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "562063a080cb99d6", + "type": "debug", + "z": "c5746e29f53f72ce", + "name": "eventData", + "active": true, + "tosidebar": true, + "console": false, + "tostatus": false, + "complete": "payload", + "targetType": "msg", + "statusVal": "", + "statusType": "auto", + "x": 990, + "y": 220, + "wires": [] + }, + { + "id": "172060688d87f510", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "notifyHeartbeat", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "5", + "crontab": "", + "once": true, + "onceDelay": 0.1, + "topic": "notifyHeartbeat", + "payload": "", + "payloadType": "date", + "x": 230, + "y": 320, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "311c3b5d3d73fc24", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "notifyFileReady", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "notifyFileReady", + "payload": "", + "payloadType": "date", + "x": 240, + "y": 360, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "5437e3fdfca300c9", + "type": "http request", + "z": "c5746e29f53f72ce", + "name": "", + "method": "GET", + "ret": "txt", + "paytoqs": "ignore", + "url": "", + "tls": "7b2f4859e5963695", + "persist": true, + "proxy": "", + "insecureHTTPParser": true, + "authType": "", + "senderr": false, + "headers": [], + "x": 670, + "y": 220, + "wires": [ + [ + "dc576b6355478428" + ] + ] + }, + { + "id": "dc576b6355478428", + "type": "function", + "z": "c5746e29f53f72ce", + "name": "JSON", + "func": "const string = msg.payload;\nconst array = JSON.parse(string);\nif (Array.isArray(array)) {\n msg.payload = array.map( (item) => {\n if (typeof item === 'string' || item instanceof String) {\n return JSON.parse(item);\n }\n });\n} else {\n msg.payload = array;\n}\nreturn msg;", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 830, + "y": 220, + "wires": [ + [ + "562063a080cb99d6" + ] + ] + }, + { + "id": "e5f66f4bd6777ca0", + "type": "function", + "z": "c5746e29f53f72ce", + "name": "SET msg.url", + "func": "const base = 'https://messages.smo.o-ran-sc.org';\nconst path = 'events';\nconst urlMapping = {\n pnfRegistration: \"unauthenticated.VES_PNFREG_OUTPUT\",\n o1NotifyPnfRegistration: \"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\",\n oRanScDuHelloWorldPmStreaming: \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\",\n notifyHeartbeat: \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\",\n notifyFileReady: \"unauthenticated.VES_FILE_READY_OUTPUT\",\n oRanOpenfrontManagementPlane: \"unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT\"\n};\nconst urlTopic = urlMapping[msg.topic] || msg.topic.replace(':', '-');\nmsg.url = [base, path, urlTopic, '1','1'].join('/');\nreturn msg;", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 490, + "y": 220, + "wires": [ + [ + "5437e3fdfca300c9" + ] + ] + }, + { + "id": "42275e9c12f8e52b", + "type": "comment", + "z": "c5746e29f53f72ce", + "name": "from O-RAN-SC", + "info": "", + "x": 100, + "y": 140, + "wires": [] + }, + { + "id": "e07fa97ebc66dce0", + "type": "comment", + "z": "c5746e29f53f72ce", + "name": "from ONAP", + "info": "", + "x": 90, + "y": 40, + "wires": [] + }, + { + "id": "44b8c2cc138777f1", + "type": "comment", + "z": "c5746e29f53f72ce", + "name": "from SA5 R-18 branch", + "info": "", + "x": 120, + "y": 280, + "wires": [] + }, + { + "id": "4480e5473a65a757", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "oRanScDuHelloWorldPmStreaming", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "oRanScDuHelloWorldPmStreaming", + "payload": "", + "payloadType": "date", + "x": 180, + "y": 220, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "52f22ee054e5b4ac", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "o1NotifyPnfRegistration", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o1NotifyPnfRegistration", + "payload": "", + "payloadType": "date", + "x": 220, + "y": 180, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "3051f52553efaaa4", + "type": "http request", + "z": "c5746e29f53f72ce", + "name": "", + "method": "GET", + "ret": "txt", + "paytoqs": "ignore", + "url": "https://messages.smo.o-ran-sc.org/topics", + "tls": "7b2f4859e5963695", + "persist": true, + "proxy": "", + "insecureHTTPParser": true, + "authType": "", + "senderr": false, + "headers": [ + { + "keyType": "other", + "keyValue": "Accept", + "valueType": "other", + "valueValue": "application/json" + } + ], + "x": 670, + "y": 180, + "wires": [ + [ + "dc576b6355478428" + ] + ] + }, + { + "id": "0acceacb99b7981a", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "Topics?", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "topics", + "payload": "", + "payloadType": "date", + "x": 510, + "y": 180, + "wires": [ + [ + "3051f52553efaaa4" + ] + ] + }, + { + "id": "34b7ac222692e06d", + "type": "comment", + "z": "c5746e29f53f72ce", + "name": "from OpenFronthaul Management-Plane", + "info": "", + "x": 580, + "y": 280, + "wires": [] + }, + { + "id": "25a3eca83bbc3489", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "o-ran-supervision:supervision-notification", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-supervision:supervision-notification", + "payload": "", + "payloadType": "date", + "x": 620, + "y": 1040, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "0194d014ef8f6c5e", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "o-ran-file-management:file-upload-notification", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-file-management:file-upload-notification", + "payload": "", + "payloadType": "date", + "x": 630, + "y": 760, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "775aacf9e2cc0285", + "type": "inject", + "z": "c5746e29f53f72ce", + "name": "o-ran-file-management:file-download-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-file-management:file-download-event", + "payload": "", + "payloadType": "date", + "x": 620, + "y": 720, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "3e3be17a65a7d1bf", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-ald-port:dc-enabled-status-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-ald-port:dc-enabled-status-change", + "payload": "", + "payloadType": "date", + "x": 620, + "y": 320, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "665c45e5ccd1c9cb", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-ald-port:overcurrent-report", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-ald-port:overcurrent-report", + "payload": "", + "payloadType": "date", + "x": 590, + "y": 360, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "5520ce3b83578f17", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-coordinated", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-antenna-calibration:antenna-calibration-coordinated", + "payload": "", + "payloadType": "date", + "x": 670, + "y": 400, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "fda3090fb4f1e9d4", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params", + "payload": "", + "payloadType": "date", + "x": 730, + "y": 440, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "2551bb6c9746a7c2", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-required", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-antenna-calibration:antenna-calibration-required", + "payload": "", + "payloadType": "date", + "x": 660, + "y": 480, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "0dcc72d0235e6336", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-antenna-calibration:antenna-calibration-result", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-antenna-calibration:antenna-calibration-result", + "payload": "", + "payloadType": "date", + "x": 650, + "y": 520, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "0abafa5c1a4ebd33", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-beamforming:beamforming-information-update", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-beamforming:beamforming-information-update", + "payload": "", + "payloadType": "date", + "x": 650, + "y": 560, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "d74c5f1885485d8c", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-beamforming:capability-group-beamforming-information-update", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-beamforming:capability-group-beamforming-information-update", + "payload": "", + "payloadType": "date", + "x": 700, + "y": 600, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "8d755b355a3d5557", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-beamforming:predefined-beam-tilt-offset-complete", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-beamforming:predefined-beam-tilt-offset-complete", + "payload": "", + "payloadType": "date", + "x": 660, + "y": 640, + "wires": [ + [] + ] + }, + { + "id": "6ebe4693c580ae00", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-externalio:external-input-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-externalio:external-input-change", + "payload": "", + "payloadType": "date", + "x": 610, + "y": 680, + "wires": [ + [] + ] + }, + { + "id": "89144928a6ead625", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-fm:alarm-notif", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-fm:alarm-notif", + "payload": "", + "payloadType": "date", + "x": 550, + "y": 800, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "8ebca0cd456a9763", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-laa-operations:measurement-result", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-laa-operations:measurement-result", + "payload": "", + "payloadType": "date", + "x": 620, + "y": 840, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "4778511387bc7449", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-performance-management:measurement-result-stats", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-performance-management:measurement-result-stats", + "payload": "", + "payloadType": "date", + "x": 670, + "y": 880, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "c106623d629fbe54", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-software-management:activation-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-software-management:activation-event", + "payload": "", + "payloadType": "date", + "x": 630, + "y": 920, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "4db0e5b915d76ddb", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-software-management:download-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-software-management:download-event", + "payload": "", + "payloadType": "date", + "x": 630, + "y": 960, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "8d3fab47729a807d", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-software-management:install-event", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-software-management:install-event", + "payload": "", + "payloadType": "date", + "x": 620, + "y": 1000, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "7ac87519cb59151d", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-sync:gnss-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:gnss-state-change", + "payload": "", + "payloadType": "date", + "x": 580, + "y": 1080, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "55725b18e27c1a27", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-sync:ptp-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:ptp-state-change", + "payload": "", + "payloadType": "date", + "x": 580, + "y": 1120, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "dde01e699dec844f", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-sync:synce-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:synce-state-change", + "payload": "", + "payloadType": "date", + "x": 590, + "y": 1160, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "5457d995823e58f6", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-sync:synchronization-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-sync:synchronization-state-change", + "payload": "", + "payloadType": "date", + "x": 620, + "y": 1200, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "ca9f765b3838d5ff", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-trace:trace-log-generated", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-trace:trace-log-generated", + "payload": "", + "payloadType": "date", + "x": 590, + "y": 1240, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "0a837c4beaa140e0", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-uplane-conf:rx-array-carriers-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-uplane-conf:rx-array-carriers-state-change", + "payload": "", + "payloadType": "date", + "x": 640, + "y": 1320, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "3dfb5349f08c5ea9", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-troubleshooting:troubleshooting-log-generated", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-troubleshooting:troubleshooting-log-generated", + "payload": "", + "payloadType": "date", + "x": 650, + "y": 1280, + "wires": [ + [ + "e5f66f4bd6777ca0" + ] + ] + }, + { + "id": "030a6e7e6371402e", + "type": "inject", + "z": "c5746e29f53f72ce", + "d": true, + "name": "o-ran-uplane-conf:tx-array-carriers-state-change", + "props": [ + { + "p": "payload" + }, + { + "p": "topic", + "vt": "str" + } + ], + "repeat": "", + "crontab": "", + "once": false, + "onceDelay": 0.1, + "topic": "o-ran-uplane-conf:tx-array-carriers-state-change", + "payload": "", + "payloadType": "date", + "x": 640, + "y": 1360, "wires": [ [ "e5f66f4bd6777ca0" -- 2.16.6