robot/resources/heatbridge.robot

   1 *** Settings ***
   2 Library     HeatBridge
   3 Library     Collections
   4 Library     StringTemplater
   5 Library     OperatingSystem
   6 Library         ONAPLibrary.ServiceMapping
   7
   8 Resource    openstack/keystone_interface.robot
   9 Resource    openstack/heat_interface.robot
  10 Resource    openstack/nova_interface.robot
  11 Resource    openstack/neutron_interface.robot
  12 Resource    aai/aai_interface.robot
  13 Resource    aai/create_vnfc.robot
  14
  15 *** Variables ***
  16 ${MULTIPART_PATH}  /bulkadd
  17 ${NAMED_QUERY_PATH}  /aai/search/named-query
  18 ${NAMED_QUERY_TEMPLATE}    robot/assets/templates/aai/named_query.template
  19
  20 ${BASE_URI}   /cloud-infrastructure/cloud-regions/cloud-region/\${cloud}/\${region}
  21 ${IMAGE_URI}   ${BASE_URI}/images/image/\${image_id}
  22 ${FLAVOR_URI}   ${BASE_URI}/flavors/flavor/\${flavor}
  23 ${VSERVER_URI}   ${BASE_URI}/tenants/tenant/\${tenant}/vservers/vserver/\${vserver_id}
  24 ${L_INTERFACE_URI}   ${VSERVER_URI}/l-interfaces/l-interface/\${linterface_id}
  25 ${VSERVER_NAME}    \${vserver_name}
  26
  27 #******************** Test Case Variables ****************
  28 ${REVERSE_HEATBRIDGE}
  29
  30
  31 *** Keywords ***
  32 Execute Heatbridge
  33     [Documentation]   Run the Heatbridge against the stack to generate the bulkadd message
  34     ...    Execute the build add
  35     ...    Validate the add results by running the named query
  36     [Arguments]    ${stack_name}    ${service_instance_id}    ${service}    ${ipv4_oam_address}
  37     Return From Keyword If    '${service}' == 'vVG'
  38     Run Openstack Auth Request    auth
  39     ${stack_info}=    Wait for Stack to Be Deployed    auth    ${stack_name}
  40     ${stack_id}=    Get From Dictionary    ${stack_info}    id
  41     ${tenant_id}=   Get From Dictionary    ${stack_info}    OS::project_id
  42     ${vnf_id}=    Get From Dictionary    ${stack_info}    vnf_id
  43     ${KeyIsPresent}=    Run Keyword And Return Status       Dictionary Should Contain Key       ${stack_info}      ${ipv4_oam_address}
  44     ${ipv4_vnf_address}=   Run Keyword If      ${KeyIsPresent}     Get From Dictionary  ${stack_info}      ${ipv4_oam_address}
  45     Run Set VNF Params  ${vnf_id}  ${ipv4_vnf_address}  ACTIVE  Active
  46     ### Create a vnfc for each vServer ###
  47     ${stack_resources}=    Get Stack Resources    auth    ${stack_name}    ${stack_id}
  48     ${resource_list}=    Get From Dictionary    ${stack_resources}    resources
  49     :FOR   ${resource}    IN    @{resource_list}
  50     \    Run Keyword If    '${resource['resource_type']}' == 'OS::Nova::Server'    Run Create VNFC    auth    ${resource['physical_resource_id']}    ${service}
  51     ${keystone_api_version}=    Run Keyword If    '${GLOBAL_INJECTED_OPENSTACK_KEYSTONE_API_VERSION}'==''    Get KeystoneAPIVersion
  52     ...    ELSE    Set Variable   ${GLOBAL_INJECTED_OPENSTACK_KEYSTONE_API_VERSION}
  53     ${url}   ${path}=   Get Keystone Url And Path   ${keystone_api_version}
  54     ${openstack_identity_url}=    Catenate    ${url}${path}
  55     ${region}=   Get Openstack Region
  56     ${user}   ${pass}=   Get Openstack Credentials
  57     Run Keyword If   '${keystone_api_version}'=='v2.0'    Init Bridge    ${openstack_identity_url}    ${user}    ${pass}    ${tenant_id}    ${region}   ${GLOBAL_AAI_CLOUD_OWNER}
  58     ...    ELSE    Init Bridge    ${openstack_identity_url}    ${user}    ${pass}    ${tenant_id}    ${region}   ${GLOBAL_AAI_CLOUD_OWNER}    ${GLOBAL_INJECTED_OPENSTACK_DOMAIN_ID}    ${GLOBAL_INJECTED_OPENSTACK_PROJECT_NAME}
  59     ${request}=    Bridge Data    ${stack_id}
  60     Log    ${request}
  61     ${resp}=    Run A&AI Put Request    ${VERSIONED_INDEX_PATH}${MULTIPART_PATH}    ${request}
  62     ${status_string}=    Convert To String    ${resp.status_code}
  63     Should Match Regexp    ${status_string}     ^(201|200)$
  64     ${reverse_heatbridge}=   Generate Reverse Heatbridge From Stack Info   ${stack_info}
  65     Set Test Variable   ${REVERSE_HEATBRIDGE}   ${reverse_heatbridge}
  66     Run Validation Query    ${stack_info}    ${service}    ${vnf_id}
  67
  68 Run Create VNFC
  69     [Documentation]    Create a VNFC for a vServer
  70     [Arguments]    ${alias}     ${vserver_id}    ${service}
  71     ${resp}=    Get Openstack Server By Id   ${alias}     ${vserver_id}
  72     Return From Keyword If   '${resp.status_code}' != '200'
  73     ${info}=   Set Variable   ${resp.json()}
  74     ${keys}=    Create Dictionary
  75     Set To Dictionary   ${keys}   vserver_name=${info['server']['name']}
  76     ${vnfc_name}=   Template String    ${VSERVER_NAME}    ${keys}
  77     ${vnfc_nc}=    Set Variable  ${service}
  78     ${vnfc_func}=    Set Variable  ${service}
  79     Create VNFC If Not Exists    ${vnfc_name}     ${vnfc_nc}     ${vnfc_func}
  80
  81 Run Validation Query
  82     [Documentation]    Run A&AI query to validate the bulk add
  83     [Arguments]    ${stack_info}    ${service}    ${vnf_id}
  84     Return from Keyword If    '${service}' == ''
  85     Set Directory    default    ./demo/service_mapping
  86     ${payload}=  Run Get Generic VNF by VnfId       ${vnf_id}
  87     ${vnf_type}=    Catenate    ${payload.json()[vnf-type]}
  88     ${server_name_parameter}=    Get Validate Name Mapping    default    ${service}    ${vnf_type}
  89     ${vserver_name}=    Get From Dictionary    ${stack_info}   ${server_name_parameter}
  90     Run Vserver Query   ${vserver_name}
  91
  92 Run Vserver Query
  93     [Documentation]    Run A&AI query to validate the bulk add
  94     [Arguments]    ${vserver_name}
  95     ${dict}=    Create Dictionary    vserver_name=${vserver_name}
  96     ${request}=    OperatingSystem.Get File    ${NAMED_QUERY_TEMPLATE}
  97     ${request}=    Template String    ${request}    ${dict}
  98     ${resp}=    Run A&AI Post Request    ${NAMED_QUERY_PATH}    ${request}
  99     Should Be Equal As Strings    ${resp.status_code}    200
 100
 101
 102 Run Set VNF Params
 103     [Documentation]  Run A&A GET and PUT to set prov-status, orchestration status, and ipv4-oam-address
 104     [Arguments]   ${vnf_id}  ${ipv4_vnf_address}  ${prov_status}=ACTIVE  ${orch_status}=Active
 105     ${payload}=  Run Get Generic VNF by VnfId   ${vnf_id}
 106     ${vnf_type}=    Catenate    ${payload.json()[vnf-type]}
 107     #${payload_json}=    evaluate    json.loads('''${payload}''')    json
 108     set to dictionary    ${payload}    vnf-type    ${prov_status}
 109     set to dictionary    ${payload}    orchestration-status   ${orch_status}
 110     set to dictionary    ${payload}    ipv4-oam-address  ${ipv4_vnf_address}
 111     ${payload_string}=    evaluate    json.dumps(${payload})    json
 112
 113     ${put_resp}=    Run A&AI Put Request      ${VERSIONED_INDEX_PATH}/network/generic-vnfs/generic-vnf/${vnf_id}    ${payload_string}
 114     ${status_string}=    Convert To String    ${put_resp.status_code}
 115     Should Match Regexp    ${status_string}    ^(200|201)$
 116     Log To Console    Set VNF ProvStatus: ${vnf_id} to ${prov_status}
 117
 118 Run Get Generic VNF By VnfId
 119     [Documentation]  Get VNF GET Payload with resource ID
 120     [Arguments]   ${vnf_id}
 121     ${resp}=    Run A&AI Get Request      ${VERSIONED_INDEX_PATH}/network/generic-vnfs/generic-vnf?vnf-id=${vnf_id}
 122     Should Be Equal As Strings  ${resp.status_code}     200
 123     [Return]   ${resp.json()}
 124
 125 Execute Reverse Heatbridge
 126     [Documentation]   VID has already torn down the stack, reverse HB
 127     Return From Keyword If   len(${REVERSE_HEATBRIDGE}) == 0
 128     :FOR   ${uri}    IN   @{REVERSE_HEATBRIDGE}
 129     \    Run Keyword And Ignore Error    Delete A&AI Entity   ${uri}
 130
 131 Generate Reverse Heatbridge From Stack Name
 132     [Arguments]   ${stack_name}
 133     Run Openstack Auth Request    auth
 134     ${stack_info}=    Wait for Stack to Be Deployed    auth    ${stack_name}   timeout=10s
 135     ${reverse_heatbridge}=    Generate Reverse Heatbridge From Stack Info   ${stack_info}
 136     [Return]    ${reverse_heatbridge}
 137
 138 Generate Reverse Heatbridge From Stack Info
 139     [Arguments]   ${stack_info}
 140     ${reverse_heatbridge}=    Create List
 141     ${stack_name}=    Get From Dictionary    ${stack_info}    name
 142     ${stack_id}=    Get From Dictionary    ${stack_info}    id
 143     ${tenant_id}=   Get From Dictionary    ${stack_info}    OS::project_id
 144     ${region}=   Get Openstack Region
 145     ${keys}=    Create Dictionary   region=${region}   cloud=${GLOBAL_AAI_CLOUD_OWNER}   tenant=${tenant_id}
 146     ${stack_resources}=    Get Stack Resources    auth    ${stack_name}    ${stack_id}
 147     ${resource_list}=    Get From Dictionary    ${stack_resources}    resources
 148     :FOR   ${resource}    IN    @{resource_list}
 149     \    Log     ${resource}
 150     \    Run Keyword If    '${resource['resource_type']}' == 'OS::Neutron::Port'    Generate Linterface Uri    auth    ${resource['physical_resource_id']}   ${reverse_heatbridge}   ${keys}
 151     :FOR   ${resource}    IN    @{resource_list}
 152     \    Log     ${resource}
 153     \    Run Keyword If    '${resource['resource_type']}' == 'OS::Nova::Server'    Generate Vserver Uri    auth    ${resource['physical_resource_id']}  ${reverse_heatbridge}   ${keys}   ${resource_list}
 154     [Return]    ${reverse_heatbridge}
 155
 156 Generate Vserver Uri
 157     [Documentation]   Run teardown against the server to generate a message that removes it
 158     [Arguments]    ${alias}    ${port_id}   ${reverse_heatbridge}   ${keys}   ${resource_list}
 159     ${resp}=    Get Openstack Server By Id   ${alias}     ${port_id}
 160     Return From Keyword If   '${resp.status_code}' != '200'
 161     ${info}=   Set Variable   ${resp.json()}
 162     Set To Dictionary   ${keys}   vserver_id=${info['server']['id']}
 163     Set To Dictionary   ${keys}   flavor=${info['server']['flavor']['id']}
 164     Set To Dictionary   ${keys}   image_id=${info['server']['image']['id']}
 165     ${uri}=   Template String    ${VSERVER_URI}    ${keys}
 166     Append To List  ${reverse_heatbridge}   ${uri}
 167     ${uri}=   Template String    ${FLAVOR_URI}    ${keys}
 168     Append To List  ${reverse_heatbridge}   ${uri}
 169     ${uri}=   Template String    ${IMAGE_URI}    ${keys}
 170     Append To List  ${reverse_heatbridge}   ${uri}
 171
 172 Generate Linterface Uri
 173     [Documentation]   Run teardown against the server to generate a message that removes it
 174     [Arguments]    ${alias}    ${server_id}   ${reverse_heatbridge}   ${keys}
 175     ${resp}=    Get Openstack Port By Id   ${alias}     ${server_id}
 176     Return From Keyword If   '${resp.status_code}' != '200'
 177     ${info}=   Set Variable   ${resp.json()}
 178     Set To Dictionary   ${keys}   vserver_id=${info['port']['device_id']}
 179     Set To Dictionary   ${keys}   linterface_id=${info['port']['name']}
 180     ${uri}=   Template String    ${L_INTERFACE_URI}    ${keys}
 181     Append To List  ${reverse_heatbridge}   ${uri}
 182