aboutsummaryrefslogtreecommitdiffstats
path: root/onap-client/onap_client
diff options
context:
space:
mode:
Diffstat (limited to 'onap-client/onap_client')
-rw-r--r--onap-client/onap_client/client/request.py2
-rw-r--r--onap-client/onap_client/engine.py10
-rw-r--r--onap-client/onap_client/sdc/catalog/service_catalog.py52
-rw-r--r--onap-client/onap_client/sdc/catalog/vnf_catalog.py133
-rw-r--r--onap-client/onap_client/sdc/catalog/vsp_catalog.py26
-rw-r--r--onap-client/onap_client/sdc/service.py75
-rw-r--r--onap-client/onap_client/sdc/vnf.py354
-rw-r--r--onap-client/onap_client/sdc/vsp.py36
8 files changed, 547 insertions, 141 deletions
diff --git a/onap-client/onap_client/client/request.py b/onap-client/onap_client/client/request.py
index 0e40591..0e1ce5c 100644
--- a/onap-client/onap_client/client/request.py
+++ b/onap-client/onap_client/client/request.py
@@ -96,6 +96,7 @@ class Request:
self.kwargs["headers"] = request_object.headers
if request_object.payload:
+ logger.info(self.kwargs.get("data"))
self.kwargs["data"] = request_object.payload
if request_object.files:
@@ -107,6 +108,7 @@ class Request:
try:
logger.info(json.dumps(debug_request, indent=4))
+ # logger.info(debug_request)
except TypeError:
logger.info(debug_request)
diff --git a/onap-client/onap_client/engine.py b/onap-client/onap_client/engine.py
index 7543783..a352163 100644
--- a/onap-client/onap_client/engine.py
+++ b/onap-client/onap_client/engine.py
@@ -70,7 +70,7 @@ def show_resource_spec(resource_name):
list_spec_resources()
-def load_spec(input_spec, validate_only=False):
+def load_spec(input_spec, validate_only=False, submit=True):
try:
with open(input_spec, "r") as f:
jdata = json.loads(f.read())
@@ -79,7 +79,7 @@ def load_spec(input_spec, validate_only=False):
raise
engine = SpecEngine()
- return engine.load_spec(jdata, validate_only=validate_only)
+ return engine.load_spec(jdata, validate_only=validate_only, distribute=submit)
def spec_cli(args):
@@ -102,6 +102,10 @@ def spec_cli(args):
)
parser.add_argument(
+ "--no-submit", action="store_false", required=False, default=True, help="Dont execute submit() for each resource in spec."
+ )
+
+ parser.add_argument(
"--list-spec-resources",
action="store_true",
required=False,
@@ -117,7 +121,7 @@ def spec_cli(args):
elif arguments.validate_spec:
print(json.dumps(load_spec(arguments.validate_spec, validate_only=True), indent=4))
elif arguments.load_spec:
- load_spec(arguments.load_spec)
+ load_spec(arguments.load_spec, submit=arguments.no_submit)
class SpecEngine:
diff --git a/onap-client/onap_client/sdc/catalog/service_catalog.py b/onap-client/onap_client/sdc/catalog/service_catalog.py
index 1d30725..eff2784 100644
--- a/onap-client/onap_client/sdc/catalog/service_catalog.py
+++ b/onap-client/onap_client/sdc/catalog/service_catalog.py
@@ -98,6 +98,29 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "CHECKOUT_CATALOG_SERVICE": {
+ "verb": "POST",
+ "description": "Creates a new version of a Service in the SDC catalog",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_service_id}/lifecycleState/CHECKOUT".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_SERVICES_PATH,
+ ),
+ "uri-parameters": ["catalog_service_id"],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "return_data": {"catalog_service_id": ("uniqueId",)},
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"ADD_RESOURCE_INSTANCE": {
"verb": "POST",
"description": "Attaches a Resource to a Service",
@@ -130,6 +153,32 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "UPDATE_RESOURCE_VERSION": {
+ "verb": "POST",
+ "description": "Updates a component version in a service",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_service_id}/resourceInstance/{component_name}/changeVersion".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_SERVICES_PATH,
+ ),
+ "uri-parameters": ["catalog_service_id", "component_name"],
+ "payload": "{}/update_resource_instance.jinja".format(PAYLOADS_DIR),
+ "payload-parameters": [
+ "component_id",
+ ],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"CHECKIN_SERVICE": {
"verb": "POST",
"description": "Checks a service into the SDC Catalog",
@@ -261,11 +310,12 @@ CATALOG_RESOURCES = {
),
"uri-parameters": ["catalog_service_id"],
"success_code": 200,
+ "header-parameters": ["X-TransactionId"],
"headers": {
"Accept": "application/json",
"Content-Type": "application/json",
"USER_ID": sdc_properties.SDC_OPS_USER_ID,
- "X-TransactionId": str(uuid.uuid4()),
+ # "X-TransactionId": str(uuid.uuid4()),
"X-FromAppId": application_id,
},
"auth": (
diff --git a/onap-client/onap_client/sdc/catalog/vnf_catalog.py b/onap-client/onap_client/sdc/catalog/vnf_catalog.py
index c4fd3da..cd08dad 100644
--- a/onap-client/onap_client/sdc/catalog/vnf_catalog.py
+++ b/onap-client/onap_client/sdc/catalog/vnf_catalog.py
@@ -142,6 +142,52 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "UPDATE_CATALOG_RESOURCE": {
+ "verb": "PUT",
+ "description": "Creates a new version of a VF resource",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_resource_id}".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_RESOURCES_PATH,
+ ),
+ "uri-parameters": ["catalog_resource_id"],
+ "success_code": 200,
+ "payload": "{}/generic_payload.jinja".format(PAYLOADS_DIR),
+ "payload-parameters": ["payload_data"],
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
+ "CHECKOUT_CATALOG_RESOURCE": {
+ "verb": "POST",
+ "description": "Checks out a VF from the catalog",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_resource_id}/lifecycleState/CHECKOUT".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_RESOURCES_PATH,
+ ),
+ "uri-parameters": ["catalog_resource_id"],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"ADD_CATALOG_RESOURCE_PROPERTY": {
"verb": "POST",
"description": "Adds an property value for a VNF",
@@ -174,6 +220,38 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "ADD_CATALOG_RESOURCE_PROPERTY_NON_VF": {
+ "verb": "POST",
+ "description": "Adds an property value for a VNF",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_resource_id}/resourceInstance/{catalog_resource_instance_id}/properties".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_RESOURCES_PATH,
+ ),
+ "payload": "{}/catalog_vnf_property.jinja".format(PAYLOADS_DIR),
+ "payload-parameters": [
+ "unique_id",
+ "parent_unique_id",
+ "owner_id",
+ "property_name",
+ "property_default_value",
+ "schema_type",
+ "property_type",
+ ],
+ "uri-parameters": ["catalog_resource_id", "catalog_resource_instance_id"],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"ADD_CATALOG_RESOURCE_POLICY": {
"verb": "POST",
"description": "Adds an policy resource to a VNF",
@@ -362,6 +440,39 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "ADD_RESOURCE_RELATIONSHIP": {
+ "verb": "POST",
+ "description": "Creates a relationship between two resources in a VF",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_resource_id}/resourceInstance/associate".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_RESOURCES_PATH,
+ ),
+ "uri-parameters": ["catalog_resource_id"],
+ "payload": "{}/add_resource_relationship.jinja".format(PAYLOADS_DIR),
+ "payload-parameters": [
+ "from_node_resource_id",
+ "to_node_resource_id",
+ "relationship_type",
+ "capability_name",
+ "capability_owner_id",
+ "capability_id",
+ "requirement_name",
+ "requirement_id",
+ ],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"GET_CATALOG_RESOURCE": {
"verb": "GET",
"description": "Gets a VNF in the SDC catalog",
@@ -385,6 +496,28 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "GET_CATALOG_RESOURCE_METADATA": {
+ "verb": "GET",
+ "description": "Gets metadata for a VNF in the SDC catalog",
+ "uri": partial(
+ "{endpoint}{service_path}/{catalog_resource_id}/filteredDataByParams?include=metadata".format,
+ endpoint=sdc_properties.SDC_BE_ENDPOINT,
+ service_path=sdc_properties.SDC_CATALOG_RESOURCES_PATH,
+ ),
+ "uri-parameters": ["catalog_resource_id"],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"GET_RESOURCES": {
"verb": "GET",
"description": "Get all resources in the SDC catalog",
diff --git a/onap-client/onap_client/sdc/catalog/vsp_catalog.py b/onap-client/onap_client/sdc/catalog/vsp_catalog.py
index 65781a6..574149e 100644
--- a/onap-client/onap_client/sdc/catalog/vsp_catalog.py
+++ b/onap-client/onap_client/sdc/catalog/vsp_catalog.py
@@ -95,6 +95,32 @@ CATALOG_RESOURCES = {
sdc_properties.GLOBAL_SDC_PASSWORD,
),
},
+ "UPDATE_SOFTWARE_PRODUCT": {
+ "verb": "POST",
+ "description": "Updates a VSP to a new version",
+ "uri": partial(
+ "{endpoint}{service_path}/{software_product_id}/versions/{software_product_version_id}".format,
+ endpoint=sdc_properties.SDC_BE_ONBOARD_ENDPOINT,
+ service_path=sdc_properties.SDC_VENDOR_ITEMS_PATH,
+ ),
+ "payload": "{}/software_product_update.jinja".format(PAYLOADS_DIR),
+ "payload-parameters": [
+ "description",
+ ],
+ "uri-parameters": ["software_product_id", "software_product_version_id"],
+ "success_code": 200,
+ "headers": {
+ "Accept": "application/json",
+ "Content-Type": "application/json",
+ "USER_ID": sdc_properties.SDC_DESIGNER_USER_ID,
+ "X-TransactionId": str(uuid.uuid4()),
+ "X-FromAppId": application_id,
+ },
+ "auth": (
+ sdc_properties.GLOBAL_SDC_USERNAME,
+ sdc_properties.GLOBAL_SDC_PASSWORD,
+ ),
+ },
"UPLOAD_HEAT_PACKAGE": {
"verb": "POST",
"description": "Uploads a heat zip to a VSP",
diff --git a/onap-client/onap_client/sdc/service.py b/onap-client/onap_client/sdc/service.py
index 4e3dd03..57ef646 100644
--- a/onap-client/onap_client/sdc/service.py
+++ b/onap-client/onap_client/sdc/service.py
@@ -47,6 +47,7 @@ from onap_client.util import utility
import time
import json
import random
+import uuid
service_client = SDCClient().sdc.service
sdc_properties = sdc.SDC_PROPERTIES
@@ -115,6 +116,7 @@ class Service(Resource):
"properties": {"type": dict, "required": False, "default": {}},
},
},
+ "allow_update": {"type": bool, "required": False, "default": False},
"wait_for_distribution": {"type": bool, "required": False, "default": False},
}
@@ -134,6 +136,7 @@ class Service(Resource):
naming_policy,
resources=[],
wait_for_distribution=False,
+ allow_update=False,
):
service_input = {}
@@ -158,6 +161,7 @@ class Service(Resource):
service_input["naming_policy"] = naming_policy
service_input["resources"] = resources
service_input["wait_for_distribution"] = wait_for_distribution
+ service_input["allow_update"] = allow_update
super().__init__(service_input)
@@ -165,8 +169,11 @@ class Service(Resource):
"""Creates a service object in SDC"""
service = None
- if get_service_id(service_input.get("service_name")) is None:
+ existing = get_service_id(service_input.get("service_name"))
+ if existing is None:
service = create_service(service_input)
+ elif service_input.get("allow_update"):
+ service = update_service(existing, service_input)
else:
raise exceptions.ResourceAlreadyExistsException(
"Service resource {} already exists".format(
@@ -237,8 +244,8 @@ class Service(Resource):
service_client.approve_service_certification(
**self.attributes, user_remarks="approved"
)
-
- service_client.distribute_sdc_service(**self.attributes)
+ headers = {"X-TransactionId": str(uuid.uuid4())}
+ service_client.distribute_sdc_service(**self.attributes, **headers)
if self.wait_for_distribution:
poll_distribution(self.service_name)
@@ -256,20 +263,29 @@ class Service(Resource):
"""
milli_timestamp = int(time.time() * 1000)
-
- resource_instance = service_client.add_resource_instance(
- **self.attributes,
- posX=random.randrange(150, 550), # nosec
- posY=random.randrange(150, 450), # nosec
- milli_timestamp=milli_timestamp,
- catalog_resource_id=catalog_resource_id,
- catalog_resource_name=catalog_resource_name,
- originType=origin_type,
- )
+ component_instances = self.tosca.get("componentInstances", [])
+ existing = False
+ if component_instances:
+ for component in component_instances:
+ if component.get("componentName") == catalog_resource_name:
+ existing = True
+ resource_instance = self.update_resource_instance_version(component)
+ break
+
+ if not existing:
+ resource_instance = service_client.add_resource_instance(
+ **self.attributes,
+ posX=random.randrange(150, 550), # nosec
+ posY=random.randrange(150, 450), # nosec
+ milli_timestamp=milli_timestamp,
+ catalog_resource_id=catalog_resource_id,
+ catalog_resource_name=catalog_resource_name,
+ originType=origin_type,
+ ).response_data
response = {
- "id": resource_instance.catalog_resource_instance_id,
- "tosca": resource_instance.response_data,
+ "id": resource_instance.get("uniqueId"),
+ "tosca": resource_instance,
}
self.attributes[catalog_resource_name] = response
@@ -325,6 +341,35 @@ class Service(Resource):
catalog_service_id=self.catalog_service_id
).response_data
+ def update_resource_instance_version(self, component):
+ resource_name = component.get("componentName")
+ resource_unique_id = component.get("uniqueId")
+ resource_id = component.get("componentUid")
+
+ vf_id = get_vnf_id(resource_name)
+
+ if vf_id != resource_id:
+ return service_client.update_resource_version(
+ catalog_service_id=self.catalog_service_id,
+ component_name=resource_unique_id,
+ component_id=vf_id
+ ).response_data
+ else:
+ return component
+
+
+def update_service(existing_service_id, service_input):
+ kwargs = service_input
+
+ service = service_client.checkout_catalog_service(catalog_service_id=existing_service_id).response_data
+
+ new_service_id = service.get("uniqueId")
+
+ kwargs["catalog_service_id"] = new_service_id
+ kwargs["tosca"] = service_client.get_sdc_service(catalog_service_id=new_service_id).response_data
+
+ return kwargs
+
def create_service(service_input):
"""Creates a service object in SDC
diff --git a/onap-client/onap_client/sdc/vnf.py b/onap-client/onap_client/sdc/vnf.py
index da8f213..5fa401c 100644
--- a/onap-client/onap_client/sdc/vnf.py
+++ b/onap-client/onap_client/sdc/vnf.py
@@ -43,6 +43,8 @@ from onap_client.sdc import vsp
from onap_client.util import utility
import time
+import random
+import json
vnf_client = SDCClient().sdc.vnf
@@ -66,6 +68,30 @@ class VNF(Resource):
"nested": {
"vm_type": {"type": str, "required": True},
"properties": {"type": dict, "required": True, "default": {}},
+ "resources": {
+ "type": list,
+ "list_item": dict,
+ "required": False,
+ "default": [],
+ "nested": {
+ "resource_name": {"type": str, "required": True},
+ "resource_id": {"type": str, "required": False},
+ "catalog_resource_name": {"type": str, "required": False},
+ "origin_type": {"type": str, "required": False, "default": "VF"},
+ "properties": {"type": dict, "required": False, "default": {}},
+ "relationship": {
+ "type": dict,
+ "required": False,
+ "default": {},
+ "nested": {
+ "relationship_type": {"type": str, "required": True},
+ "requirement": {"type": str, "required": True},
+ "requirement_id": {"type": str, "required": True},
+ "properties": {"type": dict, "required": False, "default": {}},
+ }
+ },
+ },
+ },
},
},
"network_roles": {
@@ -94,6 +120,7 @@ class VNF(Resource):
"properties": {"type": dict, "required": False, "default": {}},
},
},
+ "allow_update": {"type": bool, "required": False, "default": False},
}
def __init__(
@@ -105,6 +132,7 @@ class VNF(Resource):
vm_types=[],
network_roles=[],
policies=[],
+ allow_update=False,
):
vnf_input = {}
@@ -122,6 +150,7 @@ class VNF(Resource):
vnf_input["vm_types"] = vm_types
vnf_input["network_roles"] = network_roles
vnf_input["policies"] = policies
+ vnf_input["allow_update"] = allow_update
super().__init__(vnf_input)
@@ -129,8 +158,11 @@ class VNF(Resource):
"""Creates a vnf object in SDC"""
vnf = None
- if get_vnf_id(vnf_input.get("vnf_name")) is None:
+ existing = get_vnf_id(vnf_input.get("vnf_name"))
+ if not existing:
vnf = create_vnf(vnf_input)
+ elif vnf_input.get("allow_update"):
+ vnf = update_vnf(existing, vnf_input)
else:
raise exceptions.ResourceAlreadyExistsException(
"VNF resource {} already exists".format(vnf_input.get("vnf_name"))
@@ -149,39 +181,18 @@ class VNF(Resource):
for vm_type in vm_types:
vm_type_tag = vm_type.get("vm_type")
properties = vm_type.get("properties")
+ resources = vm_type.get("resources", [])
instance_ids = instance_ids_for_property(model, "vm_type_tag", vm_type_tag)
for instance_id in instance_ids:
- for k, v in properties.items():
- # updating vm_type properties
- self.add_instance_property(instance_id, k, v)
- vm_type_instances.append(instance_id)
- for network_role in network_roles:
- # checking if abstract node has matching network role,
- # and updating if found
- nrt = network_role.get("network_role_tag")
- nr = network_role.get("network_role")
- related_networks = network_role.get("related_networks")
- instance_property = network_role_property_for_instance(
- nrt, model, instance_id
- )
- if instance_property:
- self.add_instance_property(instance_id, instance_property, nr)
- if related_networks:
- property_val = [
- {"related_network_role": related_network_role}
- for related_network_role in related_networks
- ]
- rnr_instance_property = instance_property.replace(
- "_network_role", "_related_networks"
- )
- self.add_instance_property(
- instance_id,
- rnr_instance_property,
- str(property_val).replace("'", '\\"'),
- )
+ vm_type_instances.append(instance_id)
+ self._add_instance_properties(instance_id, properties)
+ self._add_resources(instance_id, resources)
+ self._add_vm_type_network_role(instance_id, network_roles)
for policy in policies:
policy_name = policy.get("policy_name")
+ if self.policy_exists(policy_name):
+ continue
policy_model = self.add_policy_resource(policy_name)
self.associate_policy(policy_model.catalog_resource_id, vm_type_instances)
for k, v in policy.get("properties", {}).items():
@@ -190,6 +201,115 @@ class VNF(Resource):
for k, v in inputs.items():
self.add_input_value(k, v)
+ def _add_instance_properties(self, instance_id, properties_dict):
+ for k, v in properties_dict.items():
+ # updating vm_type properties
+ self.add_instance_property(instance_id, k, v)
+
+ def _add_resources(self, instance_id, resources_dict):
+ for resource in resources_dict:
+ resource_name = resource.get("resource_name")
+
+ if self.resource_exists(resource_name):
+ continue
+
+ catalog_resource_name = resource.get("catalog_resource_name")
+ resource_id = resource.get("resource_id")
+ resource_origin = resource.get("origin_type")
+ resource_relationship = resource.get("relationship", {})
+
+ if not resource_id:
+ resource_id = get_vnf_id(catalog_resource_name)
+ if not resource_id:
+ raise exceptions.ResourceIDNotFoundException(
+ "resource ID was not passed, and resource lookup by name was not found {}".format(
+ resource_name
+ )
+ )
+ new_resource = add_resource(self.catalog_resource_id, resource_id, resource_name, origin_type=resource_origin)
+ new_resource_id = new_resource["id"]
+ if resource_relationship:
+ relationship_type = resource_relationship.get("relationship_type")
+ relationship_requirement = resource_relationship.get("requirement")
+ relationship_requirement_id = resource_relationship.get("requirement_id")
+ self.add_resource_relationship(new_resource_id, instance_id, relationship_type, relationship_requirement, relationship_requirement_id)
+ for k, v in resource_relationship.get("properties", {}).items():
+ self.add_instance_property_non_vf(new_resource_id, k, v, origin_section="componentInstancesProperties")
+
+ def add_resource_relationship(self, from_node, to_node, relationship_type, relationship_requirement, relationship_requirement_id):
+ components = self.tosca.get("componentInstances", [])
+ for component in components:
+ if component.get("uniqueId") == to_node:
+ capabilities = component.get("capabilities", {}).get(relationship_type, [])
+ for capability in capabilities:
+ capability_owner_id = capability.get("ownerId")
+ capability_name = capability.get("name")
+ capability_uid = capability.get("uniqueId")
+
+ return vnf_client.add_resource_relationship(
+ **self.attributes,
+ from_node_resource_id=from_node,
+ to_node_resource_id=to_node,
+ relationship_type=relationship_type,
+ capability_name=capability_name,
+ capability_owner_id=capability_owner_id,
+ capability_id=capability_uid,
+ requirement_name=relationship_requirement,
+ requirement_id=relationship_requirement_id,
+ )
+
+ def _add_vm_type_network_role(self, instance_id, network_roles_dict):
+ model = self.tosca
+ for network_role in network_roles_dict:
+ # checking if abstract node has matching network role,
+ # and updating if found
+ nrt = network_role.get("network_role_tag")
+ nr = network_role.get("network_role")
+ related_networks = network_role.get("related_networks")
+ instance_property = network_role_property_for_instance(
+ nrt, model, instance_id
+ )
+ if instance_property:
+ self.add_instance_property(instance_id, instance_property, nr)
+ if related_networks:
+ property_val = [
+ {"related_network_role": related_network_role}
+ for related_network_role in related_networks
+ ]
+ rnr_instance_property = instance_property.replace(
+ "_network_role", "_related_networks"
+ )
+ self.add_instance_property(
+ instance_id,
+ rnr_instance_property,
+ str(property_val).replace("'", '\\"'),
+ )
+
+ def resource_exists(self, resource_name):
+ """Checking the tosca model for a VF to see if a resource
+ has already been added"""
+
+ component_instances = self.tosca.get("componentInstances", [])
+
+ for component in component_instances:
+ if component.get("name") == resource_name:
+ return True
+
+ return False
+
+ def policy_exists(self, policy_name):
+ """Checking the tosca model for a VF to see if a resource
+ has already been added"""
+
+ policies = self.tosca.get("policies", {})
+
+ for p_name, policy in policies.items():
+ tosca_policy_name = policy.get("name").lower()
+ if tosca_policy_name.find("{}..{}".format(self.vnf_name.lower(), policy_name.lower())) != -1:
+ return True
+
+ return False
+
def _submit(self):
"""Submits the vnf in SDC"""
certification = vnf_client.certify_catalog_resource(
@@ -202,34 +322,6 @@ class VNF(Resource):
self.attributes["catalog_resource_name"] = vnf.catalog_resource_name
self.attributes["tosca"] = vnf.response_data
- def add_resource(
- self, catalog_resource_id, catalog_resource_name, origin_type="VF"
- ):
- """Attaches a resource to a VNF in SDC
-
- :catalog_resource_id: ID of a resource in the SDC catalog
- :catalog_resource_name: name to give to the resource when attaching to vnf
- :origin_type: specifies the origin of the attached resource
-
- """
- milli_timestamp = int(time.time() * 1000)
-
- resource_instance = vnf_client.add_resource_instance(
- **self.attributes,
- posX=306,
- posY=248,
- milli_timestamp=milli_timestamp,
- new_catalog_resource_id=catalog_resource_id,
- new_catalog_resource_name=catalog_resource_name,
- originType=origin_type,
- )
-
- response = {
- "id": resource_instance.catalog_resource_instance_id,
- "tosca": resource_instance.response_data,
- }
- self.attributes[catalog_resource_name] = response
-
def add_input_value(self, input_name, input_default_value):
"""Updates an input value on a VNF
@@ -262,7 +354,7 @@ class VNF(Resource):
# instance, policy, and group properties can probably be merged
# rn there is a lot of dup
- def add_instance_property(self, instance_id, property_name, property_value):
+ def add_instance_property(self, instance_id, property_name, property_value, origin_section="componentInstancesInputs"):
"""Updates an instance property on a abstract instance attached to a VNF
:instance_id: ID of a instance attached to a VNF
@@ -272,7 +364,7 @@ class VNF(Resource):
"""
self._refresh()
- instance_inputs = self.tosca.get("componentInstancesInputs", {}).get(
+ instance_inputs = self.tosca.get(origin_section, {}).get(
instance_id, {}
)
@@ -301,97 +393,82 @@ class VNF(Resource):
)
)
- def add_policy_property(self, policy_id, property_name, property_value):
- """Updates a policy property on a polic attached to a VNF
+ def add_instance_property_non_vf(self, instance_id, property_name, property_value, origin_section="componentInstancesProperties"):
+ """Updates an instance property on a abstract instance attached to a VNF
- :policy_id: ID of a policy attached to a VNF
+ :instance_id: ID of a instance attached to a VNF
:property_name: property name to update
:property_value: value to update property with
"""
self._refresh()
- policies = (
- self.tosca.get("policies", {}).get(policy_id, {}).get("properties", {})
+ instance_inputs = self.tosca.get(origin_section, {}).get(
+ instance_id, {}
)
- for prop in policies:
+ for prop in instance_inputs:
if prop.get("name") == property_name:
unique_id = prop.get("uniqueId")
+ parent_unique_id = prop.get("parentUniqueId")
+ owner_id = prop.get("ownerId")
+ schemaType = prop.get("schemaType", "")
property_type = prop.get("type")
- description = prop.get("description")
- return vnf_client.add_catalog_policy_property(
+ return vnf_client.add_catalog_resource_property_non_vf(
**self.attributes,
unique_id=unique_id,
- catalog_policy_id=policy_id,
+ parent_unique_id=parent_unique_id,
+ owner_id=owner_id,
+ catalog_resource_instance_id=instance_id,
property_name=property_name,
property_default_value=property_value,
- description=description,
+ schema_type=schemaType,
property_type=property_type,
)
raise exceptions.PropertyNotFoundException(
- "Property {} was not found in policy {}".format(property_name, policy_id)
+ "Property {} was not found in Instance {}".format(
+ property_name, instance_id
+ )
)
- def add_group_property(self, group_id, property_name, property_value):
- """Updates a group property on a group attached to a VNF
+ def add_policy_property(self, policy_id, property_name, property_value):
+ """Updates a policy property on a polic attached to a VNF
- :group_id: ID of a group attached to a VNF
+ :policy_id: ID of a policy attached to a VNF
:property_name: property name to update
:property_value: value to update property with
"""
self._refresh()
- groups = self.tosca.get("groups", [])
-
- for group in groups:
- if group.get("uniqueId") == group_id:
- properties = group.get("properties", [])
- for prop in properties:
- unique_id = prop.get("uniqueId")
- property_type = prop.get("type")
- description = prop.get("description")
- parent_unique_id = prop.get("parentUniqueId")
- owner_id = prop.get("ownerId")
- return vnf_client.add_catalog_group_property(
- **self.attributes,
- unique_id=unique_id,
- catalog_group_id=group_id,
- property_name=property_name,
- property_default_value=property_value,
- description=description,
- property_type=property_type,
- parent_unique_id=parent_unique_id,
- owner_id=owner_id,
- )
-
- raise exceptions.PropertyNotFoundException(
- "Property {} was not found in group {}".format(property_name, group_id)
+ policies = (
+ self.tosca.get("policies", {}).get(policy_id, {}).get("properties", {})
)
- def add_group_resource(self, group_name):
- """Adds an SDC group resource to a VNF
-
- :group_name: name of the group, matching onap-client.conf
-
- """
- sdc_properties = sdc.SDC_PROPERTIES
- group = sdc_properties.GROUPS.get(group_name)
- if not group:
- raise exceptions.UnknownGroupException(
- "Group {} was not found in configuration file".format(group_name)
- )
+ for prop in policies:
+ if prop.get("name") == property_name:
+ unique_id = prop.get("uniqueId")
+ property_type = prop.get("type")
+ description = prop.get("description")
+ return vnf_client.add_catalog_policy_property(
+ **self.attributes,
+ unique_id=unique_id,
+ catalog_policy_id=policy_id,
+ property_name=property_name,
+ property_default_value=property_value,
+ description=description,
+ property_type=property_type,
+ )
- return vnf_client.add_catalog_resource_group(
- **self.attributes, catalog_group_name=group
+ raise exceptions.PropertyNotFoundException(
+ "Property {} was not found in policy {}".format(property_name, policy_id)
)
def add_policy_resource(self, policy_name):
"""Adds an SDC policy resource to a VNF
- :group_name: name of the policy, matching onap-client.conf
+ :policy_name: name of the policy, matching onap-client.conf
"""
sdc_properties = sdc.SDC_PROPERTIES
@@ -417,18 +494,30 @@ class VNF(Resource):
**self.attributes, catalog_policy_id=policy_id, instance_ids=instance_ids
)
- def associate_group(self, group_id, instance_id):
- """associates an SDC group resource to an VNF instance resource"""
- return vnf_client.add_group_to_instance(
- **self.attributes, catalog_group_id=group_id, instance_id=instance_id
- )
-
def _refresh(self):
"""GETs the VNF model from SDC and updates the VNF object"""
vnf = vnf_client.get_catalog_resource(**self.attributes)
self.attributes["tosca"] = vnf.response_data
+def update_vnf(catalog_resource_id, vnf_input):
+ vnf = vnf_client.checkout_catalog_resource(catalog_resource_id=catalog_resource_id).response_data
+
+ new_vnf_metadata = vnf_client.get_catalog_resource_metadata(catalog_resource_id=vnf.get("uniqueId")).response_data.get("metadata", {})
+
+ csar_version = vsp.get_vsp_version_id(vnf.get("csarUUID"), search_key="name")
+
+ vnf["csarVersion"] = csar_version
+ vnf["componentMetadata"] = new_vnf_metadata
+
+ updated_vnf = vnf_client.update_catalog_resource(catalog_resource_id=vnf.get("uniqueId"), payload_data=json.dumps(vnf)).response_data
+
+ vnf_input["catalog_resource_id"] = updated_vnf.get("uniqueId")
+ vnf_input["tosca"] = updated_vnf
+
+ return vnf_input
+
+
def create_vnf(vnf_input):
"""Creates a vnf object in SDC
@@ -490,6 +579,33 @@ def network_role_property_for_instance(network_role_tag, vnf_model, instance_id)
return None
+def add_resource(parent_resource_id, catalog_resource_id, catalog_resource_name, origin_type="VF"):
+ """Attaches a resource to a VNF in SDC
+
+ :catalog_resource_id: ID of a resource in the SDC catalog
+ :catalog_resource_name: name to give to the resource when attaching to vnf
+ :origin_type: specifies the origin of the attached resource
+
+ """
+ milli_timestamp = int(time.time() * 1000)
+
+ resource_instance = vnf_client.add_resource_instance(
+ catalog_resource_id=parent_resource_id,
+ posX=random.randrange(150, 550), # nosec
+ posY=random.randrange(150, 450), # nosec
+ milli_timestamp=milli_timestamp,
+ new_catalog_resource_id=catalog_resource_id,
+ new_catalog_resource_name=catalog_resource_name,
+ originType=origin_type,
+ )
+
+ response = {
+ "id": resource_instance.catalog_resource_instance_id,
+ "tosca": resource_instance.response_data,
+ }
+ return response
+
+
@utility
def get_vnf(vnf_name):
"""Queries SDC for the TOSCA model for a VNF"""
diff --git a/onap-client/onap_client/sdc/vsp.py b/onap-client/onap_client/sdc/vsp.py
index fc9258b..7e99ece 100644
--- a/onap-client/onap_client/sdc/vsp.py
+++ b/onap-client/onap_client/sdc/vsp.py
@@ -70,6 +70,7 @@ class VSP(Resource):
"required": False,
"default": [],
},
+ "allow_update": {"type": bool, "required": False, "default": False},
}
def __init__(
@@ -83,6 +84,7 @@ class VSP(Resource):
category,
sub_category,
contributers=[],
+ allow_update=False,
):
vsp_input = {}
@@ -110,6 +112,7 @@ class VSP(Resource):
vsp_input["category"] = category.lower()
vsp_input["sub_category"] = sub_category.lower()
vsp_input["contributers"] = contributers
+ vsp_input["allow_update"] = allow_update
super().__init__(vsp_input)
@@ -117,8 +120,11 @@ class VSP(Resource):
"""Creates a vsp object in SDC"""
vsp = None
- if get_vsp_id(kwargs.get("software_product_name")) is None:
+ existing = get_vsp(kwargs.get("software_product_name"))
+ if not existing:
vsp = create_vsp(kwargs)
+ elif kwargs.get("allow_update"):
+ vsp = update_vsp(existing, kwargs)
else:
raise ResourceAlreadyExistsException(
"VSP resource {} already exists".format(
@@ -143,6 +149,28 @@ class VSP(Resource):
self.attributes["tosca"] = vsp.response_data
+def update_vsp(existing_vsp, vsp_input):
+ existing_vsp_id = existing_vsp.get("id")
+ existing_vsp_version_id = existing_vsp.get("version")
+
+ vsp_client.update_software_product(
+ software_product_id=existing_vsp_id,
+ software_product_version_id=existing_vsp_version_id,
+ description=vsp_input.get("description", "New VSP Version")
+ ).response_data
+
+ vsp_input["software_product_id"] = existing_vsp_id
+ vsp_input["software_product_version_id"] = get_vsp_version_id(existing_vsp_id)
+
+ vsp_client.upload_heat_package(**vsp_input)
+ vsp_client.validate_software_product(**vsp_input)
+
+ vsp = vsp_client.get_software_product(**vsp_input)
+ vsp_input["tosca"] = vsp.response_data
+
+ return vsp_input
+
+
def create_vsp(vsp_input):
"""Creates a VSP object in SDC
@@ -180,7 +208,7 @@ def get_vsp_id(vsp_name):
return None
-def get_vsp_version_id(vsp_id):
+def get_vsp_version_id(vsp_id, search_key="id"):
"""GETs vsp model version UUID from SDC
:vsp_id: uuid of vsp model in SDC
@@ -194,7 +222,7 @@ def get_vsp_version_id(vsp_id):
for version in results:
if version.get("creationTime", 0) > creation_time:
creation_time = version.get("creationTime")
- vsp_version_id = version.get("id")
+ vsp_version_id = version.get(search_key)
return vsp_version_id
@@ -209,5 +237,7 @@ def get_vsp_model(vsp_id, vsp_version_id):
def get_vsp(vsp_name):
"""Queries SDC for the tosca model for a VSP"""
vsp_id = get_vsp_id(vsp_name)
+ if vsp_id is None:
+ return None
vsp_version_id = get_vsp_version_id(vsp_id)
return get_vsp_model(vsp_id, vsp_version_id)