Merge "cds-bash script package"

6 files changed, 353 insertions, 0 deletions

diff --git a/cds-regression-test/cba/cli/elalto/Definitions/cli.json b/cds-regression-test/cba/cli/elalto/Definitions/cli.json
new file mode 100644
index 0000000..722663e
--- /dev/null
+++ b/cds-regression-test/cba/cli/elalto/Definitions/cli.json
@@ -0,0 +1,106 @@
+{
+  "metadata": {
+    "template_author": "Selffish",
+    "author-email": "test@bell.ca",
+    "template_name": "RT-cli",
+    "template_version": "1.0.0",
+    "template_tags": "test, regression"
+  },
+  "dsl_definitions": {
+    "device-properties": {
+      "type": "basic-auth",
+      "host": {
+        "get_input": "host"
+      },
+      "username": {
+        "get_input": "username"
+      },
+      "password": {
+        "get_input": "password"
+      },
+      "port": {
+        "get_input": "port"
+      },
+      "connectionTimeOut": {
+        "get_input": "connectionTimeOut"
+      }
+    }
+  },
+  "topology_template": {
+    "workflows": {
+      "cli": {
+        "steps": {
+          "cli": {
+            "description": "CLI Workflow",
+            "target": "cli"
+          }
+        },
+        "inputs": {
+          "resolution-key": {
+            "required": false,
+            "type": "string"
+          },
+          "password": {
+            "required": true,
+            "type": "string"
+          },
+          "username": {
+            "required": true,
+            "type": "string"
+          },
+          "host": {
+            "required": true,
+            "type": "string"
+          },
+          "port": {
+            "required": false,
+            "type": "string"
+          },
+          "connectionTimeOut": {
+            "required": true,
+            "type": "string"
+          },
+          "commands": {
+            "required": true,
+            "type": "list",
+            "entry_schema": {
+              "type": "string"
+            }
+          }
+        },
+        "outputs": {
+          "response-data": {
+            "type": "string",
+            "value": {
+              "get_attribute": [
+                "cli",
+                "response-data"
+              ]
+            }
+          }
+        }
+      }
+    },
+    "node_templates": {
+      "cli": {
+        "type": "component-script-executor",
+        "interfaces": {
+          "ComponentScriptExecutor": {
+            "operations": {
+              "process": {
+                "implementation": {
+                  "primary": "component-script"
+                },
+                "inputs": {
+                  "script-type": "kotlin",
+                  "script-class-reference": "cli.CliRegressionTest"
+                },
+                "outputs": {}
+              }
+            }
+          }
+        }
+      }
+    }
+  }
+}
diff --git a/cds-regression-test/cba/cli/elalto/Scripts/kotlin/cli/cli.kt b/cds-regression-test/cba/cli/elalto/Scripts/kotlin/cli/cli.kt
new file mode 100755
index 0000000..12786c8
--- /dev/null
+++ b/cds-regression-test/cba/cli/elalto/Scripts/kotlin/cli/cli.kt
@@ -0,0 +1,59 @@
+/*

+ *  Copyright © 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.

+ */

+

+package cli

+

+import org.onap.ccsdk.cds.controllerblueprints.core.logger

+import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput

+import org.onap.ccsdk.cds.blueprintsprocessor.functions.cli.executor.cliDeviceInfo

+import org.onap.ccsdk.cds.blueprintsprocessor.functions.cli.executor.getSshClientService

+import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction

+import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.ComponentScriptExecutor

+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive

+import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils

+

+

+open class CliRegressionTest : AbstractScriptComponentFunction() {

+

+    private val log = logger(CliRegressionTest::class)

+

+    override suspend fun processNB(executionRequest: ExecutionServiceInput) {

+        // Get Client Service

+        val sshClientService = getSshClientService(cliDeviceInfo("device-properties"))

+		sshClientService.startSession()

+ 		

+        // Read Commands

+        val timeout = bluePrintRuntimeService.getInputValue("connectionTimeOut").asText()

+        val commands = bluePrintRuntimeService.getInputValue("commands")

+            .let { JacksonUtils.getListFromJsonNode(it, String::class.java) }

+

+        // Execute

+        var responsesLog = "Error"

+        try {

+            responsesLog = sshClientService.executeCommands(commands, timeout.toLong())

+            log.info(responsesLog)

+        } catch (e: Exception) {

+            e.message?.let { addError(it) }

+        } finally {

+            setAttribute(ComponentScriptExecutor.ATTRIBUTE_RESPONSE_DATA, responsesLog.asJsonPrimitive())

+            sshClientService.closeSession()

+        }

+    }

+

+    override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) {

+        log.info("Executing Recovery")

+    }

+}
\ No newline at end of file
diff --git a/cds-regression-test/cba/cli/elalto/TOSCA-Metadata/TOSCA.meta b/cds-regression-test/cba/cli/elalto/TOSCA-Metadata/TOSCA.meta
new file mode 100755
index 0000000..7bb2d45
--- /dev/null
+++ b/cds-regression-test/cba/cli/elalto/TOSCA-Metadata/TOSCA.meta
@@ -0,0 +1,8 @@
+TOSCA-Meta-File-Version: 1.0.0
+CSAR-Version: 1.0
+Created-By: Selffish
+Entry-Definitions: Definitions/cli.json
+Template-Tags: test, regression
+Template-Name: RT-cli
+Template-Version: 1.0.0
+Template-Type: DEFAULT
\ No newline at end of file
diff --git a/cds-regression-test/cba/cli/frankfurt/Definitions/cli.json b/cds-regression-test/cba/cli/frankfurt/Definitions/cli.json
new file mode 100644
index 0000000..c0070da
--- /dev/null
+++ b/cds-regression-test/cba/cli/frankfurt/Definitions/cli.json
@@ -0,0 +1,113 @@
+{
+  "metadata": {
+    "template_author": "Selffish",
+    "author-email": "test@bell.ca",
+    "template_name": "RT-cli",
+    "template_version": "1.0.0",
+    "template_tags": "test, regression"
+  },
+  "dsl_definitions": {
+    "device-properties": {
+      "type": "basic-auth",
+      "host": {
+        "get_input": "host"
+      },
+      "username": {
+        "get_input": "username"
+      },
+      "password": {
+        "get_input": "password"
+      },
+      "port": {
+        "get_input": "port"
+      },
+      "logging": {
+        "get_input": "logging"
+      },
+      "connectionTimeOut": {
+        "get_input": "connectionTimeOut"
+      }
+    }
+  },
+  "topology_template": {
+    "workflows": {
+      "cli": {
+        "steps": {
+          "cli": {
+            "description": "CLI Workflow",
+            "target": "cli"
+          }
+        },
+        "inputs": {
+          "resolution-key": {
+            "required": false,
+            "type": "string"
+          },
+          "password": {
+            "required": true,
+            "type": "string"
+          },
+          "username": {
+            "required": true,
+            "type": "string"
+          },
+          "host": {
+            "required": true,
+            "type": "string"
+          },
+          "port": {
+            "required": false,
+            "type": "string"
+          },
+          "connectionTimeOut": {
+            "required": true,
+            "type": "string"
+          },
+          "logging": {
+            "required": true,
+            "type": "boolean"
+          },
+          "commands": {
+            "required": true,
+            "type": "list",
+            "entry_schema": {
+              "type": "string"
+            }
+          }
+        },
+        "outputs": {
+          "response-data": {
+            "type": "string",
+            "value": {
+              "get_attribute": [
+                "cli",
+                "response-data"
+              ]
+            }
+          }
+        }
+      }
+    },
+    "node_templates": {
+      "cli": {
+        "type": "component-script-executor",
+        "interfaces": {
+          "ComponentScriptExecutor": {
+            "operations": {
+              "process": {
+                "implementation": {
+                  "primary": "component-script"
+                },
+                "inputs": {
+                  "script-type": "kotlin",
+                  "script-class-reference": "cli.CliRegressionTest"
+                },
+                "outputs": {}
+              }
+            }
+          }
+        }
+      }
+    }
+  }
+}
diff --git a/cds-regression-test/cba/cli/frankfurt/Scripts/kotlin/cli/cli.kt b/cds-regression-test/cba/cli/frankfurt/Scripts/kotlin/cli/cli.kt
new file mode 100755
index 0000000..1e1ade0
--- /dev/null
+++ b/cds-regression-test/cba/cli/frankfurt/Scripts/kotlin/cli/cli.kt
@@ -0,0 +1,59 @@
+/*
+ *  Copyright © 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.
+ */
+
+package cli
+
+import org.onap.ccsdk.cds.controllerblueprints.core.logger
+import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.cli.executor.cliDeviceInfo
+import org.onap.ccsdk.cds.blueprintsprocessor.functions.cli.executor.getSshClientService
+import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction
+import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.ComponentScriptExecutor
+import org.onap.ccsdk.cds.blueprintsprocessor.ssh.service.CommandResult
+import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonType
+
+open class CliRegressionTest : AbstractScriptComponentFunction() {
+
+    private val log = logger(CliRegressionTest::class)
+
+    override suspend fun processNB(executionRequest: ExecutionServiceInput) {
+        // Get Client Service
+        val sshClientService = getSshClientService(cliDeviceInfo("device-properties"))
+        sshClientService.startSession()
+
+        // Read Commands
+        val timeout = bluePrintRuntimeService.getInputValue("connectionTimeOut").asText()
+        val commands = bluePrintRuntimeService.getInputValue("commands")
+            .let { JacksonUtils.getListFromJsonNode(it, String::class.java) }
+
+        // Execute
+        var responsesLog: List<CommandResult>? = null
+        try {
+            responsesLog = sshClientService.executeCommands(commands, timeout.toLong())
+            log.info(responsesLog.toString())
+        } catch (e: Exception) {
+            e.message?.let { addError(it) }
+        } finally {
+            setAttribute(ComponentScriptExecutor.ATTRIBUTE_RESPONSE_DATA, responsesLog?.map { it->it.asJsonType()}.asJsonType())
+            sshClientService.closeSession()
+        }
+    }
+
+    override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) {
+        log.info("Executing Recovery")
+    }
+}
diff --git a/cds-regression-test/cba/cli/frankfurt/TOSCA-Metadata/TOSCA.meta b/cds-regression-test/cba/cli/frankfurt/TOSCA-Metadata/TOSCA.meta
new file mode 100755
index 0000000..7bb2d45
--- /dev/null
+++ b/cds-regression-test/cba/cli/frankfurt/TOSCA-Metadata/TOSCA.meta
@@ -0,0 +1,8 @@
+TOSCA-Meta-File-Version: 1.0.0
+CSAR-Version: 1.0
+Created-By: Selffish
+Entry-Definitions: Definitions/cli.json
+Template-Tags: test, regression
+Template-Name: RT-cli
+Template-Version: 1.0.0
+Template-Type: DEFAULT
\ No newline at end of file