blob: 63f23f2de5e5a40baac9eb7b37a8528daddf59fc (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
*** Settings ***
Library Collections
Library Process
Library RequestsLibrary
Library String
Library OperatingSystem
Suite Teardown Delete All Sessions
*** Variables ***
${SON_HANDLER_BASE_URL} http://${SONHMS_IP}:8080
${HEALTHCHECK_ENDPOINT} /healthcheck
${DMAAP_URL} http://${DMAAP_IP}:3904/events
${unauthenticated.DCAE_CL_OUTPUT} /unauthenticated.DCAE_CL_OUTPUT/23/23
${POST_DMAAP_EVENT_FOR_FM_NOTIF_URL} http://${DMAAP_IP}:3904/events/unauthenticated.SEC_FAULT_OUTPUT
${POST_DMAAP_EVENT_FOR_PM_NOTIF_URL} http://${DMAAP_IP}:3904/events/unauthenticated.VES_MEASUREMENT_OUTPUT
${POST_DMAAP_EVENT_FOR_POLICY_RESPONSE} http://${DMAAP_IP}:3904/events/DCAE_CL_RSP
*** Test Cases ***
HealthCheck
Create Session sonhms ${SON_HANDLER_BASE_URL}
${resp}= Get Request sonhms ${HEALTHCHECK_ENDPOINT}
Should Be Equal As Strings ${resp.status_code} 200
Post fm notification to dmaap
Create Session dmaap ${DMAAP_URL}
${headers}= Create Dictionary Content-Type application/json
${data}= Get File ${TEST_ROBOT_DIR}/data/cps_fault_notification.json
${response}= Evaluate requests.post('${POST_DMAAP_EVENT_FOR_FM_NOTIF_URL}', data=$data)
Should Be Equal As Strings ${response.status_code} 200
Verify fm notification trigger in sonhms
Create Session dmaap ${DMAAP_URL}
FOR ${i} IN RANGE 10
${result}= Get Request dmaap ${unauthenticated.DCAE_CL_OUTPUT}
Exit For Loop If ${result.json()} != @{EMPTY}
Log Waiting for sonhms to handle trigger... console=${True}
Sleep 30s
END
${expected_payload}= Get File ${TEST_ROBOT_DIR}/data/cps_expected_payload_fm.json
${result}= Convert To String ${result.content}
${result_string}= Get Substring ${result} 2 -2
${actual_data}= Evaluate json.loads("""${result_string}""") json
${actual_payload}= Set Variable ${actual_data['payload']}
Should Be True """${actual_payload}""".strip() == """${expected_payload}""".strip()
Post pm notification to dmaap
${data}= Get File ${TEST_ROBOT_DIR}/data/performance_notification.json
${response}= Evaluate requests.post('${POST_DMAAP_EVENT_FOR_PM_NOTIF_URL}', data=$data)
Should Be Equal As Strings ${response.status_code} 200
Verify pm notification trigger in sonhms
Create Session dmaap ${DMAAP_URL}
FOR ${i} IN RANGE 5
${result}= Get Request dmaap ${unauthenticated.DCAE_CL_OUTPUT}
Exit For Loop If ${result.json()} != @{EMPTY}
Log Waiting for sonhms to handle trigger... console=${True}
Sleep 30s
END
${expected_payload}= Get File ${TEST_ROBOT_DIR}/data/cps_expected_payload_pm.json
${result}= Convert To String ${result.content}
${result_string}= Get Substring ${result} 2 -2
${actual_data}= Evaluate json.loads("""${result_string}""") json
${actual_payload}= Set Variable ${actual_data['payload']}
Should Be True """${actual_payload}""".strip() == """${expected_payload}""".strip()
Post policy negative acknowledgement to dmaap
${data}= Get File ${TEST_ROBOT_DIR}/data/negative_ack_from_policy.json
FOR ${i} IN RANGE 3
${response}= Evaluate requests.post('${POST_DMAAP_EVENT_FOR_POLICY_RESPONSE}', data=$data)
END
Should Be Equal As Strings ${response.status_code} 200
Oof trigger for fixed Pci cells
Create Session dmaap ${DMAAP_URL}
${headers}= Create Dictionary Content-Type application/json
${data}= Get File ${TEST_ROBOT_DIR}/data/cps_fault_notification.json
${response}= Evaluate requests.post('${POST_DMAAP_EVENT_FOR_FM_NOTIF_URL}', data=$data)
Create Session dmaap ${DMAAP_URL}
FOR ${i} IN RANGE 15
${result}= Get Request dmaap ${unauthenticated.DCAE_CL_OUTPUT}
Exit For Loop If ${result.json()} != @{EMPTY}
Log Waiting for sonhms to handle trigger... console=${True}
Sleep 30s
END
${expected_payload}= Get File ${TEST_ROBOT_DIR}/data/cps_expected_payload_fm.json
${result}= Convert To String ${result.content}
${result_string}= Get Substring ${result} 2 -2
${actual_data}= Evaluate json.loads("""${result_string}""") json
${actual_payload}= Set Variable ${actual_data['payload']}
Should Be True """${actual_payload}""".strip() == """${expected_payload}""".strip()
|
