diff options
Diffstat (limited to 'cds-regression-test/cba/cba/py-executor')
6 files changed, 0 insertions, 273 deletions
diff --git a/cds-regression-test/cba/cba/py-executor/.DS_Store b/cds-regression-test/cba/cba/py-executor/.DS_Store Binary files differdeleted file mode 100644 index 5008ddf..0000000 --- a/cds-regression-test/cba/cba/py-executor/.DS_Store +++ /dev/null diff --git a/cds-regression-test/cba/cba/py-executor/Definitions/py-executor.json b/cds-regression-test/cba/cba/py-executor/Definitions/py-executor.json deleted file mode 100644 index b28162c..0000000 --- a/cds-regression-test/cba/cba/py-executor/Definitions/py-executor.json +++ /dev/null @@ -1,174 +0,0 @@ -{ - "metadata": { - "template_author": "Selffish", - "author-email": "test@bell.ca", - "template_name": "RT-py-executor", - "template_version": "1.0.0", - "template_tags": "Bell, CBA, test" - }, - "dsl_definitions": { - "py-executor": { - "type": "tls-auth", - "host": "cds-py-executor-py-exec", - "port": "50052", - "trustCertCollection": "/opt/app/onap/config/certs/py-executor/py-executor-chain.pem" - }, - "invalid-py-executor": { - "type": "tls-auth", - "host": "127.0.0.1", - "port": "12345", - "trustCertCollection": "/opt/app/onap/config/certs/py-executor/py-executor-chain.pem" - }, - "parameters": { - "hello": "world" - } - }, - "topology_template": { - "workflows": { - "remote-python": { - "steps": { - "execute-script": { - "description": "Execute Remote Python Script", - "target": "execute-remote-python" - } - }, - "inputs": {}, - "outputs": { - "status": { - "type": "string", - "value": { - "get_attribute": [ - "execute-remote-python", - "status" - ] - } - }, - "response-data": { - "type": "json", - "value": { - "get_attribute": [ - "execute-remote-python", - "response-data" - ] - } - } - } - }, - "connection-fail": { - "steps": { - "execute-script": { - "description": "Execute Remote Python Script to an invalid endpoint", - "target": "execute-connection-fail" - } - }, - "inputs": {}, - "outputs": { - "status": { - "type": "string", - "value": { - "get_attribute": [ - "execute-connection-fail", - "status" - ] - } - }, - "response-data": { - "type": "json", - "value": { - "get_attribute": [ - "execute-connection-fail", - "response-data" - ] - } - } - } - }, - "failing-remote-python": { - "steps": { - "execute-script": { - "description": "Execute Remote Python Script", - "target": "execute-failing-remote-python" - } - }, - "inputs": {}, - "outputs": { - "status": { - "type": "string", - "value": { - "get_attribute": [ - "execute-failing-remote-python", - "status" - ] - } - }, - "response-data": { - "type": "json", - "value": { - "get_attribute": [ - "execute-failing-remote-python", - "response-data" - ] - } - } - } - } - }, - "node_templates": { - "execute-remote-python": { - "type": "component-remote-script-executor", - "interfaces": { - "ComponentRemoteScriptExecutor": { - "operations": { - "process": { - "inputs": { - "selector": "*py-executor", - "blueprint-name": "RT-py-executor", - "blueprint-version": "1.0.0", - "blueprint-action": "HelloWorld", - "timeout": 1000, - "request-data": "*parameters" - } - } - } - } - } - }, - "execute-connection-fail": { - "type": "component-remote-script-executor", - "interfaces": { - "ComponentRemoteScriptExecutor": { - "operations": { - "process": { - "inputs": { - "selector": "*invalid-py-executor", - "blueprint-name": "RT-py-executor", - "blueprint-version": "1.0.0", - "blueprint-action": "HelloWorld", - "timeout": 1000 - } - } - } - } - } - }, - "execute-failing-remote-python": { - "type": "component-remote-script-executor", - "interfaces": { - "ComponentRemoteScriptExecutor": { - "operations": { - "process": { - "inputs": { - "selector": "*py-executor", - "blueprint-name": "RT-py-executor", - "blueprint-version": "1.0.0", - "blueprint-action": "FailingScript", - "timeout": 1000 - } - } - } - } - } - } - } - } -} diff --git a/cds-regression-test/cba/cba/py-executor/Scripts/python/__init__.py b/cds-regression-test/cba/cba/py-executor/Scripts/python/__init__.py deleted file mode 100644 index dcef3a9..0000000 --- a/cds-regression-test/cba/cba/py-executor/Scripts/python/__init__.py +++ /dev/null @@ -1,16 +0,0 @@ -# Copyright © 2018-2019 AT&T Intellectual Property. -# -# 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. - -from .hello_world import * -from .failing_script import * diff --git a/cds-regression-test/cba/cba/py-executor/Scripts/python/failing_script.py b/cds-regression-test/cba/cba/py-executor/Scripts/python/failing_script.py deleted file mode 100644 index 66efd3f..0000000 --- a/cds-regression-test/cba/cba/py-executor/Scripts/python/failing_script.py +++ /dev/null @@ -1,34 +0,0 @@ -#!/usr/bin/python -# -# Copyright © 2018-2019 AT&T Intellectual Property. -# -# 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. - -import logging -from blueprints_grpc import executor_utils -from blueprints_grpc.blueprint_processing_server import AbstractScriptFunction - - -class FailingScript(AbstractScriptFunction): - def __init__(self): - self.logger = logging.getLogger(self.__class__.__name__) - - def process(self, execution_request): - self.logger.info("Request Received in Script : {}".format(execution_request)) - raise RuntimeError('Script raised an exception') - - def recover(self): - return None - - def send_notification(self, execution_request): - yield executor_utils.send_notification(execution_request, "I am notification") diff --git a/cds-regression-test/cba/cba/py-executor/Scripts/python/hello_world.py b/cds-regression-test/cba/cba/py-executor/Scripts/python/hello_world.py deleted file mode 100644 index 1d308ee..0000000 --- a/cds-regression-test/cba/cba/py-executor/Scripts/python/hello_world.py +++ /dev/null @@ -1,41 +0,0 @@ -#!/usr/bin/python -# -# Copyright © 2018-2019 AT&T Intellectual Property. -# -# 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. - -import logging -from blueprints_grpc import executor_utils -from blueprints_grpc.blueprint_processing_server import AbstractScriptFunction -import json -from google.protobuf import json_format - -class HelloWorld(AbstractScriptFunction): - def __init__(self): - self.logger = logging.getLogger(self.__class__.__name__) - - def process(self, execution_request): - self.logger.info("Request Received in Script : {}".format(execution_request)) - - inputs = json_format.MessageToJson(execution_request.payload) - response_payload_json = json.loads(inputs) - - execution_response = executor_utils.success_response(execution_request, response_payload_json, 200) - self.logger.info("Response returned : {}".format(execution_response)) - yield execution_response - - def recover(self): - return None - - def send_notification(self, execution_request): - yield executor_utils.send_notification(execution_request, "I am notification") diff --git a/cds-regression-test/cba/cba/py-executor/TOSCA-Metadata/TOSCA.meta b/cds-regression-test/cba/cba/py-executor/TOSCA-Metadata/TOSCA.meta deleted file mode 100644 index 8389ebb..0000000 --- a/cds-regression-test/cba/cba/py-executor/TOSCA-Metadata/TOSCA.meta +++ /dev/null @@ -1,8 +0,0 @@ -TOSCA-Meta-File-Version: 1.0.0 -CSAR-Version: 1.0 -Created-By: Selffish -Entry-Definitions: Definitions/py-executor.json -Template-Tags: test, regression -Template-Name: RT-py-executor -Template-Version: 1.0.0 -Template-Type: DEFAULT |