Add test for Greeter server/client

Author: Lipen

buildSrc/src/main/kotlin/Dependencies.kt

@@ -357,6 +357,11 @@ object Libs {
     )
 
     // https://github.com/grpc/grpc-java
+    val grpc_api = dep(
+        group = "io.grpc",
+        name = "grpc-api",
+        version = Versions.grpc
+    )
     val grpc_protobuf = dep(
         group = "io.grpc",
         name = "grpc-protobuf",

jacodb-ets/build.gradle.kts

@@ -20,6 +20,7 @@ dependencies {
 
     testImplementation(kotlin("test"))
     testImplementation(Libs.mockk)
+    testImplementation(Libs.grpc_api)
 
     testFixturesImplementation(Libs.kotlin_logging)
     testFixturesImplementation(Libs.junit_jupiter_api)

jacodb-ets/src/test/kotlin/org/jacodb/ets/test/WireTest.kt

@@ -0,0 +1,55 @@
+/*
+ *  Copyright 2022 UnitTestBot contributors (utbot.org)
+ * <p>
+ *  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
+ * <p>
+ *  http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ *  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.jacodb.ets.test
+
+import greeter.GreeterClient
+import greeter.HelloRequest
+import io.grpc.ServerBuilder
+import mu.KotlinLogging
+import org.jacodb.ets.service.GreeterService
+import org.jacodb.ets.service.grpcClient
+import kotlin.test.Test
+
+private val logger = KotlinLogging.logger {}
+
+class WireTest {
+    companion object {
+        private const val PORT = 7777
+    }
+
+    @Test
+    fun `test Greeter`() {
+        val server = ServerBuilder
+            .forPort(PORT)
+            .addService(GreeterService())
+            .build()
+        server.start()
+        logger.info { "Server listening on port ${server.port}" }
+
+        val client: GreeterClient = grpcClient(PORT).create()
+
+        val request = HelloRequest(name = "Kotlin")
+        logger.info { "Sending $request" }
+        val response = client.SayHello().executeBlocking(request)
+        logger.info { "Received $response" }
+
+        logger.info { "Shutting down server..." }
+        server.shutdown()
+        server.awaitTermination()
+        logger.info { "Server shut down" }
+    }
+}

jacodb-ets/wire-server/build.gradle.kts

@@ -15,6 +15,7 @@ dependencies {
     api(Libs.wire_grpc_server)
     implementation(Libs.grpc_protobuf)
     implementation(Libs.grpc_services) // for ProtoReflectionService
+    implementation(Libs.kotlin_logging)
     runtimeOnly(Libs.grpc_netty_shaded)
     runtimeOnly(Libs.wire_runtime)
 }

jacodb-ets/wire-server/src/main/kotlin/org/jacodb/ets/service/Greeter.kt

@@ -24,6 +24,8 @@ import io.grpc.ServerBuilder
 import io.grpc.protobuf.services.ProtoReflectionService
 import io.grpc.stub.StreamObserver
 
+private val logger = mu.KotlinLogging.logger {}
+
 class GreeterImpl : GreeterBlockingServer {
     override fun SayHello(request: HelloRequest): HelloReply {
         return HelloReply(message = "Hello, ${request.name}!")
@@ -34,8 +36,10 @@ class GreeterService : GreeterWireGrpc.GreeterImplBase() {
     private val impl = GreeterImpl()
 
     override fun SayHello(request: HelloRequest, response: StreamObserver<HelloReply>) {
-        println("Received $request")
-        response.onNext(impl.SayHello(request))
+        logger.info { "Received $request" }
+        val reply = impl.SayHello(request)
+        logger.info { "Sending $reply" }
+        response.onNext(reply)
         response.onCompleted()
     }
 }