"type": "tab",
"label": "Message Topics",
"disabled": false,
- "info": "Subscribes to Kafka topics ",
+ "info": "Subscribes to Kafka topics",
+ "env": []
+ },
+ {
+ "id": "7ba02ed596e8cde5",
+ "type": "tab",
+ "label": "OpenFronthaul",
+ "disabled": false,
+ "info": "",
"env": []
},
{
"payload": "",
"payloadType": "date",
"x": 120,
- "y": 460,
+ "y": 500,
"wires": [
[
"b5533c10604af5a6",
"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 notifyFilePreparationError: 'file-ready',\n notifyNewAlarm: '3GPP-FaultSupervision',\n notifyChangedAlarm: '3GPP-FaultSupervision',\n notifyChangedAlarmGeneral: '3GPP-FaultSupervision',\n notifyAckStateChanged: '3GPP-FaultSupervision',\n notifyCorrelatedNotificationChanged: '3GPP-FaultSupervision',\n notifyComments: '3GPP-FaultSupervision',\n notifyClearedAlarm: '3GPP-FaultSupervision',\n notifyAlarmListRebuilt: '3GPP-FaultSupervision',\n notifyPotentialFaultyAlarmList: '3GPP-FaultSupervision'\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": "",
"finalize": "",
"libs": [],
"x": 470,
- "y": 460,
+ "y": 500,
"wires": [
[
"f65b1c13e0243ef6"
"id": "1d6949a57bce82ab",
"type": "function",
"z": "51e83a0892da060e",
- "name": "createVesEvent",
- "func": "msg.payload = {\n event: msg.payload\n};\nreturn msg;",
+ "name": "http-preparation",
+ "func": "const protocol = env.get('VES_ENDPOINT_PROTOCOL');\nconst host = env.get('VES_ENDPOINT_HOST');\nconst port = env.get('VES_ENDPOINT_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst path = 'eventListener/v7';\nmsg.url = [base, path].join('/');\n\nconst user = env.get('VES_ENDPOINT_USERNAME');\nconst password = env.get('VES_ENDPOINT_PASSWORD');\nconst auth = Buffer.from([user, password].join(':')).toString('base64')\nconst basicAuth = ['Basic', auth].join(' ');\n\nmsg.headers = {};\nmsg.headers['Content-Type'] = 'application/json';\nmsg.headers['Accept'] = 'application/json';\nmsg.headers['Authorization'] = basicAuth;\n\nmsg.payload = {\n event: msg.payload\n};\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"method": "POST",
"ret": "txt",
"paytoqs": "ignore",
- "url": "https://ves-collector.oam.smo.o-ran-sc.org/eventListener/v7",
+ "url": "",
"tls": "7b2f4859e5963695",
- "persist": false,
+ "persist": true,
"proxy": "",
"insecureHTTPParser": false,
- "authType": "basic",
+ "authType": "",
"senderr": false,
"headers": [],
"x": 1030,
"z": "51e83a0892da060e",
"name": "VesCollectorResponse",
"active": true,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
+ "tosidebar": false,
+ "console": true,
+ "tostatus": true,
"complete": "payload",
"targetType": "msg",
- "statusVal": "",
+ "statusVal": "payload",
"statusType": "auto",
- "x": 1220,
+ "x": 1230,
"y": 280,
"wires": []
},
"type": "debug",
"z": "51e83a0892da060e",
"name": "ves-message-data",
- "active": false,
- "tosidebar": true,
- "console": false,
- "tostatus": false,
+ "active": true,
+ "tosidebar": false,
+ "console": true,
+ "tostatus": true,
"complete": "payload",
"targetType": "msg",
- "statusVal": "",
- "statusType": "auto",
- "x": 1050,
- "y": 320,
+ "statusVal": "payload.event.commonEventHeader.stndDefinedNamespace",
+ "statusType": "msg",
+ "x": 1060,
+ "y": 220,
"wires": []
},
{
]
]
},
- {
- "id": "2d033da139fb379e",
- "type": "comment",
- "z": "51e83a0892da060e",
- "name": "from OpenFronthaul Management-Plane",
- "info": "",
- "x": 820,
- "y": 380,
- "wires": []
- },
{
"id": "456597d0477d239f",
"type": "inject",
"topic": "o-ran-file-management:file-download-event",
"payload": "",
"payloadType": "date",
- "x": 840,
- "y": 420,
+ "x": 820,
+ "y": 820,
"wires": [
[
"f40d1d16c7044edc",
"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-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-download-event': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.oam.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
+ "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-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-download-event': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.dcn.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
- "x": 1170,
- "y": 420,
+ "x": 1150,
+ "y": 820,
"wires": [
[
"f65b1c13e0243ef6"
"topic": "o-ran-file-management:file-upload-notification",
"payload": "",
"payloadType": "date",
- "x": 850,
- "y": 460,
+ "x": 830,
+ "y": 860,
"wires": [
[
"d473bf42d8169599",
"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-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-upload-notification': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.oam.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
+ "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-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-upload-notification': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.dcn.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
- "x": 1170,
- "y": 460,
+ "x": 1150,
+ "y": 860,
"wires": [
[
"f65b1c13e0243ef6"
]
},
{
- "id": "910dfec7eb74df65",
+ "id": "ec85f2a64f79450d",
"type": "inject",
- "z": "c5746e29f53f72ce",
- "name": "pnfRegistration",
+ "z": "51e83a0892da060e",
+ "name": "o-ran-supervision:supervision-notification",
"props": [
{
"p": "payload"
"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"
"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"
"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"
"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"
"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,
+ "x": 930,
+ "y": 540,
"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": [
+ "id": "8e98d432fcaef200",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "o-ran-antenna-calibration:antenna-calibration-required",
+ "props": [
+ {
+ "p": "payload"
+ },
{
- "keyType": "other",
- "keyValue": "Accept",
- "valueType": "other",
- "valueValue": "application/json"
+ "p": "topic",
+ "vt": "str"
}
],
- "x": 670,
- "y": 180,
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "o-ran-antenna-calibration:antenna-calibration-required",
+ "payload": "",
+ "payloadType": "date",
+ "x": 860,
+ "y": 580,
"wires": [
- [
- "dc576b6355478428"
- ]
+ []
]
},
{
- "id": "0acceacb99b7981a",
+ "id": "554cb2ce5934b36c",
"type": "inject",
- "z": "c5746e29f53f72ce",
- "name": "Topics?",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "o-ran-antenna-calibration:antenna-calibration-result",
"props": [
{
"p": "payload"
"crontab": "",
"once": false,
"onceDelay": 0.1,
- "topic": "topics",
+ "topic": "o-ran-antenna-calibration:antenna-calibration-result",
"payload": "",
"payloadType": "date",
- "x": 510,
- "y": 180,
+ "x": 850,
+ "y": 620,
"wires": [
- [
- "3051f52553efaaa4"
- ]
+ []
]
},
{
- "id": "34b7ac222692e06d",
- "type": "comment",
- "z": "c5746e29f53f72ce",
+ "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": "bfa425cb3d578d07",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "name": "notifyNewAlarm",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyNewAlarm",
+ "payload": "",
+ "payloadType": "date",
+ "x": 120,
+ "y": 620,
+ "wires": [
+ [
+ "f71ebd595a7de756",
+ "b5533c10604af5a6"
+ ]
+ ]
+ },
+ {
+ "id": "f71ebd595a7de756",
+ "type": "function",
+ "z": "51e83a0892da060e",
+ "name": "vesStndDefindBody",
+ "func": "const timeStamp = new Date(msg.payload);\nconst alarm = 'Connection Loss';\nconst severity = 'CRITICAL';\n\nmsg.payload = {\n schemaReference: 'https://forge.3gpp.org/rep/sa5/MnS/raw/Rel-18/OpenAPI/TS28532_FaultMnS.yaml#components/schemas/NotifyNewAlarm',\n stndDefinedFieldsVersion: '1.0',\n data: {\n href: global.get('os').hostname(),\n notificationId: Number(timeStamp),\n notificationType: msg.topic,\n eventTime: timeStamp.toISOString(),\n systemDN: '/',\n alarmId: alarm,\n alarmType: 'COMMUNICATIONS_ALARM',\n probableCause: alarm,\n specificProblem: alarm,\n perceivedSeverity: severity,\n backedUpStatus: true,\n backUpObject: 'xyz',\n trendIndication: 'MORE_SEVERE',\n thresholdInfo: {\n observedMeasurement: 'new',\n observedValue: 123.1\n },\n correlatedNotifications: [],\n stateChangeDefinition: [{ 'operational-state': 'DISABLED' }],\n monitoredAttributes: {\n interface: 'uuid-of-the-interface'\n },\n proposedRepairActions: 'Call the police!',\n additionalText: 'O-RAN Software Community OAM',\n additionalInformation: {\n description: 'a test alarm'\n },\n rootCauseIndicator: false\n }\n\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 470,
+ "y": 620,
+ "wires": [
+ [
+ "f65b1c13e0243ef6"
+ ]
+ ]
+ },
+ {
+ "id": "82da4e47972195a4",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyChangedAlarm",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyChangedAlarm",
+ "payload": "",
+ "payloadType": "date",
+ "x": 130,
+ "y": 660,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "a3d85c62bee11dad",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyChangedAlarmGeneral",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyChangedAlarmGeneral",
+ "payload": "",
+ "payloadType": "date",
+ "x": 160,
+ "y": 700,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "e4651c07a56f2448",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyAckStateChanged",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyAckStateChanged",
+ "payload": "",
+ "payloadType": "date",
+ "x": 140,
+ "y": 740,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "e949006e1b1fe0f0",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyCorrelatedNotificationChanged",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyCorrelatedNotificationChanged",
+ "payload": "",
+ "payloadType": "date",
+ "x": 180,
+ "y": 780,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "a80169493419d5d0",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyComments",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyComments",
+ "payload": "",
+ "payloadType": "date",
+ "x": 120,
+ "y": 820,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "9e0f49b3d9b0a5ef",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "name": "notifyClearedAlarm",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyClearedAlarm",
+ "payload": "",
+ "payloadType": "date",
+ "x": 130,
+ "y": 860,
+ "wires": [
+ [
+ "69b8d53969426ebf",
+ "b5533c10604af5a6"
+ ]
+ ]
+ },
+ {
+ "id": "418d585d7406029b",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyAlarmListRebuilt",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyAlarmListRebuilt",
+ "payload": "",
+ "payloadType": "date",
+ "x": 140,
+ "y": 900,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "f856982bb3c3a65c",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "d": true,
+ "name": "notifyPotentialFaultyAlarmList",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyPotentialFaultyAlarmList",
+ "payload": "",
+ "payloadType": "date",
+ "x": 160,
+ "y": 940,
+ "wires": [
+ []
+ ]
+ },
+ {
+ "id": "4617f66b8940469e",
+ "type": "comment",
+ "z": "51e83a0892da060e",
+ "name": "TS28532_FaultMnS.yaml",
+ "info": "",
+ "x": 130,
+ "y": 580,
+ "wires": []
+ },
+ {
+ "id": "69b8d53969426ebf",
+ "type": "function",
+ "z": "51e83a0892da060e",
+ "name": "vesStndDefindBody",
+ "func": "const timeStamp = new Date(msg.payload);\nconst alarm = 'Connection Loss';\nconst severity = 'CRITICAL';\n\nmsg.payload = {\n schemaReference: 'https://forge.3gpp.org/rep/sa5/MnS/raw/Rel-18/OpenAPI/TS28532_FaultMnS.yaml#components/schemas/NotifyClearedAlarm',\n stndDefinedFieldsVersion: '1.0',\n data: {\n href: global.get('os').hostname(),\n notificationId: Number(timeStamp),\n notificationType: msg.topic,\n eventTime: timeStamp.toISOString(),\n systemDN: '/',\n alarmId: alarm,\n alarmType: 'COMMUNICATIONS_ALARM',\n probableCause: alarm,\n perceivedSeverity: severity,\n correlatedNotifications: [],\n clearSystemId: global.get('os').hostname()\n }\n\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 470,
+ "y": 860,
+ "wires": [
+ [
+ "f65b1c13e0243ef6"
+ ]
+ ]
+ },
+ {
+ "id": "01e14b971772ee0a",
+ "type": "comment",
+ "z": "51e83a0892da060e",
+ "name": "TS28532_FileDataReportingMnS.yaml",
+ "info": "",
+ "x": 170,
+ "y": 460,
+ "wires": []
+ },
+ {
+ "id": "ea15cafd2325d76f",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "name": "notifyFilePreparationError",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyFilePreparationError",
+ "payload": "",
+ "payloadType": "date",
+ "x": 150,
+ "y": 540,
+ "wires": [
+ [
+ "9f4bc0920fa3c0eb",
+ "b5533c10604af5a6"
+ ]
+ ]
+ },
+ {
+ "id": "9f4bc0920fa3c0eb",
+ "type": "function",
+ "z": "51e83a0892da060e",
+ "name": "vesStndDefindBody",
+ "func": "const timeStamp = new Date(msg.payload);\nconst startTime = new Date(Math.floor(Number(timeStamp) / 900000) * 900000);\nconst endTime = new Date(Number(startTime) + 900000);\nconst paddy = (num, padlen, padchar) => {\n const pad_char = typeof padchar !== 'undefined' ? padchar : '0';\n const pad = new Array(1 + padlen).join(pad_char);\n return (pad + num).slice(-pad.length);\n}\nconst fileStartTime = [\n paddy(startTime.getFullYear(), 4),\n paddy(startTime.getMonth() + 1, 2),\n paddy(startTime.getDate(), 2),\n '.',\n paddy(startTime.getHours(), 2),\n paddy(startTime.getMinutes(), 2),\n '+0000'\n].join('');\nconst fileEndTime = [\n paddy(endTime.getHours(), 2),\n paddy(endTime.getMinutes(), 2),\n '+0000'\n].join('');\nconst fileLocation = ['/pm-data-files/A', fileStartTime, '-', fileEndTime, '_', env.get('APP_NETWORK_FUNCTION_ID'), '.xml'].join('');\nmsg.payload = {\n schemaReference: 'https://forge.3gpp.org/rep/sa5/MnS/raw/Rel-18/OpenAPI/TS28532_FileDataReportingMnS.yaml#components/schemas/NotifyFilePreparationError',\n stndDefinedFieldsVersion: '1.0',\n data: {\n href: global.get('os').hostname(),\n notificationId: Number(startTime),\n notificationType: msg.topic,\n eventTime: timeStamp.toISOString(),\n systemDN: '/',\n fileInfoList: [\n {\n fileLocation: fileLocation,\n fileSize: 1234,\n fileReadyTime: startTime.toISOString(),\n fileExpirationTime: endTime.toISOString(),\n fileCompression: 'no',\n fileFormat: 'xml',\n fileDataType: 'Performance'\n }\n ],\n reason: 'No Measurements',\n additionalText: 'Please consult customer documentation!'\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 470,
+ "y": 540,
+ "wires": [
+ [
+ "f65b1c13e0243ef6"
+ ]
+ ]
+ },
+ {
+ "id": "910dfec7eb74df65",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "pnfRegistration",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "60",
+ "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": true,
+ "tostatus": true,
+ "complete": "payload",
+ "targetType": "msg",
+ "statusVal": "payload.length",
+ "statusType": "msg",
+ "x": 1170,
+ "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": 400,
+ "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": 480,
+ "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": 850,
+ "y": 220,
+ "wires": [
+ [
+ "dc576b6355478428"
+ ]
+ ]
+ },
+ {
+ "id": "dc576b6355478428",
+ "type": "function",
+ "z": "c5746e29f53f72ce",
+ "name": "Provider",
+ "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}\nglobal.set('topicData', msg.payload)\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 1020,
+ "y": 220,
+ "wires": [
+ [
+ "562063a080cb99d6"
+ ]
+ ]
+ },
+ {
+ "id": "e5f66f4bd6777ca0",
+ "type": "function",
+ "z": "c5746e29f53f72ce",
+ "name": "http-preparation",
+ "func": "const protocol = env.get('MESSAGES_PROTOCOL');\nconst host = env.get('MESSAGES_HOST');\nconst port = env.get('MESSAGES_PORT');;\nconst base = protocol + '://' + host + ':' + port;\n\nconst path = 'events';\nconst urlMapping = {\n pnfRegistration: 'unauthenticated.VES_PNFREG_OUTPUT',\n heartbeat: 'unauthenticated.SEC_HEARTBEAT_OUTPUT',\n fault: 'unauthenticated.SEC_FAULT_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 notifyFilePreparationError: 'unauthenticated.VES_FILE_READY_OUTPUT',\n oRanOpenfrontManagementPlane: 'unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT',\n notifyNewAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyChangedAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyChangedAlarmGeneral: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyAckStateChanged: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyCorrelatedNotificationChanged: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyComments: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyClearedAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyAlarmListRebuilt: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyPotentialFaultyAlarmList: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT'\n};\nconst longPolling = '?timeout=60000'\nconst urlTopic = urlMapping[msg.topic] || msg.topic.replace(':', '-');\nmsg.url = [base, path, urlTopic, '1', '1'].join('/') + longPolling;\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 500,
+ "y": 220,
+ "wires": [
+ [
+ "5437e3fdfca300c9"
+ ]
+ ]
+ },
+ {
+ "id": "42275e9c12f8e52b",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
+ "name": "from O-RAN-SC",
+ "info": "",
+ "x": 100,
+ "y": 220,
+ "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": 360,
+ "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": 300,
+ "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": 260,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "3051f52553efaaa4",
+ "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": 850,
+ "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": 530,
+ "y": 180,
+ "wires": [
+ [
+ "e4ec70e46406674f"
+ ]
+ ]
+ },
+ {
+ "id": "34b7ac222692e06d",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
"name": "from OpenFronthaul Management-Plane",
"info": "",
- "x": 180,
- "y": 280,
+ "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": "60",
+ "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"
+ ]
+ ]
+ },
+ {
+ "id": "d932661ae80274a1",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyNewAlarm",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyNewAlarm",
+ "payload": "",
+ "payloadType": "date",
+ "x": 240,
+ "y": 600,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "c4337f08252203ec",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyChangedAlarm",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyChangedAlarm",
+ "payload": "",
+ "payloadType": "date",
+ "x": 230,
+ "y": 640,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "62048992a866405d",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyChangedAlarmGeneral",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyChangedAlarmGeneral",
+ "payload": "",
+ "payloadType": "date",
+ "x": 200,
+ "y": 680,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "353e0a6e1e693ae5",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyAckStateChanged",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyAckStateChanged",
+ "payload": "",
+ "payloadType": "date",
+ "x": 220,
+ "y": 720,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "3879e3d1320f1459",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyCorrelatedNotificationChanged",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyCorrelatedNotificationChanged",
+ "payload": "",
+ "payloadType": "date",
+ "x": 180,
+ "y": 760,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "ea314b13220c8f40",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyComments",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyComments",
+ "payload": "",
+ "payloadType": "date",
+ "x": 240,
+ "y": 800,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "407c7befca74d24b",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyClearedAlarm",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyClearedAlarm",
+ "payload": "",
+ "payloadType": "date",
+ "x": 230,
+ "y": 840,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "c054dd03a80a4e48",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyAlarmListRebuilt",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyAlarmListRebuilt",
+ "payload": "",
+ "payloadType": "date",
+ "x": 220,
+ "y": 880,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "5c8b20a14ea5863a",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyPotentialFaultyAlarmList",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyPotentialFaultyAlarmList",
+ "payload": "",
+ "payloadType": "date",
+ "x": 200,
+ "y": 920,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "f5d7d173f1ac5213",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
+ "name": "TS28532_FaultMnS.yaml",
+ "info": "",
+ "x": 130,
+ "y": 560,
+ "wires": []
+ },
+ {
+ "id": "c6687553f38611cd",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
+ "name": "TS28532_FileDataReportingMnS.yaml",
+ "info": "",
+ "x": 170,
+ "y": 440,
"wires": []
},
{
- "id": "efd550c650283862",
+ "id": "64720217524b2f2c",
"type": "inject",
"z": "c5746e29f53f72ce",
- "name": "oRanOpenfrontManagementPlane",
+ "name": "notifyFilePreparationError",
"props": [
{
"p": "payload"
"crontab": "",
"once": false,
"onceDelay": 0.1,
- "topic": "oRanOpenfrontManagementPlane",
+ "topic": "notifyFilePreparationError",
"payload": "",
"payloadType": "date",
- "x": 180,
- "y": 320,
+ "x": 210,
+ "y": 520,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "e4ec70e46406674f",
+ "type": "function",
+ "z": "c5746e29f53f72ce",
+ "name": "http-preparation",
+ "func": "const protocol = env.get('MESSAGES_PROTOCOL');\nconst host = env.get('MESSAGES_HOST');\nconst port = env.get('MESSAGES_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst path = msg.topic;\nmsg.url = [base, path].join('/');\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 680,
+ "y": 180,
+ "wires": [
+ [
+ "3051f52553efaaa4"
+ ]
+ ]
+ },
+ {
+ "id": "58232148f55eafc9",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "heartbeat (deprecated)",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "60",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "heartbeat",
+ "payload": "",
+ "payloadType": "date",
+ "x": 210,
+ "y": 120,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "23cf0bc0546d281b",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "fault (deprecated)",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "60",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "fault",
+ "payload": "",
+ "payloadType": "date",
+ "x": 230,
+ "y": 160,
"wires": [
[
"e5f66f4bd6777ca0"
]
]
+ },
+ {
+ "id": "c5648c1528804847",
+ "type": "inject",
+ "z": "7ba02ed596e8cde5",
+ "name": "supervision-watchdog-reset for O-RU-11221",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "supervision-watchdog-reset",
+ "payload": "[\"O-RU-11221\"]",
+ "payloadType": "json",
+ "x": 230,
+ "y": 100,
+ "wires": [
+ [
+ "2bd693b8c7e5a3cb"
+ ]
+ ]
+ },
+ {
+ "id": "329e838eb4bf63f4",
+ "type": "function",
+ "z": "7ba02ed596e8cde5",
+ "name": "http-preparation",
+ "func": "const protocol = env.get('SDN_CONTROLLER_PROTOCOL');\nconst host = env.get('SDN_CONTROLLER_HOST');\nconst port = env.get('SDN_CONTROLLER_PORT');;\nconst base = protocol + '://' + host + ':' + port;\nconst path = 'rests/operations/network-topology:network-topology/topology=topology-netconf/node=';\nconst nodeId = msg.payload;\nconst mount = 'yang-ext:mount';\nconst action = 'o-ran-supervision:supervision-watchdog-reset';\nmsg.url = [base,path + nodeId, mount, action].join('/');\n\nconst user = env.get('SDN_CONTROLLER_USERNAME');\nconst password = env.get('SDN_CONTROLLER_PASSWORD');\nconst auth = Buffer.from([user, password].join(':')).toString('base64')\nconst basicAuth = ['Basic', auth].join(' ');\n\nmsg.headers = {};\nmsg.headers['Content-Type'] = 'application/yang-data+json';\nmsg.headers['Accept'] = 'application/yang-data+json';\nmsg.headers['Authorization'] = basicAuth;\n\nmsg.payload = { \n \"o-ran-supervision:input\": \n {\n \"supervision-notification-interval\": 60, \n \"guard-timer-overhead\": 10\n }\n}\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 560,
+ "y": 220,
+ "wires": [
+ [
+ "1a4b6a4ec23c8f9f",
+ "2bd693b8c7e5a3cb"
+ ]
+ ]
+ },
+ {
+ "id": "1a4b6a4ec23c8f9f",
+ "type": "http request",
+ "z": "7ba02ed596e8cde5",
+ "name": "RESTCONF request",
+ "method": "POST",
+ "ret": "txt",
+ "paytoqs": "ignore",
+ "url": "",
+ "tls": "7b2f4859e5963695",
+ "persist": true,
+ "proxy": "",
+ "insecureHTTPParser": true,
+ "authType": "",
+ "senderr": false,
+ "headers": [],
+ "x": 800,
+ "y": 220,
+ "wires": [
+ [
+ "eb6c2de759c8eb54"
+ ]
+ ]
+ },
+ {
+ "id": "eb6c2de759c8eb54",
+ "type": "debug",
+ "z": "7ba02ed596e8cde5",
+ "name": "Response",
+ "active": true,
+ "tosidebar": true,
+ "console": true,
+ "tostatus": true,
+ "complete": "payload",
+ "targetType": "msg",
+ "statusVal": "payload.length",
+ "statusType": "msg",
+ "x": 1010,
+ "y": 220,
+ "wires": []
+ },
+ {
+ "id": "0d3ade9a80560c04",
+ "type": "inject",
+ "z": "7ba02ed596e8cde5",
+ "name": "Every 5s",
+ "props": [],
+ "repeat": "5",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "",
+ "x": 120,
+ "y": 140,
+ "wires": [
+ [
+ "5322d78ad66fcb96"
+ ]
+ ]
+ },
+ {
+ "id": "5322d78ad66fcb96",
+ "type": "function",
+ "z": "7ba02ed596e8cde5",
+ "name": "Consumer (new Data?)",
+ "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": "",
+ "finalize": "",
+ "libs": [],
+ "x": 310,
+ "y": 140,
+ "wires": [
+ [
+ "2bd693b8c7e5a3cb"
+ ]
+ ]
+ },
+ {
+ "id": "2bd693b8c7e5a3cb",
+ "type": "loop",
+ "z": "7ba02ed596e8cde5",
+ "name": "Loop through O-RUs",
+ "kind": "enum",
+ "count": "",
+ "initial": "1",
+ "step": "1",
+ "condition": "",
+ "conditionType": "js",
+ "when": "before",
+ "enumeration": "payload",
+ "enumerationType": "msg",
+ "limit": "",
+ "loopPayload": "loop-val",
+ "finalPayload": "final-last",
+ "x": 580,
+ "y": 140,
+ "wires": [
+ [],
+ [
+ "329e838eb4bf63f4"
+ ]
+ ]
+ },
+ {
+ "id": "f7dc363e5421d1cf",
+ "type": "comment",
+ "z": "7ba02ed596e8cde5",
+ "name": "Supervision",
+ "info": "",
+ "x": 90,
+ "y": 40,
+ "wires": []
+ },
+ {
+ "id": "a72d8f5e9683dd39",
+ "type": "comment",
+ "z": "7ba02ed596e8cde5",
+ "name": "The Consumer checks for data on the message router provided by the \"Massage Topics\" flow.",
+ "info": "The Consumer checks for data on the message router provided by the \"Massage Topics\" flow.",
+ "x": 520,
+ "y": 280,
+ "wires": []
}
]
\ No newline at end of file
Code Review / oam.git / blobdiff