Add DMaaP Update topic ACL test

fixed Pomba Documentation warning

Issue-ID: INT-1058
Change-Id: Ifda1ccf4002312d031fde2520226de719b788853
Signed-off-by: Brian Freeman <bf1936@att.com>

1 files changed, 60 insertions, 1 deletions

diff --git a/robot/resources/mr_interface.robot b/robot/resources/mr_interface.robot
index 29e9dd3e..0c194c10 100644
--- a/robot/resources/mr_interface.robot
+++ b/robot/resources/mr_interface.robot
@@ -1,17 +1,24 @@
 *** 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           RequestsLibrary
 Library           UUID
+Library           DateTime
+Library           Process
+Library           JSONUtils
 
 Resource          global_properties.robot
+Resource          ../resources/json_templater.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_CREATE_TOPIC_PATH}        /topics/create
+${MR_UPDATE_ACL_TOPIC_PATH}        /topics/TEST_TOPIC_ACL/producers
 ${MR_ENDPOINT}     ${GLOBAL_MR_SERVER_PROTOCOL}://${GLOBAL_INJECTED_MR_IP_ADDR}:${GLOBAL_MR_SERVER_PORT}
 ${MR_PUBLISH_TEMPLATE}     robot/assets/templates/mr_publish.template
+${MR_PUT_ACL_TEMPLATE}    robot/assets/templates/mr_put_acl.template
 
 
 *** Keywords ***
@@ -37,6 +44,58 @@ Run MR PubSub Health Check
      Should Be Equal As Strings         ${resp.status_code}     200
      Should Contain    ${resp.json()[0]}    timestamp    Failed to Read Data
 
+
+Run MR Update Topic Acl
+     [Documentation]    Runs MR create topic and update producer credentials
+     #
+     #   Testing to Delete a Topic:
+     #           /opt/kafka/bin/kafka-topics.sh --zookeeper message-router-zookeeper:2181 --delete --topic <topic_name>
+     #           /opt/kafka/bin/kafka-topics.sh --zookeeper message-router-zookeeper:2181 --delete --topic TEST_TOPIC_ACL
+     #
+     #   Appears to not care if topic already exists with the POST / PUT method
+     #
+     ${dict}=    Create Dictionary    TOPIC_NAME=TEST_TOPIC_ACL
+     ${data}=   Fill JSON Template File    ${MR_PUT_ACL_TEMPLATE}    ${dict}
+     #Log To Console    ${\n}Create TEST_TOPIC_ACL
+     ${resp}=    Run MR Auth Post Request    ${MR_CREATE_TOPIC_PATH}   iPIxkpAMI8qTcQj8  Ehq3WyT4bkif4zwgEbvshGal   ${data}
+     #Log To Console    Update Owner for TEST_TOPIC_ACL
+     ${resp}=    Run MR Auth Put Request    ${MR_UPDATE_ACL_TOPIC_PATH}/iPIxkpAMI8qTcQj8  iPIxkpAMI8qTcQj8    Ehq3WyT4bkif4zwgEbvshGal    ${data}
+     Should Be Equal As Strings         ${resp.status_code}     200
+
+Run MR Auth Post Request
+     [Documentation]    Runs MR Authenticated Post Request
+     [Arguments]     ${data_path}     ${id_key}   ${secret_key}    ${data}
+     ${current_time}=   Get Time
+     ${time}=    Evaluate    datetime.datetime.today().replace(tzinfo=pytz.UTC).replace(microsecond=0).isoformat()    modules=datetime,pytz
+     ${command}=  Set Variable    /bin/echo -n "${time}" | /usr/bin/openssl sha1 -hmac "${secret_key}" -binary | /usr/bin/openssl base64
+     ${result}=    Run Process    ${command}   shell=True
+     ${signature}=   Set Variable    ${result.stdout}
+     ${xAuth}=    Set Variable    ${id_key}:${signature}
+     ${headers}=  Create Dictionary     Content-Type=application/json    X-CambriaAuth=${xAuth}    X-CambriaDate=${time}
+     ${session}=    Create Session      mr      ${MR_ENDPOINT}
+     ${resp}=   Post Request     mr      ${data_path}     headers=${headers}   data=${data}
+     ${status_string}=    Convert To String    ${resp.status_code}
+     Should Match Regexp    ${status_string}    ^(204|200)$
+     Log    Received response from message router ${resp.text}
+     [Return]    ${resp}
+
+
+Run MR Auth Put Request
+     [Documentation]    Runs MR Authenticated Put Request
+     [Arguments]     ${data_path}     ${id_key}   ${secret_key}    ${data}
+     ${current_time}=   Get Time
+     ${time}=    Evaluate    datetime.datetime.today().replace(tzinfo=pytz.UTC).replace(microsecond=0).isoformat()    modules=datetime,pytz
+     ${command}=  Set Variable    /bin/echo -n "${time}" | /usr/bin/openssl sha1 -hmac "${secret_key}" -binary | /usr/bin/openssl base64
+     ${result}=    Run Process    ${command}   shell=True
+     ${signature}=   Set Variable    ${result.stdout}
+     ${xAuth}=    Set Variable    ${id_key}:${signature}
+     ${headers}=  Create Dictionary     Content-Type=application/json    X-CambriaAuth=${xAuth}    X-CambriaDate=${time}
+     ${session}=    Create Session      mr      ${MR_ENDPOINT}
+     ${resp}=   Put Request     mr      ${data_path}     headers=${headers}   data=${data}
+     Should Be Equal As Strings         ${resp.status_code}     200
+     Log    Received response from message router ${resp.text}
+     [Return]    ${resp}
+
 Run MR Get Request
      [Documentation]    Runs MR Get request
      [Arguments]    ${data_path}