[DCAEGEN2] CSIT Update to Read all Subscriptions and it's associated NFS
[integration/csit.git] / tests / dcaegen2-services-pmsh / testcases / pmsh.robot
index 74a575c..135d65d 100644 (file)
 *** Settings ***
 Documentation     Testing PMSH functionality
+
 Library           OperatingSystem
 Library           RequestsLibrary
 Library           String
+Library           Process
 
-Test Setup        Create Session  pmsh_session  ${PMSH_BASE_URL}
+Resource          ../../common.robot
 Test Teardown     Delete All Sessions
 
 
 *** Variables ***
+
 ${PMSH_BASE_URL}                    https://${PMSH_IP}:8443
-${HEALTHCHECK_ENDPOINT}             /healthcheck
+${MR_BASE_URL}                      http://${MR_IP_ADDRESS}:3904
+${CBS_BASE_URL}                     https://${CBS_SIM_IP_ADDRESS}:10443
+${SUBSCRIPTION_ENDPOINT}            /subscription
+${POLICY_PUBLISH_MR_TOPIC}          /events/unauthenticated.PMSH_CL_INPUT
+${AAI_MR_TOPIC}                     /events/AAI_EVENT
 
+${MR_AAI_PNF_CREATED}                       %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/aai-pnf-create.json
+${MR_AAI_PNF_REMOVED}                       %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/aai-pnf-delete.json
+${MR_POLICY_RESPONSE_PNF_EXISTING}          %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/policy-sub-created-pnf-existing.json
+${CBS_EXPECTATION_ADMIN_STATE_UNLOCKED}     %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/cbs-expectation-unlocked-config.json
+${CREATE_SUBSCRIPTION_DATA}                 %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/create_subscription_request.json
+${CREATE_SECOND_SUBSCRIPTION_DATA}          %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/create_second_subscription_request.json
+${CREATE_SUBSCRIPTION_BAD_DATA}             %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/create_subscription_bad_request.json
+${CREATE_SUBSCRIPTION_SCHEMA_ERROR_DATA}    %{WORKSPACE}/tests/dcaegen2-services-pmsh/testcases/assets/create_subscription_schema_error_request.json
+${ADMIN_STATE_LOCKED_PATTERN}       'administrativeState': 'LOCKED'
+${CLI_EXEC_GET_CBS_CONFIG_FIRST}    docker exec pmsh /bin/sh -c "grep -m 1 'PMSH config from CBS' /var/log/ONAP/dcaegen2/services/pmsh/application.log"
 
 *** Test Cases ***
-Verify Health Check returns 200 when a REST GET request to healthcheck url
+Verify Get subscriptions with Network Functions None
     [Tags]                          PMSH_01
-    [Documentation]                 Verify Health Check returns 200 when a REST GET request to healthcheck url
-    [Timeout]                       1 minute
-    ${resp}=                        Get Request                      pmsh_session  ${HEALTHCHECK_ENDPOINT}
-    VerifyResponse                  ${resp.status_code}              200
+    [Documentation]                 Verify Get all subscriptions when there are no defined subscriptions
+    [Timeout]                       10 seconds
+    ${resp}=                        GetSubsCall    ${SUBSCRIPTION_ENDPOINT}     ""
+    Should Be True                  ${resp.status_code} == 200
+    Should Contain                  ${resp.text}                     []
+
+Verify Create Subscriptions API
+    [Tags]                          PMSH_07
+    [Documentation]                 Verify Create Subscription API
+    [Timeout]                       60 seconds
+    ${json_value}=                  json_from_file                  ${CREATE_SUBSCRIPTION_DATA}
+    ${resp}=                        PostSubscriptionCall     ${SUBSCRIPTION_ENDPOINT}   ${json_value}
+    Should Be True                  ${resp.status_code} == 201
+     ${resp}=                       GetSubsCall    ${SUBSCRIPTION_ENDPOINT}   "/subs_01"
+    Should Be Equal As Strings      ${resp.json()[0]['subscription']['subscriptionName']}       subs_01
 
-Verify Health Check response includes healthy status
+Verify database tables exist and are empty
     [Tags]                          PMSH_02
-    [Documentation]                 Verify Health Check response includes healthy status
-    [Timeout]                       1 minute
-    ${resp}=                        Get Request                      pmsh_session  ${HEALTHCHECK_ENDPOINT}
-    VerifyResponseContains          ${resp.text}                  healthy
+    [Documentation]                 Verify database has been created and is empty
+    [Timeout]                       10 seconds
+    ${resp}=                        GetSubsCall    ${SUBSCRIPTION_ENDPOINT}     ""
+    Should Be True                  ${resp.status_code} == 200
+    Should Contain                  ${resp.text}                     []
+
+Verify PNF detected in AAI when administrative state unlocked
+    [Tags]                          PMSH_03
+    [Documentation]                 Verify PNF detected when administrative state unlocked
+    [Timeout]                       60 seconds
+    SetAdministrativeStateToUnlocked
+    Sleep                           31             Allow PMSH time to pick up changes in CBS config
+    ${resp}=                        GetMeasGrpCall    /subscription/subs_01/measurementGroups/msg_grp_01
+    Should Be Equal As Strings      ${resp.json()['subscriptionName']}      subs_01
+    Should Be Equal As Strings      ${resp.json()['administrativeState']}       UNLOCKED
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][0]['nfName']}            pnf-existing
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][0]['nfMgStatus']}      PENDING_CREATE
+
+Verify Policy response on MR is handled
+    [Tags]                          PMSH_04
+    [Documentation]                 Verify policy response on MR is handled
+    [Timeout]                       60 seconds
+    SimulatePolicyResponse          ${MR_POLICY_RESPONSE_PNF_EXISTING}
+    Sleep                           31 seconds      Ensure Policy response on MR is picked up
+    ${resp}=                        GetMeasGrpCall    /subscription/subs_01/measurementGroups/msg_grp_01
+    Should Be Equal As Strings      ${resp.json()['subscriptionName']}      subs_01
+    Should Be Equal As Strings      ${resp.json()['administrativeState']}       UNLOCKED
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][0]['nfName']}            pnf-existing
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][0]['nfMgStatus']}     CREATED
+
+Verify AAI event on MR detailing new PNF being detected is handled
+    [Tags]                          PMSH_05
+    [Documentation]                 Verify PNF created AAI event on MR is handled
+    [Timeout]                       60 seconds
+    SimulateNewPNF                  ${MR_AAI_PNF_CREATED}
+    Sleep                           31 seconds      Ensure AAI event on MR is picked up
+    ${resp}=                        GetMeasGrpCall    /subscription/subs_01/measurementGroups/msg_grp_01
+    Should Be Equal As Strings      ${resp.json()['subscriptionName']}      subs_01
+    Should Be Equal As Strings      ${resp.json()['administrativeState']}       UNLOCKED
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][1]['nfName']}            pnf_newly_discovered
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][1]['nfMgStatus']}      PENDING_CREATE
+
+Verify AAI event on MR detailing PNF being deleted is handled
+    [Tags]                          PMSH_06
+    [Documentation]                 Verify PNF deleted AAI event on MR is handled
+    [Timeout]                       60 seconds
+    SimulateDeletedPNF              ${MR_AAI_PNF_REMOVED}
+    Sleep                           31 seconds      Ensure AAI event on MR is picked up
+    ${resp}=                        GetMeasGrpCall    /subscription/subs_01/measurementGroups/msg_grp_01
+    Should Not Contain              ${resp.text}    pnf_newly_discovered
+
+Verify Create Subscription API for duplicate subscription Id
+    [Tags]                          PMSH_08
+    [Documentation]                 Verify Create Subscription API
+    [Timeout]                       60 seconds
+    ${json_value}=                  json_from_file                  ${CREATE_SUBSCRIPTION_DATA}
+    ${resp}=                        PostSubscriptionCall     ${SUBSCRIPTION_ENDPOINT}   ${json_value}
+    Should Be True                  ${resp.status_code} == 409
+    Should Contain                  ${resp.json()}      subscription Name: subs_01 already exists.
+
+Verify Create Subscription API for schema error
+    [Tags]                          PMSH_09
+    [Documentation]                 Verify Create Subscription API
+    [Timeout]                       60 seconds
+    ${json_value}=                  json_from_file                  ${CREATE_SUBSCRIPTION_SCHEMA_ERROR_DATA}
+    ${resp}=                        PostSubscriptionCall     ${SUBSCRIPTION_ENDPOINT}   ${json_value}
+    Should Be True                  ${resp.status_code} == 400
+    Should Contain                  ${resp.json()['detail']}      'administrativeState' is a required property - 'subscription.measurementGroups.0.measurementGroup'
+
+Verify Create Subscription API for filter values missing
+    [Tags]                          PMSH_10
+    [Documentation]                 Verify Create Subscription API
+    [Timeout]                       60 seconds
+    ${json_value}=                  json_from_file                  ${CREATE_SUBSCRIPTION_BAD_DATA}
+    ${resp}=                        PostSubscriptionCall     ${SUBSCRIPTION_ENDPOINT}   ${json_value}
+    Should Be True                  ${resp.status_code} == 400
+    Should Contain                  ${resp.json()}      At least one filter within nfFilter must not be empty
+
+Verify Get Measurement Group with Network Functions
+    [Tags]                          PMSH_11
+    [Documentation]                 Verify Get Measurement Group with Network Functions by using MGName and SubName
+    [Timeout]                       60 seconds
+    ${resp}=                        GetMeasGrpWithNFSCall     /subscription/subs_01/measurementGroups/msg_grp_01
+    ${nf_length}=                   Get length  ${resp.json()['networkFunctions']}
+    Should Be True                  ${resp.status_code} == 200
+    Should Be Equal As Strings      ${resp.json()['subscriptionName']}      subs_01
+    Should Be Equal As Strings      ${resp.json()['measurementGroupName']}      msg_grp_01
+    Should Be Equal As Strings      ${resp.json()['networkFunctions'][0]['nfName']}      pnf-existing
+    Should be equal as numbers      ${nf_length}  1
+
+Verify Get single subscription with Network Functions
+    [Tags]                          PMSH_12
+    [Documentation]                 Verify Get single subscription with Network Functions by using subscription name
+    [Timeout]                       60 seconds
+    ${resp}=                        GetSubsCall    ${SUBSCRIPTION_ENDPOINT}/subs_01  ""
+    ${nf_length}=                   Get length  ${resp.json()['subscription']['nfs']}
+    Should Be True                  ${resp.status_code} == 200
+    Should Be Equal As Strings      ${resp.json()['subscription']['subscriptionName']}      subs_01
+    Should Be Equal As Strings      ${resp.json()['subscription']['nfs'][0]}      pnf-existing
+       Should Be Equal As Strings      ${resp.json()['subscription']['measurementGroups'][0]['measurementGroup']['measurementGroupName']}  msg_grp_02
+    Should be equal as numbers      ${nf_length}  1
+
+Verify Get single subscription with Network Functions None
+    [Tags]                          PMSH_13
+    [Documentation]                 Verify Get single subscription with Network Functions when there is no defined subscription
+    [Timeout]                       60 seconds
+    ${resp}=                        GetSubsCall    ${SUBSCRIPTION_ENDPOINT}/sub_none  ""
+    Should Be True                  ${resp.status_code} == 404
+    Should Be Equal As Strings      ${resp.json()['error']}     Subscription was not defined with the name : sub_none
+
+Verify Get subscriptions with Network Functions
+    [Tags]                          PMSH_14
+    [Documentation]                 Verify Get all defined subscriptions with associated Network Functions
+    [Timeout]                       60 seconds
+    ${json_value}=                  json_from_file                  ${CREATE_SECOND_SUBSCRIPTION_DATA}
+    ${resp_post}=                   PostSubscriptionCall     ${SUBSCRIPTION_ENDPOINT}   ${json_value}
+    ${resp}=                        GetSubsCall    ${SUBSCRIPTION_ENDPOINT}  ""
+    ${nf_length_first}=             Get length  ${resp.json()[0]['subscription']['nfs']}
+    ${nf_length_second}=            Get length  ${resp.json()[1]['subscription']['nfs']}
+    Should Be True                  ${resp.status_code} == 200
+    Should Be Equal As Strings      ${resp.json()[0]['subscription']['subscriptionName']}      subs_01
+    Should Be Equal As Strings      ${resp.json()[0]['subscription']['nfs'][0]}      pnf-existing
+       Should Be Equal As Strings      ${resp.json()[0]['subscription']['measurementGroups'][0]['measurementGroup']['measurementGroupName']}  msg_grp_02
+    Should be equal as numbers      ${nf_length_first}  1
+    Should Be Equal As Strings      ${resp.json()[1]['subscription']['subscriptionName']}      subs_02
+    Should Be Equal As Strings      ${resp.json()[1]['subscription']['nfs'][0]}      pnf-existing
+       Should Be Equal As Strings      ${resp.json()[1]['subscription']['measurementGroups'][0]['measurementGroup']['measurementGroupName']}  msg_grp_04
+    Should be equal as numbers      ${nf_length_second}  1
+
 
 *** Keywords ***
-VerifyResponse
-    [Arguments]                     ${actual_response_value}         ${expected_response_value}
-    Should Be Equal As Strings      ${actual_response_value}         ${expected_response_value}
 
-VerifyResponseContains
-    [Arguments]                     ${response_content}             ${string_to_check_for}
-    Should Contain                  ${response_content}             ${string_to_check_for}
+SetAdministrativeStateToUnlocked
+    ${data}=            Get Data From File      ${CBS_EXPECTATION_ADMIN_STATE_UNLOCKED}
+    Create Session      cbs_sim_session   ${CBS_BASE_URL}    verify=false
+    ${resp}=            PUT On Session    cbs_sim_session    url=/clear  data={"path": "/service_component_all/.*"}
+    Should Be True      ${resp.status_code} == 200
+    Sleep               2                 Allow CBS time to set expectation
+    ${resp} =           PUT On Session    cbs_sim_session    url=/expectation     data=${data}
+    Should Be True      ${resp.status_code} == 201
+
+
+SimulatePolicyResponse
+    [Arguments]                     ${expected_contents}
+    ${json_value}=                  json_from_file                  ${expected_contents}
+    ${resp}=                                           PostMrCall                                  ${POLICY_PUBLISH_MR_TOPIC}     ${json_value}
+    log                                                ${resp.text}
+    Should Be Equal As Strings         ${resp.status_code}             200
+    ${count}=                          Evaluate                                        $resp.json().get('count')
+    log                                                        'JSON Response Code:'${resp}
+
+SimulateNewPNF
+    [Arguments]                     ${expected_contents}
+    ${json_value}=                  json_from_file                  ${expected_contents}
+    ${resp}=                                           PostMrCall                                      ${AAI_MR_TOPIC}      ${json_value}
+    log                                                ${resp.text}
+    Should Be Equal As Strings         ${resp.status_code}             200
+    ${count}=                          Evaluate                                        $resp.json().get('count')
+    log                                                        'JSON Response Code:'${resp}
+
+SimulateDeletedPNF
+    [Arguments]                     ${expected_contents}
+    ${json_value}=                  json_from_file                  ${expected_contents}
+    ${resp}=                                           PostMrCall                                      ${AAI_MR_TOPIC}      ${json_value}
+    log                                                ${resp.text}
+    Should Be Equal As Strings         ${resp.status_code}             200
+    ${count}=                          Evaluate                                        $resp.json().get('count')
+    log                                                        'JSON Response Code:'${resp}
+
+PostMrCall
+    [Arguments]     ${url}     ${data}
+    Create Session  mr_sim_session       ${MR_BASE_URL}    verify=false
+    ${headers}=     Create Dictionary    Accept=application/json     Content-Type=application/json
+    ${resp}=        POST On Session      mr_sim_session    url=${url}    json=${data}     headers=${headers}
+    [Return]        ${resp}
+
+GetSubsCall
+    [Arguments]     ${url}      ${url_path_param}
+    Create Session  pmsh_session      ${PMSH_BASE_URL}    verify=false
+    ${resp}=        GET On Session    pmsh_session        url=${url}    data={"path": {url_path_param}}    expected_status=any
+    [Return]        ${resp}
+
+GetMeasGrpCall
+    [Arguments]     ${url}
+    Create Session  pmsh_session      ${PMSH_BASE_URL}    verify=false
+    ${resp}=        GET On Session    pmsh_session        url=${url}
+    [Return]        ${resp}
+
+GetMeasGrpWithNFSCall
+    [Arguments]     ${url}
+    Create Session  pmsh_session      ${PMSH_BASE_URL}    verify=false
+    ${resp}=        GET On Session    pmsh_session        url=${url}
+    [Return]        ${resp}
+
+PostSubscriptionCall
+    [Arguments]     ${url}     ${data}
+    Create Session  pmsh_sub_session       ${PMSH_BASE_URL}    verify=false
+    ${headers}=     Create Dictionary    Accept=application/json     Content-Type=application/json
+    ${resp}=        POST On Session      pmsh_sub_session    url=${url}    json=${data}     headers=${headers}  expected_status=anything
+    [Return]        ${resp}