aboutsummaryrefslogtreecommitdiffstats
path: root/components/scripts/python
diff options
context:
space:
mode:
authorAlexis de Talhouët <adetalhouet89@gmail.com>2019-03-26 09:49:13 -0400
committerAlexis de Talhouët <adetalhouet89@gmail.com>2019-03-26 09:49:13 -0400
commit72d22a4339db09824d46746dacbba1e141763dc0 (patch)
tree7fbfea4b81afca0bc0c95e5d4b810f236f4dea29 /components/scripts/python
parentef6983b670796becfa66c69075c1829e8f9aef4b (diff)
Migrate ccdsk/apps to ccsdk/cds
Change-Id: I020a2ccec4e691717f888e8bd2afec91a7c4e987 Issue-ID: CCSDK-1178 Signed-off-by: Alexis de Talhouët <adetalhouet89@gmail.com>
Diffstat (limited to 'components/scripts/python')
-rw-r--r--components/scripts/python/ccsdk_blueprints/__init__.py0
-rw-r--r--components/scripts/python/ccsdk_blueprints/abstract_blueprint_function.py15
-rw-r--r--components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py29
-rw-r--r--components/scripts/python/ccsdk_blueprints/blueprint_constants.py26
-rw-r--r--components/scripts/python/ccsdk_blueprints/blueprint_runtime_service.py21
-rw-r--r--components/scripts/python/ccsdk_blueprints/sample_blueprint_component.py18
-rw-r--r--components/scripts/python/ccsdk_blueprints/sample_ra_processor_function.py14
-rw-r--r--components/scripts/python/ccsdk_netconf/__init__.py0
-rw-r--r--components/scripts/python/ccsdk_netconf/common.py28
-rw-r--r--components/scripts/python/ccsdk_netconf/netconf_constant.py15
-rw-r--r--components/scripts/python/ccsdk_netconf/netconfclient.py62
11 files changed, 0 insertions, 228 deletions
diff --git a/components/scripts/python/ccsdk_blueprints/__init__.py b/components/scripts/python/ccsdk_blueprints/__init__.py
deleted file mode 100644
index e69de29b..00000000
--- a/components/scripts/python/ccsdk_blueprints/__init__.py
+++ /dev/null
diff --git a/components/scripts/python/ccsdk_blueprints/abstract_blueprint_function.py b/components/scripts/python/ccsdk_blueprints/abstract_blueprint_function.py
deleted file mode 100644
index 1ffa75d4..00000000
--- a/components/scripts/python/ccsdk_blueprints/abstract_blueprint_function.py
+++ /dev/null
@@ -1,15 +0,0 @@
-from org.onap.ccsdk.apps.blueprintsprocessor.services.execution import AbstractComponentFunction
-
-
-class AbstractPythonComponentFunction(AbstractComponentFunction):
-
- def __init__(self):
- AbstractComponentFunction.__init__(self)
-
- def process(self, execution_request):
- print "Processing calling from parent..."
- return None
-
- def recover(self, runtime_exception, execution_request):
- print "Recovering calling from parent..."
- return None
diff --git a/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py b/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py
deleted file mode 100644
index 6489b1e7..00000000
--- a/components/scripts/python/ccsdk_blueprints/abstract_ra_processor.py
+++ /dev/null
@@ -1,29 +0,0 @@
-from org.onap.ccsdk.apps.blueprintsprocessor.functions.resource.resolution.processor import \
- ResourceAssignmentProcessor
-from org.onap.ccsdk.apps.blueprintsprocessor.functions.resource.resolution.utils import \
- ResourceAssignmentUtils
-from org.onap.ccsdk.apps.controllerblueprints.core import \
- BluePrintProcessorException
-
-
-class AbstractRAProcessor(ResourceAssignmentProcessor):
-
- def process(self, resource_assignment):
- print "Processing.."
- return None
-
- def recover(self, runtime_exception, resource_assignment):
- print "Recovering.."
- return None
-
- def set_resource_data_value(self, resource_assignment, value):
- try:
- if value is not None:
- ResourceAssignmentUtils.Companion.setResourceDataValue(
- resource_assignment, self.raRuntimeService, value)
- else:
- ResourceAssignmentUtils.Companion.setFailedResourceDataValue(
- resource_assignment, "Fail to resolve value")
- except BluePrintProcessorException, err:
- raise BluePrintProcessorException(
- "Error on resource assignment. Message = " + err.message)
diff --git a/components/scripts/python/ccsdk_blueprints/blueprint_constants.py b/components/scripts/python/ccsdk_blueprints/blueprint_constants.py
deleted file mode 100644
index 50246773..00000000
--- a/components/scripts/python/ccsdk_blueprints/blueprint_constants.py
+++ /dev/null
@@ -1,26 +0,0 @@
-
-PROPERTY_BLUEPRINT_PROCESS_ID= "blueprint-process-id"
-PROPERTY_BLUEPRINT_BASE_PATH= "blueprint-basePath"
-PROPERTY_BLUEPRINT_RUNTIME= "blueprint-runtime"
-PROPERTY_BLUEPRINT_INPUTS_DATA= "blueprint-inputs-data"
-PROPERTY_BLUEPRINT_CONTEXT= "blueprint-context"
-PROPERTY_BLUEPRINT_NAME= "template_name"
-PROPERTY_BLUEPRINT_VERSION= "template_version"
-PROPERTY_BLUEPRINT_USER_SYSTEM= "System"
-PROPERTY_BLUEPRINT_STATUS_SUCCESS= "success"
-PROPERTY_BLUEPRINT_STATUS_FAILURE= "failure"
-
-METADATA_USER_GROUPS = "user-groups"
-METADATA_TEMPLATE_NAME = "template_name"
-METADATA_TEMPLATE_VERSION = "template_version"
-METADATA_TEMPLATE_AUTHOR = "template_author"
-METADATA_TEMPLATE_TAGS = "template_tags"
-METADATA_WORKFLOW_NAME = "workflow_name"
-
-PAYLOAD_DATA = "payload-data"
-PROPERTY_CURRENT_STEP = "current-step"
-PROPERTY_CURRENT_NODE_TEMPLATE = "current-node-template"
-PROPERTY_CURRENT_INTERFACE = "current-interface"
-PROPERTY_CURRENT_OPERATION = "current-operation"
-PROPERTY_CURRENT_IMPLEMENTATION = "current-implementation"
-PROPERTY_EXECUTION_REQUEST = "execution-request"
diff --git a/components/scripts/python/ccsdk_blueprints/blueprint_runtime_service.py b/components/scripts/python/ccsdk_blueprints/blueprint_runtime_service.py
deleted file mode 100644
index 7c7beff7..00000000
--- a/components/scripts/python/ccsdk_blueprints/blueprint_runtime_service.py
+++ /dev/null
@@ -1,21 +0,0 @@
-class BluePrintRuntimeService:
-
- def __init__(self, bps):
- self.bps = bps
-
- def resolveNodeTemplateArtifact(self, node_template_name, artifact_name):
- return self.bps.resolveNodeTemplateArtifact(node_template_name, artifact_name)
-
- def setNodeTemplateAttributeValue(self, nodeTemplateName, attributeName, value):
- return self.bps.setNodeTemplateAttributeValue(nodeTemplateName, attributeName, value)
-
- def setNodeTemplatePropertyValue(self, nodeTemplateName, propertyName, value):
- return self.bps.setNodeTemplatePropertyValue(nodeTemplateName, propertyName, value)
-
- def put_resolution_store(self, ra_name, value):
- self.bps.putResolutionStore(ra_name, value)
- return None
-
- def put_dictionary_store(self, ra_dictionary_name, value):
- self.bps.putResolutionStore(ra_dictionary_name, value)
- return None
diff --git a/components/scripts/python/ccsdk_blueprints/sample_blueprint_component.py b/components/scripts/python/ccsdk_blueprints/sample_blueprint_component.py
deleted file mode 100644
index a1e6c5d3..00000000
--- a/components/scripts/python/ccsdk_blueprints/sample_blueprint_component.py
+++ /dev/null
@@ -1,18 +0,0 @@
-from abstract_blueprint_function import AbstractPythonComponentFunction
-from blueprint_constants import *
-
-
-class SampleBlueprintComponent(AbstractPythonComponentFunction):
-
- def __init__(self):
- AbstractPythonComponentFunction.__init__(self)
-
- def process(self, execution_request):
- super(SamplePythonComponentNode, self).process(execution_request)
- print "Processing calling..." + PROPERTY_BLUEPRINT_BASE_PATH
- return None
-
- def recover(self, runtime_exception, execution_request):
- super(SamplePythonComponentNode, self).recover(runtime_exception, execution_request)
- print "Recovering calling..." + PROPERTY_BLUEPRINT_BASE_PATH
- return None
diff --git a/components/scripts/python/ccsdk_blueprints/sample_ra_processor_function.py b/components/scripts/python/ccsdk_blueprints/sample_ra_processor_function.py
deleted file mode 100644
index fa821082..00000000
--- a/components/scripts/python/ccsdk_blueprints/sample_ra_processor_function.py
+++ /dev/null
@@ -1,14 +0,0 @@
-from abstract_ra_processor import AbstractRAProcessor
-from blueprint_constants import *
-
-
-class SampleRAProcessorFunction(AbstractRAProcessor):
-
- def process(self, resource_assignment):
- print "Processing calling.." + PROPERTY_BLUEPRINT_BASE_PATH
- self.set_resource_data_value(resource_assignment, "")
- return None
-
- def recover(self, runtime_exception, resource_assignment):
- print "Recovering calling.." + PROPERTY_BLUEPRINT_BASE_PATH
- return None
diff --git a/components/scripts/python/ccsdk_netconf/__init__.py b/components/scripts/python/ccsdk_netconf/__init__.py
deleted file mode 100644
index e69de29b..00000000
--- a/components/scripts/python/ccsdk_netconf/__init__.py
+++ /dev/null
diff --git a/components/scripts/python/ccsdk_netconf/common.py b/components/scripts/python/ccsdk_netconf/common.py
deleted file mode 100644
index f161e29f..00000000
--- a/components/scripts/python/ccsdk_netconf/common.py
+++ /dev/null
@@ -1,28 +0,0 @@
-# Copyright (c) 2019 Bell Canada.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-class ResolutionHelper:
-
- def __init__(self, component_function):
- self.component_function = component_function
-
- def resolve_and_generate_message_from_template_prefix(self, artifact_prefix):
- return self.component_function.resolveAndGenerateMessage(artifact_prefix)
-
- def resolve_and_generate_message(self, artifact_mapping, artifact_template):
- return self.component_function.resolveAndGenerateMessage(artifact_mapping,
- artifact_template)
-
- def retrieve_resolved_template_from_database(self, key, artifact_template):
- return self.component_function.resolveFromDatabase(key, artifact_template)
diff --git a/components/scripts/python/ccsdk_netconf/netconf_constant.py b/components/scripts/python/ccsdk_netconf/netconf_constant.py
deleted file mode 100644
index 534ca9e1..00000000
--- a/components/scripts/python/ccsdk_netconf/netconf_constant.py
+++ /dev/null
@@ -1,15 +0,0 @@
-SERVICE_LOG = "log"
-SERVICE_NETCONF = "netconfService"
-SERVICE_MESSAGE = "messageService"
-
-PARAM_REQUEST_ID = "requestId"
-PARAM_ACTION = "action"
-
-STATUS_SUCCESS = "success"
-STATUS_FAILURE = "failure"
-
-CONFIG_TARGET_RUNNING = "running"
-CONFIG_TARGET_CANDIDATE = "candidate"
-CONFIG_DEFAULT_OPERATION_MERGE = "merge"
-CONFIG_DEFAULT_OPERATION_REPLACE = "replace"
-CONFIG_DEFAULT_OPERATION_NONE = "none"
diff --git a/components/scripts/python/ccsdk_netconf/netconfclient.py b/components/scripts/python/ccsdk_netconf/netconfclient.py
deleted file mode 100644
index e263ba8f..00000000
--- a/components/scripts/python/ccsdk_netconf/netconfclient.py
+++ /dev/null
@@ -1,62 +0,0 @@
-from netconf_constant import CONFIG_TARGET_RUNNING, CONFIG_TARGET_CANDIDATE, \
- CONFIG_DEFAULT_OPERATION_REPLACE
-
-
-class NetconfClient:
-
- def __init__(self, log, component_function, requirement_name):
- self.log = log
- self.component_function = component_function
- netconf_device = self.component_function.initializeNetconfConnection(
- requirement_name)
- self.netconf_rpc_client = netconf_device.netconfRpcService
- self.netconf_session = netconf_device.netconfSession
-
- def disconnect(self):
- self.netconf_session.disconnect()
- return
-
- def connect(self):
- self.netconf_session.connect()
- return
-
- def lock(self, config_target=CONFIG_TARGET_CANDIDATE):
- device_response = self.netconf_rpc_client.lock(config_target)
- return device_response
-
- def get_config(self, filter="", config_target=CONFIG_TARGET_RUNNING):
- device_response = self.netconf_rpc_client.getConfig(filter, config_target)
- return device_response
-
- def edit_config(self, message_content, config_target=CONFIG_TARGET_CANDIDATE,
- edit_default_peration=CONFIG_DEFAULT_OPERATION_REPLACE):
- device_response = self.netconf_rpc_client.editConfig(message_content,
- config_target,
- edit_default_peration)
- return device_response
-
- def commit(self, confirmed=False, confirm_timeout=60, persist="",
- persist_id=""):
- device_response = self.netconf_rpc_client.commit(confirmed, confirm_timeout,
- persist, persist_id)
- return device_response
-
- def invoke_rpc(self, rpc):
- device_response = self.netconf_rpc_client.invokeRpc(rpc)
- return device_response
-
- def cancel_commit(self, persist_id=""):
- device_response = self.netconf_rpc_client.cancelCommit(persist_id)
- return device_response
-
- def unlock(self, config_target=CONFIG_TARGET_CANDIDATE):
- device_response = self.netconf_rpc_client.unLock(config_target)
- return device_response
-
- def validate(self, config_target=CONFIG_TARGET_CANDIDATE):
- device_response = self.netconf_rpc_client.validate(config_target)
- return device_response
-
- def discard_change(self):
- device_response = self.netconf_rpc_client.discardConfig()
- return device_response