diff options
Diffstat (limited to 'cds-regression-test/cba/netconf/Scripts')
-rw-r--r-- | cds-regression-test/cba/netconf/Scripts/kotlin/kotlin.kt | 47 | ||||
-rw-r--r-- | cds-regression-test/cba/netconf/Scripts/python/NetconfTest.py | 53 |
2 files changed, 0 insertions, 100 deletions
diff --git a/cds-regression-test/cba/netconf/Scripts/kotlin/kotlin.kt b/cds-regression-test/cba/netconf/Scripts/kotlin/kotlin.kt deleted file mode 100644 index 956890a..0000000 --- a/cds-regression-test/cba/netconf/Scripts/kotlin/kotlin.kt +++ /dev/null @@ -1,47 +0,0 @@ -package org.onap.ccsdk.cds.blueprintsprocessor.functions.netconf.executor - -import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction -import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput -import org.onap.ccsdk.cds.blueprintsprocessor.functions.resource.resolution.storedContentFromResolvedArtifactNB -import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils -import org.slf4j.LoggerFactory - -open class ConfigDeploy : AbstractScriptComponentFunction() { - - private val log = LoggerFactory.getLogger(ConfigDeploy::class.java)!! - - override suspend fun processNB(executionRequest: ExecutionServiceInput) { - val device = netconfDevice("netconf-connection") - val client = device.netconfRpcService - val session = device.netconfSession - - val payload=""" - <configuration xmlns:junos="http://xml.juniper.net/junos/17.4R1/junos"> - <system xmlns="http://yang.juniper.net/junos-qfx/conf/system"> - <host-name operation="delete" /> - <host-name operation="create">Regression-Mock</host-name> - </system> - </configuration> - """ - - val response: MutableMap<String, Boolean> = mutableMapOf("deploySuccess" to false) - - try { - session.connect() - client.lock() - client.editConfig(payload) - client.commit() - client.unLock() - session.disconnect() - response["deploySuccess"] = true - } catch (e: Exception) { - e.message?.let { super.addError(it) } - } - - super.setAttribute("response-data", JacksonUtils.jsonNodeFromObject(response)) - } - - override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) { - log.info("Executing Recovery") - } -} diff --git a/cds-regression-test/cba/netconf/Scripts/python/NetconfTest.py b/cds-regression-test/cba/netconf/Scripts/python/NetconfTest.py deleted file mode 100644 index c52c8af..0000000 --- a/cds-regression-test/cba/netconf/Scripts/python/NetconfTest.py +++ /dev/null @@ -1,53 +0,0 @@ -# Copyright (c) 2019 IBM, 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. -import netconf_constant -from java.lang import Exception as JavaException -from netconfclient import NetconfClient -import json -from org.onap.ccsdk.cds.blueprintsprocessor.services.execution import AbstractScriptComponentFunction -from com.fasterxml.jackson.databind import ObjectMapper - -class NetconfTest(AbstractScriptComponentFunction): - - def process(self): - log = globals()[netconf_constant.SERVICE_LOG] - payload=""" - <configuration xmlns:junos="http://xml.juniper.net/junos/17.4R1/junos"> - <system xmlns="http://yang.juniper.net/junos-qfx/conf/system"> - <host-name operation="delete" /> - <host-name operation="create">Regression-Mock</host-name> - </system> - </configuration> - """ - responsePayload = '{"deploySuccess": false}' - - try: - nc = NetconfClient(log, self, "netconf-connection") - nc.connect() - nc.lock() - nc.edit_config(message_content=payload, config_target="candidate") - operationResponse = nc.commit() - nc.unlock() - nc.disconnect() - responsePayload = json.dumps({"deploySuccess": operationResponse.isSuccess()}) - except JavaException as err: - self.addError(err.message) - except Exception as err: - self.addError("Python error: {}".format(err)) - - self.setAttribute("response-data", ObjectMapper().readTree(responsePayload)) - return None - - def recover(self): - return None |