blob: 29e9dd3eb60ddc7ce245369b8d9a087433059060 (
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
|
*** Settings ***
Documentation The main interface for interacting with Message router. It handles low level stuff like managing the http request library and message router required fields
Library RequestsClientCert
Library RequestsLibrary
Library UUID
Resource global_properties.robot
*** Variables ***
${MR_HEALTH_CHECK_PATH} /topics
${MR_PUB_HEALTH_CHECK_PATH} /events/TEST_TOPIC
${MR_SUB_HEALTH_CHECK_PATH} /events/TEST_TOPIC/g1/c4?timeout=5000
${MR_ENDPOINT} ${GLOBAL_MR_SERVER_PROTOCOL}://${GLOBAL_INJECTED_MR_IP_ADDR}:${GLOBAL_MR_SERVER_PORT}
${MR_PUBLISH_TEMPLATE} robot/assets/templates/mr_publish.template
*** Keywords ***
Run MR Health Check
[Documentation] Runs MR Health check
${resp}= Run MR Get Request ${MR_HEALTH_CHECK_PATH}
Should Be Equal As Strings ${resp.status_code} 200
Should Contain ${resp.json()} topics
Run MR PubSub Health Check
[Documentation] Runs MR PubSub Health check
#${resp}= Run MR Get Request ${MR_SUB_HEALTH_CHECK_PATH}
# topic may not be created which is a 400 error
${resp}= Run MR Post Request ${MR_PUB_HEALTH_CHECK_PATH}
Should Be Equal As Strings ${resp.status_code} 200
Should Contain ${resp.json()} serverTimeMs Failed to Write Data
${resp}= Run MR Get Request ${MR_SUB_HEALTH_CHECK_PATH}
# Always Write twice to catch lost first message
${resp}= Run MR Post Request ${MR_PUB_HEALTH_CHECK_PATH}
${resp}= Run MR Get Request ${MR_SUB_HEALTH_CHECK_PATH}
# ${resp} is an array
Should Be Equal As Strings ${resp.status_code} 200
Should Contain ${resp.json()[0]} timestamp Failed to Read Data
Run MR Get Request
[Documentation] Runs MR Get request
[Arguments] ${data_path}
${session}= Create Session mr ${MR_ENDPOINT}
${uuid}= Generate UUID
${headers}= Create Dictionary Accept=application/json Content-Type=application/json X-TransactionId=${GLOBAL_APPLICATION_ID}-${uuid} X-FromAppId=${GLOBAL_APPLICATION_ID}
${resp}= Get Request mr ${data_path} headers=${headers}
Log Received response from message router ${resp.text}
[Return] ${resp}
Run MR Post Request
[Documentation] Runs MR Post request
[Arguments] ${data_path}
${session}= Create Session mr ${MR_ENDPOINT}
${timestamp}= Get Current Date
${dict}= Create Dictionary timestamp=${timestamp}
${data}= Fill JSON Template File ${MR_PUBLISH_TEMPLATE} ${dict}
${uuid}= Generate UUID
${headers}= Create Dictionary Accept=application/json Content-Type=application/json X-TransactionId=${GLOBAL_APPLICATION_ID}-${uuid} X-FromAppId=${GLOBAL_APPLICATION_ID}
${resp}= Post Request mr ${data_path} data=${data} headers=${headers}
Log Received response from message router ${resp.text}
[Return] ${resp}
|
