e00bb5cfc0377368b31de03c1a0262a0d7f4e112
[oam.git] / solution / smo / apps / flows / data / flows.json
1 [
2     {
3         "id": "51e83a0892da060e",
4         "type": "tab",
5         "label": "Event Streaming (VES)",
6         "disabled": false,
7         "info": "Sends a VES messages with body defined by 3GPP TS 28.532.\n",
8         "env": []
9     },
10     {
11         "id": "c5746e29f53f72ce",
12         "type": "tab",
13         "label": "Message Topics",
14         "disabled": false,
15         "info": "Subscribes to Kafka topics ",
16         "env": []
17     },
18     {
19         "id": "7b2f4859e5963695",
20         "type": "tls-config",
21         "name": "",
22         "cert": "",
23         "key": "",
24         "ca": "",
25         "certname": "",
26         "keyname": "",
27         "caname": "",
28         "servername": "",
29         "verifyservercert": false,
30         "alpnprotocol": ""
31     },
32     {
33         "id": "91a1f8d3ce84ceda",
34         "type": "inject",
35         "z": "51e83a0892da060e",
36         "name": "notifyFileReady",
37         "props": [
38             {
39                 "p": "payload"
40             },
41             {
42                 "p": "topic",
43                 "vt": "str"
44             }
45         ],
46         "repeat": "",
47         "crontab": "",
48         "once": false,
49         "onceDelay": 0.1,
50         "topic": "notifyFileReady",
51         "payload": "",
52         "payloadType": "date",
53         "x": 120,
54         "y": 460,
55         "wires": [
56             [
57                 "b5533c10604af5a6",
58                 "f8e64d1cb25eb4ab"
59             ]
60         ]
61     },
62     {
63         "id": "b5533c10604af5a6",
64         "type": "function",
65         "z": "51e83a0892da060e",
66         "name": "vesHeader",
67         "func": "const timeStamp = new Date(msg.payload);\nconst eventType = msg.topic;\nlet domain = \"stndDefined\";\n// handle domain expecption for 'pnfRegistration'\nif (eventType === 'pnfRegistration') {\n    domain = eventType;\n} \nconst nfNamingCode = env.get('APP_NETWORK_FUNCTION_ID');\nconst namespaces = {\n    pnfRegistration: undefined,\n    o1NotifyPnfRegistration: 'o1-notify-pnf-registration',\n    oRanScDuHelloWorldPmStreaming: 'o-ran-sc-du-hello-world-pm-streaming-oas3',\n    notifyHeartbeat: '3GPP-Heartbeat',\n    notifyFileReady: 'file-ready'\n};\nconst topic = namespaces[eventType] || msg.topic;\n\nmsg.topic = \"commonEventHeader\"\nmsg.payload = {\n    domain: domain,\n    eventType: eventType,\n    eventId:[nfNamingCode, eventType, msg._msgid].join('_'),\n    eventName: [domain, eventType].join('_'),\n    sequence: Number(timeStamp),\n    priority: \"Low\",\n    reportingEntityId: \"c2b7d6e9-ee35-459a-ab8e-717a6fc1fde6\",\n    reportingEntityName: global.get('os').hostname(),\n    sourceId: \"378e9904-6d39-40ea-9994-0596fe2235a3\",\n    sourceName: env.get('APP_SOURCE'),\n    startEpochMicrosec: timeStamp.getTime() * 1000,\n    lastEpochMicrosec: timeStamp.getTime() * 1000,\n    nfNamingCode: nfNamingCode,\n    nfVendorName: env.get('APP_VENDOR'),\n    timeZoneOffset: \"+00:00\",\n    stndDefinedNamespace: topic,\n    version: \"4.1\",\n    vesEventListenerVersion: \"7.2.1\"\n}\nreturn msg;",
68         "outputs": 1,
69         "noerr": 0,
70         "initialize": "",
71         "finalize": "",
72         "libs": [],
73         "x": 430,
74         "y": 260,
75         "wires": [
76             [
77                 "f65b1c13e0243ef6"
78             ]
79         ]
80     },
81     {
82         "id": "f8e64d1cb25eb4ab",
83         "type": "function",
84         "z": "51e83a0892da060e",
85         "name": "vesStndDefindBody",
86         "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;",
87         "outputs": 1,
88         "noerr": 0,
89         "initialize": "",
90         "finalize": "",
91         "libs": [],
92         "x": 470,
93         "y": 460,
94         "wires": [
95             [
96                 "f65b1c13e0243ef6"
97             ]
98         ]
99     },
100     {
101         "id": "f65b1c13e0243ef6",
102         "type": "join",
103         "z": "51e83a0892da060e",
104         "name": "",
105         "mode": "custom",
106         "build": "object",
107         "property": "payload",
108         "propertyType": "msg",
109         "key": "topic",
110         "joiner": "\\n",
111         "joinerType": "str",
112         "accumulate": false,
113         "timeout": "",
114         "count": "2",
115         "reduceRight": false,
116         "reduceExp": "",
117         "reduceInit": "",
118         "reduceInitType": "",
119         "reduceFixup": "",
120         "x": 690,
121         "y": 280,
122         "wires": [
123             [
124                 "1d6949a57bce82ab"
125             ]
126         ]
127     },
128     {
129         "id": "1d6949a57bce82ab",
130         "type": "function",
131         "z": "51e83a0892da060e",
132         "name": "createVesEvent",
133         "func": "msg.payload = {\n  event: msg.payload\n};\nreturn msg;",
134         "outputs": 1,
135         "noerr": 0,
136         "initialize": "",
137         "finalize": "",
138         "libs": [],
139         "x": 840,
140         "y": 280,
141         "wires": [
142             [
143                 "27e1d8d1e9b8fd93",
144                 "9ab2b4d9caf52c14"
145             ]
146         ]
147     },
148     {
149         "id": "27e1d8d1e9b8fd93",
150         "type": "http request",
151         "z": "51e83a0892da060e",
152         "name": "",
153         "method": "POST",
154         "ret": "txt",
155         "paytoqs": "ignore",
156         "url": "https://ves-collector.oam.smo.o-ran-sc.org/eventListener/v7",
157         "tls": "7b2f4859e5963695",
158         "persist": false,
159         "proxy": "",
160         "insecureHTTPParser": false,
161         "authType": "basic",
162         "senderr": false,
163         "headers": [],
164         "x": 1030,
165         "y": 280,
166         "wires": [
167             [
168                 "f3412bcb9e134063"
169             ]
170         ]
171     },
172     {
173         "id": "f3412bcb9e134063",
174         "type": "debug",
175         "z": "51e83a0892da060e",
176         "name": "VesCollectorResponse",
177         "active": true,
178         "tosidebar": true,
179         "console": false,
180         "tostatus": false,
181         "complete": "payload",
182         "targetType": "msg",
183         "statusVal": "",
184         "statusType": "auto",
185         "x": 1220,
186         "y": 280,
187         "wires": []
188     },
189     {
190         "id": "b5e1e7a83051b5b6",
191         "type": "inject",
192         "z": "51e83a0892da060e",
193         "name": "pnfRegistration",
194         "props": [
195             {
196                 "p": "payload"
197             },
198             {
199                 "p": "topic",
200                 "vt": "str"
201             }
202         ],
203         "repeat": "",
204         "crontab": "",
205         "once": false,
206         "onceDelay": 0.1,
207         "topic": "pnfRegistration",
208         "payload": "",
209         "payloadType": "date",
210         "x": 120,
211         "y": 80,
212         "wires": [
213             [
214                 "bd43459cf3907a5a",
215                 "b5533c10604af5a6"
216             ]
217         ]
218     },
219     {
220         "id": "bd43459cf3907a5a",
221         "type": "function",
222         "z": "51e83a0892da060e",
223         "name": "vesBody",
224         "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;",
225         "outputs": 1,
226         "noerr": 0,
227         "initialize": "",
228         "finalize": "",
229         "libs": [],
230         "x": 440,
231         "y": 80,
232         "wires": [
233             [
234                 "f65b1c13e0243ef6"
235             ]
236         ]
237     },
238     {
239         "id": "9ab2b4d9caf52c14",
240         "type": "debug",
241         "z": "51e83a0892da060e",
242         "name": "ves-message-data",
243         "active": false,
244         "tosidebar": true,
245         "console": false,
246         "tostatus": false,
247         "complete": "payload",
248         "targetType": "msg",
249         "statusVal": "",
250         "statusType": "auto",
251         "x": 1050,
252         "y": 320,
253         "wires": []
254     },
255     {
256         "id": "7d589030272c0a94",
257         "type": "inject",
258         "z": "51e83a0892da060e",
259         "d": true,
260         "name": "notifyHeartbeat",
261         "props": [
262             {
263                 "p": "payload"
264             },
265             {
266                 "p": "topic",
267                 "vt": "str"
268             }
269         ],
270         "repeat": "3",
271         "crontab": "",
272         "once": true,
273         "onceDelay": 0.1,
274         "topic": "notifyHeartbeat",
275         "payload": "",
276         "payloadType": "date",
277         "x": 130,
278         "y": 420,
279         "wires": [
280             [
281                 "b5533c10604af5a6",
282                 "ab3bc53f12d28d8f"
283             ]
284         ]
285     },
286     {
287         "id": "ab3bc53f12d28d8f",
288         "type": "function",
289         "z": "51e83a0892da060e",
290         "name": "vesStndDefindBody",
291         "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;",
292         "outputs": 1,
293         "noerr": 0,
294         "initialize": "",
295         "finalize": "",
296         "libs": [],
297         "x": 470,
298         "y": 420,
299         "wires": [
300             [
301                 "f65b1c13e0243ef6"
302             ]
303         ]
304     },
305     {
306         "id": "1bada25ea9a5aa01",
307         "type": "comment",
308         "z": "51e83a0892da060e",
309         "name": "from SA5 R-18 branch",
310         "info": "",
311         "x": 120,
312         "y": 380,
313         "wires": []
314     },
315     {
316         "id": "f4f4670363ec760f",
317         "type": "comment",
318         "z": "51e83a0892da060e",
319         "name": "from O-RAN-SC",
320         "info": "",
321         "x": 100,
322         "y": 140,
323         "wires": []
324     },
325     {
326         "id": "e4dc4647c388ab77",
327         "type": "comment",
328         "z": "51e83a0892da060e",
329         "name": "from ONAP",
330         "info": "",
331         "x": 90,
332         "y": 40,
333         "wires": []
334     },
335     {
336         "id": "fb6413675e22dc71",
337         "type": "inject",
338         "z": "51e83a0892da060e",
339         "name": "o1NotifyPnfRegistration",
340         "props": [
341             {
342                 "p": "payload"
343             },
344             {
345                 "p": "topic",
346                 "vt": "str"
347             }
348         ],
349         "repeat": "",
350         "crontab": "",
351         "once": false,
352         "onceDelay": 0.1,
353         "topic": "o1NotifyPnfRegistration",
354         "payload": "",
355         "payloadType": "date",
356         "x": 140,
357         "y": 180,
358         "wires": [
359             [
360                 "b5533c10604af5a6",
361                 "51f5fa54867b7e65"
362             ]
363         ]
364     },
365     {
366         "id": "73beab79d5024f4b",
367         "type": "inject",
368         "z": "51e83a0892da060e",
369         "name": "oRanScDuHelloWorldPmStreaming",
370         "props": [
371             {
372                 "p": "payload"
373             },
374             {
375                 "p": "topic",
376                 "vt": "str"
377             }
378         ],
379         "repeat": "",
380         "crontab": "",
381         "once": false,
382         "onceDelay": 0.1,
383         "topic": "oRanScDuHelloWorldPmStreaming",
384         "payload": "",
385         "payloadType": "date",
386         "x": 180,
387         "y": 220,
388         "wires": [
389             [
390                 "5c6f93626fac58b5",
391                 "b5533c10604af5a6"
392             ]
393         ]
394     },
395     {
396         "id": "51f5fa54867b7e65",
397         "type": "function",
398         "z": "51e83a0892da060e",
399         "name": "vesStndDefindBody",
400         "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;",
401         "outputs": 1,
402         "noerr": 0,
403         "initialize": "",
404         "finalize": "",
405         "libs": [],
406         "x": 470,
407         "y": 180,
408         "wires": [
409             [
410                 "f65b1c13e0243ef6"
411             ]
412         ]
413     },
414     {
415         "id": "5c6f93626fac58b5",
416         "type": "function",
417         "z": "51e83a0892da060e",
418         "name": "vesStndDefindBody",
419         "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",
420         "outputs": 1,
421         "noerr": 0,
422         "initialize": "",
423         "finalize": "",
424         "libs": [],
425         "x": 470,
426         "y": 220,
427         "wires": [
428             [
429                 "f65b1c13e0243ef6"
430             ]
431         ]
432     },
433     {
434         "id": "456597d0477d239f",
435         "type": "inject",
436         "z": "51e83a0892da060e",
437         "name": "o-ran-file-management:file-download-event",
438         "props": [
439             {
440                 "p": "payload"
441             },
442             {
443                 "p": "topic",
444                 "vt": "str"
445             }
446         ],
447         "repeat": "",
448         "crontab": "",
449         "once": false,
450         "onceDelay": 0.1,
451         "topic": "o-ran-file-management:file-download-event",
452         "payload": "",
453         "payloadType": "date",
454         "x": 820,
455         "y": 820,
456         "wires": [
457             [
458                 "f40d1d16c7044edc",
459                 "b5533c10604af5a6"
460             ]
461         ]
462     },
463     {
464         "id": "f40d1d16c7044edc",
465         "type": "function",
466         "z": "51e83a0892da060e",
467         "name": "vesStndDefindBody",
468         "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;",
469         "outputs": 1,
470         "noerr": 0,
471         "initialize": "",
472         "finalize": "",
473         "libs": [],
474         "x": 1150,
475         "y": 820,
476         "wires": [
477             [
478                 "f65b1c13e0243ef6"
479             ]
480         ]
481     },
482     {
483         "id": "3d8f8180f204d804",
484         "type": "inject",
485         "z": "51e83a0892da060e",
486         "name": "o-ran-file-management:file-upload-notification",
487         "props": [
488             {
489                 "p": "payload"
490             },
491             {
492                 "p": "topic",
493                 "vt": "str"
494             }
495         ],
496         "repeat": "",
497         "crontab": "",
498         "once": false,
499         "onceDelay": 0.1,
500         "topic": "o-ran-file-management:file-upload-notification",
501         "payload": "",
502         "payloadType": "date",
503         "x": 830,
504         "y": 860,
505         "wires": [
506             [
507                 "d473bf42d8169599",
508                 "b5533c10604af5a6"
509             ]
510         ]
511     },
512     {
513         "id": "d473bf42d8169599",
514         "type": "function",
515         "z": "51e83a0892da060e",
516         "name": "vesStndDefindBody",
517         "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;",
518         "outputs": 1,
519         "noerr": 0,
520         "initialize": "",
521         "finalize": "",
522         "libs": [],
523         "x": 1150,
524         "y": 860,
525         "wires": [
526             [
527                 "f65b1c13e0243ef6"
528             ]
529         ]
530     },
531     {
532         "id": "ec85f2a64f79450d",
533         "type": "inject",
534         "z": "51e83a0892da060e",
535         "name": "o-ran-supervision:supervision-notification",
536         "props": [
537             {
538                 "p": "payload"
539             },
540             {
541                 "p": "topic",
542                 "vt": "str"
543             }
544         ],
545         "repeat": "",
546         "crontab": "",
547         "once": false,
548         "onceDelay": 0.1,
549         "topic": "o-ran-supervision:supervision-notification",
550         "payload": "",
551         "payloadType": "date",
552         "x": 820,
553         "y": 1140,
554         "wires": [
555             [
556                 "96ea9b3d7d4121dc",
557                 "b5533c10604af5a6"
558             ]
559         ]
560     },
561     {
562         "id": "96ea9b3d7d4121dc",
563         "type": "function",
564         "z": "51e83a0892da060e",
565         "name": "vesStndDefindBody",
566         "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;",
567         "outputs": 1,
568         "noerr": 0,
569         "initialize": "",
570         "finalize": "",
571         "libs": [],
572         "x": 1150,
573         "y": 1140,
574         "wires": [
575             [
576                 "f65b1c13e0243ef6"
577             ]
578         ]
579     },
580     {
581         "id": "027098b9ba7cd1e6",
582         "type": "comment",
583         "z": "51e83a0892da060e",
584         "name": "from OpenFronthaul Management-Plane",
585         "info": "",
586         "x": 780,
587         "y": 380,
588         "wires": []
589     },
590     {
591         "id": "e80ff3c876a343e5",
592         "type": "inject",
593         "z": "51e83a0892da060e",
594         "d": true,
595         "name": "o-ran-ald-port:dc-enabled-status-change",
596         "props": [
597             {
598                 "p": "payload"
599             },
600             {
601                 "p": "topic",
602                 "vt": "str"
603             }
604         ],
605         "repeat": "",
606         "crontab": "",
607         "once": false,
608         "onceDelay": 0.1,
609         "topic": "o-ran-ald-port:dc-enabled-status-change",
610         "payload": "",
611         "payloadType": "date",
612         "x": 820,
613         "y": 420,
614         "wires": [
615             []
616         ]
617     },
618     {
619         "id": "c61fe1f3bdb954d5",
620         "type": "inject",
621         "z": "51e83a0892da060e",
622         "d": true,
623         "name": "o-ran-ald-port:overcurrent-report",
624         "props": [
625             {
626                 "p": "payload"
627             },
628             {
629                 "p": "topic",
630                 "vt": "str"
631             }
632         ],
633         "repeat": "",
634         "crontab": "",
635         "once": false,
636         "onceDelay": 0.1,
637         "topic": "o-ran-ald-port:overcurrent-report",
638         "payload": "",
639         "payloadType": "date",
640         "x": 790,
641         "y": 460,
642         "wires": [
643             []
644         ]
645     },
646     {
647         "id": "939ac153e888cc93",
648         "type": "inject",
649         "z": "51e83a0892da060e",
650         "d": true,
651         "name": "o-ran-antenna-calibration:antenna-calibration-coordinated",
652         "props": [
653             {
654                 "p": "payload"
655             },
656             {
657                 "p": "topic",
658                 "vt": "str"
659             }
660         ],
661         "repeat": "",
662         "crontab": "",
663         "once": false,
664         "onceDelay": 0.1,
665         "topic": "o-ran-antenna-calibration:antenna-calibration-coordinated",
666         "payload": "",
667         "payloadType": "date",
668         "x": 870,
669         "y": 500,
670         "wires": [
671             []
672         ]
673     },
674     {
675         "id": "f7834ee33e7731fb",
676         "type": "inject",
677         "z": "51e83a0892da060e",
678         "d": true,
679         "name": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params",
680         "props": [
681             {
682                 "p": "payload"
683             },
684             {
685                 "p": "topic",
686                 "vt": "str"
687             }
688         ],
689         "repeat": "",
690         "crontab": "",
691         "once": false,
692         "onceDelay": 0.1,
693         "topic": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params",
694         "payload": "",
695         "payloadType": "date",
696         "x": 930,
697         "y": 540,
698         "wires": [
699             []
700         ]
701     },
702     {
703         "id": "8e98d432fcaef200",
704         "type": "inject",
705         "z": "51e83a0892da060e",
706         "d": true,
707         "name": "o-ran-antenna-calibration:antenna-calibration-required",
708         "props": [
709             {
710                 "p": "payload"
711             },
712             {
713                 "p": "topic",
714                 "vt": "str"
715             }
716         ],
717         "repeat": "",
718         "crontab": "",
719         "once": false,
720         "onceDelay": 0.1,
721         "topic": "o-ran-antenna-calibration:antenna-calibration-required",
722         "payload": "",
723         "payloadType": "date",
724         "x": 860,
725         "y": 580,
726         "wires": [
727             []
728         ]
729     },
730     {
731         "id": "554cb2ce5934b36c",
732         "type": "inject",
733         "z": "51e83a0892da060e",
734         "d": true,
735         "name": "o-ran-antenna-calibration:antenna-calibration-result",
736         "props": [
737             {
738                 "p": "payload"
739             },
740             {
741                 "p": "topic",
742                 "vt": "str"
743             }
744         ],
745         "repeat": "",
746         "crontab": "",
747         "once": false,
748         "onceDelay": 0.1,
749         "topic": "o-ran-antenna-calibration:antenna-calibration-result",
750         "payload": "",
751         "payloadType": "date",
752         "x": 850,
753         "y": 620,
754         "wires": [
755             []
756         ]
757     },
758     {
759         "id": "391ce0bfa3b8003d",
760         "type": "inject",
761         "z": "51e83a0892da060e",
762         "d": true,
763         "name": "o-ran-beamforming:beamforming-information-update",
764         "props": [
765             {
766                 "p": "payload"
767             },
768             {
769                 "p": "topic",
770                 "vt": "str"
771             }
772         ],
773         "repeat": "",
774         "crontab": "",
775         "once": false,
776         "onceDelay": 0.1,
777         "topic": "o-ran-beamforming:beamforming-information-update",
778         "payload": "",
779         "payloadType": "date",
780         "x": 850,
781         "y": 660,
782         "wires": [
783             []
784         ]
785     },
786     {
787         "id": "966ca15e87b419f5",
788         "type": "inject",
789         "z": "51e83a0892da060e",
790         "d": true,
791         "name": "o-ran-beamforming:capability-group-beamforming-information-update",
792         "props": [
793             {
794                 "p": "payload"
795             },
796             {
797                 "p": "topic",
798                 "vt": "str"
799             }
800         ],
801         "repeat": "",
802         "crontab": "",
803         "once": false,
804         "onceDelay": 0.1,
805         "topic": "o-ran-beamforming:capability-group-beamforming-information-update",
806         "payload": "",
807         "payloadType": "date",
808         "x": 900,
809         "y": 700,
810         "wires": [
811             []
812         ]
813     },
814     {
815         "id": "243cffacec890e26",
816         "type": "inject",
817         "z": "51e83a0892da060e",
818         "d": true,
819         "name": "o-ran-beamforming:predefined-beam-tilt-offset-complete",
820         "props": [
821             {
822                 "p": "payload"
823             },
824             {
825                 "p": "topic",
826                 "vt": "str"
827             }
828         ],
829         "repeat": "",
830         "crontab": "",
831         "once": false,
832         "onceDelay": 0.1,
833         "topic": "o-ran-beamforming:predefined-beam-tilt-offset-complete",
834         "payload": "",
835         "payloadType": "date",
836         "x": 860,
837         "y": 740,
838         "wires": [
839             []
840         ]
841     },
842     {
843         "id": "843c4093e2ddd914",
844         "type": "inject",
845         "z": "51e83a0892da060e",
846         "d": true,
847         "name": "o-ran-externalio:external-input-change",
848         "props": [
849             {
850                 "p": "payload"
851             },
852             {
853                 "p": "topic",
854                 "vt": "str"
855             }
856         ],
857         "repeat": "",
858         "crontab": "",
859         "once": false,
860         "onceDelay": 0.1,
861         "topic": "o-ran-externalio:external-input-change",
862         "payload": "",
863         "payloadType": "date",
864         "x": 810,
865         "y": 780,
866         "wires": [
867             []
868         ]
869     },
870     {
871         "id": "627b31335d7e5b6f",
872         "type": "inject",
873         "z": "51e83a0892da060e",
874         "d": true,
875         "name": "o-ran-fm:alarm-notif",
876         "props": [
877             {
878                 "p": "payload"
879             },
880             {
881                 "p": "topic",
882                 "vt": "str"
883             }
884         ],
885         "repeat": "",
886         "crontab": "",
887         "once": false,
888         "onceDelay": 0.1,
889         "topic": "o-ran-fm:alarm-notif",
890         "payload": "",
891         "payloadType": "date",
892         "x": 750,
893         "y": 900,
894         "wires": [
895             []
896         ]
897     },
898     {
899         "id": "87c1e3e0e87bd7c1",
900         "type": "inject",
901         "z": "51e83a0892da060e",
902         "d": true,
903         "name": "o-ran-laa-operations:measurement-result",
904         "props": [
905             {
906                 "p": "payload"
907             },
908             {
909                 "p": "topic",
910                 "vt": "str"
911             }
912         ],
913         "repeat": "",
914         "crontab": "",
915         "once": false,
916         "onceDelay": 0.1,
917         "topic": "o-ran-laa-operations:measurement-result",
918         "payload": "",
919         "payloadType": "date",
920         "x": 820,
921         "y": 940,
922         "wires": [
923             []
924         ]
925     },
926     {
927         "id": "27d98684362bee02",
928         "type": "inject",
929         "z": "51e83a0892da060e",
930         "d": true,
931         "name": "o-ran-performance-management:measurement-result-stats",
932         "props": [
933             {
934                 "p": "payload"
935             },
936             {
937                 "p": "topic",
938                 "vt": "str"
939             }
940         ],
941         "repeat": "",
942         "crontab": "",
943         "once": false,
944         "onceDelay": 0.1,
945         "topic": "o-ran-performance-management:measurement-result-stats",
946         "payload": "",
947         "payloadType": "date",
948         "x": 870,
949         "y": 980,
950         "wires": [
951             []
952         ]
953     },
954     {
955         "id": "03292a70960f7d50",
956         "type": "inject",
957         "z": "51e83a0892da060e",
958         "d": true,
959         "name": "o-ran-software-management:activation-event",
960         "props": [
961             {
962                 "p": "payload"
963             },
964             {
965                 "p": "topic",
966                 "vt": "str"
967             }
968         ],
969         "repeat": "",
970         "crontab": "",
971         "once": false,
972         "onceDelay": 0.1,
973         "topic": "o-ran-software-management:activation-event",
974         "payload": "",
975         "payloadType": "date",
976         "x": 830,
977         "y": 1020,
978         "wires": [
979             []
980         ]
981     },
982     {
983         "id": "652dbf9c0ef73057",
984         "type": "inject",
985         "z": "51e83a0892da060e",
986         "d": true,
987         "name": "o-ran-software-management:download-event",
988         "props": [
989             {
990                 "p": "payload"
991             },
992             {
993                 "p": "topic",
994                 "vt": "str"
995             }
996         ],
997         "repeat": "",
998         "crontab": "",
999         "once": false,
1000         "onceDelay": 0.1,
1001         "topic": "o-ran-software-management:download-event",
1002         "payload": "",
1003         "payloadType": "date",
1004         "x": 830,
1005         "y": 1060,
1006         "wires": [
1007             []
1008         ]
1009     },
1010     {
1011         "id": "0636add6c6d4d5e2",
1012         "type": "inject",
1013         "z": "51e83a0892da060e",
1014         "d": true,
1015         "name": "o-ran-software-management:install-event",
1016         "props": [
1017             {
1018                 "p": "payload"
1019             },
1020             {
1021                 "p": "topic",
1022                 "vt": "str"
1023             }
1024         ],
1025         "repeat": "",
1026         "crontab": "",
1027         "once": false,
1028         "onceDelay": 0.1,
1029         "topic": "o-ran-software-management:install-event",
1030         "payload": "",
1031         "payloadType": "date",
1032         "x": 820,
1033         "y": 1100,
1034         "wires": [
1035             []
1036         ]
1037     },
1038     {
1039         "id": "4c274d02a62c7565",
1040         "type": "inject",
1041         "z": "51e83a0892da060e",
1042         "d": true,
1043         "name": "o-ran-sync:gnss-state-change",
1044         "props": [
1045             {
1046                 "p": "payload"
1047             },
1048             {
1049                 "p": "topic",
1050                 "vt": "str"
1051             }
1052         ],
1053         "repeat": "",
1054         "crontab": "",
1055         "once": false,
1056         "onceDelay": 0.1,
1057         "topic": "o-ran-sync:gnss-state-change",
1058         "payload": "",
1059         "payloadType": "date",
1060         "x": 780,
1061         "y": 1180,
1062         "wires": [
1063             []
1064         ]
1065     },
1066     {
1067         "id": "ad0e319d109512e7",
1068         "type": "inject",
1069         "z": "51e83a0892da060e",
1070         "d": true,
1071         "name": "o-ran-sync:ptp-state-change",
1072         "props": [
1073             {
1074                 "p": "payload"
1075             },
1076             {
1077                 "p": "topic",
1078                 "vt": "str"
1079             }
1080         ],
1081         "repeat": "",
1082         "crontab": "",
1083         "once": false,
1084         "onceDelay": 0.1,
1085         "topic": "o-ran-sync:ptp-state-change",
1086         "payload": "",
1087         "payloadType": "date",
1088         "x": 780,
1089         "y": 1220,
1090         "wires": [
1091             []
1092         ]
1093     },
1094     {
1095         "id": "de24c11aa05ce94e",
1096         "type": "inject",
1097         "z": "51e83a0892da060e",
1098         "d": true,
1099         "name": "o-ran-sync:synce-state-change",
1100         "props": [
1101             {
1102                 "p": "payload"
1103             },
1104             {
1105                 "p": "topic",
1106                 "vt": "str"
1107             }
1108         ],
1109         "repeat": "",
1110         "crontab": "",
1111         "once": false,
1112         "onceDelay": 0.1,
1113         "topic": "o-ran-sync:synce-state-change",
1114         "payload": "",
1115         "payloadType": "date",
1116         "x": 790,
1117         "y": 1260,
1118         "wires": [
1119             []
1120         ]
1121     },
1122     {
1123         "id": "a9b33c01b841cc78",
1124         "type": "inject",
1125         "z": "51e83a0892da060e",
1126         "d": true,
1127         "name": "o-ran-sync:synchronization-state-change",
1128         "props": [
1129             {
1130                 "p": "payload"
1131             },
1132             {
1133                 "p": "topic",
1134                 "vt": "str"
1135             }
1136         ],
1137         "repeat": "",
1138         "crontab": "",
1139         "once": false,
1140         "onceDelay": 0.1,
1141         "topic": "o-ran-sync:synchronization-state-change",
1142         "payload": "",
1143         "payloadType": "date",
1144         "x": 820,
1145         "y": 1300,
1146         "wires": [
1147             []
1148         ]
1149     },
1150     {
1151         "id": "f4a87018c664902f",
1152         "type": "inject",
1153         "z": "51e83a0892da060e",
1154         "d": true,
1155         "name": "o-ran-trace:trace-log-generated",
1156         "props": [
1157             {
1158                 "p": "payload"
1159             },
1160             {
1161                 "p": "topic",
1162                 "vt": "str"
1163             }
1164         ],
1165         "repeat": "",
1166         "crontab": "",
1167         "once": false,
1168         "onceDelay": 0.1,
1169         "topic": "o-ran-trace:trace-log-generated",
1170         "payload": "",
1171         "payloadType": "date",
1172         "x": 790,
1173         "y": 1340,
1174         "wires": [
1175             []
1176         ]
1177     },
1178     {
1179         "id": "7cbe4e4faa26098b",
1180         "type": "inject",
1181         "z": "51e83a0892da060e",
1182         "d": true,
1183         "name": "o-ran-uplane-conf:rx-array-carriers-state-change",
1184         "props": [
1185             {
1186                 "p": "payload"
1187             },
1188             {
1189                 "p": "topic",
1190                 "vt": "str"
1191             }
1192         ],
1193         "repeat": "",
1194         "crontab": "",
1195         "once": false,
1196         "onceDelay": 0.1,
1197         "topic": "o-ran-uplane-conf:rx-array-carriers-state-change",
1198         "payload": "",
1199         "payloadType": "date",
1200         "x": 840,
1201         "y": 1420,
1202         "wires": [
1203             []
1204         ]
1205     },
1206     {
1207         "id": "a5eeb9d399c203ca",
1208         "type": "inject",
1209         "z": "51e83a0892da060e",
1210         "d": true,
1211         "name": "o-ran-troubleshooting:troubleshooting-log-generated",
1212         "props": [
1213             {
1214                 "p": "payload"
1215             },
1216             {
1217                 "p": "topic",
1218                 "vt": "str"
1219             }
1220         ],
1221         "repeat": "",
1222         "crontab": "",
1223         "once": false,
1224         "onceDelay": 0.1,
1225         "topic": "o-ran-troubleshooting:troubleshooting-log-generated",
1226         "payload": "",
1227         "payloadType": "date",
1228         "x": 850,
1229         "y": 1380,
1230         "wires": [
1231             []
1232         ]
1233     },
1234     {
1235         "id": "b9d72e03c66c78b3",
1236         "type": "inject",
1237         "z": "51e83a0892da060e",
1238         "d": true,
1239         "name": "o-ran-uplane-conf:tx-array-carriers-state-change",
1240         "props": [
1241             {
1242                 "p": "payload"
1243             },
1244             {
1245                 "p": "topic",
1246                 "vt": "str"
1247             }
1248         ],
1249         "repeat": "",
1250         "crontab": "",
1251         "once": false,
1252         "onceDelay": 0.1,
1253         "topic": "o-ran-uplane-conf:tx-array-carriers-state-change",
1254         "payload": "",
1255         "payloadType": "date",
1256         "x": 840,
1257         "y": 1460,
1258         "wires": [
1259             []
1260         ]
1261     },
1262     {
1263         "id": "910dfec7eb74df65",
1264         "type": "inject",
1265         "z": "c5746e29f53f72ce",
1266         "name": "pnfRegistration",
1267         "props": [
1268             {
1269                 "p": "payload"
1270             },
1271             {
1272                 "p": "topic",
1273                 "vt": "str"
1274             }
1275         ],
1276         "repeat": "",
1277         "crontab": "",
1278         "once": false,
1279         "onceDelay": 0.1,
1280         "topic": "pnfRegistration",
1281         "payload": "",
1282         "payloadType": "date",
1283         "x": 240,
1284         "y": 80,
1285         "wires": [
1286             [
1287                 "e5f66f4bd6777ca0"
1288             ]
1289         ]
1290     },
1291     {
1292         "id": "562063a080cb99d6",
1293         "type": "debug",
1294         "z": "c5746e29f53f72ce",
1295         "name": "eventData",
1296         "active": true,
1297         "tosidebar": true,
1298         "console": false,
1299         "tostatus": false,
1300         "complete": "payload",
1301         "targetType": "msg",
1302         "statusVal": "",
1303         "statusType": "auto",
1304         "x": 990,
1305         "y": 220,
1306         "wires": []
1307     },
1308     {
1309         "id": "172060688d87f510",
1310         "type": "inject",
1311         "z": "c5746e29f53f72ce",
1312         "d": true,
1313         "name": "notifyHeartbeat",
1314         "props": [
1315             {
1316                 "p": "payload"
1317             },
1318             {
1319                 "p": "topic",
1320                 "vt": "str"
1321             }
1322         ],
1323         "repeat": "5",
1324         "crontab": "",
1325         "once": true,
1326         "onceDelay": 0.1,
1327         "topic": "notifyHeartbeat",
1328         "payload": "",
1329         "payloadType": "date",
1330         "x": 230,
1331         "y": 320,
1332         "wires": [
1333             [
1334                 "e5f66f4bd6777ca0"
1335             ]
1336         ]
1337     },
1338     {
1339         "id": "311c3b5d3d73fc24",
1340         "type": "inject",
1341         "z": "c5746e29f53f72ce",
1342         "name": "notifyFileReady",
1343         "props": [
1344             {
1345                 "p": "payload"
1346             },
1347             {
1348                 "p": "topic",
1349                 "vt": "str"
1350             }
1351         ],
1352         "repeat": "",
1353         "crontab": "",
1354         "once": false,
1355         "onceDelay": 0.1,
1356         "topic": "notifyFileReady",
1357         "payload": "",
1358         "payloadType": "date",
1359         "x": 240,
1360         "y": 360,
1361         "wires": [
1362             [
1363                 "e5f66f4bd6777ca0"
1364             ]
1365         ]
1366     },
1367     {
1368         "id": "5437e3fdfca300c9",
1369         "type": "http request",
1370         "z": "c5746e29f53f72ce",
1371         "name": "",
1372         "method": "GET",
1373         "ret": "txt",
1374         "paytoqs": "ignore",
1375         "url": "",
1376         "tls": "7b2f4859e5963695",
1377         "persist": true,
1378         "proxy": "",
1379         "insecureHTTPParser": true,
1380         "authType": "",
1381         "senderr": false,
1382         "headers": [],
1383         "x": 670,
1384         "y": 220,
1385         "wires": [
1386             [
1387                 "dc576b6355478428"
1388             ]
1389         ]
1390     },
1391     {
1392         "id": "dc576b6355478428",
1393         "type": "function",
1394         "z": "c5746e29f53f72ce",
1395         "name": "JSON",
1396         "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;",
1397         "outputs": 1,
1398         "noerr": 0,
1399         "initialize": "",
1400         "finalize": "",
1401         "libs": [],
1402         "x": 830,
1403         "y": 220,
1404         "wires": [
1405             [
1406                 "562063a080cb99d6"
1407             ]
1408         ]
1409     },
1410     {
1411         "id": "e5f66f4bd6777ca0",
1412         "type": "function",
1413         "z": "c5746e29f53f72ce",
1414         "name": "SET msg.url",
1415         "func": "const base = 'https://messages.smo.o-ran-sc.org';\nconst path = 'events';\nconst urlMapping = {\n    pnfRegistration: \"unauthenticated.VES_PNFREG_OUTPUT\",\n    o1NotifyPnfRegistration: \"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\",\n    oRanScDuHelloWorldPmStreaming: \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\",\n    notifyHeartbeat: \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\",\n    notifyFileReady: \"unauthenticated.VES_FILE_READY_OUTPUT\",\n    oRanOpenfrontManagementPlane: \"unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT\"\n};\nconst urlTopic = urlMapping[msg.topic] || msg.topic.replace(':', '-');\nmsg.url = [base, path, urlTopic, '1','1'].join('/');\nreturn msg;",
1416         "outputs": 1,
1417         "noerr": 0,
1418         "initialize": "",
1419         "finalize": "",
1420         "libs": [],
1421         "x": 490,
1422         "y": 220,
1423         "wires": [
1424             [
1425                 "5437e3fdfca300c9"
1426             ]
1427         ]
1428     },
1429     {
1430         "id": "42275e9c12f8e52b",
1431         "type": "comment",
1432         "z": "c5746e29f53f72ce",
1433         "name": "from O-RAN-SC",
1434         "info": "",
1435         "x": 100,
1436         "y": 140,
1437         "wires": []
1438     },
1439     {
1440         "id": "e07fa97ebc66dce0",
1441         "type": "comment",
1442         "z": "c5746e29f53f72ce",
1443         "name": "from ONAP",
1444         "info": "",
1445         "x": 90,
1446         "y": 40,
1447         "wires": []
1448     },
1449     {
1450         "id": "44b8c2cc138777f1",
1451         "type": "comment",
1452         "z": "c5746e29f53f72ce",
1453         "name": "from SA5 R-18 branch",
1454         "info": "",
1455         "x": 120,
1456         "y": 280,
1457         "wires": []
1458     },
1459     {
1460         "id": "4480e5473a65a757",
1461         "type": "inject",
1462         "z": "c5746e29f53f72ce",
1463         "name": "oRanScDuHelloWorldPmStreaming",
1464         "props": [
1465             {
1466                 "p": "payload"
1467             },
1468             {
1469                 "p": "topic",
1470                 "vt": "str"
1471             }
1472         ],
1473         "repeat": "",
1474         "crontab": "",
1475         "once": false,
1476         "onceDelay": 0.1,
1477         "topic": "oRanScDuHelloWorldPmStreaming",
1478         "payload": "",
1479         "payloadType": "date",
1480         "x": 180,
1481         "y": 220,
1482         "wires": [
1483             [
1484                 "e5f66f4bd6777ca0"
1485             ]
1486         ]
1487     },
1488     {
1489         "id": "52f22ee054e5b4ac",
1490         "type": "inject",
1491         "z": "c5746e29f53f72ce",
1492         "name": "o1NotifyPnfRegistration",
1493         "props": [
1494             {
1495                 "p": "payload"
1496             },
1497             {
1498                 "p": "topic",
1499                 "vt": "str"
1500             }
1501         ],
1502         "repeat": "",
1503         "crontab": "",
1504         "once": false,
1505         "onceDelay": 0.1,
1506         "topic": "o1NotifyPnfRegistration",
1507         "payload": "",
1508         "payloadType": "date",
1509         "x": 220,
1510         "y": 180,
1511         "wires": [
1512             [
1513                 "e5f66f4bd6777ca0"
1514             ]
1515         ]
1516     },
1517     {
1518         "id": "3051f52553efaaa4",
1519         "type": "http request",
1520         "z": "c5746e29f53f72ce",
1521         "name": "",
1522         "method": "GET",
1523         "ret": "txt",
1524         "paytoqs": "ignore",
1525         "url": "https://messages.smo.o-ran-sc.org/topics",
1526         "tls": "7b2f4859e5963695",
1527         "persist": true,
1528         "proxy": "",
1529         "insecureHTTPParser": true,
1530         "authType": "",
1531         "senderr": false,
1532         "headers": [
1533             {
1534                 "keyType": "other",
1535                 "keyValue": "Accept",
1536                 "valueType": "other",
1537                 "valueValue": "application/json"
1538             }
1539         ],
1540         "x": 670,
1541         "y": 180,
1542         "wires": [
1543             [
1544                 "dc576b6355478428"
1545             ]
1546         ]
1547     },
1548     {
1549         "id": "0acceacb99b7981a",
1550         "type": "inject",
1551         "z": "c5746e29f53f72ce",
1552         "name": "Topics?",
1553         "props": [
1554             {
1555                 "p": "payload"
1556             },
1557             {
1558                 "p": "topic",
1559                 "vt": "str"
1560             }
1561         ],
1562         "repeat": "",
1563         "crontab": "",
1564         "once": false,
1565         "onceDelay": 0.1,
1566         "topic": "topics",
1567         "payload": "",
1568         "payloadType": "date",
1569         "x": 510,
1570         "y": 180,
1571         "wires": [
1572             [
1573                 "3051f52553efaaa4"
1574             ]
1575         ]
1576     },
1577     {
1578         "id": "34b7ac222692e06d",
1579         "type": "comment",
1580         "z": "c5746e29f53f72ce",
1581         "name": "from OpenFronthaul Management-Plane",
1582         "info": "",
1583         "x": 580,
1584         "y": 280,
1585         "wires": []
1586     },
1587     {
1588         "id": "25a3eca83bbc3489",
1589         "type": "inject",
1590         "z": "c5746e29f53f72ce",
1591         "name": "o-ran-supervision:supervision-notification",
1592         "props": [
1593             {
1594                 "p": "payload"
1595             },
1596             {
1597                 "p": "topic",
1598                 "vt": "str"
1599             }
1600         ],
1601         "repeat": "",
1602         "crontab": "",
1603         "once": false,
1604         "onceDelay": 0.1,
1605         "topic": "o-ran-supervision:supervision-notification",
1606         "payload": "",
1607         "payloadType": "date",
1608         "x": 620,
1609         "y": 1040,
1610         "wires": [
1611             [
1612                 "e5f66f4bd6777ca0"
1613             ]
1614         ]
1615     },
1616     {
1617         "id": "0194d014ef8f6c5e",
1618         "type": "inject",
1619         "z": "c5746e29f53f72ce",
1620         "name": "o-ran-file-management:file-upload-notification",
1621         "props": [
1622             {
1623                 "p": "payload"
1624             },
1625             {
1626                 "p": "topic",
1627                 "vt": "str"
1628             }
1629         ],
1630         "repeat": "",
1631         "crontab": "",
1632         "once": false,
1633         "onceDelay": 0.1,
1634         "topic": "o-ran-file-management:file-upload-notification",
1635         "payload": "",
1636         "payloadType": "date",
1637         "x": 630,
1638         "y": 760,
1639         "wires": [
1640             [
1641                 "e5f66f4bd6777ca0"
1642             ]
1643         ]
1644     },
1645     {
1646         "id": "775aacf9e2cc0285",
1647         "type": "inject",
1648         "z": "c5746e29f53f72ce",
1649         "name": "o-ran-file-management:file-download-event",
1650         "props": [
1651             {
1652                 "p": "payload"
1653             },
1654             {
1655                 "p": "topic",
1656                 "vt": "str"
1657             }
1658         ],
1659         "repeat": "",
1660         "crontab": "",
1661         "once": false,
1662         "onceDelay": 0.1,
1663         "topic": "o-ran-file-management:file-download-event",
1664         "payload": "",
1665         "payloadType": "date",
1666         "x": 620,
1667         "y": 720,
1668         "wires": [
1669             [
1670                 "e5f66f4bd6777ca0"
1671             ]
1672         ]
1673     },
1674     {
1675         "id": "3e3be17a65a7d1bf",
1676         "type": "inject",
1677         "z": "c5746e29f53f72ce",
1678         "d": true,
1679         "name": "o-ran-ald-port:dc-enabled-status-change",
1680         "props": [
1681             {
1682                 "p": "payload"
1683             },
1684             {
1685                 "p": "topic",
1686                 "vt": "str"
1687             }
1688         ],
1689         "repeat": "",
1690         "crontab": "",
1691         "once": false,
1692         "onceDelay": 0.1,
1693         "topic": "o-ran-ald-port:dc-enabled-status-change",
1694         "payload": "",
1695         "payloadType": "date",
1696         "x": 620,
1697         "y": 320,
1698         "wires": [
1699             [
1700                 "e5f66f4bd6777ca0"
1701             ]
1702         ]
1703     },
1704     {
1705         "id": "665c45e5ccd1c9cb",
1706         "type": "inject",
1707         "z": "c5746e29f53f72ce",
1708         "d": true,
1709         "name": "o-ran-ald-port:overcurrent-report",
1710         "props": [
1711             {
1712                 "p": "payload"
1713             },
1714             {
1715                 "p": "topic",
1716                 "vt": "str"
1717             }
1718         ],
1719         "repeat": "",
1720         "crontab": "",
1721         "once": false,
1722         "onceDelay": 0.1,
1723         "topic": "o-ran-ald-port:overcurrent-report",
1724         "payload": "",
1725         "payloadType": "date",
1726         "x": 590,
1727         "y": 360,
1728         "wires": [
1729             [
1730                 "e5f66f4bd6777ca0"
1731             ]
1732         ]
1733     },
1734     {
1735         "id": "5520ce3b83578f17",
1736         "type": "inject",
1737         "z": "c5746e29f53f72ce",
1738         "d": true,
1739         "name": "o-ran-antenna-calibration:antenna-calibration-coordinated",
1740         "props": [
1741             {
1742                 "p": "payload"
1743             },
1744             {
1745                 "p": "topic",
1746                 "vt": "str"
1747             }
1748         ],
1749         "repeat": "",
1750         "crontab": "",
1751         "once": false,
1752         "onceDelay": 0.1,
1753         "topic": "o-ran-antenna-calibration:antenna-calibration-coordinated",
1754         "payload": "",
1755         "payloadType": "date",
1756         "x": 670,
1757         "y": 400,
1758         "wires": [
1759             [
1760                 "e5f66f4bd6777ca0"
1761             ]
1762         ]
1763     },
1764     {
1765         "id": "fda3090fb4f1e9d4",
1766         "type": "inject",
1767         "z": "c5746e29f53f72ce",
1768         "d": true,
1769         "name": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params",
1770         "props": [
1771             {
1772                 "p": "payload"
1773             },
1774             {
1775                 "p": "topic",
1776                 "vt": "str"
1777             }
1778         ],
1779         "repeat": "",
1780         "crontab": "",
1781         "once": false,
1782         "onceDelay": 0.1,
1783         "topic": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params",
1784         "payload": "",
1785         "payloadType": "date",
1786         "x": 730,
1787         "y": 440,
1788         "wires": [
1789             [
1790                 "e5f66f4bd6777ca0"
1791             ]
1792         ]
1793     },
1794     {
1795         "id": "2551bb6c9746a7c2",
1796         "type": "inject",
1797         "z": "c5746e29f53f72ce",
1798         "d": true,
1799         "name": "o-ran-antenna-calibration:antenna-calibration-required",
1800         "props": [
1801             {
1802                 "p": "payload"
1803             },
1804             {
1805                 "p": "topic",
1806                 "vt": "str"
1807             }
1808         ],
1809         "repeat": "",
1810         "crontab": "",
1811         "once": false,
1812         "onceDelay": 0.1,
1813         "topic": "o-ran-antenna-calibration:antenna-calibration-required",
1814         "payload": "",
1815         "payloadType": "date",
1816         "x": 660,
1817         "y": 480,
1818         "wires": [
1819             [
1820                 "e5f66f4bd6777ca0"
1821             ]
1822         ]
1823     },
1824     {
1825         "id": "0dcc72d0235e6336",
1826         "type": "inject",
1827         "z": "c5746e29f53f72ce",
1828         "d": true,
1829         "name": "o-ran-antenna-calibration:antenna-calibration-result",
1830         "props": [
1831             {
1832                 "p": "payload"
1833             },
1834             {
1835                 "p": "topic",
1836                 "vt": "str"
1837             }
1838         ],
1839         "repeat": "",
1840         "crontab": "",
1841         "once": false,
1842         "onceDelay": 0.1,
1843         "topic": "o-ran-antenna-calibration:antenna-calibration-result",
1844         "payload": "",
1845         "payloadType": "date",
1846         "x": 650,
1847         "y": 520,
1848         "wires": [
1849             [
1850                 "e5f66f4bd6777ca0"
1851             ]
1852         ]
1853     },
1854     {
1855         "id": "0abafa5c1a4ebd33",
1856         "type": "inject",
1857         "z": "c5746e29f53f72ce",
1858         "d": true,
1859         "name": "o-ran-beamforming:beamforming-information-update",
1860         "props": [
1861             {
1862                 "p": "payload"
1863             },
1864             {
1865                 "p": "topic",
1866                 "vt": "str"
1867             }
1868         ],
1869         "repeat": "",
1870         "crontab": "",
1871         "once": false,
1872         "onceDelay": 0.1,
1873         "topic": "o-ran-beamforming:beamforming-information-update",
1874         "payload": "",
1875         "payloadType": "date",
1876         "x": 650,
1877         "y": 560,
1878         "wires": [
1879             [
1880                 "e5f66f4bd6777ca0"
1881             ]
1882         ]
1883     },
1884     {
1885         "id": "d74c5f1885485d8c",
1886         "type": "inject",
1887         "z": "c5746e29f53f72ce",
1888         "d": true,
1889         "name": "o-ran-beamforming:capability-group-beamforming-information-update",
1890         "props": [
1891             {
1892                 "p": "payload"
1893             },
1894             {
1895                 "p": "topic",
1896                 "vt": "str"
1897             }
1898         ],
1899         "repeat": "",
1900         "crontab": "",
1901         "once": false,
1902         "onceDelay": 0.1,
1903         "topic": "o-ran-beamforming:capability-group-beamforming-information-update",
1904         "payload": "",
1905         "payloadType": "date",
1906         "x": 700,
1907         "y": 600,
1908         "wires": [
1909             [
1910                 "e5f66f4bd6777ca0"
1911             ]
1912         ]
1913     },
1914     {
1915         "id": "8d755b355a3d5557",
1916         "type": "inject",
1917         "z": "c5746e29f53f72ce",
1918         "d": true,
1919         "name": "o-ran-beamforming:predefined-beam-tilt-offset-complete",
1920         "props": [
1921             {
1922                 "p": "payload"
1923             },
1924             {
1925                 "p": "topic",
1926                 "vt": "str"
1927             }
1928         ],
1929         "repeat": "",
1930         "crontab": "",
1931         "once": false,
1932         "onceDelay": 0.1,
1933         "topic": "o-ran-beamforming:predefined-beam-tilt-offset-complete",
1934         "payload": "",
1935         "payloadType": "date",
1936         "x": 660,
1937         "y": 640,
1938         "wires": [
1939             []
1940         ]
1941     },
1942     {
1943         "id": "6ebe4693c580ae00",
1944         "type": "inject",
1945         "z": "c5746e29f53f72ce",
1946         "d": true,
1947         "name": "o-ran-externalio:external-input-change",
1948         "props": [
1949             {
1950                 "p": "payload"
1951             },
1952             {
1953                 "p": "topic",
1954                 "vt": "str"
1955             }
1956         ],
1957         "repeat": "",
1958         "crontab": "",
1959         "once": false,
1960         "onceDelay": 0.1,
1961         "topic": "o-ran-externalio:external-input-change",
1962         "payload": "",
1963         "payloadType": "date",
1964         "x": 610,
1965         "y": 680,
1966         "wires": [
1967             []
1968         ]
1969     },
1970     {
1971         "id": "89144928a6ead625",
1972         "type": "inject",
1973         "z": "c5746e29f53f72ce",
1974         "d": true,
1975         "name": "o-ran-fm:alarm-notif",
1976         "props": [
1977             {
1978                 "p": "payload"
1979             },
1980             {
1981                 "p": "topic",
1982                 "vt": "str"
1983             }
1984         ],
1985         "repeat": "",
1986         "crontab": "",
1987         "once": false,
1988         "onceDelay": 0.1,
1989         "topic": "o-ran-fm:alarm-notif",
1990         "payload": "",
1991         "payloadType": "date",
1992         "x": 550,
1993         "y": 800,
1994         "wires": [
1995             [
1996                 "e5f66f4bd6777ca0"
1997             ]
1998         ]
1999     },
2000     {
2001         "id": "8ebca0cd456a9763",
2002         "type": "inject",
2003         "z": "c5746e29f53f72ce",
2004         "d": true,
2005         "name": "o-ran-laa-operations:measurement-result",
2006         "props": [
2007             {
2008                 "p": "payload"
2009             },
2010             {
2011                 "p": "topic",
2012                 "vt": "str"
2013             }
2014         ],
2015         "repeat": "",
2016         "crontab": "",
2017         "once": false,
2018         "onceDelay": 0.1,
2019         "topic": "o-ran-laa-operations:measurement-result",
2020         "payload": "",
2021         "payloadType": "date",
2022         "x": 620,
2023         "y": 840,
2024         "wires": [
2025             [
2026                 "e5f66f4bd6777ca0"
2027             ]
2028         ]
2029     },
2030     {
2031         "id": "4778511387bc7449",
2032         "type": "inject",
2033         "z": "c5746e29f53f72ce",
2034         "d": true,
2035         "name": "o-ran-performance-management:measurement-result-stats",
2036         "props": [
2037             {
2038                 "p": "payload"
2039             },
2040             {
2041                 "p": "topic",
2042                 "vt": "str"
2043             }
2044         ],
2045         "repeat": "",
2046         "crontab": "",
2047         "once": false,
2048         "onceDelay": 0.1,
2049         "topic": "o-ran-performance-management:measurement-result-stats",
2050         "payload": "",
2051         "payloadType": "date",
2052         "x": 670,
2053         "y": 880,
2054         "wires": [
2055             [
2056                 "e5f66f4bd6777ca0"
2057             ]
2058         ]
2059     },
2060     {
2061         "id": "c106623d629fbe54",
2062         "type": "inject",
2063         "z": "c5746e29f53f72ce",
2064         "d": true,
2065         "name": "o-ran-software-management:activation-event",
2066         "props": [
2067             {
2068                 "p": "payload"
2069             },
2070             {
2071                 "p": "topic",
2072                 "vt": "str"
2073             }
2074         ],
2075         "repeat": "",
2076         "crontab": "",
2077         "once": false,
2078         "onceDelay": 0.1,
2079         "topic": "o-ran-software-management:activation-event",
2080         "payload": "",
2081         "payloadType": "date",
2082         "x": 630,
2083         "y": 920,
2084         "wires": [
2085             [
2086                 "e5f66f4bd6777ca0"
2087             ]
2088         ]
2089     },
2090     {
2091         "id": "4db0e5b915d76ddb",
2092         "type": "inject",
2093         "z": "c5746e29f53f72ce",
2094         "d": true,
2095         "name": "o-ran-software-management:download-event",
2096         "props": [
2097             {
2098                 "p": "payload"
2099             },
2100             {
2101                 "p": "topic",
2102                 "vt": "str"
2103             }
2104         ],
2105         "repeat": "",
2106         "crontab": "",
2107         "once": false,
2108         "onceDelay": 0.1,
2109         "topic": "o-ran-software-management:download-event",
2110         "payload": "",
2111         "payloadType": "date",
2112         "x": 630,
2113         "y": 960,
2114         "wires": [
2115             [
2116                 "e5f66f4bd6777ca0"
2117             ]
2118         ]
2119     },
2120     {
2121         "id": "8d3fab47729a807d",
2122         "type": "inject",
2123         "z": "c5746e29f53f72ce",
2124         "d": true,
2125         "name": "o-ran-software-management:install-event",
2126         "props": [
2127             {
2128                 "p": "payload"
2129             },
2130             {
2131                 "p": "topic",
2132                 "vt": "str"
2133             }
2134         ],
2135         "repeat": "",
2136         "crontab": "",
2137         "once": false,
2138         "onceDelay": 0.1,
2139         "topic": "o-ran-software-management:install-event",
2140         "payload": "",
2141         "payloadType": "date",
2142         "x": 620,
2143         "y": 1000,
2144         "wires": [
2145             [
2146                 "e5f66f4bd6777ca0"
2147             ]
2148         ]
2149     },
2150     {
2151         "id": "7ac87519cb59151d",
2152         "type": "inject",
2153         "z": "c5746e29f53f72ce",
2154         "d": true,
2155         "name": "o-ran-sync:gnss-state-change",
2156         "props": [
2157             {
2158                 "p": "payload"
2159             },
2160             {
2161                 "p": "topic",
2162                 "vt": "str"
2163             }
2164         ],
2165         "repeat": "",
2166         "crontab": "",
2167         "once": false,
2168         "onceDelay": 0.1,
2169         "topic": "o-ran-sync:gnss-state-change",
2170         "payload": "",
2171         "payloadType": "date",
2172         "x": 580,
2173         "y": 1080,
2174         "wires": [
2175             [
2176                 "e5f66f4bd6777ca0"
2177             ]
2178         ]
2179     },
2180     {
2181         "id": "55725b18e27c1a27",
2182         "type": "inject",
2183         "z": "c5746e29f53f72ce",
2184         "d": true,
2185         "name": "o-ran-sync:ptp-state-change",
2186         "props": [
2187             {
2188                 "p": "payload"
2189             },
2190             {
2191                 "p": "topic",
2192                 "vt": "str"
2193             }
2194         ],
2195         "repeat": "",
2196         "crontab": "",
2197         "once": false,
2198         "onceDelay": 0.1,
2199         "topic": "o-ran-sync:ptp-state-change",
2200         "payload": "",
2201         "payloadType": "date",
2202         "x": 580,
2203         "y": 1120,
2204         "wires": [
2205             [
2206                 "e5f66f4bd6777ca0"
2207             ]
2208         ]
2209     },
2210     {
2211         "id": "dde01e699dec844f",
2212         "type": "inject",
2213         "z": "c5746e29f53f72ce",
2214         "d": true,
2215         "name": "o-ran-sync:synce-state-change",
2216         "props": [
2217             {
2218                 "p": "payload"
2219             },
2220             {
2221                 "p": "topic",
2222                 "vt": "str"
2223             }
2224         ],
2225         "repeat": "",
2226         "crontab": "",
2227         "once": false,
2228         "onceDelay": 0.1,
2229         "topic": "o-ran-sync:synce-state-change",
2230         "payload": "",
2231         "payloadType": "date",
2232         "x": 590,
2233         "y": 1160,
2234         "wires": [
2235             [
2236                 "e5f66f4bd6777ca0"
2237             ]
2238         ]
2239     },
2240     {
2241         "id": "5457d995823e58f6",
2242         "type": "inject",
2243         "z": "c5746e29f53f72ce",
2244         "d": true,
2245         "name": "o-ran-sync:synchronization-state-change",
2246         "props": [
2247             {
2248                 "p": "payload"
2249             },
2250             {
2251                 "p": "topic",
2252                 "vt": "str"
2253             }
2254         ],
2255         "repeat": "",
2256         "crontab": "",
2257         "once": false,
2258         "onceDelay": 0.1,
2259         "topic": "o-ran-sync:synchronization-state-change",
2260         "payload": "",
2261         "payloadType": "date",
2262         "x": 620,
2263         "y": 1200,
2264         "wires": [
2265             [
2266                 "e5f66f4bd6777ca0"
2267             ]
2268         ]
2269     },
2270     {
2271         "id": "ca9f765b3838d5ff",
2272         "type": "inject",
2273         "z": "c5746e29f53f72ce",
2274         "d": true,
2275         "name": "o-ran-trace:trace-log-generated",
2276         "props": [
2277             {
2278                 "p": "payload"
2279             },
2280             {
2281                 "p": "topic",
2282                 "vt": "str"
2283             }
2284         ],
2285         "repeat": "",
2286         "crontab": "",
2287         "once": false,
2288         "onceDelay": 0.1,
2289         "topic": "o-ran-trace:trace-log-generated",
2290         "payload": "",
2291         "payloadType": "date",
2292         "x": 590,
2293         "y": 1240,
2294         "wires": [
2295             [
2296                 "e5f66f4bd6777ca0"
2297             ]
2298         ]
2299     },
2300     {
2301         "id": "0a837c4beaa140e0",
2302         "type": "inject",
2303         "z": "c5746e29f53f72ce",
2304         "d": true,
2305         "name": "o-ran-uplane-conf:rx-array-carriers-state-change",
2306         "props": [
2307             {
2308                 "p": "payload"
2309             },
2310             {
2311                 "p": "topic",
2312                 "vt": "str"
2313             }
2314         ],
2315         "repeat": "",
2316         "crontab": "",
2317         "once": false,
2318         "onceDelay": 0.1,
2319         "topic": "o-ran-uplane-conf:rx-array-carriers-state-change",
2320         "payload": "",
2321         "payloadType": "date",
2322         "x": 640,
2323         "y": 1320,
2324         "wires": [
2325             [
2326                 "e5f66f4bd6777ca0"
2327             ]
2328         ]
2329     },
2330     {
2331         "id": "3dfb5349f08c5ea9",
2332         "type": "inject",
2333         "z": "c5746e29f53f72ce",
2334         "d": true,
2335         "name": "o-ran-troubleshooting:troubleshooting-log-generated",
2336         "props": [
2337             {
2338                 "p": "payload"
2339             },
2340             {
2341                 "p": "topic",
2342                 "vt": "str"
2343             }
2344         ],
2345         "repeat": "",
2346         "crontab": "",
2347         "once": false,
2348         "onceDelay": 0.1,
2349         "topic": "o-ran-troubleshooting:troubleshooting-log-generated",
2350         "payload": "",
2351         "payloadType": "date",
2352         "x": 650,
2353         "y": 1280,
2354         "wires": [
2355             [
2356                 "e5f66f4bd6777ca0"
2357             ]
2358         ]
2359     },
2360     {
2361         "id": "030a6e7e6371402e",
2362         "type": "inject",
2363         "z": "c5746e29f53f72ce",
2364         "d": true,
2365         "name": "o-ran-uplane-conf:tx-array-carriers-state-change",
2366         "props": [
2367             {
2368                 "p": "payload"
2369             },
2370             {
2371                 "p": "topic",
2372                 "vt": "str"
2373             }
2374         ],
2375         "repeat": "",
2376         "crontab": "",
2377         "once": false,
2378         "onceDelay": 0.1,
2379         "topic": "o-ran-uplane-conf:tx-array-carriers-state-change",
2380         "payload": "",
2381         "payloadType": "date",
2382         "x": 640,
2383         "y": 1360,
2384         "wires": [
2385             [
2386                 "e5f66f4bd6777ca0"
2387             ]
2388         ]
2389     }
2390 ]