Add watchdog reset function for O-RUs

[oam.git] / solution / smo / apps / flows / data / flows.json

diff --git a/solution/smo/apps/flows/data/flows.json b/solution/smo/apps/flows/data/flows.json
index e00bb5c..56c18e6 100644 (file)
--- a/solution/smo/apps/flows/data/flows.json
+++ b/solution/smo/apps/flows/data/flows.json
@@ -15,6 +15,14 @@
         "info": "Subscribes to Kafka topics ",
         "env": []
     },
+    {
+        "id": "7ba02ed596e8cde5",
+        "type": "tab",
+        "label": "OpenFronthaul",
+        "disabled": false,
+        "info": "",
+        "env": []
+    },
     {
         "id": "7b2f4859e5963695",
         "type": "tls-config",
@@ -1293,7 +1301,7 @@
         "type": "debug",
         "z": "c5746e29f53f72ce",
         "name": "eventData",
-        "active": true,
+        "active": false,
         "tosidebar": true,
         "console": false,
         "tostatus": false,
@@ -1301,7 +1309,7 @@
         "targetType": "msg",
         "statusVal": "",
         "statusType": "auto",
-        "x": 990,
+        "x": 1150,
         "y": 220,
         "wires": []
     },
@@ -1403,7 +1411,7 @@
         "y": 220,
         "wires": [
             [
-                "562063a080cb99d6"
+                "2a2e05d79287f4a0"
             ]
         ]
     },
@@ -1598,7 +1606,7 @@
                 "vt": "str"
             }
         ],
-        "repeat": "",
+        "repeat": "5",
         "crontab": "",
         "once": false,
         "onceDelay": 0.1,
@@ -2386,5 +2394,211 @@
                 "e5f66f4bd6777ca0"
             ]
         ]
+    },
+    {
+        "id": "2a2e05d79287f4a0",
+        "type": "function",
+        "z": "c5746e29f53f72ce",
+        "name": "Provider",
+        "func": "global.set('topicData', msg.payload)\nreturn msg;",
+        "outputs": 1,
+        "noerr": 0,
+        "initialize": "",
+        "finalize": "",
+        "libs": [],
+        "x": 980,
+        "y": 220,
+        "wires": [
+            [
+                "562063a080cb99d6"
+            ]
+        ]
+    },
+    {
+        "id": "c5648c1528804847",
+        "type": "inject",
+        "z": "7ba02ed596e8cde5",
+        "name": "supervision-watchdog-reset for O-RU-11221",
+        "props": [
+            {
+                "p": "payload"
+            },
+            {
+                "p": "topic",
+                "vt": "str"
+            }
+        ],
+        "repeat": "",
+        "crontab": "",
+        "once": false,
+        "onceDelay": 0.1,
+        "topic": "supervision-watchdog-reset",
+        "payload": "[\"O-RU-11221\"]",
+        "payloadType": "json",
+        "x": 230,
+        "y": 100,
+        "wires": [
+            [
+                "2bd693b8c7e5a3cb"
+            ]
+        ]
+    },
+    {
+        "id": "329e838eb4bf63f4",
+        "type": "function",
+        "z": "7ba02ed596e8cde5",
+        "name": "ResetActionData",
+        "func": "const base = 'https://odlux.oam.smo.o-ran-sc.org';\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';\n\nmsg.url = [base,path + nodeId, mount, action].join('/');\nmsg.payload = { \n  \"o-ran-supervision:input\": \n    {\n      \"supervision-notification-interval\": 60, \n      \"guard-timer-overhead\": 10\n    }\n}\nreturn msg;",
+        "outputs": 1,
+        "noerr": 0,
+        "initialize": "",
+        "finalize": "",
+        "libs": [],
+        "x": 570,
+        "y": 220,
+        "wires": [
+            [
+                "1a4b6a4ec23c8f9f",
+                "2bd693b8c7e5a3cb"
+            ]
+        ]
+    },
+    {
+        "id": "1a4b6a4ec23c8f9f",
+        "type": "http request",
+        "z": "7ba02ed596e8cde5",
+        "name": "RESTCONF request",
+        "method": "POST",
+        "ret": "txt",
+        "paytoqs": "ignore",
+        "url": "",
+        "tls": "7b2f4859e5963695",
+        "persist": true,
+        "proxy": "",
+        "insecureHTTPParser": true,
+        "authType": "basic",
+        "senderr": false,
+        "headers": [
+            {
+                "keyType": "other",
+                "keyValue": "Accept",
+                "valueType": "other",
+                "valueValue": "application/json"
+            },
+            {
+                "keyType": "other",
+                "keyValue": "Content-Type",
+                "valueType": "other",
+                "valueValue": "application/json"
+            }
+        ],
+        "x": 800,
+        "y": 220,
+        "wires": [
+            [
+                "eb6c2de759c8eb54"
+            ]
+        ]
+    },
+    {
+        "id": "eb6c2de759c8eb54",
+        "type": "debug",
+        "z": "7ba02ed596e8cde5",
+        "name": "Response",
+        "active": true,
+        "tosidebar": true,
+        "console": false,
+        "tostatus": false,
+        "complete": "payload",
+        "targetType": "msg",
+        "statusVal": "",
+        "statusType": "auto",
+        "x": 1000,
+        "y": 220,
+        "wires": []
+    },
+    {
+        "id": "0d3ade9a80560c04",
+        "type": "inject",
+        "z": "7ba02ed596e8cde5",
+        "name": "Every 5s",
+        "props": [],
+        "repeat": "5",
+        "crontab": "",
+        "once": false,
+        "onceDelay": 0.1,
+        "topic": "",
+        "x": 120,
+        "y": 140,
+        "wires": [
+            [
+                "5322d78ad66fcb96"
+            ]
+        ]
+    },
+    {
+        "id": "5322d78ad66fcb96",
+        "type": "function",
+        "z": "7ba02ed596e8cde5",
+        "name": "Consumer (new Data?)",
+        "func": "const topicData = global.get('topicData');\nmsg.payload = topicData.map(event => {\n    if (event.event.commonEventHeader.stndDefinedNamespace === 'o-ran-supervision:supervision-notification')\n        return event.event.commonEventHeader.sourceName;\n}).filter(element => {\n    return element !== undefined;\n});\nglobal.set('topicData', []);\nreturn msg;",
+        "outputs": 1,
+        "noerr": 0,
+        "initialize": "",
+        "finalize": "",
+        "libs": [],
+        "x": 310,
+        "y": 140,
+        "wires": [
+            [
+                "2bd693b8c7e5a3cb"
+            ]
+        ]
+    },
+    {
+        "id": "2bd693b8c7e5a3cb",
+        "type": "loop",
+        "z": "7ba02ed596e8cde5",
+        "name": "Loop through O-RUs",
+        "kind": "enum",
+        "count": "",
+        "initial": "1",
+        "step": "1",
+        "condition": "",
+        "conditionType": "js",
+        "when": "before",
+        "enumeration": "payload",
+        "enumerationType": "msg",
+        "limit": "",
+        "loopPayload": "loop-val",
+        "finalPayload": "final-last",
+        "x": 580,
+        "y": 140,
+        "wires": [
+            [],
+            [
+                "329e838eb4bf63f4"
+            ]
+        ]
+    },
+    {
+        "id": "f7dc363e5421d1cf",
+        "type": "comment",
+        "z": "7ba02ed596e8cde5",
+        "name": "Supervision",
+        "info": "",
+        "x": 90,
+        "y": 40,
+        "wires": []
+    },
+    {
+        "id": "a72d8f5e9683dd39",
+        "type": "comment",
+        "z": "7ba02ed596e8cde5",
+        "name": "The Consumer checks for data on the message router provided by the \"Massage Topics\" flow.",
+        "info": "The Consumer checks for data on the message router provided by the \"Massage Topics\" flow.",
+        "x": 520,
+        "y": 260,
+        "wires": []
     }
 ]
\ No newline at end of file