Clean restconf duplicate models and Implementation.

[ccsdk/cds.git] / ms / blueprintsprocessor / functions / restconf-executor / src / main / kotlin / org / onap / ccsdk / cds / blueprintsprocessor / functions / restconf / executor / RestconfExecutorExtensions.kt

diff --git a/ms/blueprintsprocessor/functions/restconf-executor/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/restconf/executor/RestconfExecutorExtensions.kt b/ms/blueprintsprocessor/functions/restconf-executor/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/restconf/executor/RestconfExecutorExtensions.kt
index 6e0c3b6..49fd025 100644 (file)
--- a/ms/blueprintsprocessor/functions/restconf-executor/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/restconf/executor/RestconfExecutorExtensions.kt
+++ b/ms/blueprintsprocessor/functions/restconf-executor/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/restconf/executor/RestconfExecutorExtensions.kt
@@ -17,21 +17,86 @@
 
 package org.onap.ccsdk.cds.blueprintsprocessor.functions.restconf.executor
 
+import org.hibernate.annotations.common.util.impl.LoggerFactory
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.restClientService
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.service.BlueprintWebClientService
+import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintRetryException
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintDependencyService
+
 /**
  * Register the Restconf module exposed dependency
  */
 
+val log = LoggerFactory.logger(AbstractScriptComponentFunction::class.java)!!
+
+fun AbstractScriptComponentFunction.restconfClientService(selector: String): BlueprintWebClientService {
+    return BluePrintDependencyService.restClientService(selector)
+}
 
 /**
  * Generic Mount function
  */
 
+suspend fun AbstractScriptComponentFunction.restconfMountDevice(webClientService: BlueprintWebClientService,
+                                                                deviceId: String, payload: Any) {
+    val headers: MutableMap<String, String> = hashMapOf()
+    headers["Content-Type"] = "application/xml"
+    val mountUrl = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/$deviceId"
+    log.info("sending mount request, url: $mountUrl")
+    webClientService.exchangeNB("PUT", mountUrl, payload, headers)
+
+    /** Check device has mounted */
+    val mountCheckUrl = "restconf/operational/network-topology:network-topology/topology/topology-netconf/node/$deviceId"
+
+    val expectedResult = """"netconf-node-topology:connection-status":"connected""""
+    val mountCheckExecutionBlock: suspend (Int) -> String = { tryCount: Int ->
+        val result = webClientService.exchangeNB("GET", mountCheckUrl, "")
+        if (result.body.contains(expectedResult)) {
+            log.info("NF was mounted successfully on ODL")
+            result.body
+        } else {
+            throw BluePrintRetryException("Wait for device($deviceId) to mount")
+        }
+    }
+
+    log.info("url for ODL status check: $mountCheckUrl")
+    webClientService.retry<String>(10, 0, 1000, mountCheckExecutionBlock)
+}
 
 /**
  * Generic Configure function
  */
+suspend fun AbstractScriptComponentFunction.restconfApplyDeviceConfig(webClientService: BlueprintWebClientService,
+                                                                      deviceId: String, configletResourcePath: String,
+                                                                      configletToApply: Any,
+                                                                      additionalHeaders: Map<String, String>?) {
 
+    log.debug("headers: $additionalHeaders")
+    log.info("configuring device: $deviceId, Configlet: $configletToApply")
+    val applyConfigUrl = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/" +
+            "$deviceId/$configletResourcePath"
+    val result = webClientService.exchangeNB("PATCH", applyConfigUrl, configletToApply, additionalHeaders)
+    log.info("Configuration application result: $result")
+}
+
+
+suspend fun AbstractScriptComponentFunction.restconfDeviceConfig(webClientService: BlueprintWebClientService,
+                                                                 deviceId: String, configletResourcePath: String)
+        : BlueprintWebClientService.WebClientResponse<String> {
+
+    val configPathUrl = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/" +
+            "$deviceId/$configletResourcePath"
+    log.debug("sending GET request,  url: $configPathUrl")
+    return webClientService.exchangeNB("GET", configPathUrl, "")
+}
 
 /**
- * Generic Unmount function
- */
\ No newline at end of file
+ * Generic UnMount function
+ */
+suspend fun AbstractScriptComponentFunction.restconfUnMountDevice(webClientService: BlueprintWebClientService,
+                                                                  deviceId: String, payload: String) {
+    val unMountUrl = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/$deviceId"
+    log.info("sending unMount request, url: $unMountUrl")
+    webClientService.exchangeNB("DELETE", unMountUrl, "")
+}
\ No newline at end of file