X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fusecases%2Flinkfailure%2Fsimulators%2Fmessage_generator.py;h=f6b4e25bc005a095ec40224e6ebb9d0713194d1c;hb=2772b3e52b693924df131a195859ff8e44458bb3;hp=0ab37e5ec705a562e39732df7ee7598746daee61;hpb=00fd1e7bdea32ecef53f99b5e94541350af27504;p=nonrtric.git diff --git a/test/usecases/linkfailure/simulators/message_generator.py b/test/usecases/linkfailure/simulators/message_generator.py index 0ab37e5e..f6b4e25b 100644 --- a/test/usecases/linkfailure/simulators/message_generator.py +++ b/test/usecases/linkfailure/simulators/message_generator.py @@ -25,19 +25,21 @@ import json # randomly generated between 0 and 9. # When the modulo of the ID is 1, a "heartbeat" message will also be sent to MR. +MR_PATH = "http://localhost:3904/events/unauthenticated.SEC_FAULT_OUTPUT" + linkFailureMessage = { "event": { "commonEventHeader": { "domain": "fault", "eventId": "nt:network-topology/nt:topology/nt:node/nt:node-id", "eventName": "fault_O-RAN-RU-Fault_Alarms_CUS_Link_Failure", - "eventType": "O-RAN-RU-Fault_Alarms", + "eventType": "O-RAN-RU-Fault", "sequence": 0, - "priority": "High", - "reportingEntityId": "uro1", + "priority": "Normal", + "reportingEntityId": "SDNR", "reportingEntityName": "@controllerName@", "sourceId": "", - "sourceName": "nt:network-topology/nt:topology/nt:node/nt:node-id", + "sourceName": "O-RU-ID", "startEpochMicrosec": "@timestamp@", "lastEpochMicrosec": "@timestamp@", "nfNamingCode": "", @@ -48,10 +50,10 @@ linkFailureMessage = { }, "faultFields": { "faultFieldsVersion": "4.0", - "alarmCondition": "o-ran-fm:alarm-notif/fault-id", + "alarmCondition": "30", "alarmInterfaceA": "o-ran-fm:alarm-notif/fault-source", "eventSourceType": "ietf-hardware (RFC8348) /hardware/component[not(parent)][1]/mfg-model or \"O-RU\"", - "specificProblem": "CUS Link Failure", + "specificProblem": "", "eventSeverity": "CRITICAL", "vfStatus": "Active", "alarmAdditionalInformation": { @@ -89,13 +91,13 @@ while True: random_time = int(10 * random.random()) if (random_time % 3 == 1): print("Sent heart beat") - requests.post("http://localhost:3904/events/ALARMS-WRITE", json=heartBeatMessage); + requests.post(MR_PATH, json=heartBeatMessage); o_ru_id = "O-RAN-RU-0" + str(random_time) print("Sent link failure for O-RAN-RU: " + o_ru_id) msg_as_json = json.loads(json.dumps(linkFailureMessage)) - msg_as_json["event"]["commonEventHeader"]["reportingEntityId"] = o_ru_id - requests.post("http://localhost:3904/events/ALARMS-WRITE", json=msg_as_json); + msg_as_json["event"]["commonEventHeader"]["sourceName"] = o_ru_id + requests.post(MR_PATH, json=msg_as_json); time.sleep(random_time)