*** Keywords ***
Run Consul Get Request
- [Documentation] Runs Consul Get Request
+ [Documentation] Runs Consul Tcagen2 Get Request
[Arguments] ${data_path}
${session}= Create Session consul ${CONSUL_ENDPOINT}
${headers}= Create Dictionary Accept=application/json Content-Type=application/json
${resp}= Get Request consul ${data_path} headers=${headers}
- Log Received response from policy ${resp.text}
+ Log Received response from tcagen2 ${resp.text}
Should Be Equal As Strings ${resp.status_code} 200
[Return] ${resp}
Run Consul Put Request
- [Documentation] Runs Consul Put request
+ [Documentation] Runs Consul Tcagen2 Put request
[Arguments] ${data_path} ${data}
${session}= Create Session consul ${CONSUL_ENDPOINT}
${headers}= Create Dictionary Accept=application/json Content-Type=application/json
[Arguments] ${resource_id}
${closedLoopControlName}= Set Variable ControlLoop-vFirewall-${resource_id}
Log Obtained closedLoopControlName ${closedLoopControlName}
- ${resp}= Run Consul Get Request /v1/kv/dcae-tca-analytics
+ ${resp}= Run Consul Get Request /v1/kv/dcae-tcagen2
Should Be Equal As Strings ${resp.status_code} 200
${base64Obj}= Set Variable ${resp.json()[0]["Value"]}
${binObj}= Evaluate base64.b64decode("${base64Obj}") modules=base64
${escaped}= Replace String ${binObj} \\ \\\\
${dict}= Evaluate json.loads('${escaped}') json
- ${tca_policy}= Set Variable ${dict['app_preferences']['tca_policy']}
+ ${tca_policy}= Set Variable ${dict['tca.policy']}
${mdf_tca_policy}= Replace String Using Regexp ${tca_policy} ControlLoop-vFirewall[^"]* ${closedLoopControlName}
- Set To Dictionary ${dict['app_preferences']} tca_policy=${mdf_tca_policy}
+ #Set To Dictionary ${dict['app_preferences']} tca_policy=${mdf_tca_policy}
+ Set To Dictionary ${dict} tca.policy=${mdf_tca_policy}
${json}= Evaluate json.dumps(${dict}) json
- ${resp}= Run Consul Put Request /v1/kv/dcae-tca-analytics data=${json}
+ ${resp}= Run Consul Put Request /v1/kv/dcae-tcagen2 data=${json}
Should Be Equal As Strings ${resp.status_code} 200
-
+++ /dev/null
-*** Settings ***
-Library HeatBridge
-Library Collections
-Library OperatingSystem
-Library ONAPLibrary.ServiceMapping WITH NAME ServiceMapping
-Library ONAPLibrary.Templating WITH NAME Templating
-Library ONAPLibrary.AAI WITH NAME AAI
-
-
-Resource openstack/keystone_interface.robot
-Resource openstack/heat_interface.robot
-Resource openstack/nova_interface.robot
-Resource openstack/neutron_interface.robot
-Resource aai/aai_interface.robot
-Resource aai/create_vnfc.robot
-
-*** Variables ***
-${MULTIPART_PATH} /bulkadd
-${NAMED_QUERY_PATH} /aai/search/named-query
-${NAMED_QUERY_TEMPLATE} aai/named_query.jinja
-
-${BASE_URI} /cloud-infrastructure/cloud-regions/cloud-region/\${cloud}/\${region}
-${IMAGE_URI} ${BASE_URI}/images/image/\${image_id}
-${FLAVOR_URI} ${BASE_URI}/flavors/flavor/\${flavor}
-${VSERVER_URI} ${BASE_URI}/tenants/tenant/\${tenant}/vservers/vserver/\${vserver_id}
-${L_INTERFACE_URI} ${VSERVER_URI}/l-interfaces/l-interface/\${linterface_id}
-
-*** Keywords ***
-Execute Heatbridge
- [Documentation] Run the Heatbridge against the stack to generate the bulkadd message
- ... Execute the build add
- ... Validate the add results by running the named query
- [Arguments] ${stack_name} ${vnf} ${service} ${ipv4_oam_address}
- Return From Keyword If '${service}' == 'vVG'
- Run Openstack Auth Request auth
- ${stack_info}= Wait for Stack to Be Deployed auth ${stack_name}
- ${stack_id}= Get From Dictionary ${stack_info} id
- ${tenant_id}= Get From Dictionary ${stack_info} OS::project_id
- ${vnf_id}= Get From Dictionary ${stack_info} vnf_id
- ${KeyIsPresent}= Run Keyword And Return Status Dictionary Should Contain Key ${stack_info} ${ipv4_oam_address}
- ${ipv4_vnf_address}= Run Keyword If ${KeyIsPresent} Get From Dictionary ${stack_info} ${ipv4_oam_address}
- Run Set VNF Params ${vnf_id} ${ipv4_vnf_address} ACTIVE Active
- ### Create a vnfc for each vServer ###
- ${stack_resources}= Get Stack Resources auth ${stack_name} ${stack_id}
- ${resource_list}= Get From Dictionary ${stack_resources} resources
- :FOR ${resource} IN @{resource_list}
- \ Run Keyword If '${resource['resource_type']}' == 'OS::Nova::Server' Run Create VNFC auth ${resource['physical_resource_id']} ${service}
- ${keystone_api_version}= Run Keyword If '${GLOBAL_INJECTED_OPENSTACK_KEYSTONE_API_VERSION}'=='' Get KeystoneAPIVersion
- ... ELSE Set Variable ${GLOBAL_INJECTED_OPENSTACK_KEYSTONE_API_VERSION}
- ${url} ${path}= Get Keystone Url And Path ${keystone_api_version}
- ${openstack_identity_url}= Catenate ${url}${path}
- ${region}= Get Openstack Region
- ${user} ${pass}= Get Openstack Credentials
- Run Keyword If '${keystone_api_version}'=='v2.0' Init Bridge ${openstack_identity_url} ${user} ${pass} ${tenant_id} ${region} ${GLOBAL_AAI_CLOUD_OWNER}
- ... 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}
- ${request}= Bridge Data ${stack_id}
- Log ${request}
- ${resp}= AAI.Run Put Request ${AAI_FRONTEND_ENDPOINT} ${VERSIONED_INDEX_PATH}${MULTIPART_PATH} ${request} auth=${GLOBAL_AAI_AUTHENTICATION}
- ${status_string}= Convert To String ${resp.status_code}
- Should Match Regexp ${status_string} ^(201|200)$
- ${reverse_heatbridge}= Generate Reverse Heatbridge From Stack Info ${stack_info}
- Run Validation Query ${stack_info} ${service} ${vnf}
- [Return] ${reverse_heatbridge}
-
-Run Create VNFC
- [Documentation] Create a VNFC for a vServer
- [Arguments] ${alias} ${vserver_id} ${service}
- ${resp}= Get Openstack Server By Id ${alias} ${vserver_id}
- Return From Keyword If '${resp.status_code}' != '200'
- ${info}= Set Variable ${resp.json()}
- ${keys}= Create Dictionary
- ${vnfc_name}= Catenate ${info['server']['name']}
- ${vnfc_nc}= Set Variable ${service}
- ${vnfc_func}= Set Variable ${service}
- Create VNFC If Not Exists ${vnfc_name} ${vnfc_nc} ${vnfc_func}
-
-Run Validation Query
- [Documentation] Run A&AI query to validate the bulk add
- [Arguments] ${stack_info} ${service} ${vnf}
- Return from Keyword If '${service}' == ''
- ServiceMapping.Set Directory default ${GLOBAL_SERVICE_MAPPING_DIRECTORY}
- ${server_name_parameter}= ServiceMapping.Get Validate Name Mapping default ${service} ${vnf}
- ${vserver_name}= Get From Dictionary ${stack_info} ${server_name_parameter}
- Run Vserver Query ${vserver_name}
-
-Run Vserver Query
- [Documentation] Run A&AI query to validate the bulk add
- [Arguments] ${vserver_name}
- ${dict}= Create Dictionary vserver_name=${vserver_name}
- Templating.Create Environment aai ${GLOBAL_TEMPLATE_FOLDER}
- ${request}= Templating.Apply Template aai ${NAMED_QUERY_TEMPLATE} ${dict}
- ${resp}= AAI.Run Post Request ${AAI_FRONTEND_ENDPOINT} ${NAMED_QUERY_PATH} ${request} auth=${GLOBAL_AAI_AUTHENTICATION}
- Should Be Equal As Strings ${resp.status_code} 200
-
-Run Set VNF Params
- [Documentation] Run A&A GET and PUT to set prov-status, orchestration status, and ipv4-oam-address
- [Arguments] ${vnf_id} ${ipv4_vnf_address} ${prov_status}=ACTIVE ${orch_status}=Active
- ${payload}= Run Get Generic VNF by VnfId ${vnf_id}
- ${vnf_type}= Catenate ${payload['vnf-type']}
- set to dictionary ${payload} prov-status ${prov_status}
- set to dictionary ${payload} orchestration-status ${orch_status}
- set to dictionary ${payload} ipv4-oam-address ${ipv4_vnf_address}
- ${payload_string}= evaluate json.dumps(${payload}) json
- ${put_resp}= AAI.Run Put Request ${AAI_FRONTEND_ENDPOINT} ${VERSIONED_INDEX_PATH}/network/generic-vnfs/generic-vnf/${vnf_id} ${payload_string} auth=${GLOBAL_AAI_AUTHENTICATION}
- ${status_string}= Convert To String ${put_resp.status_code}
- Should Match Regexp ${status_string} ^(200|201)$
- Log Set VNF ProvStatus: ${vnf_id} to ${prov_status}
-
-Run Get Generic VNF By VnfId
- [Documentation] Get VNF GET Payload with resource ID
- [Arguments] ${vnf_id}
- ${resp}= AAI.Run Get Request ${AAI_FRONTEND_ENDPOINT} ${VERSIONED_INDEX_PATH}/network/generic-vnfs/generic-vnf?vnf-id=${vnf_id} auth=${GLOBAL_AAI_AUTHENTICATION}
- Should Be Equal As Strings ${resp.status_code} 200
- [Return] ${resp.json()}
-
-Execute Reverse Heatbridge
- [Documentation] VID has already torn down the stack, reverse HB
- [Arguments] ${uris_to_delete}
- Return From Keyword If len(${uris_to_delete}) == 0
- :FOR ${uri} IN @{uris_to_delete}
- \ Run Keyword And Ignore Error Delete A&AI Entity ${uri}
-
-Generate Reverse Heatbridge From Stack Name
- [Arguments] ${stack_name}
- Run Openstack Auth Request auth
- ${stack_info}= Wait for Stack to Be Deployed auth ${stack_name} timeout=10s
- ${reverse_heatbridge}= Generate Reverse Heatbridge From Stack Info ${stack_info}
- [Return] ${reverse_heatbridge}
-
-Generate Reverse Heatbridge From Stack Info
- [Arguments] ${stack_info}
- ${reverse_heatbridge}= Create List
- ${stack_name}= Get From Dictionary ${stack_info} name
- ${stack_id}= Get From Dictionary ${stack_info} id
- ${tenant_id}= Get From Dictionary ${stack_info} OS::project_id
- ${region}= Get Openstack Region
- ${keys}= Create Dictionary region=${region} cloud=${GLOBAL_AAI_CLOUD_OWNER} tenant=${tenant_id}
- ${stack_resources}= Get Stack Resources auth ${stack_name} ${stack_id}
- ${resource_list}= Get From Dictionary ${stack_resources} resources
- :FOR ${resource} IN @{resource_list}
- \ Log ${resource}
- \ Run Keyword If '${resource['resource_type']}' == 'OS::Neutron::Port' Generate Linterface Uri auth ${resource['physical_resource_id']} ${reverse_heatbridge} ${keys}
- :FOR ${resource} IN @{resource_list}
- \ Log ${resource}
- \ Run Keyword If '${resource['resource_type']}' == 'OS::Nova::Server' Generate Vserver Uri auth ${resource['physical_resource_id']} ${reverse_heatbridge} ${keys} ${resource_list}
- [Return] ${reverse_heatbridge}
-
-Generate Vserver Uri
- [Documentation] Run teardown against the server to generate a message that removes it
- [Arguments] ${alias} ${port_id} ${reverse_heatbridge} ${keys} ${resource_list}
- ${resp}= Get Openstack Server By Id ${alias} ${port_id}
- Return From Keyword If '${resp.status_code}' != '200'
- ${info}= Set Variable ${resp.json()}
- Set To Dictionary ${keys} vserver_id=${info['server']['id']}
- Set To Dictionary ${keys} flavor=${info['server']['flavor']['id']}
- Set To Dictionary ${keys} image_id=${info['server']['image']['id']}
- ${uri}= Templating.Template String ${VSERVER_URI} ${keys}
- Append To List ${reverse_heatbridge} ${uri}
- ${uri}= Templating.Template String ${FLAVOR_URI} ${keys}
- Append To List ${reverse_heatbridge} ${uri}
- ${uri}= Templating.Template String ${IMAGE_URI} ${keys}
- Append To List ${reverse_heatbridge} ${uri}
-
-Generate Linterface Uri
- [Documentation] Run teardown against the server to generate a message that removes it
- [Arguments] ${alias} ${server_id} ${reverse_heatbridge} ${keys}
- ${resp}= Get Openstack Port By Id ${alias} ${server_id}
- Return From Keyword If '${resp.status_code}' != '200'
- ${info}= Set Variable ${resp.json()}
- Set To Dictionary ${keys} vserver_id=${info['port']['device_id']}
- Set To Dictionary ${keys} linterface_id=${info['port']['name']}
- ${uri}= Templating.Template String ${L_INTERFACE_URI} ${keys}
- Append To List ${reverse_heatbridge} ${uri}
-
Code Review / testsuite.git / commitdiff