Add grpc TLS property lib services.

Issue-ID: CCSDK-1853
Signed-off-by: Brinda Santh <bs2796@att.com>
Change-Id: I92c8b39a6db0bf7c1fe7e9928e4eddaef8a30f07

3 files changed, 261 insertions, 4 deletions

diff --git a/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcLibPropertyServiceTest.kt b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcLibPropertyServiceTest.kt
index 8df218fe9..b7ddc1569 100644
--- a/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcLibPropertyServiceTest.kt
+++ b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcLibPropertyServiceTest.kt
@@ -1,5 +1,6 @@
 /*
  *  Copyright © 2019 IBM.
+ *  Modifications 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.
@@ -22,9 +23,8 @@ import org.junit.Test
 import org.junit.runner.RunWith
 import org.onap.ccsdk.cds.blueprintsprocessor.core.BluePrintProperties
 import org.onap.ccsdk.cds.blueprintsprocessor.core.BlueprintPropertyConfiguration
-import org.onap.ccsdk.cds.blueprintsprocessor.grpc.BasicAuthGrpcClientProperties
-import org.onap.ccsdk.cds.blueprintsprocessor.grpc.BluePrintGrpcLibConfiguration
-import org.onap.ccsdk.cds.blueprintsprocessor.grpc.TokenAuthGrpcClientProperties
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.*
+import org.onap.ccsdk.cds.controllerblueprints.core.jsonAsJsonType
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.test.context.ContextConfiguration
 import org.springframework.test.context.TestPropertySource
@@ -42,11 +42,25 @@ import kotlin.test.assertTrue
     "blueprintsprocessor.grpcclient.sample.port=50505",
     "blueprintsprocessor.grpcclient.sample.username=sampleuser",
     "blueprintsprocessor.grpcclient.sample.password=sampleuser",
+
     "blueprintsprocessor.grpcclient.token.type=token-auth",
     "blueprintsprocessor.grpcclient.token.host=127.0.0.1",
     "blueprintsprocessor.grpcclient.token.port=50505",
     "blueprintsprocessor.grpcclient.token.username=sampleuser",
-    "blueprintsprocessor.grpcclient.token.password=sampleuser"
+    "blueprintsprocessor.grpcclient.token.password=sampleuser",
+
+    "blueprintsprocessor.grpcserver.tls-sample.type=tls-auth",
+    "blueprintsprocessor.grpcserver.tls-sample.port=50505",
+    "blueprintsprocessor.grpcserver.tls-sample.certChain=server1.pem",
+    "blueprintsprocessor.grpcserver.tls-sample.privateKey=server1.key",
+    "blueprintsprocessor.grpcserver.tls-sample.trustCertCollection=ca.pem",
+
+    "blueprintsprocessor.grpcclient.tls-sample.type=tls-auth",
+    "blueprintsprocessor.grpcclient.tls-sample.host=127.0.0.1",
+    "blueprintsprocessor.grpcclient.tls-sample.port=50505",
+    "blueprintsprocessor.grpcclient.tls-sample.trustCertCollection=ca.pem",
+    "blueprintsprocessor.grpcclient.tls-sample.clientCertChain=client.pem",
+    "blueprintsprocessor.grpcclient.tls-sample.clientPrivateKey=client.key"
 ])
 class BluePrintGrpcLibPropertyServiceTest {
 
@@ -129,4 +143,52 @@ class BluePrintGrpcLibPropertyServiceTest {
                 .blueprintGrpcClientService(actualObj)
         assertTrue(svc is BasicAuthGrpcClientService)
     }
+
+    @Test
+    fun testGrpcClientTLSProperties() {
+        val properties = bluePrintGrpcLibPropertyService
+                .grpcClientProperties("blueprintsprocessor.grpcclient.tls-sample") as TLSAuthGrpcClientProperties
+        assertNotNull(properties, "failed to create property bean")
+        assertNotNull(properties.host, "failed to get host property in property bean")
+        assertNotNull(properties.port, "failed to get host property in property bean")
+        assertNotNull(properties.trustCertCollection, "failed to get trustCertCollection property in property bean")
+        assertNotNull(properties.clientCertChain, "failed to get clientCertChain property in property bean")
+        assertNotNull(properties.clientPrivateKey, "failed to get clientPrivateKey property in property bean")
+
+        val configDsl = """{
+            "type" : "tls-auth",
+            "host" : "localhost",
+            "port" : "50505",
+            "trustCertCollection" : "server1.pem",
+            "clientCertChain" : "server1.key",
+            "clientPrivateKey" : "ca.pem"
+            }           
+        """.trimIndent()
+        val jsonProperties = bluePrintGrpcLibPropertyService
+                .grpcClientProperties(configDsl.jsonAsJsonType()) as TLSAuthGrpcClientProperties
+        assertNotNull(jsonProperties, "failed to create property bean from json")
+    }
+
+    @Test
+    fun testGrpcServerTLSProperties() {
+        val properties = bluePrintGrpcLibPropertyService
+                .grpcServerProperties("blueprintsprocessor.grpcserver.tls-sample") as TLSAuthGrpcServerProperties
+        assertNotNull(properties, "failed to create property bean")
+        assertNotNull(properties.port, "failed to get host property in property bean")
+        assertNotNull(properties.trustCertCollection, "failed to get trustCertCollection property in property bean")
+        assertNotNull(properties.certChain, "failed to get certChain property in property bean")
+        assertNotNull(properties.privateKey, "failed to get privateKey property in property bean")
+
+        val configDsl = """{
+            "type" : "tls-auth",
+            "port" : "50505",
+            "certChain" : "server1.pem",
+            "privateKey" : "server1.key",
+            "trustCertCollection" : "ca.pem"
+            }           
+        """.trimIndent()
+        val jsonProperties = bluePrintGrpcLibPropertyService
+                .grpcServerProperties(configDsl.jsonAsJsonType()) as TLSAuthGrpcServerProperties
+        assertNotNull(jsonProperties, "failed to create property bean from json")
+    }
 }
\ No newline at end of file
diff --git a/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcServerTest.kt b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcServerTest.kt
new file mode 100644
index 000000000..a08425048
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/BluePrintGrpcServerTest.kt
@@ -0,0 +1,105 @@
+/*
+ * 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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.grpc.service
+
+import com.github.marcoferrer.krotoplus.coroutines.client.clientCallBidiStreaming
+import com.google.protobuf.util.JsonFormat
+import kotlinx.coroutines.channels.consumeEach
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ACTION_MODE_SYNC
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.GRPCLibConstants
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.TLSAuthGrpcClientProperties
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.TLSAuthGrpcServerProperties
+import org.onap.ccsdk.cds.controllerblueprints.common.api.ActionIdentifiers
+import org.onap.ccsdk.cds.controllerblueprints.common.api.CommonHeader
+import org.onap.ccsdk.cds.controllerblueprints.processing.api.BluePrintProcessingServiceGrpc
+import org.onap.ccsdk.cds.controllerblueprints.processing.api.ExecutionServiceInput
+import java.util.*
+import kotlin.test.Test
+import kotlin.test.assertNotNull
+
+class BluePrintGrpcServerTest {
+
+    private val tlsAuthGrpcServerProperties = TLSAuthGrpcServerProperties().apply {
+        port = 50052
+        type = GRPCLibConstants.TYPE_TLS_AUTH
+        certChain = "src/test/resources/tls-manual/my-public-key-cert.pem"
+        privateKey = "src/test/resources/tls-manual/my-private-key.pem"
+    }
+
+    private val tlsAuthGrpcClientProperties = TLSAuthGrpcClientProperties().apply {
+        host = "localhost"
+        port = 50052
+        type = GRPCLibConstants.TYPE_TLS_AUTH
+        trustCertCollection = "src/test/resources/tls-manual/my-public-key-cert.pem"
+    }
+
+    @Test
+    fun testGrpcTLSContext() {
+        val tlsAuthGrpcServerService = TLSAuthGrpcServerService(tlsAuthGrpcServerProperties)
+        val sslContext = tlsAuthGrpcServerService.sslContext()
+        assertNotNull(sslContext, "failed to create grpc server ssl context")
+
+        val tlsAuthGrpcClientService = TLSAuthGrpcClientService(tlsAuthGrpcClientProperties)
+        val clientSslContext = tlsAuthGrpcClientService.sslContext()
+        assertNotNull(clientSslContext, "failed to create grpc client ssl context")
+    }
+
+    /** TLS Client Integration testing, GRPC TLS Junit testing is not supported. */
+    //@Test
+    fun testGrpcTLSServerIntegration() {
+        runBlocking {
+            val tlsAuthGrpcClientService = TLSAuthGrpcClientService(tlsAuthGrpcClientProperties)
+            val grpcChannel = tlsAuthGrpcClientService.channel()
+            /** Get Send and Receive Channel for bidirectional process method*/
+            val (reqChannel, resChannel) = clientCallBidiStreaming(BluePrintProcessingServiceGrpc.getProcessMethod(),
+                    grpcChannel)
+            launch {
+                resChannel.consumeEach {
+                    log.info("Received Response")
+                }
+            }
+            val request = getRequest("12345")
+            reqChannel.send(request)
+        }
+    }
+
+    private fun getRequest(requestId: String): ExecutionServiceInput {
+        val commonHeader = CommonHeader.newBuilder()
+                .setTimestamp("2012-04-23T18:25:43.511Z")
+                .setOriginatorId("System")
+                .setRequestId(requestId)
+                .setSubRequestId("$requestId-" + UUID.randomUUID().toString()).build()
+        val actionIdentifier = ActionIdentifiers.newBuilder()
+                .setActionName("SampleScript")
+                .setBlueprintName("sample-cba")
+                .setBlueprintVersion("1.0.0")
+                .setMode(ACTION_MODE_SYNC)
+                .build()
+        val jsonContent = """{ "key1" : "value1" }"""
+        val payloadBuilder = ExecutionServiceInput.newBuilder().payloadBuilder
+        JsonFormat.parser().merge(jsonContent, payloadBuilder)
+
+        return ExecutionServiceInput.newBuilder()
+                .setCommonHeader(commonHeader)
+                .setActionIdentifiers(actionIdentifier)
+                .setPayload(payloadBuilder.build())
+                .build()
+    }
+
+}
\ No newline at end of file
diff --git a/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/MockTLSBluePrintProcessingServer.kt b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/MockTLSBluePrintProcessingServer.kt
new file mode 100644
index 000000000..c6991af9b
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/service/MockTLSBluePrintProcessingServer.kt
@@ -0,0 +1,90 @@
+/*
+ * 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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.grpc.service
+
+import io.grpc.stub.StreamObserver
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.GRPCLibConstants
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.TLSAuthGrpcServerProperties
+import org.onap.ccsdk.cds.blueprintsprocessor.grpc.interceptor.GrpcServerLoggingInterceptor
+import org.onap.ccsdk.cds.controllerblueprints.common.api.EventType
+import org.onap.ccsdk.cds.controllerblueprints.common.api.Status
+import org.onap.ccsdk.cds.controllerblueprints.core.logger
+import org.onap.ccsdk.cds.controllerblueprints.processing.api.BluePrintProcessingServiceGrpc
+import org.onap.ccsdk.cds.controllerblueprints.processing.api.ExecutionServiceInput
+import org.onap.ccsdk.cds.controllerblueprints.processing.api.ExecutionServiceOutput
+
+
+val log = logger(MockTLSBluePrintProcessingServer::class)
+
+/** For Integration testing stat this server, Set the working path to run this method */
+fun main() {
+    try {
+        val tlsAuthGrpcServerProperties = TLSAuthGrpcServerProperties().apply {
+            port = 50052
+            type = GRPCLibConstants.TYPE_TLS_AUTH
+            certChain = "src/test/resources/tls-manual/my-public-key-cert.pem"
+            privateKey = "src/test/resources/tls-manual/my-private-key.pem"
+        }
+        val server = TLSAuthGrpcServerService(tlsAuthGrpcServerProperties).serverBuilder()
+                .intercept(GrpcServerLoggingInterceptor())
+                .addService(MockTLSBluePrintProcessingServer())
+                .build()
+        server.start()
+        log.info("GRPC Serve started(${server.isShutdown}) on port(${server.port})...")
+        server.awaitTermination()
+    } catch (e: Exception) {
+        log.error("Failed to start tls grpc integration server", e)
+    }
+
+}
+
+class MockTLSBluePrintProcessingServer : BluePrintProcessingServiceGrpc.BluePrintProcessingServiceImplBase() {
+    override fun process(responseObserver: StreamObserver<ExecutionServiceOutput>): StreamObserver<ExecutionServiceInput> {
+
+        return object : StreamObserver<ExecutionServiceInput> {
+            override fun onNext(executionServiceInput: ExecutionServiceInput) {
+                log.info("Received requestId(${executionServiceInput.commonHeader.requestId})  " +
+                        "subRequestId(${executionServiceInput.commonHeader.subRequestId})")
+                responseObserver.onNext(buildResponse(executionServiceInput))
+                responseObserver.onCompleted()
+            }
+
+            override fun onError(error: Throwable) {
+                log.debug("Fail to process message", error)
+                responseObserver.onError(io.grpc.Status.INTERNAL
+                        .withDescription(error.message)
+                        .asException())
+            }
+
+            override fun onCompleted() {
+                log.info("Completed")
+            }
+        }
+    }
+
+    private fun buildResponse(input: ExecutionServiceInput): ExecutionServiceOutput {
+        val status = Status.newBuilder().setCode(200)
+                .setEventType(EventType.EVENT_COMPONENT_EXECUTED)
+                .build()
+        return ExecutionServiceOutput.newBuilder()
+                .setCommonHeader(input.commonHeader)
+                .setActionIdentifiers(input.actionIdentifiers)
+                .setStatus(status)
+                .build()
+
+    }
+}
\ No newline at end of file