X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=solution%2Fsmo%2Fapps%2Fflows%2Fdata%2Fflows.json;h=5f65a8c75ccb4f6d267cbf74295ac511b376b376;hb=refs%2Fchanges%2F21%2F11321%2F1;hp=bb3b5eea878da5e3cfd6c86575a01cb33e62fa6a;hpb=a39b3c10f5742c603e06886e07ac21b5a62b14ec;p=oam.git diff --git a/solution/smo/apps/flows/data/flows.json b/solution/smo/apps/flows/data/flows.json index bb3b5ee..5f65a8c 100644 --- a/solution/smo/apps/flows/data/flows.json +++ b/solution/smo/apps/flows/data/flows.json @@ -8,11 +8,11 @@ "env": [] }, { - "id": "c5746e29f53f72ce", + "id": "db7b8dca98eba850", "type": "tab", "label": "Message Topics", "disabled": false, - "info": "Subscribes to Kafka topics ", + "info": "Subscribes to kafka topics using the strimzi kafka bridge implementation. \n", "env": [] }, { @@ -137,8 +137,8 @@ "id": "1d6949a57bce82ab", "type": "function", "z": "51e83a0892da060e", - "name": "createVesEvent", - "func": "msg.payload = {\n event: msg.payload\n};\nreturn msg;", + "name": "http-preparation", + "func": "const protocol = env.get('VES_ENDPOINT_PROTOCOL');\nconst host = env.get('VES_ENDPOINT_HOST');\nconst port = env.get('VES_ENDPOINT_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst path = 'eventListener/v7';\nmsg.url = [base, path].join('/');\n\nconst user = env.get('VES_ENDPOINT_USERNAME');\nconst password = env.get('VES_ENDPOINT_PASSWORD');\nconst auth = Buffer.from([user, password].join(':')).toString('base64')\nconst basicAuth = ['Basic', auth].join(' ');\n\nmsg.headers = {};\nmsg.headers['Content-Type'] = 'application/json';\nmsg.headers['Accept'] = 'application/json';\nmsg.headers['Authorization'] = basicAuth;\n\nmsg.payload = {\n event: msg.payload\n};\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -161,12 +161,12 @@ "method": "POST", "ret": "txt", "paytoqs": "ignore", - "url": "https://ves-collector.oam.smo.o-ran-sc.org/eventListener/v7", + "url": "", "tls": "7b2f4859e5963695", "persist": true, "proxy": "", "insecureHTTPParser": false, - "authType": "basic", + "authType": "", "senderr": false, "headers": [], "x": 1030, @@ -183,14 +183,14 @@ "z": "51e83a0892da060e", "name": "VesCollectorResponse", "active": true, - "tosidebar": true, - "console": false, - "tostatus": false, + "tosidebar": false, + "console": true, + "tostatus": true, "complete": "payload", "targetType": "msg", - "statusVal": "", + "statusVal": "payload", "statusType": "auto", - "x": 1220, + "x": 1230, "y": 280, "wires": [] }, @@ -248,16 +248,16 @@ "type": "debug", "z": "51e83a0892da060e", "name": "ves-message-data", - "active": false, - "tosidebar": true, - "console": false, - "tostatus": false, + "active": true, + "tosidebar": false, + "console": true, + "tostatus": true, "complete": "payload", "targetType": "msg", - "statusVal": "", - "statusType": "auto", - "x": 1050, - "y": 320, + "statusVal": "payload.event.commonEventHeader.stndDefinedNamespace", + "statusType": "msg", + "x": 1060, + "y": 220, "wires": [] }, { @@ -277,7 +277,7 @@ ], "repeat": "3", "crontab": "", - "once": true, + "once": false, "onceDelay": 0.1, "topic": "notifyHeartbeat", "payload": "", @@ -473,7 +473,7 @@ "type": "function", "z": "51e83a0892da060e", "name": "vesStndDefindBody", - "func": "const eventTime = new Date(msg.payload).toISOString();\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/yang/published/o-ran/ru-fh/o-ran-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-download-event': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.oam.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;", + "func": "const eventTime = new Date(msg.payload).toISOString();\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/yang/published/o-ran/ru-fh/o-ran-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-download-event': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.dcn.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -522,7 +522,7 @@ "type": "function", "z": "51e83a0892da060e", "name": "vesStndDefindBody", - "func": "const eventTime = new Date(msg.payload).toISOString();\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/yang/published/o-ran/ru-fh/o-ran-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-upload-notification': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.oam.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;", + "func": "const eventTime = new Date(msg.payload).toISOString();\nmsg.payload = {\n schemaReference: 'https://gerrit.o-ran-sc.org/r/gitweb?p=scp/oam/modeling.git;a=blob_plain;f=data-model/yang/published/o-ran/ru-fh/o-ran-file-management.yang#components/schemas/ofhm-event-stream',\n stndDefinedFieldsVersion: '1.0',\n data: {\n 'ietf:notification': {\n 'eventTime': eventTime,\n 'o-ran-file-management:file-upload-notification': {\n 'local-logical-file-path': 'o-ran/log',\n 'remote-file-path': 'ftpes://username@ftpes.dcn.smo.o-ran-sc/downloads',\n 'status': 'FAILURE',\n 'reject-reason': 'FTPes Server not reachable.'\n }\n }\n }\n};\nmsg.topic = 'stndDefinedFields';\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -1631,57 +1631,27 @@ ] }, { - "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": 240, - "y": 80, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "562063a080cb99d6", + "id": "a2d14719998c5951", "type": "debug", - "z": "c5746e29f53f72ce", + "z": "db7b8dca98eba850", "name": "eventData", "active": true, "tosidebar": true, - "console": false, - "tostatus": false, + "console": true, + "tostatus": true, "complete": "payload", "targetType": "msg", - "statusVal": "", - "statusType": "auto", - "x": 1150, - "y": 220, + "statusVal": "payload.length", + "statusType": "msg", + "x": 770, + "y": 520, "wires": [] }, { - "id": "172060688d87f510", + "id": "393ee0aac0784928", "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "notifyHeartbeat", + "z": "db7b8dca98eba850", + "name": "Get Topics", "props": [ { "p": "payload" @@ -1693,55 +1663,26 @@ ], "repeat": "5", "crontab": "", - "once": true, - "onceDelay": 0.1, - "topic": "notifyHeartbeat", - "payload": "", - "payloadType": "date", - "x": 230, - "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", + "topic": "get", "payload": "", "payloadType": "date", - "x": 240, - "y": 400, + "x": 130, + "y": 520, "wires": [ [ - "e5f66f4bd6777ca0" + "f8d2934457eb7030" ] ] }, { - "id": "5437e3fdfca300c9", + "id": "9745e4eaaad146b5", "type": "http request", - "z": "c5746e29f53f72ce", + "z": "db7b8dca98eba850", "name": "", "method": "GET", - "ret": "txt", + "ret": "obj", "paytoqs": "ignore", "url": "", "tls": "7b2f4859e5963695", @@ -1751,87 +1692,67 @@ "authType": "", "senderr": false, "headers": [], - "x": 670, - "y": 220, + "x": 470, + "y": 520, "wires": [ [ - "dc576b6355478428" + "ec4917fbcca1ea55" ] ] }, { - "id": "dc576b6355478428", + "id": "ec4917fbcca1ea55", "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;", + "z": "db7b8dca98eba850", + "name": "Provider", + "func": "global.set('topicData', msg.payload)\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], - "x": 830, - "y": 220, + "x": 620, + "y": 520, "wires": [ [ - "2a2e05d79287f4a0" + "a2d14719998c5951" ] ] }, { - "id": "e5f66f4bd6777ca0", + "id": "f8d2934457eb7030", "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 notifyFilePreparationError: 'unauthenticated.VES_FILE_READY_OUTPUT',\n oRanOpenfrontManagementPlane: 'unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT',\n notifyNewAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyChangedAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyChangedAlarmGeneral: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyAckStateChanged: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyCorrelatedNotificationChanged: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyComments: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyClearedAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyAlarmListRebuilt: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyPotentialFaultyAlarmList: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT'\n};\nconst longPolling = '?timeout=60000'\nconst urlTopic = urlMapping[msg.topic] || msg.topic.replace(':', '-');\nmsg.url = [base, path, urlTopic, '1', '1'].join('/') + longPolling;\nreturn msg;", + "z": "db7b8dca98eba850", + "name": "http-preparation", + "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');;\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\n\nconst urlMapping = {\n pnfRegistration: 'unauthenticated.VES_PNFREG_OUTPUT',\n heartbeat: 'unauthenticated.SEC_HEARTBEAT_OUTPUT',\n fault: 'unauthenticated.SEC_FAULT_OUTPUT',\n o1NotifyPnfRegistration: 'unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT',\n oRanScDuHelloWorldPmStreaming: 'unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT',\n notifyHeartbeat: 'unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT',\n notifyFileReady: 'unauthenticated.VES_FILE_READY_OUTPUT',\n notifyFilePreparationError: 'unauthenticated.VES_FILE_READY_OUTPUT',\n oRanOpenfrontManagementPlane: 'unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT',\n notifyNewAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyChangedAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyChangedAlarmGeneral: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyAckStateChanged: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyCorrelatedNotificationChanged: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyComments: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyClearedAlarm: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyAlarmListRebuilt: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT',\n notifyPotentialFaultyAlarmList: 'unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT'\n};\n\nmsg.url = [base, 'consumers', group, 'instances', name, 'records'].join('/');\nmsg.headers = {\n accept: 'application/vnd.kafka.json.v2+json'\n}\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], - "x": 490, - "y": 220, + "x": 300, + "y": 520, "wires": [ [ - "5437e3fdfca300c9" + "9745e4eaaad146b5" ] ] }, { - "id": "42275e9c12f8e52b", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from O-RAN-SC", - "info": "", - "x": 100, - "y": 140, - "wires": [] - }, - { - "id": "e07fa97ebc66dce0", + "id": "c82c06ee1b7fad77", "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from ONAP", + "z": "db7b8dca98eba850", + "name": "Get Records", "info": "", "x": 90, - "y": 40, - "wires": [] - }, - { - "id": "44b8c2cc138777f1", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from SA5 R-18 branch", - "info": "", - "x": 120, - "y": 280, + "y": 480, "wires": [] }, { - "id": "4480e5473a65a757", + "id": "6cc496f1420404b3", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "oRanScDuHelloWorldPmStreaming", + "z": "db7b8dca98eba850", + "name": "Topics?", "props": [ { "p": "payload" @@ -1843,24 +1764,43 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "oRanScDuHelloWorldPmStreaming", + "once": true, + "onceDelay": "0.8", + "topic": "topics", "payload": "", "payloadType": "date", - "x": 180, - "y": 220, + "x": 120, + "y": 400, + "wires": [ + [ + "7a931d124e3fdc64" + ] + ] + }, + { + "id": "7a931d124e3fdc64", + "type": "function", + "z": "db7b8dca98eba850", + "name": "http-preparation", + "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst path = msg.topic;\nmsg.url = [base, path].join('/');\nmsg.method = 'get';\nmsg.headers = {\n accept: 'application/vnd.kafka.v2+json'\n}\nreturn msg;", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 340, + "y": 400, "wires": [ [ - "e5f66f4bd6777ca0" + "53aae16b268527f7" ] ] }, { - "id": "52f22ee054e5b4ac", + "id": "051acf7693d4d457", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "o1NotifyPnfRegistration", + "z": "db7b8dca98eba850", + "name": "Do Subscription", "props": [ { "p": "payload" @@ -1872,55 +1812,84 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o1NotifyPnfRegistration", + "once": true, + "onceDelay": "0.6", + "topic": "subscription", "payload": "", "payloadType": "date", - "x": 220, - "y": 180, + "x": 140, + "y": 300, + "wires": [ + [ + "a72e6d0ab9261954" + ] + ] + }, + { + "id": "a72e6d0ab9261954", + "type": "function", + "z": "db7b8dca98eba850", + "name": "http-preparation", + "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, 'consumers', group, 'instances', name, msg.topic].join('/');\nmsg.method = 'post';\nmsg.headers = {\n 'content-type': 'application/vnd.kafka.v2+json',\n accept: 'application/vnd.kafka.v2+json'\n}\nmsg.payload = {\n \"topics\": [\"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\", \"unauthenticated.SEC_HEARTBEAT_OUTPUT\", \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\", \"unauthenticated.VES_PNFREG_OUTPUT\", \"unauthenticated.VES_FILE_READY_OUTPUT\", \"o-ran-file-management-file-download-event\", \"bridge-quickstart-topic\", \"o-ran-file-management-file-upload-notification\", \"o-ran-supervision-supervision-notification\", \"unauthenticated.SEC_3GPP_FAULTSUPERVISION_OUTPUT\", \"my-topic\", \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\", \"unauthenticated.SEC_FAULT_OUTPUT\"]\n}\n\nreturn msg;\n", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 340, + "y": 300, "wires": [ [ - "e5f66f4bd6777ca0" + "53aae16b268527f7" ] ] }, { - "id": "3051f52553efaaa4", + "id": "53aae16b268527f7", "type": "http request", - "z": "c5746e29f53f72ce", - "name": "", - "method": "GET", + "z": "db7b8dca98eba850", + "name": "http request", + "method": "use", "ret": "txt", "paytoqs": "ignore", - "url": "https://messages.smo.o-ran-sc.org/topics", + "url": "", "tls": "7b2f4859e5963695", "persist": true, "proxy": "", "insecureHTTPParser": true, "authType": "", "senderr": false, - "headers": [ - { - "keyType": "other", - "keyValue": "Accept", - "valueType": "other", - "valueValue": "application/json" - } - ], - "x": 670, - "y": 180, + "headers": [], + "x": 590, + "y": 300, "wires": [ [ - "dc576b6355478428" + "025484501aa58b31" ] ] }, { - "id": "0acceacb99b7981a", + "id": "025484501aa58b31", + "type": "debug", + "z": "db7b8dca98eba850", + "name": "Response", + "active": true, + "tosidebar": true, + "console": true, + "tostatus": true, + "complete": "payload", + "targetType": "msg", + "statusVal": "statusCode", + "statusType": "msg", + "x": 770, + "y": 300, + "wires": [] + }, + { + "id": "2bcd1fcc0cb4f747", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "Topics?", + "z": "db7b8dca98eba850", + "name": "healthy?", "props": [ { "p": "payload" @@ -1932,34 +1901,43 @@ ], "repeat": "", "crontab": "", - "once": false, + "once": true, "onceDelay": 0.1, - "topic": "topics", + "topic": "healthy", "payload": "", "payloadType": "date", - "x": 510, - "y": 180, + "x": 120, + "y": 80, "wires": [ [ - "3051f52553efaaa4" + "4b695d52e3231b6b" ] ] }, { - "id": "34b7ac222692e06d", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "from OpenFronthaul Management-Plane", - "info": "", - "x": 580, - "y": 280, - "wires": [] + "id": "4b695d52e3231b6b", + "type": "function", + "z": "db7b8dca98eba850", + "name": "http-preparation", + "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nmsg.url = [base, msg.topic].join('/');\nmsg.method = 'get';\nmsg.headers = {\n accept: 'application/json'\n}\nreturn msg;\n", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 340, + "y": 200, + "wires": [ + [ + "53aae16b268527f7" + ] + ] }, { - "id": "25a3eca83bbc3489", + "id": "2d834fde764e3443", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "o-ran-supervision:supervision-notification", + "z": "db7b8dca98eba850", + "name": "ready?", "props": [ { "p": "payload" @@ -1969,26 +1947,26 @@ "vt": "str" } ], - "repeat": "60", + "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-supervision:supervision-notification", + "once": true, + "onceDelay": "0.2", + "topic": "ready", "payload": "", "payloadType": "date", - "x": 620, - "y": 1040, + "x": 120, + "y": 120, "wires": [ [ - "e5f66f4bd6777ca0" + "4b695d52e3231b6b" ] ] }, { - "id": "0194d014ef8f6c5e", + "id": "7bbff4bdad2683f0", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "o-ran-file-management:file-upload-notification", + "z": "db7b8dca98eba850", + "name": "Schema?", "props": [ { "p": "payload" @@ -2000,24 +1978,24 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-file-management:file-upload-notification", + "once": true, + "onceDelay": "0.4", + "topic": "openapi", "payload": "", "payloadType": "date", - "x": 630, - "y": 760, + "x": 120, + "y": 200, "wires": [ [ - "e5f66f4bd6777ca0" + "4b695d52e3231b6b" ] ] }, { - "id": "775aacf9e2cc0285", + "id": "1b322733222d5c1d", "type": "inject", - "z": "c5746e29f53f72ce", - "name": "o-ran-file-management:file-download-event", + "z": "db7b8dca98eba850", + "name": "Version?", "props": [ { "p": "payload" @@ -2029,25 +2007,24 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-file-management:file-download-event", + "once": true, + "onceDelay": "0.3", + "topic": " ", "payload": "", "payloadType": "date", - "x": 620, - "y": 720, + "x": 120, + "y": 160, "wires": [ [ - "e5f66f4bd6777ca0" + "4b695d52e3231b6b" ] ] }, { - "id": "3e3be17a65a7d1bf", + "id": "12e182c0bee28aad", "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-ald-port:dc-enabled-status-change", + "z": "db7b8dca98eba850", + "name": "CreateConsumer", "props": [ { "p": "payload" @@ -2059,55 +2036,43 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-ald-port:dc-enabled-status-change", + "once": true, + "onceDelay": "0.5", + "topic": "consumers", "payload": "", "payloadType": "date", - "x": 620, - "y": 320, + "x": 150, + "y": 260, "wires": [ [ - "e5f66f4bd6777ca0" + "46c33603561bf711" ] ] }, { - "id": "665c45e5ccd1c9cb", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-ald-port:overcurrent-report", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-ald-port:overcurrent-report", - "payload": "", - "payloadType": "date", - "x": 590, - "y": 360, + "id": "46c33603561bf711", + "type": "function", + "z": "db7b8dca98eba850", + "name": "http-preparation", + "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, msg.topic, group].join('/');\nmsg.method = 'post';\nmsg.headers = {\n 'content-type': 'application/vnd.kafka.v2+json',\n accept: 'application/vnd.kafka.v2+json'\n}\nmsg.payload = {\n name: name,\n format: 'json',\n 'auto.offset.reset': 'earliest',\n 'enable.auto.commit': true,\n 'fetch.min.bytes': 1,\n 'consumer.request.timeout.ms': 30000,\n 'isolation.level': 'read_uncommitted'\n}\n\nreturn msg;\n", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 340, + "y": 260, "wires": [ [ - "e5f66f4bd6777ca0" + "53aae16b268527f7" ] ] }, { - "id": "5520ce3b83578f17", + "id": "63c336487e6e0eb9", "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-antenna-calibration:antenna-calibration-coordinated", + "z": "db7b8dca98eba850", + "name": "Get Subscription", "props": [ { "p": "payload" @@ -2119,974 +2084,48 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-antenna-calibration:antenna-calibration-coordinated", + "once": true, + "onceDelay": "0.7", + "topic": "subscription", "payload": "", "payloadType": "date", - "x": 670, - "y": 400, + "x": 150, + "y": 340, "wires": [ [ - "e5f66f4bd6777ca0" + "b0f5987ab4bd1256" ] ] }, { - "id": "fda3090fb4f1e9d4", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-antenna-calibration:antenna-calibration-multiple-time-resource-params", - "payload": "", - "payloadType": "date", - "x": 730, - "y": 440, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "2551bb6c9746a7c2", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-antenna-calibration:antenna-calibration-required", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-antenna-calibration:antenna-calibration-required", - "payload": "", - "payloadType": "date", - "x": 660, - "y": 480, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "0dcc72d0235e6336", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-antenna-calibration:antenna-calibration-result", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-antenna-calibration:antenna-calibration-result", - "payload": "", - "payloadType": "date", - "x": 650, - "y": 520, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "0abafa5c1a4ebd33", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-beamforming:beamforming-information-update", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-beamforming:beamforming-information-update", - "payload": "", - "payloadType": "date", - "x": 650, - "y": 560, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "d74c5f1885485d8c", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-beamforming:capability-group-beamforming-information-update", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-beamforming:capability-group-beamforming-information-update", - "payload": "", - "payloadType": "date", - "x": 700, - "y": 600, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "8d755b355a3d5557", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-beamforming:predefined-beam-tilt-offset-complete", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-beamforming:predefined-beam-tilt-offset-complete", - "payload": "", - "payloadType": "date", - "x": 660, - "y": 640, - "wires": [ - [] - ] - }, - { - "id": "6ebe4693c580ae00", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-externalio:external-input-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-externalio:external-input-change", - "payload": "", - "payloadType": "date", - "x": 610, - "y": 680, - "wires": [ - [] - ] - }, - { - "id": "89144928a6ead625", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-fm:alarm-notif", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-fm:alarm-notif", - "payload": "", - "payloadType": "date", - "x": 550, - "y": 800, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "8ebca0cd456a9763", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-laa-operations:measurement-result", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-laa-operations:measurement-result", - "payload": "", - "payloadType": "date", - "x": 620, - "y": 840, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "4778511387bc7449", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-performance-management:measurement-result-stats", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-performance-management:measurement-result-stats", - "payload": "", - "payloadType": "date", - "x": 670, - "y": 880, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "c106623d629fbe54", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-software-management:activation-event", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-software-management:activation-event", - "payload": "", - "payloadType": "date", - "x": 630, - "y": 920, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "4db0e5b915d76ddb", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-software-management:download-event", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-software-management:download-event", - "payload": "", - "payloadType": "date", - "x": 630, - "y": 960, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "8d3fab47729a807d", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-software-management:install-event", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-software-management:install-event", - "payload": "", - "payloadType": "date", - "x": 620, - "y": 1000, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "7ac87519cb59151d", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-sync:gnss-state-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-sync:gnss-state-change", - "payload": "", - "payloadType": "date", - "x": 580, - "y": 1080, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "55725b18e27c1a27", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-sync:ptp-state-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-sync:ptp-state-change", - "payload": "", - "payloadType": "date", - "x": 580, - "y": 1120, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "dde01e699dec844f", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-sync:synce-state-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-sync:synce-state-change", - "payload": "", - "payloadType": "date", - "x": 590, - "y": 1160, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "5457d995823e58f6", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-sync:synchronization-state-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-sync:synchronization-state-change", - "payload": "", - "payloadType": "date", - "x": 620, - "y": 1200, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "ca9f765b3838d5ff", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-trace:trace-log-generated", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-trace:trace-log-generated", - "payload": "", - "payloadType": "date", - "x": 590, - "y": 1240, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "0a837c4beaa140e0", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-uplane-conf:rx-array-carriers-state-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-uplane-conf:rx-array-carriers-state-change", - "payload": "", - "payloadType": "date", - "x": 640, - "y": 1320, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "3dfb5349f08c5ea9", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-troubleshooting:troubleshooting-log-generated", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-troubleshooting:troubleshooting-log-generated", - "payload": "", - "payloadType": "date", - "x": 650, - "y": 1280, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "030a6e7e6371402e", - "type": "inject", - "z": "c5746e29f53f72ce", - "d": true, - "name": "o-ran-uplane-conf:tx-array-carriers-state-change", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "o-ran-uplane-conf:tx-array-carriers-state-change", - "payload": "", - "payloadType": "date", - "x": 640, - "y": 1360, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "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": "d932661ae80274a1", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyNewAlarm", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyNewAlarm", - "payload": "", - "payloadType": "date", - "x": 240, - "y": 520, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "c4337f08252203ec", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyChangedAlarm", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyChangedAlarm", - "payload": "", - "payloadType": "date", - "x": 230, - "y": 560, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "62048992a866405d", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyChangedAlarmGeneral", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyChangedAlarmGeneral", - "payload": "", - "payloadType": "date", - "x": 200, - "y": 600, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "353e0a6e1e693ae5", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyAckStateChanged", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyAckStateChanged", - "payload": "", - "payloadType": "date", - "x": 220, - "y": 640, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "3879e3d1320f1459", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyCorrelatedNotificationChanged", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyCorrelatedNotificationChanged", - "payload": "", - "payloadType": "date", - "x": 180, - "y": 680, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "ea314b13220c8f40", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyComments", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyComments", - "payload": "", - "payloadType": "date", - "x": 240, - "y": 720, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "407c7befca74d24b", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyClearedAlarm", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyClearedAlarm", - "payload": "", - "payloadType": "date", - "x": 230, - "y": 760, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "c054dd03a80a4e48", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyAlarmListRebuilt", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyAlarmListRebuilt", - "payload": "", - "payloadType": "date", - "x": 220, - "y": 800, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, - { - "id": "5c8b20a14ea5863a", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyPotentialFaultyAlarmList", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyPotentialFaultyAlarmList", - "payload": "", - "payloadType": "date", - "x": 200, - "y": 840, + "id": "b0f5987ab4bd1256", + "type": "function", + "z": "db7b8dca98eba850", + "name": "http-preparation", + "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, 'consumers', group, 'instances', name, msg.topic].join('/');\nmsg.method = 'get';\nmsg.headers = {\n accept: 'application/vnd.kafka.v2+json'\n}\nreturn msg;\n", + "outputs": 1, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 340, + "y": 340, "wires": [ [ - "e5f66f4bd6777ca0" + "53aae16b268527f7" ] ] }, { - "id": "f5d7d173f1ac5213", - "type": "comment", - "z": "c5746e29f53f72ce", - "name": "TS28532_FaultMnS.yaml", - "info": "", - "x": 130, - "y": 480, - "wires": [] - }, - { - "id": "c6687553f38611cd", + "id": "ccf49a001b3e92d2", "type": "comment", - "z": "c5746e29f53f72ce", - "name": "TS28532_FileDataReportingMnS.yaml", + "z": "db7b8dca98eba850", + "name": "Preparation", "info": "", - "x": 170, - "y": 360, + "x": 90, + "y": 40, "wires": [] }, - { - "id": "64720217524b2f2c", - "type": "inject", - "z": "c5746e29f53f72ce", - "name": "notifyFilePreparationError", - "props": [ - { - "p": "payload" - }, - { - "p": "topic", - "vt": "str" - } - ], - "repeat": "", - "crontab": "", - "once": false, - "onceDelay": 0.1, - "topic": "notifyFilePreparationError", - "payload": "", - "payloadType": "date", - "x": 210, - "y": 440, - "wires": [ - [ - "e5f66f4bd6777ca0" - ] - ] - }, { "id": "c5648c1528804847", "type": "inject", @@ -3120,14 +2159,14 @@ "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;", + "name": "http-preparation", + "func": "const protocol = env.get('SDN_CONTROLLER_PROTOCOL');\nconst host = env.get('SDN_CONTROLLER_HOST');\nconst port = env.get('SDN_CONTROLLER_PORT');;\nconst base = protocol + '://' + host + ':' + port;\nconst path = 'rests/operations/network-topology:network-topology/topology=topology-netconf/node=';\nconst nodeId = msg.payload;\nconst mount = 'yang-ext:mount';\nconst action = 'o-ran-supervision:supervision-watchdog-reset';\nmsg.url = [base,path + nodeId, mount, action].join('/');\n\nconst user = env.get('SDN_CONTROLLER_USERNAME');\nconst password = env.get('SDN_CONTROLLER_PASSWORD');\nconst auth = Buffer.from([user, password].join(':')).toString('base64')\nconst basicAuth = ['Basic', auth].join(' ');\n\nmsg.headers = {};\nmsg.headers['Content-Type'] = 'application/yang-data+json';\nmsg.headers['Accept'] = 'application/yang-data+json';\nmsg.headers['Authorization'] = basicAuth;\n\nmsg.payload = { \n \"o-ran-supervision:input\": \n {\n \"supervision-notification-interval\": 60, \n \"guard-timer-overhead\": 10\n }\n}\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", "finalize": "", "libs": [], - "x": 570, + "x": 560, "y": 220, "wires": [ [ @@ -3149,22 +2188,9 @@ "persist": true, "proxy": "", "insecureHTTPParser": true, - "authType": "basic", + "authType": "", "senderr": false, - "headers": [ - { - "keyType": "other", - "keyValue": "Accept", - "valueType": "other", - "valueValue": "application/json" - }, - { - "keyType": "other", - "keyValue": "Content-Type", - "valueType": "other", - "valueValue": "application/json" - } - ], + "headers": [], "x": 800, "y": 220, "wires": [ @@ -3180,13 +2206,13 @@ "name": "Response", "active": true, "tosidebar": true, - "console": false, - "tostatus": false, + "console": true, + "tostatus": true, "complete": "payload", "targetType": "msg", - "statusVal": "", - "statusType": "auto", - "x": 1000, + "statusVal": "payload.length", + "statusType": "msg", + "x": 1010, "y": 220, "wires": [] }, @@ -3214,7 +2240,7 @@ "type": "function", "z": "7ba02ed596e8cde5", "name": "Consumer (new Data?)", - "func": "// read topic data from global context\nconst topicData = global.get('topicData');\n// init result as array\nlet result = [];\nif (Array.isArray(topicData)) {\n result = topicData.filter(event => {\n return event.event.commonEventHeader.stndDefinedNamespace === 'o-ran-supervision:supervision-notification';\n }).map(event => {\n return event.event.commonEventHeader.sourceName;;\n });\n}\nmsg.payload = result;\nglobal.set('topicData', []);\nreturn msg; ", + "func": "// read topic data from global context\nconst topicData = global.get('topicData');\n// init result as array\nlet result = [];\nif (Array.isArray(topicData)) {\n result = topicData.filter(event => {\n return event.value.event.commonEventHeader.stndDefinedNamespace === 'o-ran-supervision:supervision-notification';\n }).map(event => {\n return event.value.event.commonEventHeader.sourceName;;\n });\n}\nmsg.payload = result;\nglobal.set('topicData', []);\nreturn msg; ", "outputs": 1, "noerr": 0, "initialize": "", @@ -3271,7 +2297,7 @@ "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, + "y": 280, "wires": [] } ] \ No newline at end of file