Small improvements after fixing apex-pdp image generation 35/139935/1
authoradheli.tavares <adheli.tavares@est.tech>
Mon, 13 Jan 2025 15:33:55 +0000 (15:33 +0000)
committeradheli.tavares <adheli.tavares@est.tech>
Tue, 14 Jan 2025 14:15:47 +0000 (14:15 +0000)
Issue-ID: POLICY-5192
Change-Id: I77e9a517a17ca685a1b14b518f4da7691d1b4b2f
Signed-off-by: adheli.tavares <adheli.tavares@est.tech>
csit/resources/tests/apex-pdp-common.robot
csit/resources/tests/apex-pdp-test.robot
csit/resources/tests/apex-slas.robot
csit/resources/tests/drools-applications-test.robot

index 8192460..d88d16f 100644 (file)
@@ -1,26 +1,26 @@
 *** Settings ***
-Library     Collections
-Library     RequestsLibrary
-Library     OperatingSystem
-Library     json
-Library     Process
+Library    Collections
+Library    RequestsLibrary
+Library    OperatingSystem
+Library    json
+Library    Process
 Resource    common-library.robot
 
 *** Keywords ***
 
 DeployPolicy
-     [Documentation]    Deploy the policy in apex-pdp engine
-     ${postjson}=    Get File  ${CURDIR}/data/policy_deploy.json
-     ${postjson}=    evaluate    json.loads('''${postjson}''')    json
-     set to dictionary    ${postjson['groups'][0]['deploymentSubgroups'][0]['policies'][0]}    name=${policyName}
-     ${postjson}=    evaluate    json.dumps(${postjson})    json
-     ${policyadmin}=  PolicyAdminAuth
-     PerformPostRequest  ${POLICY_PAP_IP}  /policy/pap/v1/pdps/deployments/batch  202  ${postjson}  null  ${policyadmin}
+    [Documentation]    Deploy the policy in apex-pdp engine
+    ${postjson}=    Get File  ${CURDIR}/data/policy_deploy.json
+    ${postjson}=    evaluate    json.loads('''${postjson}''')    json
+    set to dictionary    ${postjson['groups'][0]['deploymentSubgroups'][0]['policies'][0]}    name=${policyName}
+    ${postjson}=    evaluate    json.dumps(${postjson})    json
+    ${policyadmin}=  PolicyAdminAuth
+    PerformPostRequest  ${POLICY_PAP_IP}  /policy/pap/v1/pdps/deployments/batch  202  ${postjson}  null  ${policyadmin}
 
 RunEventOnApexEngine
     [Documentation]    Send event to verify policy execution
     Create Session   apexSession  http://${APEX_EVENTS_IP}   max_retries=1
-    ${data}=    Get Binary File     ${CURDIR}/data/event.json
+    ${data}=    Get Binary File    ${CURDIR}/data/event.json
     &{headers}=  Create Dictionary    Content-Type=application/json    Accept=application/json
     ${resp}=    PUT On Session    apexSession    /apex/FirstConsumer/EventIn    data=${data}   headers=${headers}
     Should Be Equal As Strings    ${resp.status_code}   200
@@ -32,8 +32,8 @@ CheckLogMessage
     Should Contain    ${result}    ${expectedMsg}
 
 ValidateEventExecution
-    [Arguments]  ${eventStartTime}  ${eventEndTime}  ${eventsNo}
-    [Documentation]    Check that X amount of events were exeuted per second
+    [Arguments]    ${eventStartTime}    ${eventEndTime}    ${eventsNo}
+    [Documentation]    Check that X amount of events were executed per second
     ${eventTimeTaken}=  Subtract Date From Date  ${eventEndTime}  ${eventStartTime}
     ${eventResult}=  Set Variable  ${eventTimeTaken * ${1000}}
     ${eventsPerSecond}=  Set Variable  ${${1000} / ${eventResult}}
index 3989ec4..cf4c713 100644 (file)
@@ -1,96 +1,96 @@
 *** Settings ***
-Library     Collections
-Library     RequestsLibrary
-Library     OperatingSystem
-Library     json
-Library     Process
+Library    Collections
+Library    RequestsLibrary
+Library    OperatingSystem
+Library    json
+Library    Process
 Resource    common-library.robot
 Resource    apex-pdp-common.robot
 
 *** Test Cases ***
 
 Healthcheck
-     [Documentation]    Runs Apex PDP Health check
-     ${hcauth}=  PolicyAdminAuth
-     ${resp}=  PerformGetRequest  ${APEX_IP}  /policy/apex-pdp/v1/healthcheck  200  null  ${hcauth}
-     Should Be Equal As Strings    ${resp.json()['code']}    200
-     Set Suite Variable    ${pdpName}    ${resp.json()['name']}
+    [Documentation]    Runs Apex PDP Health check
+    ${hcauth}=  PolicyAdminAuth
+    ${resp}=  PerformGetRequest  ${APEX_IP}  /policy/apex-pdp/v1/healthcheck  200  null  ${hcauth}
+    Should Be Equal As Strings    ${resp.json()['code']}    200
+    Set Suite Variable    ${pdpName}    ${resp.json()['name']}
 
 ExecuteApexSampleDomainPolicy
-     # [Tags]    docker
-     Set Test Variable    ${policyName}    onap.policies.native.apex.Sampledomain
-     ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
-     CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
-     DeployPolicy
-     Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
-     Wait Until Keyword Succeeds    4 min    5 sec    RunEventOnApexEngine
+    # [Tags]    docker
+    Set Test Variable    ${policyName}    onap.policies.native.apex.Sampledomain
+    ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
+    CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
+    DeployPolicy
+    Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
+    Wait Until Keyword Succeeds    4 min    5 sec    RunEventOnApexEngine
 
 ExecuteApexTestPnfPolicy
-     Set Test Variable    ${policyName}    onap.policies.apex.pnf.Test
-     ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
-     CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
-     DeployPolicy
-     Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
-     GetKafkaTopic    apex-cl-mgt
-     Wait Until Keyword Succeeds    2 min    5 sec    TriggerAndVerifyTestPnfPolicy    apex-cl-mgt
+    Set Test Variable    ${policyName}    onap.policies.apex.pnf.Test
+    ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
+    CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
+    DeployPolicy
+    Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
+    GetKafkaTopic    apex-cl-mgt
+    TriggerAndVerifyTestPnfPolicy    apex-cl-mgt
 
 #ExecuteApexTestVnfPolicy
-#     Set Test Variable    ${policyName}    onap.policies.apex.vnf.Test
-#     ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
-#     CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
-#     DeployPolicy
-#     Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
-#     GetTopic     apex-cl-mgt
-#     Wait Until Keyword Succeeds    2 min    5 sec    TriggerAndVerifyTestVnfPolicy
+#    Set Test Variable    ${policyName}    onap.policies.apex.vnf.Test
+#    ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
+#    CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
+#    DeployPolicy
+#    Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
+#    GetKafkaTopic    apex-cl-mgt
+#    TriggerAndVerifyTestVnfPolicy    apex-cl-mgt
 
 ExecuteApexTestPnfPolicyWithMetadataSet
-      Set Test Variable    ${policyName}    onap.policies.apex.pnf.metadataSet.Test
-      ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
-      CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
-      ${postjson}=  Get File  ${CURDIR}/data/onap.pnf.metadataSet.Test.json
-      CreateNodeTemplate  /policy/api/v1/nodetemplates  201  ${postjson}  1
-      DeployPolicy
-      Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
-      GetKafkaTopic     apex-cl-mgt2
-      Wait Until Keyword Succeeds    2 min    5 sec    TriggerAndVerifyTestPnfPolicy    apex-cl-mgt2
+    Set Test Variable    ${policyName}    onap.policies.apex.pnf.metadataSet.Test
+    ${postjson}=  Get File  ${CURDIR}/data/${policyName}.json
+    CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
+    ${postjson}=  Get File  ${CURDIR}/data/onap.pnf.metadataSet.Test.json
+    CreateNodeTemplate  /policy/api/v1/nodetemplates  201  ${postjson}  1
+    DeployPolicy
+    Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
+    GetKafkaTopic    apex-cl-mgt2
+    TriggerAndVerifyTestPnfPolicy    apex-cl-mgt2
 
 Metrics
-     [Documentation]  Verify policy-apex-pdp is exporting prometheus metrics
-     ${auth}=  PolicyAdminAuth
-     ${resp}=  PerformGetRequest  ${APEX_IP}  /metrics  200  null  ${auth}
-     Should Contain  ${resp.text}  pdpa_policy_deployments_total{operation="deploy",status="TOTAL",} 3.0
-     Should Contain  ${resp.text}  pdpa_policy_deployments_total{operation="deploy",status="SUCCESS",} 3.0
-     Should Contain  ${resp.text}  pdpa_policy_executions_total{status="SUCCESS",} 6.0
-     Should Contain  ${resp.text}  pdpa_policy_executions_total{status="TOTAL",} 6.0
-     Should Match  ${resp.text}  *pdpa_engine_event_executions{engine_instance_id="NSOApexEngine-*:0.0.1",}*
-     Should Match  ${resp.text}  *pdpa_engine_event_executions{engine_instance_id="MyApexEngine-*:0.0.1",}*
-     Should Match  ${resp.text}  *pdpa_engine_state{engine_instance_id=*,} 2.0*
-     Should Contain  ${resp.text}  pdpa_engine_event_executions
-     Should Contain  ${resp.text}  pdpa_engine_average_execution_time_seconds
-     Should Contain  ${resp.text}  pdpa_engine_last_execution_time_bucket
-     Should Contain  ${resp.text}  pdpa_engine_last_execution_time_count
-     Should Contain  ${resp.text}  pdpa_engine_last_execution_time_sum
-     Should Match  ${resp.text}  *pdpa_engine_last_start_timestamp_epoch{engine_instance_id="NSOApexEngine-*:0.0.1",}*E12*
-     Should Match  ${resp.text}  *pdpa_engine_last_start_timestamp_epoch{engine_instance_id="MyApexEngine-*:0.0.1",}*E12*
-     Should Contain  ${resp.text}  jvm_threads_current
+    [Documentation]  Verify policy-apex-pdp is exporting prometheus metrics
+    ${auth}=  PolicyAdminAuth
+    ${resp}=  PerformGetRequest  ${APEX_IP}  /metrics  200  null  ${auth}
+    Should Contain  ${resp.text}  pdpa_policy_deployments_total{operation="deploy",status="TOTAL",} 3.0
+    Should Contain  ${resp.text}  pdpa_policy_deployments_total{operation="deploy",status="SUCCESS",} 3.0
+    Should Contain  ${resp.text}  pdpa_policy_executions_total{status="SUCCESS",} 3.0
+    Should Contain  ${resp.text}  pdpa_policy_executions_total{status="TOTAL",} 3.0
+    Should Match  ${resp.text}  *pdpa_engine_event_executions{engine_instance_id="NSOApexEngine-*:0.0.1",}*
+    Should Match  ${resp.text}  *pdpa_engine_event_executions{engine_instance_id="MyApexEngine-*:0.0.1",}*
+    Should Match  ${resp.text}  *pdpa_engine_state{engine_instance_id=*,} 2.0*
+    Should Contain  ${resp.text}  pdpa_engine_event_executions
+    Should Contain  ${resp.text}  pdpa_engine_average_execution_time_seconds
+    Should Contain  ${resp.text}  pdpa_engine_last_execution_time_bucket
+    Should Contain  ${resp.text}  pdpa_engine_last_execution_time_count
+    Should Contain  ${resp.text}  pdpa_engine_last_execution_time_sum
+    Should Match  ${resp.text}  *pdpa_engine_last_start_timestamp_epoch{engine_instance_id="NSOApexEngine-*:0.0.1",}*E12*
+    Should Match  ${resp.text}  *pdpa_engine_last_start_timestamp_epoch{engine_instance_id="MyApexEngine-*:0.0.1",}*E12*
+    Should Contain  ${resp.text}  jvm_threads_current
 
 *** Keywords ***
 
 TriggerAndVerifyTestPnfPolicy
     [Documentation]    Send TestPnf policy trigger event to Kafka and read notifications to verify policy execution
     [Arguments]    ${topic}
-    ${data}=    Get Binary File     ${CURDIR}/data/VesEventForPnfPolicy.json
+    ${data}=    Get Binary File    ${CURDIR}/data/VesEventForPnfPolicy.json
     ${resp}=    Run Process    ${CURDIR}/kafka_producer.py    unauthenticated.dcae_cl_output    ${data}    ${KAFKA_IP}
-    Run Keyword    CheckLogMessage    ${topic}    ACTIVE    VES event has been received. Going to fetch details from AAI.
-    Run Keyword    CheckLogMessage    ${topic}    SUCCESS    Received response from AAI successfully. Hostname in AAI matches with the one in Ves event. Going to make the update-config request to CDS.
-    Run Keyword    CheckLogMessage    ${topic}    FINAL_SUCCESS    Successfully processed the VES event. Hostname is updated.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    ACTIVE    VES event has been received. Going to fetch details from AAI.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    SUCCESS    Received response from AAI successfully. Hostname in AAI matches with the one in Ves event. Going to make the update-config request to CDS.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    FINAL_SUCCESS    Successfully processed the VES event. Hostname is updated.
 
 TriggerAndVerifyTestVnfPolicy
     [Documentation]    Send TestVnf policy trigger event to Kafka and read notifications to verify policy execution
     [Arguments]    ${topic}
-    ${data}=    Get Binary File     ${CURDIR}/data/VesEventForVnfPolicy.json
+    ${data}=    Get Binary File    ${CURDIR}/data/VesEventForVnfPolicy.json
     ${resp}=    Run Process    ${CURDIR}/kafka_producer.py    unauthenticated.dcae_policy_example_output    ${data}    ${KAFKA_IP}
-    Run Keyword    CheckLogMessage    ${topic}    ACTIVE    VES event has been received. Going to fetch VNF details from AAI.
-    Run Keyword    CheckLogMessage    ${topic}    SUCCESS    VNF details are received from AAI successfully. Sending ConfigModify request to CDS.
-    Run Keyword    CheckLogMessage    ${topic}    SUCCESS    ConfigModify request is successful. Sending restart request to CDS.
-    Run Keyword    CheckLogMessage    ${topic}    FINAL_SUCCESS    Successfully processed the VES Event. Restart is complete.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    ACTIVE    VES event has been received. Going to fetch VNF details from AAI.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    SUCCESS    VNF details are received from AAI successfully. Sending ConfigModify request to CDS.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    SUCCESS    ConfigModify request is successful. Sending restart request to CDS.
+    Wait Until Keyword Succeeds    4 x    10 sec    CheckLogMessage    ${topic}    FINAL_SUCCESS    Successfully processed the VES Event. Restart is complete.
index 760bc34..e27f0da 100644 (file)
@@ -10,11 +10,11 @@ Resource    apex-pdp-common.robot
 
 *** Test Cases ***
 Healthcheck
-     [Documentation]    Runs Apex PDP Health check
-     ${hcauth}=  PolicyAdminAuth
-     ${resp}=  PerformGetRequest  ${APEX_IP}  /policy/apex-pdp/v1/healthcheck  200  null  ${hcauth}
-     Should Be Equal As Strings    ${resp.json()['code']}    200
-     Set Suite Variable    ${pdpName}    ${resp.json()['name']}
+    [Documentation]    Runs Apex PDP Health check
+    ${hcauth}=  PolicyAdminAuth
+    ${resp}=  PerformGetRequest  ${APEX_IP}  /policy/apex-pdp/v1/healthcheck  200  null  ${hcauth}
+    Should Be Equal As Strings    ${resp.json()['code']}    200
+    Set Suite Variable    ${pdpName}    ${resp.json()['name']}
 
 ValidatePolicyExecutionAndEventRateLowComplexity
     [Documentation]  Validate that a moderate complexity policy can be executed in less than 100ms and minimum 10 events triggered per second
@@ -23,8 +23,8 @@ ValidatePolicyExecutionAndEventRateLowComplexity
     CreatePolicySuccessfully  /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies  ${postjson}  ${policyName}  1.0.0
     DeployPolicy
     Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
-    GetKafkaTopic     apex-cl-mgt
-    ${data}=    Get Binary File     ${CURDIR}/data/VesEventForPnfPolicy.json
+    GetKafkaTopic    apex-cl-mgt
+    ${data}=    Get Binary File    ${CURDIR}/data/VesEventForPnfPolicy.json
     ${eventStartTime}=  Get Current Date
     ${resp}=    Run Process    ${CURDIR}/kafka_producer.py    unauthenticated.dcae_cl_output    ${data}    ${KAFKA_IP}
     ${eventEndTime}=  Get Current Date
@@ -50,8 +50,8 @@ ValidatePolicyExecutionAndEventRateHighComplexity
     CreateNodeTemplate  /policy/api/v1/nodetemplates  201  ${postjson}  1
     DeployPolicy
     Wait Until Keyword Succeeds    2 min    5 sec    QueryPolicyStatus  ${policyName}  defaultGroup  apex  ${pdpName}  onap.policies.native.Apex
-    GetKafkaTopic     apex-cl-mgt2
-    ${data}=    Get Binary File     ${CURDIR}/data/VesEventForVnfPolicy.json
+    GetKafkaTopic    apex-cl-mgt2
+    ${data}=    Get Binary File    ${CURDIR}/data/VesEventForVnfPolicy.json
     ${eventStartTime}=  Get Current Date
     ${resp}=    Run Process    ${CURDIR}/kafka_producer.py    unauthenticated.dcae_policy_example_output    ${data}    ${KAFKA_IP}
     ${eventEndTime}=  Get Current Date
index 4ceb288..61d7759 100644 (file)
@@ -1,10 +1,10 @@
 *** Settings ***
-Library     Collections
-Library     String
-Library     RequestsLibrary
-Library     OperatingSystem
-Library     Process
-Library     json
+Library    Collections
+Library    String
+Library    RequestsLibrary
+Library    OperatingSystem
+Library    Process
+Library    json
 Resource    common-library.robot
 
 *** Test Cases ***
@@ -29,18 +29,18 @@ Controller
 
 AssertTopicsOnKafkaClient
     [Documentation]    Verify that the Policy topics policy-pdp-pap and policy-cl-mgt are available on kafka
-    GetKafkaTopic     policy-pdp-pap
-    GetKafkaTopic     policy-cl-mgt
+    GetKafkaTopic    policy-pdp-pap
+    GetKafkaTopic    policy-cl-mgt
 
 CheckTopics
-    [Documentation]     List the topics registered with TopicManager
+    [Documentation]    List the topics registered with TopicManager
     ${resp}=  PerformGetRequestOnDrools  /policy/pdp/engine/topics  ${DROOLS_IP_2}  200
     Should Contain    ${resp.text}    policy-cl-mgt
     Should Contain    ${resp.text}    policy-pdp-pap
     Should Contain    ${resp.text}    dcae_topic
 
 CheckEngineFeatures
-    [Documentation]     List the features available in the drools engine
+    [Documentation]    List the features available in the drools engine
     ${resp}=  PerformGetRequestOnDrools  /policy/pdp/engine/features  ${DROOLS_IP_2}  200
     Should Contain    ${resp.text}    "org.onap.policy.drools.lifecycle.LifecycleFeature"
     Should Contain    ${resp.text}    "org.onap.policy.drools.apps.controlloop.feature.usecases.UsecasesFeature"
@@ -98,7 +98,7 @@ DeployXacmlPolicies
     [Documentation]    Deploys the Policies to Xacml
     DeployPolicy  deploy.xacml.policies.json
     Sleep  5s
-    @{otherMessages}=   Create List     deployed-policies   onap.scaleout.tca    onap.restart.tca
+    @{otherMessages}=   Create List    deployed-policies   onap.scaleout.tca    onap.restart.tca
     AssertMessageFromTopic    policy-notification    onap.vfirewall.tca    ${otherMessages}
 
 VerifyDeployedXacmlPolicies
@@ -106,14 +106,14 @@ VerifyDeployedXacmlPolicies
     ${resp}=    GetDeployedPolicies
     @{policies}=   Create List    onap.vfirewall.tca    onap.scaleout.tca    onap.restart.tca
     FOR    ${policy}    IN    @{policies}
-        Should Contain    ${resp.text}    ${policy}
+       Should Contain    ${resp.text}    ${policy}
     END
 
 DeployDroolsPolicies
     [Documentation]    Deploys the Policies to Drools
     DeployPolicy   deploy.drools.policies.json
     Sleep  5s
-    @{otherMessages}=   Create List     deployed-policies   operational.scaleout    operational.restart
+    @{otherMessages}=   Create List    deployed-policies   operational.scaleout    operational.restart
     AssertMessageFromTopic    policy-notification    operational.modifyconfig    ${otherMessages}
 
 VerifyDeployedDroolsPolicies
@@ -121,68 +121,68 @@ VerifyDeployedDroolsPolicies
     ${resp}=    GetDeployedPolicies
     @{policies}=   Create List    operational.modifyconfig    operational.scaleout    operational.restart
     FOR    ${policy}    IN    @{policies}
-        Should Contain    ${resp.text}    ${policy}
+       Should Contain    ${resp.text}    ${policy}
     END
 
 VcpeExecute
     [Documentation]    Executes VCPE Policy
-    OnSet     ${CURDIR}/data/drools/vcpeOnset.json
+    OnSet    ${CURDIR}/data/drools/vcpeOnset.json
     ${policyExecuted}=  Set Variable    ControlLoop-vCPE-48f0c2c3-a172-4192-9ae3-052274181b6e
     @{otherMessages}=   Create List    ACTIVE
-    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 
     @{otherMessages}=   Create List    ${policyExecuted}    OPERATION
-    AssertMessageFromTopic     policy-cl-mgt   Sending guard query for APPC Restart   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   Sending guard query for APPC Restart   ${otherMessages}
 
-    AssertMessageFromTopic     policy-cl-mgt   Guard result for APPC Restart is Permit   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   Guard result for APPC Restart is Permit   ${otherMessages}
 
-    AssertMessageFromTopic     policy-cl-mgt   actor=APPC,operation=Restart   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   actor=APPC,operation=Restart   ${otherMessages}
 
 #    @{otherMessages}=   Create List    OPERATION: SUCCESS   actor=APPC,operation=Restart
-#    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+#    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 #
 #    @{otherMessages}=   Create List    FINAL: SUCCESS   APPC    Restart
-#    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+#    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 
 VdnsExecute
     [Documentation]    Executes VDNS Policy
-    OnSet     ${CURDIR}/data/drools/vdnsOnset.json
+    OnSet    ${CURDIR}/data/drools/vdnsOnset.json
     ${policyExecuted}=  Set Variable    ControlLoop-vDNS-6f37f56d-a87d-4b85-b6a9-cc953cf779b3
     @{otherMessages}=   Create List    ACTIVE
-    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 
     @{otherMessages}=   Create List    ${policyExecuted}    OPERATION
-    AssertMessageFromTopic     policy-cl-mgt   Sending guard query for SO VF Module Create   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   Sending guard query for SO VF Module Create   ${otherMessages}
 
-    AssertMessageFromTopic     policy-cl-mgt   Guard result for SO VF Module Create is Permit   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   Guard result for SO VF Module Create is Permit   ${otherMessages}
 
-    AssertMessageFromTopic     policy-cl-mgt   actor=SO,operation=VF Module Create   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   actor=SO,operation=VF Module Create   ${otherMessages}
 
     @{otherMessages}=   Create List    ${policyExecuted}    OPERATION: SUCCESS
-    AssertMessageFromTopic     policy-cl-mgt   actor=SO,operation=VF Module Create   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   actor=SO,operation=VF Module Create   ${otherMessages}
 
     @{otherMessages}=   Create List    ${policyExecuted}    FINAL: SUCCESS   SO
-    AssertMessageFromTopic     policy-cl-mgt   VF Module Create   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   VF Module Create   ${otherMessages}
 
 VfwExecute
     [Documentation]    Executes VFW Policy
-    OnSet     ${CURDIR}/data/drools/vfwOnset.json
+    OnSet    ${CURDIR}/data/drools/vfwOnset.json
     ${policyExecuted}=  Set Variable    ControlLoop-vFirewall-d0a1dfc6-94f5-4fd4-a5b5-4630b438850a
     @{otherMessages}=   Create List    ACTIVE
-    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 
     @{otherMessages}=   Create List    ${policyExecuted}    OPERATION
-    AssertMessageFromTopic     policy-cl-mgt   Sending guard query for APPC ModifyConfig   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   Sending guard query for APPC ModifyConfig   ${otherMessages}
 
-    AssertMessageFromTopic     policy-cl-mgt   Guard result for APPC ModifyConfig is Permit   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   Guard result for APPC ModifyConfig is Permit   ${otherMessages}
 
-    AssertMessageFromTopic     policy-cl-mgt   actor=APPC,operation=ModifyConfig   ${otherMessages}
+    AssertMessageFromTopic    policy-cl-mgt   actor=APPC,operation=ModifyConfig   ${otherMessages}
 
 #    @{otherMessages}=   Create List    OPERATION: SUCCESS    actor=APPC,operation=ModifyConfig
-#    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+#    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 #
 #    @{otherMessages}=   Create List    FINAL: SUCCESS    APPC   ModifyConfig
-#    AssertMessageFromTopic     policy-cl-mgt   ${policyExecuted}   ${otherMessages}
+#    AssertMessageFromTopic    policy-cl-mgt   ${policyExecuted}   ${otherMessages}
 
 
 *** Keywords ***
@@ -192,25 +192,25 @@ VerifyController
     Should Be Equal As Strings  ${resp.json()['usecases']}  1
 
 PerformGetRequestOnDrools
-     [Arguments]  ${url}  ${domain}  ${expectedstatus}
-     ${auth}=  Create List  demo@people.osaaf.org  demo123456!
-     Log  Creating session http://${domain}
-     ${session}=  Create Session  policy  http://${domain}  auth=${auth}
-     ${headers}=  Create Dictionary  Accept=application/json  Content-Type=application/json
-     ${resp}=  GET On Session  policy  ${url}  headers=${headers}  expected_status=${expectedstatus}
-     Log  Received response from policy ${resp.text}
-     RETURN  ${resp}
+    [Arguments]  ${url}  ${domain}  ${expectedstatus}
+    ${auth}=  Create List  demo@people.osaaf.org  demo123456!
+    Log  Creating session http://${domain}
+    ${session}=  Create Session  policy  http://${domain}  auth=${auth}
+    ${headers}=  Create Dictionary  Accept=application/json  Content-Type=application/json
+    ${resp}=  GET On Session  policy  ${url}  headers=${headers}  expected_status=${expectedstatus}
+    Log  Received response from policy ${resp.text}
+    RETURN  ${resp}
 
 PerformPostRequest
-     [Arguments]  ${url}  ${domain}  ${file}  ${folder}  ${contenttype}  ${expectedstatus}
-     ${auth}=  Create List  policyadmin  zb!XztG34
-     ${body}=  Get file  ${folder}/${file}
-     Log  Creating session http://${domain}
-     ${session}=  Create Session  policy  http://${domain}  auth=${auth}
-     ${headers}=  Create Dictionary  Accept=application/${contenttype}  Content-Type=application/${contenttype}
-     ${resp}=  POST On Session  policy  ${url}  data=${body}  headers=${headers}  expected_status=${expectedstatus}
-     Log  Received response from policy ${resp.text}
-     RETURN  ${resp}
+    [Arguments]  ${url}  ${domain}  ${file}  ${folder}  ${contenttype}  ${expectedstatus}
+    ${auth}=  Create List  policyadmin  zb!XztG34
+    ${body}=  Get file  ${folder}/${file}
+    Log  Creating session http://${domain}
+    ${session}=  Create Session  policy  http://${domain}  auth=${auth}
+    ${headers}=  Create Dictionary  Accept=application/${contenttype}  Content-Type=application/${contenttype}
+    ${resp}=  POST On Session  policy  ${url}  data=${body}  headers=${headers}  expected_status=${expectedstatus}
+    Log  Received response from policy ${resp.text}
+    RETURN  ${resp}
 
 OnSet
     [Arguments]    ${file}
@@ -220,18 +220,18 @@ OnSet
     RETURN    ${resp.stdout}
 
 CreatePolicy
-    [Arguments]     ${policyFile}   ${contenttype}
+    [Arguments]    ${policyFile}   ${contenttype}
     PerformPostRequest  /policy/api/v1/policies  ${POLICY_API_IP}  ${policyFile}  ${DATA}  ${contenttype}  201
 
 DeployPolicy
-    [Arguments]     ${policyName}
+    [Arguments]    ${policyName}
     PerformPostRequest  /policy/pap/v1/pdps/deployments/batch  ${POLICY_PAP_IP}  ${policyName}  ${CURDIR}/data/drools  json  202
 
 AssertMessageFromTopic
-    [Arguments]     ${topic}    ${topicMessage}     ${otherMessages}
+    [Arguments]    ${topic}    ${topicMessage}    ${otherMessages}
     ${response}=    Wait Until Keyword Succeeds    4 x    10 sec    CheckKafkaTopic    ${topic}    ${topicMessage}
     FOR    ${msg}    IN    @{otherMessages}
-        Should Contain    ${response}    ${msg}
+       Should Contain    ${response}    ${msg}
     END
 
 GetDeployedPolicies