Add netconf script component function
authorMuthuramalingam, Brinda Santh <brindasanth@in.ibm.com>
Tue, 12 Feb 2019 20:26:19 +0000 (15:26 -0500)
committerMuthuramalingam, Brinda Santh <brindasanth@in.ibm.com>
Tue, 12 Feb 2019 20:26:19 +0000 (15:26 -0500)
Change-Id: I094025fba5626bae0b4b13320f1cbbb76cda3bfd
Issue-ID: CCSDK-790
Signed-off-by: Muthuramalingam, Brinda Santh <brindasanth@in.ibm.com>
components/model-catalog/blueprint-model/test-blueprint/baseconfiguration/Definitions/activation-blueprint.json
components/model-catalog/blueprint-model/test-blueprint/baseconfiguration/Scripts/python/DefaultGetNetConfig.py
components/scripts/python/ccsdk_netconf/netconfclient.py

index 5af64ca..637b589 100644 (file)
                 },
                 "inputs": {
                   "instance-dependencies": [
-                    "json-parser-service",
-                    "netconf-rpc-service"
+                    "json-parser-service"
                   ]
                 },
                 "outputs": {
                 },
                 "inputs": {
                   "instance-dependencies": [
-                    "json-parser-service",
-                    "netconf-rpc-service"
+                    "json-parser-service"
                   ]
                 },
                 "outputs": {
index e2f5655..c966b1a 100644 (file)
@@ -1,28 +1,21 @@
 import  netconf_constant
 from netconfclient import NetconfClient
 from java.lang import Exception
-from abstract_blueprint_function import AbstractPythonComponentFunction
-from org.onap.ccsdk.apps.blueprintsprocessor.functions.netconf.executor import NetconfRpcService
+from org.onap.ccsdk.apps.blueprintsprocessor.functions.netconf.executor import NetconfComponentFunction
 
+class DefaultGetNetConfig(NetconfComponentFunction):
 
-
-class DefaultGetNetConfig(AbstractPythonComponentFunction):
     def process(self, execution_request):
         try:
             log = globals()[netconf_constant.SERVICE_LOG]
             print(globals())
             #requestId = globals()[netconf_constant.PARAM_REQUEST_ID]
             requestId = '1234'
+            nc = NetconfClient(log, self)
 
-            bluePrintRuntimeService = globals()['bluePrintRuntimeService']
-
-            capabilityProperty = bluePrintRuntimeService.resolveNodeTemplateCapabilityProperties("sample-netconf-device","netconf")
-
-            log.info("capabilityProperty {}",capabilityProperty)
-            netconfService = NetconfRpcService()
-            nc = NetconfClient(log, netconfService)
+            # Create RPC Serivice
+            nc.createRPCServiceFromRequirement("netconf-connection")
 
-            nc.connect(netconfService.getNetconfDeviceInfo(capabilityProperty))
             runningConfigTemplate = "runningconfig-template"
 
             runningConfigMessageId = "get-config-" + requestId
@@ -38,7 +31,7 @@ class DefaultGetNetConfig(AbstractPythonComponentFunction):
                     errorMessage = "Get Running Config Failure ::"+ deviceResponse.errorMessage
 
         except Exception, err:
-            log.info("Exception in the script {}",err.getMessage())
+            log.error("Exception in the script {}",err.getMessage())
             status = netconf_constant.STATUS_FAILURE
             errorMessage = "Get Running Config Failure ::"+err.getMessage()
 
index 448e03d..421e500 100644 (file)
@@ -4,15 +4,19 @@ from netconf_constant import CONFIG_TARGET_RUNNING, CONFIG_DEFAULT_OPERATION_REP
 
 class NetconfClient:
 
-    def __init__(self, log, nc):
+    def __init__(self, log, componentFunction):
         self.log = log
-        self.nc = nc
+        self.componentFunction = componentFunction
+        self.nc = None
+
+    def createRPCServiceFromRequirement(self, requirementName):
+        self.nc = self.componentFunction.netconfRpcClientService(requirementName)
 
     def disconnect(self):
         self.nc.disconnect()
         return
 
-    def connect(self,deviceInfo):
+    def connect(self, deviceInfo):
         self.nc.connect(deviceInfo)
         return