3 "id": "51e83a0892da060e",
5 "label": "Event Streaming (VES)",
7 "info": "Sends a VES messages with body defined by 3GPP TS 28.532.\n",
11 "id": "db7b8dca98eba850",
13 "label": "Message Topics",
15 "info": "Subscribes to kafka topics using the strimzi kafka bridge implementation. \n",
19 "id": "7ba02ed596e8cde5",
21 "label": "OpenFronthaul",
27 "id": "7b2f4859e5963695",
37 "verifyservercert": false,
41 "id": "91a1f8d3ce84ceda",
43 "z": "51e83a0892da060e",
44 "name": "notifyFileReady",
58 "topic": "notifyFileReady",
60 "payloadType": "date",
71 "id": "b5533c10604af5a6",
73 "z": "51e83a0892da060e",
75 "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;",
90 "id": "f8e64d1cb25eb4ab",
92 "z": "51e83a0892da060e",
93 "name": "vesStndDefindBody",
94 "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/NotifyFileReady',\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 additionalText: 'Have fun!'\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;",
109 "id": "f65b1c13e0243ef6",
111 "z": "51e83a0892da060e",
115 "property": "payload",
116 "propertyType": "msg",
123 "reduceRight": false,
126 "reduceInitType": "",
137 "id": "1d6949a57bce82ab",
139 "z": "51e83a0892da060e",
140 "name": "http-preparation",
141 "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;",
157 "id": "27e1d8d1e9b8fd93",
158 "type": "http request",
159 "z": "51e83a0892da060e",
165 "tls": "7b2f4859e5963695",
168 "insecureHTTPParser": false,
181 "id": "f3412bcb9e134063",
183 "z": "51e83a0892da060e",
184 "name": "VesCollectorResponse",
189 "complete": "payload",
191 "statusVal": "payload",
192 "statusType": "auto",
198 "id": "b5e1e7a83051b5b6",
200 "z": "51e83a0892da060e",
201 "name": "pnfRegistration",
215 "topic": "pnfRegistration",
217 "payloadType": "date",
228 "id": "bd43459cf3907a5a",
230 "z": "51e83a0892da060e",
232 "func": "msg.topic = 'pnfRegistrationFields';\nmsg.payload = {\n pnfRegistrationFieldsVersion: '2.1',\n lastServiceDate: '2023-02-05',\n macAddress: '02:42:f7:d4:62:ce',\n manufactureDate: '2021-01-16',\n modelNumber: 'O-RAN-SC Model',\n oamV4IpAddress: '10.10.10.11',\n oamV6IpAddress: '0:0:0:0:0:ffff:a0a:011',\n serialNumber: 'VENDORA-PNF2-10.10.10.11-pnf2 BestInClass',\n softwareVersion: '2.3.5',\n unitFamily: \"O-RAN-SC\",\n unitType: 'PNF2',\n vendorName: env.get('APP_VENDOR'),\n additionalFields: {\n oamPort: '830',\n protocol: 'SSH',\n username: 'netconf',\n password: 'netconf!',\n reconnectOnChangedSchema: 'false',\n 'sleep-factor': '1.5',\n tcpOnly: 'false',\n connectionTimeout: '20000',\n maxConnectionAttempts: '100',\n betweenAttemptsTimeout: '2000',\n keepaliveDelay: '120'\n}\n};\nreturn msg;",
247 "id": "9ab2b4d9caf52c14",
249 "z": "51e83a0892da060e",
250 "name": "ves-message-data",
255 "complete": "payload",
257 "statusVal": "payload.event.commonEventHeader.stndDefinedNamespace",
264 "id": "7d589030272c0a94",
266 "z": "51e83a0892da060e",
268 "name": "notifyHeartbeat",
282 "topic": "notifyHeartbeat",
284 "payloadType": "date",
295 "id": "ab3bc53f12d28d8f",
297 "z": "51e83a0892da060e",
298 "name": "vesStndDefindBody",
299 "func": "const timeStamp = new Date(msg.payload);\nmsg.payload = {\n schemaReference: 'https://forge.3gpp.org/rep/sa5/MnS/raw/Rel-18/OpenAPI/TS28532_HeartbeatNtf.yaml#components/schemas/NotifyHeartbeat',\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 heartbeatNtfPeriod: 120\n }\n};\nmsg.topic = \"stndDefinedFields\";\nreturn msg;",
314 "id": "1bada25ea9a5aa01",
316 "z": "51e83a0892da060e",
317 "name": "from SA5 R-18 branch",
324 "id": "f4f4670363ec760f",
326 "z": "51e83a0892da060e",
327 "name": "from O-RAN-SC",
334 "id": "e4dc4647c388ab77",
336 "z": "51e83a0892da060e",
344 "id": "fb6413675e22dc71",
346 "z": "51e83a0892da060e",
347 "name": "o1NotifyPnfRegistration",
361 "topic": "o1NotifyPnfRegistration",
363 "payloadType": "date",
374 "id": "73beab79d5024f4b",
376 "z": "51e83a0892da060e",
377 "name": "oRanScDuHelloWorldPmStreaming",
391 "topic": "oRanScDuHelloWorldPmStreaming",
393 "payloadType": "date",
404 "id": "51f5fa54867b7e65",
406 "z": "51e83a0892da060e",
407 "name": "vesStndDefindBody",
408 "func": "const timeStamp = new Date(msg.payload);\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/yang/working/o-ran-sc/template/yes-o1-notify-pnf-registration.yang',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'object-class': 'managed-element',\n 'object-instance': global.get('os').hostname(),\n 'notification-identifier': Number(timeStamp),\n 'notification-type': msg.topic,\n 'event-time': timeStamp.toISOString(),\n systemDN: \"/\",\n 'vendor-pen': '57272',\n 'vendor-name': 'highstreet technologies USA Corp.',\n 'oam-host': global.get('os').networkInterfaces()['eth0'][0].address || global.get('os').hostname(),\n 'oam-port': 830,\n 'unit-family': 'O-RAN-SC',\n 'unit-type': 'PNF2',\n 'restart-reason': 'system-reboot',\n 'serial-number': 'O-RAN-SC-PNF2-10.10.10.11-pnf2 BestInClass',\n 'macAddress': global.get('os').networkInterfaces()['eth0'][0].mac || '00:00:00:00:00:00',\n 'modelNumber': 'O-RAN-SC Model',\n 'softwareVersion': '2.3.5',\n 'manufactureDate': '2021-01-16',\n 'lastServiceDate': '2021-03-26',\n 'transport-protocol': 'SSH',\n 'username': 'netconf',\n 'password': 'netconf!',\n 'reconnect-on-changed-schema': 'false',\n 'sleep-factor': '1.5',\n 'tcpOnly': 'false',\n 'connection-timeout': '20000',\n 'max-connection-attempts': '100',\n 'between-attempts-timeout': '2000',\n 'keepalive-delay': '120'\n }\n};\nmsg.topic = \"stndDefinedFields\";\nreturn msg;",
423 "id": "5c6f93626fac58b5",
425 "z": "51e83a0892da060e",
426 "name": "vesStndDefindBody",
427 "func": "const timeStamp = new Date(msg.payload);\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/oas3/experimental/o-ran-sc-du-hello-world-pm-streaming-oas3.yaml#components/schemas/performance-measurement-job',\n stndDefinedFieldsVersion: '1.0',\n data: {\n id: 'id:' + Number(timeStamp),\n 'start-time': timeStamp.toISOString(),\n 'administrative-state': 'unlocked',\n 'operational-state': 'enabled',\n 'user-label': 'pm-kpis',\n 'job-tag': '1a0827b7-25e7-4292-959f-6b8ab46f14c2',\n 'granularity-period': 900,\n measurements: [\n {\n 'measurement-type-instance-reference': 'user-equipment-average-throughput-downlink',\n value: 300000000,\n unit: 'kBis/s'\n },\n {\n 'measurement-type-instance-reference': 'user-equipment-average-throughput-uplink',\n value: 300000000,\n unit: 'kBis/s'\n }\n ]\n }\n};\nmsg.topic = \"stndDefinedFields\";\nreturn msg;\n\n",
442 "id": "456597d0477d239f",
444 "z": "51e83a0892da060e",
445 "name": "o-ran-file-management:file-download-event",
459 "topic": "o-ran-file-management:file-download-event",
461 "payloadType": "date",
472 "id": "f40d1d16c7044edc",
474 "z": "51e83a0892da060e",
475 "name": "vesStndDefindBody",
476 "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;",
491 "id": "3d8f8180f204d804",
493 "z": "51e83a0892da060e",
494 "name": "o-ran-file-management:file-upload-notification",
508 "topic": "o-ran-file-management:file-upload-notification",
510 "payloadType": "date",
521 "id": "d473bf42d8169599",
523 "z": "51e83a0892da060e",
524 "name": "vesStndDefindBody",
525 "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;",
540 "id": "ec85f2a64f79450d",
542 "z": "51e83a0892da060e",
543 "name": "o-ran-supervision:supervision-notification",
557 "topic": "o-ran-supervision:supervision-notification",
559 "payloadType": "date",
570 "id": "96ea9b3d7d4121dc",
572 "z": "51e83a0892da060e",
573 "name": "vesStndDefindBody",
574 "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;",
589 "id": "027098b9ba7cd1e6",
591 "z": "51e83a0892da060e",
592 "name": "from OpenFronthaul Management-Plane",
599 "id": "e80ff3c876a343e5",
601 "z": "51e83a0892da060e",
603 "name": "o-ran-ald-port:dc-enabled-status-change",
617 "topic": "o-ran-ald-port:dc-enabled-status-change",
619 "payloadType": "date",
627 "id": "c61fe1f3bdb954d5",
629 "z": "51e83a0892da060e",
631 "name": "o-ran-ald-port:overcurrent-report",
645 "topic": "o-ran-ald-port:overcurrent-report",
647 "payloadType": "date",
655 "id": "939ac153e888cc93",
657 "z": "51e83a0892da060e",
659 "name": "o-ran-antenna-calibration:antenna-calibration-coordinated",
673 "topic": "o-ran-antenna-calibration:antenna-calibration-coordinated",
675 "payloadType": "date",
683 "id": "f7834ee33e7731fb",
685 "z": "51e83a0892da060e",
687 "name": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params",
701 "topic": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params",
703 "payloadType": "date",
711 "id": "8e98d432fcaef200",
713 "z": "51e83a0892da060e",
715 "name": "o-ran-antenna-calibration:antenna-calibration-required",
729 "topic": "o-ran-antenna-calibration:antenna-calibration-required",
731 "payloadType": "date",
739 "id": "554cb2ce5934b36c",
741 "z": "51e83a0892da060e",
743 "name": "o-ran-antenna-calibration:antenna-calibration-result",
757 "topic": "o-ran-antenna-calibration:antenna-calibration-result",
759 "payloadType": "date",
767 "id": "391ce0bfa3b8003d",
769 "z": "51e83a0892da060e",
771 "name": "o-ran-beamforming:beamforming-information-update",
785 "topic": "o-ran-beamforming:beamforming-information-update",
787 "payloadType": "date",
795 "id": "966ca15e87b419f5",
797 "z": "51e83a0892da060e",
799 "name": "o-ran-beamforming:capability-group-beamforming-information-update",
813 "topic": "o-ran-beamforming:capability-group-beamforming-information-update",
815 "payloadType": "date",
823 "id": "243cffacec890e26",
825 "z": "51e83a0892da060e",
827 "name": "o-ran-beamforming:predefined-beam-tilt-offset-complete",
841 "topic": "o-ran-beamforming:predefined-beam-tilt-offset-complete",
843 "payloadType": "date",
851 "id": "843c4093e2ddd914",
853 "z": "51e83a0892da060e",
855 "name": "o-ran-externalio:external-input-change",
869 "topic": "o-ran-externalio:external-input-change",
871 "payloadType": "date",
879 "id": "627b31335d7e5b6f",
881 "z": "51e83a0892da060e",
883 "name": "o-ran-fm:alarm-notif",
897 "topic": "o-ran-fm:alarm-notif",
899 "payloadType": "date",
907 "id": "87c1e3e0e87bd7c1",
909 "z": "51e83a0892da060e",
911 "name": "o-ran-laa-operations:measurement-result",
925 "topic": "o-ran-laa-operations:measurement-result",
927 "payloadType": "date",
935 "id": "27d98684362bee02",
937 "z": "51e83a0892da060e",
939 "name": "o-ran-performance-management:measurement-result-stats",
953 "topic": "o-ran-performance-management:measurement-result-stats",
955 "payloadType": "date",
963 "id": "03292a70960f7d50",
965 "z": "51e83a0892da060e",
967 "name": "o-ran-software-management:activation-event",
981 "topic": "o-ran-software-management:activation-event",
983 "payloadType": "date",
991 "id": "652dbf9c0ef73057",
993 "z": "51e83a0892da060e",
995 "name": "o-ran-software-management:download-event",
1009 "topic": "o-ran-software-management:download-event",
1011 "payloadType": "date",
1019 "id": "0636add6c6d4d5e2",
1021 "z": "51e83a0892da060e",
1023 "name": "o-ran-software-management:install-event",
1037 "topic": "o-ran-software-management:install-event",
1039 "payloadType": "date",
1047 "id": "4c274d02a62c7565",
1049 "z": "51e83a0892da060e",
1051 "name": "o-ran-sync:gnss-state-change",
1065 "topic": "o-ran-sync:gnss-state-change",
1067 "payloadType": "date",
1075 "id": "ad0e319d109512e7",
1077 "z": "51e83a0892da060e",
1079 "name": "o-ran-sync:ptp-state-change",
1093 "topic": "o-ran-sync:ptp-state-change",
1095 "payloadType": "date",
1103 "id": "de24c11aa05ce94e",
1105 "z": "51e83a0892da060e",
1107 "name": "o-ran-sync:synce-state-change",
1121 "topic": "o-ran-sync:synce-state-change",
1123 "payloadType": "date",
1131 "id": "a9b33c01b841cc78",
1133 "z": "51e83a0892da060e",
1135 "name": "o-ran-sync:synchronization-state-change",
1149 "topic": "o-ran-sync:synchronization-state-change",
1151 "payloadType": "date",
1159 "id": "f4a87018c664902f",
1161 "z": "51e83a0892da060e",
1163 "name": "o-ran-trace:trace-log-generated",
1177 "topic": "o-ran-trace:trace-log-generated",
1179 "payloadType": "date",
1187 "id": "7cbe4e4faa26098b",
1189 "z": "51e83a0892da060e",
1191 "name": "o-ran-uplane-conf:rx-array-carriers-state-change",
1205 "topic": "o-ran-uplane-conf:rx-array-carriers-state-change",
1207 "payloadType": "date",
1215 "id": "a5eeb9d399c203ca",
1217 "z": "51e83a0892da060e",
1219 "name": "o-ran-troubleshooting:troubleshooting-log-generated",
1233 "topic": "o-ran-troubleshooting:troubleshooting-log-generated",
1235 "payloadType": "date",
1243 "id": "b9d72e03c66c78b3",
1245 "z": "51e83a0892da060e",
1247 "name": "o-ran-uplane-conf:tx-array-carriers-state-change",
1261 "topic": "o-ran-uplane-conf:tx-array-carriers-state-change",
1263 "payloadType": "date",
1271 "id": "bfa425cb3d578d07",
1273 "z": "51e83a0892da060e",
1274 "name": "notifyNewAlarm",
1288 "topic": "notifyNewAlarm",
1290 "payloadType": "date",
1301 "id": "f71ebd595a7de756",
1303 "z": "51e83a0892da060e",
1304 "name": "vesStndDefindBody",
1305 "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;",
1320 "id": "82da4e47972195a4",
1322 "z": "51e83a0892da060e",
1324 "name": "notifyChangedAlarm",
1338 "topic": "notifyChangedAlarm",
1340 "payloadType": "date",
1348 "id": "a3d85c62bee11dad",
1350 "z": "51e83a0892da060e",
1352 "name": "notifyChangedAlarmGeneral",
1366 "topic": "notifyChangedAlarmGeneral",
1368 "payloadType": "date",
1376 "id": "e4651c07a56f2448",
1378 "z": "51e83a0892da060e",
1380 "name": "notifyAckStateChanged",
1394 "topic": "notifyAckStateChanged",
1396 "payloadType": "date",
1404 "id": "e949006e1b1fe0f0",
1406 "z": "51e83a0892da060e",
1408 "name": "notifyCorrelatedNotificationChanged",
1422 "topic": "notifyCorrelatedNotificationChanged",
1424 "payloadType": "date",
1432 "id": "a80169493419d5d0",
1434 "z": "51e83a0892da060e",
1436 "name": "notifyComments",
1450 "topic": "notifyComments",
1452 "payloadType": "date",
1460 "id": "9e0f49b3d9b0a5ef",
1462 "z": "51e83a0892da060e",
1463 "name": "notifyClearedAlarm",
1477 "topic": "notifyClearedAlarm",
1479 "payloadType": "date",
1490 "id": "418d585d7406029b",
1492 "z": "51e83a0892da060e",
1494 "name": "notifyAlarmListRebuilt",
1508 "topic": "notifyAlarmListRebuilt",
1510 "payloadType": "date",
1518 "id": "f856982bb3c3a65c",
1520 "z": "51e83a0892da060e",
1522 "name": "notifyPotentialFaultyAlarmList",
1536 "topic": "notifyPotentialFaultyAlarmList",
1538 "payloadType": "date",
1546 "id": "4617f66b8940469e",
1548 "z": "51e83a0892da060e",
1549 "name": "TS28532_FaultMnS.yaml",
1556 "id": "69b8d53969426ebf",
1558 "z": "51e83a0892da060e",
1559 "name": "vesStndDefindBody",
1560 "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;",
1575 "id": "01e14b971772ee0a",
1577 "z": "51e83a0892da060e",
1578 "name": "TS28532_FileDataReportingMnS.yaml",
1585 "id": "ea15cafd2325d76f",
1587 "z": "51e83a0892da060e",
1588 "name": "notifyFilePreparationError",
1602 "topic": "notifyFilePreparationError",
1604 "payloadType": "date",
1615 "id": "9f4bc0920fa3c0eb",
1617 "z": "51e83a0892da060e",
1618 "name": "vesStndDefindBody",
1619 "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;",
1634 "id": "a2d14719998c5951",
1636 "z": "db7b8dca98eba850",
1637 "name": "eventData",
1642 "complete": "payload",
1643 "targetType": "msg",
1644 "statusVal": "payload.length",
1645 "statusType": "msg",
1651 "id": "393ee0aac0784928",
1653 "z": "db7b8dca98eba850",
1670 "payloadType": "date",
1680 "id": "9745e4eaaad146b5",
1681 "type": "http request",
1682 "z": "db7b8dca98eba850",
1686 "paytoqs": "ignore",
1688 "tls": "7b2f4859e5963695",
1691 "insecureHTTPParser": true,
1704 "id": "ec4917fbcca1ea55",
1706 "z": "db7b8dca98eba850",
1708 "func": "global.set('topicData', msg.payload)\nreturn msg;",
1723 "id": "f8d2934457eb7030",
1725 "z": "db7b8dca98eba850",
1726 "name": "http-preparation",
1727 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');;\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\n\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};\n\nmsg.url = [base, 'consumers', group, 'instances', name, 'records'].join('/');\nmsg.headers = {\n accept: 'application/vnd.kafka.json.v2+json'\n}\nreturn msg;",
1742 "id": "c82c06ee1b7fad77",
1744 "z": "db7b8dca98eba850",
1745 "name": "Get Records",
1752 "id": "6cc496f1420404b3",
1754 "z": "db7b8dca98eba850",
1771 "payloadType": "date",
1781 "id": "7a931d124e3fdc64",
1783 "z": "db7b8dca98eba850",
1784 "name": "http-preparation",
1785 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst path = msg.topic;\nmsg.url = [base, path].join('/');\nmsg.method = 'get';\nmsg.headers = {\n accept: 'application/vnd.kafka.v2+json'\n}\nreturn msg;",
1800 "id": "051acf7693d4d457",
1802 "z": "db7b8dca98eba850",
1803 "name": "Do Subscription",
1817 "topic": "subscription",
1819 "payloadType": "date",
1829 "id": "a72e6d0ab9261954",
1831 "z": "db7b8dca98eba850",
1832 "name": "http-preparation",
1833 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, 'consumers', group, 'instances', name, msg.topic].join('/');\nmsg.method = 'post';\nmsg.headers = {\n 'content-type': 'application/vnd.kafka.v2+json',\n accept: 'application/vnd.kafka.v2+json'\n}\nmsg.payload = {\n \"topics\": [\"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\", \"unauthenticated.SEC_HEARTBEAT_OUTPUT\", \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\", \"unauthenticated.VES_PNFREG_OUTPUT\", \"unauthenticated.VES_FILE_READY_OUTPUT\", \"o-ran-file-management-file-download-event\", \"bridge-quickstart-topic\", \"o-ran-file-management-file-upload-notification\", \"o-ran-supervision-supervision-notification\", \"unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT\", \"my-topic\", \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\", \"unauthenticated.SEC_FAULT_OUTPUT\"]\n}\n\nreturn msg;\n",
1848 "id": "53aae16b268527f7",
1849 "type": "http request",
1850 "z": "db7b8dca98eba850",
1851 "name": "http request",
1854 "paytoqs": "ignore",
1856 "tls": "7b2f4859e5963695",
1859 "insecureHTTPParser": true,
1872 "id": "025484501aa58b31",
1874 "z": "db7b8dca98eba850",
1880 "complete": "payload",
1881 "targetType": "msg",
1882 "statusVal": "statusCode",
1883 "statusType": "msg",
1889 "id": "2bcd1fcc0cb4f747",
1891 "z": "db7b8dca98eba850",
1908 "payloadType": "date",
1918 "id": "4b695d52e3231b6b",
1920 "z": "db7b8dca98eba850",
1921 "name": "http-preparation",
1922 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nmsg.url = [base, msg.topic].join('/');\nmsg.method = 'get';\nmsg.headers = {\n accept: 'application/json'\n}\nreturn msg;\n",
1937 "id": "2d834fde764e3443",
1939 "z": "db7b8dca98eba850",
1956 "payloadType": "date",
1966 "id": "7bbff4bdad2683f0",
1968 "z": "db7b8dca98eba850",
1985 "payloadType": "date",
1995 "id": "1b322733222d5c1d",
1997 "z": "db7b8dca98eba850",
2014 "payloadType": "date",
2024 "id": "12e182c0bee28aad",
2026 "z": "db7b8dca98eba850",
2027 "name": "CreateConsumer",
2041 "topic": "consumers",
2043 "payloadType": "date",
2053 "id": "46c33603561bf711",
2055 "z": "db7b8dca98eba850",
2056 "name": "http-preparation",
2057 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, msg.topic, group].join('/');\nmsg.method = 'post';\nmsg.headers = {\n 'content-type': 'application/vnd.kafka.v2+json',\n accept: 'application/vnd.kafka.v2+json'\n}\nmsg.payload = {\n name: name,\n format: 'json',\n 'auto.offset.reset': 'earliest',\n 'enable.auto.commit': true,\n 'fetch.min.bytes': 1,\n 'consumer.request.timeout.ms': 30000,\n 'isolation.level': 'read_uncommitted'\n}\n\nreturn msg;\n",
2072 "id": "63c336487e6e0eb9",
2074 "z": "db7b8dca98eba850",
2075 "name": "Get Subscription",
2089 "topic": "subscription",
2091 "payloadType": "date",
2101 "id": "b0f5987ab4bd1256",
2103 "z": "db7b8dca98eba850",
2104 "name": "http-preparation",
2105 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, 'consumers', group, 'instances', name, msg.topic].join('/');\nmsg.method = 'get';\nmsg.headers = {\n accept: 'application/vnd.kafka.v2+json'\n}\nreturn msg;\n",
2120 "id": "ccf49a001b3e92d2",
2122 "z": "db7b8dca98eba850",
2123 "name": "Preparation",
2130 "id": "892cacf32948fe41",
2132 "z": "db7b8dca98eba850",
2133 "name": "http-preparation",
2134 "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, msg.topic, group, 'instances', name].join('/');\nmsg.method = 'delete';\nmsg.headers = {\n 'content-type': 'application/vnd.kafka.v2+json',\n accept: 'application/vnd.kafka.v2+json'\n}\nmsg.payload = null\n\nreturn msg;\n",
2149 "id": "ca171245ae7b6184",
2151 "z": "db7b8dca98eba850",
2152 "name": "DeleteConsumer",
2166 "topic": "consumers",
2168 "payloadType": "date",
2178 "id": "c5648c1528804847",
2180 "z": "7ba02ed596e8cde5",
2181 "name": "supervision-watchdog-reset for O-RU-11221",
2195 "topic": "supervision-watchdog-reset",
2196 "payload": "[\"O-RU-11221\"]",
2197 "payloadType": "json",
2207 "id": "329e838eb4bf63f4",
2209 "z": "7ba02ed596e8cde5",
2210 "name": "http-preparation",
2211 "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;",
2227 "id": "1a4b6a4ec23c8f9f",
2228 "type": "http request",
2229 "z": "7ba02ed596e8cde5",
2230 "name": "RESTCONF request",
2233 "paytoqs": "ignore",
2235 "tls": "7b2f4859e5963695",
2238 "insecureHTTPParser": true,
2251 "id": "eb6c2de759c8eb54",
2253 "z": "7ba02ed596e8cde5",
2259 "complete": "payload",
2260 "targetType": "msg",
2261 "statusVal": "payload.length",
2262 "statusType": "msg",
2268 "id": "0d3ade9a80560c04",
2270 "z": "7ba02ed596e8cde5",
2287 "id": "5322d78ad66fcb96",
2289 "z": "7ba02ed596e8cde5",
2290 "name": "Consumer (new Data?)",
2291 "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.value.event.commonEventHeader.stndDefinedNamespace === 'o-ran-supervision:supervision-notification';\n }).map(event => {\n return event.value.event.commonEventHeader.sourceName;;\n });\n}\nmsg.payload = result;\nglobal.set('topicData', []);\nreturn msg; ",
2306 "id": "2bd693b8c7e5a3cb",
2308 "z": "7ba02ed596e8cde5",
2309 "name": "Loop through O-RUs",
2315 "conditionType": "js",
2317 "enumeration": "payload",
2318 "enumerationType": "msg",
2320 "loopPayload": "loop-val",
2321 "finalPayload": "final-last",
2332 "id": "f7dc363e5421d1cf",
2334 "z": "7ba02ed596e8cde5",
2335 "name": "Supervision",
2342 "id": "a72d8f5e9683dd39",
2344 "z": "7ba02ed596e8cde5",
2345 "name": "The Consumer checks for data on the message router provided by the \"Massage Topics\" flow.",
2346 "info": "The Consumer checks for data on the message router provided by the \"Massage Topics\" flow.",