| marekpl | 503647c | 2018-10-24 14:33:25 +0200 | [diff] [blame] | 1 | *** Settings *** |
| 2 | Documentation HV-VES 'Sunny Scenario' Robot Framwork test - message is sent to the collector and Kafka topic is checked if the message has been published. |
| 3 | Default Tags HVVES |
| marekpl | 62c91a9 | 2018-10-29 12:13:58 +0100 | [diff] [blame] | 4 | Test Timeout 10s |
| marekpl | 503647c | 2018-10-24 14:33:25 +0200 | [diff] [blame] | 5 | Resource ${EXECDIR}/robot/resources/global_properties.robot |
| 6 | Resource ${EXECDIR}/robot/resources/test_templates/hvves_template.robot |
| 7 | Suite Teardown Reset Rammbock |
| 8 | |
| 9 | *** Variables *** |
| 10 | |
| 11 | *** Test Cases *** |
| 12 | HV-VES test case |
| 13 | ${msg_number_initial}= Check Number Of Messages On Topic ${GLOBAL_DNS_MESSAGE_ROUTER_KAFKA_NAME} ${GLOBAL_MESSAGE_ROUTER_KAFKA_PORT} ${hvves_kafka_topic} |
| 14 | Define WTP Protocol |
| 15 | Start HV-VES TCP Client And Send Message ${GLOBAL_DNS_HV_VES_NAME} ${GLOBAL_HV_VES_SERVER_PORT} |
| marekpl | 62c91a9 | 2018-10-29 12:13:58 +0100 | [diff] [blame] | 16 | Wait Until Keyword Succeeds 5s 1s Check If Topic Exists ${GLOBAL_DNS_MESSAGE_ROUTER_KAFKA_NAME} ${GLOBAL_MESSAGE_ROUTER_KAFKA_PORT} ${hvves_kafka_topic} |
| marekpl | 503647c | 2018-10-24 14:33:25 +0200 | [diff] [blame] | 17 | ${msg_number_after}= Check Number Of Messages On Topic ${GLOBAL_DNS_MESSAGE_ROUTER_KAFKA_NAME} ${GLOBAL_MESSAGE_ROUTER_KAFKA_PORT} ${hvves_kafka_topic} |
| 18 | Should Not Be Equal As Integers ${msg_number_initial} ${msg_number_after} |
| 19 | Download VesEvent Proto File ${EXECDIR} |
| 20 | ${msg_decoded}= Decode Last Message From Topic ${GLOBAL_DNS_MESSAGE_ROUTER_KAFKA_NAME} ${GLOBAL_MESSAGE_ROUTER_KAFKA_PORT} ${hvves_kafka_topic} ${EXECDIR} |
| 21 | ${msg_decoded_template}= Get File ${EXECDIR}/robot/assets/templates/hvves/hvves_decoded_msg.template |
| 22 | Should Be Equal As Strings ${msg_decoded} ${msg_decoded_template} |