-*** Settings ***\r
-Documentation Testing DCAE VES Listener with various event feeds from VoLTE, vDNS, vFW and cCPE use scenarios\r
-\r
-Library RequestsLibrary \r
-Library OperatingSystem\r
-Library Collections\r
-Library DcaeLibrary\r
-Resource resources/dcae_keywords.robot\r
-Test Setup Cleanup VES Events\r
-Suite Setup VES Collector Suite Setup DMaaP\r
-Suite Teardown VES Collector Suite Shutdown DMaaP \r
-\r
-\r
-\r
-\r
-*** Variables ***\r
-${VESC_URL_HTTPS} https://%{VESC_IP}:8443\r
-${VESC_URL} http://%{VESC_IP}:8080\r
-${VES_ANY_EVENT_PATH} /eventListener/v5\r
-${VES_BATCH_EVENT_PATH} /eventListener/v5/eventBatch\r
-${VES_THROTTLE_STATE_EVENT_PATH} /eventListener/v5/clientThrottlingState\r
-${HEADER_STRING} content-type=application/json\r
-${EVENT_DATA_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_single_fault_event.json\r
-${EVENT_MEASURE_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_vfirewall_measurement.json\r
-${EVENT_DATA_FILE_BAD} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_single_fault_event_bad.json\r
-${EVENT_BATCH_DATA_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_fault_eventlist_batch.json\r
-${EVENT_THROTTLING_STATE_DATA_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_fault_provide_throttle_state.json\r
-\r
-\r
-#DCAE Health Check\r
-${CONFIG_BINDING_URL} http://localhost:8443\r
-${CB_HEALTHCHECK_PATH} /healthcheck\r
-${CB_SERVICE_COMPONENT_PATH} /service_component/\r
-${VES_Service_Name1} dcae-controller-ves-collector\r
-${VES_Service_Name2} ves-collector-not-exist\r
-\r
-*** Comment out from R1 release ***\r
-DCAE Health Check\r
- [Tags] DCAE-HealthCheck\r
- [Documentation] Get DCAE Overall Status\r
- ${auth}= Create List ${GLOBAL_DCAE_USERNAME} ${GLOBAL_DCAE_PASSWORD}\r
- ${session}= Create Session dcae-health-check ${CONFIG_BINDING_URL} auth=${auth}\r
- ${resp}= Get Request dcae-health-check ${CB_HEALTHCHECK_PATH}\r
- Should Be Equal As Strings ${resp.status_code} 200\r
-\r
-\r
-Get VES Collector Service Status\r
- [Tags] DCAE-HealthCheck\r
- [Documentation] Get the status of a VES Collector Service Component based on service name\r
- ${urlpath}= Catenate SEPARATOR= ${CB_SERVICE_COMPONENT_PATH} ${VES_Service_Name1}\r
- Log Service component name for status query: ${urlpath}\r
- ${resp}= Get DCAE Service Component Status ${CONFIG_BINDING_URL} ${CB_SERVICE_COMPONENT_PATH} ${GLOBAL_DCAE_USERNAME} ${GLOBAL_DCAE_PASSWORD}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 200\r
- ${isEmpty}= Is Json Empty ${resp}\r
- Run Keyword If '${isEmpty}' == False Log ${resp.json()}\r
- \r
- \r
- \r
-#*** Comment out from R1 release ***\r
-Publish VES VoLTE Fault Provide Throttling State\r
- [Tags] DCAE-D1\r
- ${evtdata}= Get Event Data From File ${EVENT_THROTTLING_STATE_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- ${resp}= Publish Event To VES Collector ${VES_VOLTE_URL} ${VES_THROTTLE_STATE_EVENT_PATH} ${headers} ${evtdata} ${GLOBAL_DCAE_USERNAME} ${GLOBAL_DCAE_PASSWORD}\r
- Should Be Equal As Strings ${resp.status_code} 204\r
- \r
-Publish VES Event With Invalid Method\r
- [Tags] DCAE-D1\r
- [Documentation] Use invalid Put instead of Post method to expect 405 response\r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- Log Send HTTP Request with invalid method Put instead of Post\r
- ${resp}= Publish Event To VES Collector With Put Method ${VES_VOLTE_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata} ${GLOBAL_DCAE_USERNAME} ${GLOBAL_DCAE_PASSWORD}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 405\r
- \r
- \r
-Publish VES Event With Invalid URL Path\r
- [Tags] DCAE-D1\r
- [Documentation] Use invalid url path to expect 404 response\r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- Log Send HTTP Request with invalid /listener/v5/ instead of /eventlistener/v5 path\r
- ${resp}= Publish Event To VES Collector ${VES_VOLTE_URL} /listener/v5/ ${headers} ${evtdata} ${GLOBAL_DCAE_USERNAME} ${GLOBAL_DCAE_PASSWORD}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 404\r
-\r
-Publish VES Event With Invalid Login\r
- [Tags] DCAE-D1\r
- [Documentation] Use invalid user or password to expect 401 response\r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- Log Send HTTP Request with invalid User: BadUserName\r
- ${resp}= Publish Event To VES Collector ${VES_VOLTE_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata} BadUserName ${GLOBAL_DCAE_PASSWORD}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 401\r
- \r
-*** Test Cases ***\r
-VES Collector Health Check\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Ves Collector Health Check\r
- ${uuid}= Generate UUID\r
- ${session}= Create Session dcae ${VESC_URL}\r
- ${headers}= Create Dictionary Accept=*/* X-TransactionId=${GLOBAL_APPLICATION_ID}-${uuid} X-FromAppId=${GLOBAL_APPLICATION_ID}\r
- ${resp}= Get Request dcae /healthcheck headers=${headers}\r
- Should Be Equal As Strings ${resp.status_code} 200\r
- \r
-\r
-Publish Single VES VoLTE Fault Event\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Post single event and expect 200 Response \r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 200\r
- ${isEmpty}= Is Json Empty ${resp}\r
- Run Keyword If '${isEmpty}' == False Log ${resp.json()}\r
- ${ret}= DMaaP Message Receive ab305d54-85b4-a31b-7db2-fb6b9e546015\r
- Should Be Equal As Strings ${ret} true\r
-\r
-Publish Single VES VNF Measurement Event\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Post single event and expect 200 Response \r
- ${evtdata}= Get Event Data From File ${EVENT_MEASURE_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 200\r
- ${isEmpty}= Is Json Empty ${resp}\r
- Run Keyword If '${isEmpty}' == False Log ${resp.json()}\r
- ${ret}= DMaaP Message Receive 0b2b5790-3673-480a-a4bd-5a00b88e5af6\r
- Should Be Equal As Strings ${ret} true\r
-\r
-Publish VES VoLTE Fault Batch Events\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Post batched events and expect 202 Response \r
- ${evtdata}= Get Event Data From File ${EVENT_BATCH_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_BATCH_EVENT_PATH} ${headers} ${evtdata}\r
- Should Be Equal As Strings ${resp.status_code} 200\r
- ${ret}= DMaaP Message Receive ab305d54-85b4-a31b-7db2-fb6b9e546016\r
- Should Be Equal As Strings ${ret} true \r
- \r
- \r
-Publish Single VES VoLTE Fault Event With Bad Data\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Run with JSON Envent with missing comma to expect 400 response\r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE_BAD}\r
- ${headers}= Create Header From String ${HEADER_STRING} \r
- Log Send HTTP Request with invalid Json Event Data\r
- ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 400\r
- ${isEmpty}= Is Json Empty ${resp}\r
- Run Keyword If '${isEmpty}' == False Log ${resp.json()}\r
- \r
-Publish VES Event With Invalid Method\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Use invalid Put instead of Post method to expect 405 response\r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- Log Send HTTP Request with invalid method Put instead of Post\r
- ${resp}= Publish Event To VES Collector With Put Method No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 404\r
- \r
- \r
-Publish VES Event With Invalid URL Path\r
- [Tags] DCAE-VESC-R1\r
- [Documentation] Use invalid url path to expect 404 response\r
- ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}\r
- ${headers}= Create Header From String ${HEADER_STRING}\r
- Log Send HTTP Request with invalid /listener/v5/ instead of /eventListener/v5 path\r
- ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} /listener/v5/ ${headers} ${evtdata}\r
- Log Receive HTTP Status code ${resp.status_code}\r
- Should Be Equal As Strings ${resp.status_code} 404\r
- \r
-\r
- \r
- \r
- \r
- \r
- \r
- \r
-\r
-\r
+*** Settings ***
+Documentation Testing DCAE VES Listener with various event feeds from VoLTE, vDNS, vFW and cCPE use scenarios
+
+Library RequestsLibrary
+Library OperatingSystem
+Library Collections
+Library DcaeLibrary
+Resource resources/dcae_keywords.robot
+Test Setup Cleanup VES Events
+Suite Setup VES Collector Suite Setup DMaaP
+Suite Teardown VES Collector Suite Shutdown DMaaP
+
+
+
+
+*** Variables ***
+${VESC_URL_HTTPS} https://%{VESC_IP}:8443
+${VESC_URL} http://%{VESC_IP}:8080
+${VES_ANY_EVENT_PATH} /eventListener/v5
+${VES_BATCH_EVENT_PATH} /eventListener/v5/eventBatch
+${VES_THROTTLE_STATE_EVENT_PATH} /eventListener/v5/clientThrottlingState
+${HEADER_STRING} content-type=application/json
+${EVENT_DATA_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_single_fault_event.json
+${EVENT_MEASURE_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_vfirewall_measurement.json
+${EVENT_DATA_FILE_BAD} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_single_fault_event_bad.json
+${EVENT_BATCH_DATA_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_fault_eventlist_batch.json
+${EVENT_THROTTLING_STATE_DATA_FILE} %{WORKSPACE}/test/csit/tests/dcaegen2/testcases/assets/json_events/ves_volte_fault_provide_throttle_state.json
+
+
+#DCAE Health Check
+${CONFIG_BINDING_URL} http://localhost:8443
+${CB_HEALTHCHECK_PATH} /healthcheck
+${CB_SERVICE_COMPONENT_PATH} /service_component/
+${VES_Service_Name1} dcae-controller-ves-collector
+${VES_Service_Name2} ves-collector-not-exist
+
+
+*** Test Cases ***
+
+VES Collector Health Check
+ [Tags] DCAE-VESC-R1
+ [Documentation] Ves Collector Health Check
+ ${uuid}= Generate UUID
+ ${session}= Create Session dcae ${VESC_URL}
+ ${headers}= Create Dictionary Accept=*/* X-TransactionId=${GLOBAL_APPLICATION_ID}-${uuid} X-FromAppId=${GLOBAL_APPLICATION_ID}
+ ${resp}= Get Request dcae /healthcheck headers=${headers}
+ Should Be Equal As Strings ${resp.status_code} 200
+
+
+Publish Single VES VoLTE Fault Event
+ [Tags] DCAE-VESC-R1
+ [Documentation] Post single event and expect 200 Response
+ ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 200
+ ${isEmpty}= Is Json Empty ${resp}
+ Run Keyword If '${isEmpty}' == False Log ${resp.json()}
+ ${ret}= DMaaP Message Receive ab305d54-85b4-a31b-7db2-fb6b9e546015
+ Should Be Equal As Strings ${ret} true
+
+Publish Single VES VNF Measurement Event
+ [Tags] DCAE-VESC-R1
+ [Documentation] Post single event and expect 200 Response
+ ${evtdata}= Get Event Data From File ${EVENT_MEASURE_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 200
+ ${isEmpty}= Is Json Empty ${resp}
+ Run Keyword If '${isEmpty}' == False Log ${resp.json()}
+ ${ret}= DMaaP Message Receive 0b2b5790-3673-480a-a4bd-5a00b88e5af6
+ Should Be Equal As Strings ${ret} true
+
+Publish VES VoLTE Fault Batch Events
+ [Tags] DCAE-VESC-R1
+ [Documentation] Post batched events and expect 202 Response
+ ${evtdata}= Get Event Data From File ${EVENT_BATCH_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_BATCH_EVENT_PATH} ${headers} ${evtdata}
+ Should Be Equal As Strings ${resp.status_code} 200
+ ${ret}= DMaaP Message Receive ab305d54-85b4-a31b-7db2-fb6b9e546016
+ Should Be Equal As Strings ${ret} true
+
+
+Publish Single VES VoLTE Fault Event With Bad Data
+ [Tags] DCAE-VESC-R1
+ [Documentation] Run with JSON Envent with missing comma to expect 400 response
+ ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE_BAD}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ Log Send HTTP Request with invalid Json Event Data
+ ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 400
+ ${isEmpty}= Is Json Empty ${resp}
+ Run Keyword If '${isEmpty}' == False Log ${resp.json()}
+
+Publish VES Event With Invalid Method
+ [Tags] DCAE-VESC-R1
+ [Documentation] Use invalid Put instead of Post method to expect 405 response
+ ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ Log Send HTTP Request with invalid method Put instead of Post
+ ${resp}= Publish Event To VES Collector With Put Method No Auth ${VESC_URL} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 404
+
+
+Publish VES Event With Invalid URL Path
+ [Tags] DCAE-VESC-R1
+ [Documentation] Use invalid url path to expect 404 response
+ ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ Log Send HTTP Request with invalid /listener/v5/ instead of /eventListener/v5 path
+ ${resp}= Publish Event To VES Collector No Auth ${VESC_URL} /listener/v5/ ${headers} ${evtdata}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 404
+
+
+Enable VESC HTTPS And Basic Auth
+ [Tags] DCAE-VESC-R1
+ [Documentation] Enable VESC Https and Authentication, Disable Http and Run Health Check
+ Enable VESC Https Auth
+
+ ${auth}= Create List ${VESC_HTTPS_USER} ${VESC_HTTPS_PD}
+ ${session}= Create Session dcaegen2-r1 ${VESC_URL_HTTPS} auth=${auth} disable_warnings=1
+ ${headers}= Create Dictionary Accept=*/* X-FromAppId=${GLOBAL_APPLICATION_ID}
+ ${resp}= Get Request dcaegen2-r1 /healthcheck headers=${headers}
+ Should Be Equal As Strings ${resp.status_code} 200
+
+Publish Single VES Fault Event Over HTTPS
+ [Tags] DCAE-VESC-R1
+ [Documentation] Post single event and expect 200 Response
+ ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ Log Login User=${VESC_HTTPS_USER}, Pd=${VESC_HTTPS_PD}
+ ${resp}= Publish Event To VES Collector ${VESC_URL_HTTPS} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata} sample1 sample1
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 200
+ ${isEmpty}= Is Json Empty ${resp}
+ Run Keyword If '${isEmpty}' == False Log ${resp.json()}
+ ${ret}= DMaaP Message Receive ab305d54-85b4-a31b-7db2-fb6b9e546015
+ Should Be Equal As Strings ${ret} true
+
+
+Publish Single VES Measurement Event Over HTTPS
+ [Tags] DCAE-VESC-R1
+ [Documentation] Post single event and expect 200 Response
+ ${evtdata}= Get Event Data From File ${EVENT_MEASURE_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ ${resp}= Publish Event To VES Collector ${VESC_URL_HTTPS} ${VES_ANY_EVENT_PATH} ${headers} ${evtdata} ${VESC_HTTPS_USER} ${VESC_HTTPS_PD}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 200
+ ${isEmpty}= Is Json Empty ${resp}
+ Run Keyword If '${isEmpty}' == False Log ${resp.json()}
+ ${ret}= DMaaP Message Receive 0b2b5790-3673-480a-a4bd-5a00b88e5af6
+ Should Be Equal As Strings ${ret} true
+
+Publish VES Fault Batch Events Over HTTPS
+ [Tags] DCAE-VESC-R1
+ [Documentation] Post batched events and expect 202 Response
+ ${evtdata}= Get Event Data From File ${EVENT_BATCH_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ ${resp}= Publish Event To VES Collector ${VESC_URL_HTTPS} ${VES_BATCH_EVENT_PATH} ${headers} ${evtdata} ${VESC_HTTPS_USER} ${VESC_HTTPS_PD}
+ Should Be Equal As Strings ${resp.status_code} 200
+ ${ret}= DMaaP Message Receive ab305d54-85b4-a31b-7db2-fb6b9e546016
+ Should Be Equal As Strings ${ret} true
+
+
+Publish VES Event With Invalid URL Path HTTPS
+ [Tags] DCAE-VESC-R1
+ [Documentation] Use invalid url path to expect 404 response
+ ${evtdata}= Get Event Data From File ${EVENT_DATA_FILE}
+ ${headers}= Create Header From String ${HEADER_STRING}
+ Log Send HTTP Request with invalid /eventlistener/v5/ instead of /eventListener/v5 path
+ ${resp}= Publish Event To VES Collector ${VESC_URL_HTTPS} /eventlistener/v5 ${headers} ${evtdata} ${VESC_HTTPS_USER} ${VESC_HTTPS_PD}
+ Log Receive HTTP Status code ${resp.status_code}
+ Should Be Equal As Strings ${resp.status_code} 404
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
*** Settings ***\r
Documentation The main interface for interacting with DCAE. It handles low level stuff like managing the http request library and DCAE required fields\r
Library RequestsLibrary\r
-Library DcaeLibrary.py \r
+Library DcaeLibrary \r
Library OperatingSystem\r
Library Collections\r
Variables ../resources/DcaeVariables.py\r
Resource ../resources/dcae_properties.robot\r
-\r
-\r
*** Variables ***\r
${DCAE_HEALTH_CHECK_BODY} %{WORKSPACE}/test/csit/tests/dcae/testcases/assets/json_events/dcae_healthcheck.json\r
-\r
*** Keywords ***\r
Get DCAE Nodes\r
[Documentation] Get DCAE Nodes from Consul Catalog\r
${len}= Get Length ${NodeList} \r
Should Not Be Equal As Integers ${len} 0\r
[return] ${NodeList}\r
-\r
-\r
DCAE Node Health Check\r
[Documentation] Perform DCAE Node Health Check\r
[Arguments] ${NodeName}\r
Should Not Be Equal As Integers ${len} 0\r
DCAE Check Health Status ${NodeName} ${StatusList[0]} Serf Health Status\r
#Run Keyword if ${len} > 1 DCAE Check Health Status ${NodeName} ${StatusList[1]} Serf Health Status\r
- \r
- \r
DCAE Check Health Status\r
[Arguments] ${NodeName} ${ItemStatus} ${CheckType}\r
Should Be Equal As Strings ${ItemStatus} passing \r
Log Node: ${NodeName} ${CheckType} check pass ok\r
- \r
VES Collector Suite Setup DMaaP\r
[Documentation] Start DMaaP Mockup Server\r
${ret}= Setup DMaaP Server\r
Should Be Equal As Strings ${ret} true\r
- \r
VES Collector Suite Shutdown DMaaP\r
[Documentation] Shutdown DMaaP Mockup Server\r
${ret}= Shutdown DMaap\r
Should Be Equal As Strings ${ret} true\r
-\r
- \r
-\r
- \r
Check DCAE Results\r
[Documentation] Parse DCAE JSON response and make sure all rows have healthTestStatus=GREEN\r
[Arguments] ${json}\r
@{rows}= Get From Dictionary ${json['returns']} rows\r
@{headers}= Get From Dictionary ${json['returns']} columns\r
- \r
# Retrieve column names from headers\r
${columns}= Create List\r
:for ${header} in @{headers}\r
- \ ${colName}= Get From Dictionary ${header} colName \r
+ \ ${colName}= Get From Dictionary ${header} colName\r
\ Append To List ${columns} ${colName}\r
- \r
- # Process each row making sure status=GREEN \r
+ # Process each row making sure status=GREEN\r
:for ${row} in @{rows}\r
\ ${cells}= Get From Dictionary ${row} cells\r
- \ ${dict}= Make A Dictionary ${cells} ${columns} \r
+ \ ${dict}= Make A Dictionary ${cells} ${columns}\r
\ Dictionary Should Contain Item ${dict} healthTestStatus GREEN\r
-\r
- \r
Make A Dictionary\r
[Documentation] Given a list of column names and a list of dictionaries, map columname=value\r
[Arguments] ${columns} ${names} ${valuename}=value\r
${dict}= Create Dictionary\r
- ${collength}= Get Length ${columns} \r
- ${namelength}= Get Length ${names} \r
+ ${collength}= Get Length ${columns}\r
+ ${namelength}= Get Length ${names}\r
:for ${index} in range 0 ${collength}\r
\ ${name}= Evaluate ${names}[${index}]\r
\ ${valued}= Evaluate ${columns}[${index}]\r
\ ${value}= Get From Dictionary ${valued} ${valueName}\r
\ Set To Dictionary ${dict} ${name} ${value} \r
[Return] ${dict}\r
- \r
-\r
Get Event Data From File\r
[Arguments] ${jsonfile}\r
${data}= OperatingSystem.Get File ${jsonfile}\r
#Should Not Be_Equal ${data} None\r
[return] ${data}\r
-\r
Json String To Dictionary\r
[Arguments] ${json_string} \r
${json_dict}= evaluate json.loads('''${json_string}''') json\r
[return] ${json_dict}\r
-\r
Dictionary To Json String\r
[Arguments] ${json_dict}\r
${json_string}= evaluate json.dumps(${json_dict}) json\r
[return] ${json_string}\r
-\r
-\r
Get DCAE Service Component Status\r
[Documentation] Get the status of a DCAE Service Component\r
[Arguments] ${url} ${urlpath} ${usr} ${passwd} \r
${session}= Create Session dcae-service-component ${url} auth=${auth}\r
${resp}= Get Request dcae-service-component ${urlpath}\r
[return] ${resp}\r
- \r
Publish Event To VES Collector No Auth\r
[Documentation] Send an event to VES Collector\r
[Arguments] ${url} ${evtpath} ${httpheaders} ${evtdata}\r
Log Creating session ${url}\r
- ${session}= Create Session dcae-d1 ${url}\r
- ${resp}= Post Request dcae-d1 ${evtpath} data=${evtdata} headers=${httpheaders}\r
+ ${session}= Create Session dcaegen2-d1 ${url}\r
+ ${resp}= Post Request dcaegen2-d1 ${evtpath} data=${evtdata} headers=${httpheaders}\r
#Log Received response from dcae ${resp.json()}\r
[return] ${resp}\r
-\r
Publish Event To VES Collector\r
[Documentation] Send an event to VES Collector\r
[Arguments] ${url} ${evtpath} ${httpheaders} ${evtdata} ${user} ${pd}\r
${auth}= Create List ${user} ${pd}\r
Log Creating session ${url}\r
- ${session}= Create Session dcae-d1 ${url} auth=${auth}\r
- ${resp}= Post Request dcae-d1 ${evtpath} data=${evtdata} headers=${httpheaders}\r
+ ${session}= Create Session dcaegen2-d1 ${url} auth=${auth} disable_warnings=1\r
+ ${resp}= Post Request dcaegen2-d1 ${evtpath} data=${evtdata} headers=${httpheaders}\r
#Log Received response from dcae ${resp.json()}\r
[return] ${resp}\r
- \r
Publish Event To VES Collector With Put Method\r
[Documentation] Send an event to VES Collector\r
[Arguments] ${url} ${evtpath} ${httpheaders} ${evtdata} ${user} ${pd}\r
${resp}= Put Request dcae-d1 ${evtpath} data=${evtdata} headers=${httpheaders}\r
#Log Received response from dcae ${resp.json()}\r
[return] ${resp}\r
-\r
Publish Event To VES Collector With Put Method No Auth\r
[Documentation] Send an event to VES Collector\r
[Arguments] ${url} ${evtpath} ${httpheaders} ${evtdata}\r
${resp}= Put Request dcae-d1 ${evtpath} data=${evtdata} headers=${httpheaders}\r
#Log Received response from dcae ${resp.json()}\r
[return] ${resp}\r
-
\ No newline at end of file
Code Review / integration.git / commitdiff