+ },
+ {
+ "id": "1bada25ea9a5aa01",
+ "type": "comment",
+ "z": "51e83a0892da060e",
+ "name": "from SA5 R-18 branch",
+ "info": "",
+ "x": 120,
+ "y": 280,
+ "wires": []
+ },
+ {
+ "id": "f4f4670363ec760f",
+ "type": "comment",
+ "z": "51e83a0892da060e",
+ "name": "from O-RAN-SC",
+ "info": "",
+ "x": 100,
+ "y": 140,
+ "wires": []
+ },
+ {
+ "id": "e4dc4647c388ab77",
+ "type": "comment",
+ "z": "51e83a0892da060e",
+ "name": "from ONAP",
+ "info": "",
+ "x": 90,
+ "y": 40,
+ "wires": []
+ },
+ {
+ "id": "fb6413675e22dc71",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "name": "o1NotifyPnfRegistration",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "o1NotifyPnfRegistration",
+ "payload": "",
+ "payloadType": "date",
+ "x": 140,
+ "y": 180,
+ "wires": [
+ [
+ "b5533c10604af5a6",
+ "51f5fa54867b7e65"
+ ]
+ ]
+ },
+ {
+ "id": "73beab79d5024f4b",
+ "type": "inject",
+ "z": "51e83a0892da060e",
+ "name": "oRanScDuHelloWorldPmStreaming",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "oRanScDuHelloWorldPmStreaming",
+ "payload": "",
+ "payloadType": "date",
+ "x": 180,
+ "y": 220,
+ "wires": [
+ [
+ "5c6f93626fac58b5",
+ "b5533c10604af5a6"
+ ]
+ ]
+ },
+ {
+ "id": "51f5fa54867b7e65",
+ "type": "function",
+ "z": "51e83a0892da060e",
+ "name": "vesStndDefindBody",
+ "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;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 470,
+ "y": 180,
+ "wires": [
+ [
+ "f65b1c13e0243ef6"
+ ]
+ ]
+ },
+ {
+ "id": "5c6f93626fac58b5",
+ "type": "function",
+ "z": "51e83a0892da060e",
+ "name": "vesStndDefindBody",
+ "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",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 470,
+ "y": 220,
+ "wires": [
+ [
+ "f65b1c13e0243ef6"
+ ]
+ ]
+ },
+ {
+ "id": "910dfec7eb74df65",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "pnfRegistration",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "pnfRegistration",
+ "payload": "",
+ "payloadType": "date",
+ "x": 120,
+ "y": 80,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "562063a080cb99d6",
+ "type": "debug",
+ "z": "c5746e29f53f72ce",
+ "name": "eventData",
+ "active": true,
+ "tosidebar": true,
+ "console": false,
+ "tostatus": false,
+ "complete": "payload",
+ "targetType": "msg",
+ "statusVal": "",
+ "statusType": "auto",
+ "x": 950,
+ "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": 130,
+ "y": 320,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "311c3b5d3d73fc24",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "notifyFileReady",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "notifyFileReady",
+ "payload": "",
+ "payloadType": "date",
+ "x": 120,
+ "y": 360,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "5437e3fdfca300c9",
+ "type": "http request",
+ "z": "c5746e29f53f72ce",
+ "name": "",
+ "method": "GET",
+ "ret": "txt",
+ "paytoqs": "ignore",
+ "url": "",
+ "tls": "7b2f4859e5963695",
+ "persist": true,
+ "proxy": "",
+ "insecureHTTPParser": true,
+ "authType": "",
+ "senderr": false,
+ "headers": [],
+ "x": 630,
+ "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": 790,
+ "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};\nmsg.url = [base, path, urlMapping[msg.topic], '1','1'].join('/');\nreturn msg;",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 450,
+ "y": 220,
+ "wires": [
+ [
+ "5437e3fdfca300c9"
+ ]
+ ]
+ },
+ {
+ "id": "42275e9c12f8e52b",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
+ "name": "from O-RAN-SC",
+ "info": "",
+ "x": 100,
+ "y": 140,
+ "wires": []
+ },
+ {
+ "id": "e07fa97ebc66dce0",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
+ "name": "from ONAP",
+ "info": "",
+ "x": 90,
+ "y": 40,
+ "wires": []
+ },
+ {
+ "id": "44b8c2cc138777f1",
+ "type": "comment",
+ "z": "c5746e29f53f72ce",
+ "name": "from SA5 R-18 branch",
+ "info": "",
+ "x": 120,
+ "y": 280,
+ "wires": []
+ },
+ {
+ "id": "4480e5473a65a757",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "oRanScDuHelloWorldPmStreaming",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "oRanScDuHelloWorldPmStreaming",
+ "payload": "",
+ "payloadType": "date",
+ "x": 180,
+ "y": 220,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]
+ },
+ {
+ "id": "52f22ee054e5b4ac",
+ "type": "inject",
+ "z": "c5746e29f53f72ce",
+ "name": "o1NotifyPnfRegistration",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": 0.1,
+ "topic": "o1NotifyPnfRegistration",
+ "payload": "",
+ "payloadType": "date",
+ "x": 140,
+ "y": 180,
+ "wires": [
+ [
+ "e5f66f4bd6777ca0"
+ ]
+ ]