Add Wire-based impl

Author: Lipen

jacodb-ets/build.gradle.kts

@@ -12,6 +12,8 @@ dependencies {
     api(project(":jacodb-api-common"))
     api(project(":jacodb-ets:grpc-client"))
     api(project(":jacodb-ets:grpc-server"))
+    api(project(":jacodb-ets:wire-client"))
+    api(project(":jacodb-ets:wire-server"))
 
     implementation(Libs.kotlin_logging)
     implementation(Libs.slf4j_simple)

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

@@ -0,0 +1,15 @@
+plugins {
+    id("com.squareup.wire") version "5.3.1"
+}
+
+dependencies {
+    protoSource(project(":jacodb-ets:wire-protos"))
+    runtimeOnly("com.squareup.wire:wire-runtime:5.3.1")
+    api("com.squareup.wire:wire-grpc-client:5.3.1")
+}
+
+wire {
+    kotlin {
+        rpcRole = "client"
+    }
+}

jacodb-ets/wire-client/src/main/kotlin/org/jacodb/ets/service/ClientGreeter.kt

@@ -0,0 +1,43 @@
+/*
+ *  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.service
+
+import com.squareup.wire.GrpcMethod
+import greeter2.HelloReply
+import greeter2.HelloRequest
+
+fun main() {
+    val port = 50051
+    // val greeter: GreeterClient = grpcClient(port).create()
+    // val request = HelloRequest(name = "Kotlin")
+    // val response = greeter.SayHello().executeBlocking(request)
+    // println("Response: \"${response.message}\"")
+
+    // Below is the manual way to create a gRPC call.
+    // We use it here to make 'path' contain 'greeter' instead of 'greeter2',
+    val client = grpcClient(port)
+    val call = client.newCall(
+        GrpcMethod(
+            path = "/greeter.Greeter/SayHello",
+            requestAdapter = HelloRequest.ADAPTER,
+            responseAdapter = HelloReply.ADAPTER
+        )
+    )
+    val request = HelloRequest(name = "Kotlin")
+    val response: HelloReply = call.executeBlocking(request)
+    println("Response: \"${response.message}\"")
+}

jacodb-ets/wire-client/src/main/kotlin/org/jacodb/ets/service/ClientManager.kt

@@ -0,0 +1,29 @@
+/*
+ *  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.service
+
+import manager2.ManagerClient
+import manager2.GetSceneRequest
+
+fun main() {
+    val port = 50051
+    val manager: ManagerClient = grpcClient(port).create()
+    val path = "TODO"
+    val request = GetSceneRequest(path)
+    val scene = manager.GetScene().executeBlocking(request)
+    println("scene = $scene")
+}

jacodb-ets/wire-client/src/main/kotlin/org/jacodb/ets/service/Utils.kt

@@ -0,0 +1,33 @@
+/*
+ *  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.service
+
+import com.squareup.wire.GrpcClient
+import okhttp3.OkHttpClient
+import okhttp3.Protocol
+
+const val DEFAULT_PORT = 7777
+
+fun grpcClient(port: Int = DEFAULT_PORT): GrpcClient {
+    val okClient = OkHttpClient.Builder()
+        .protocols(listOf(Protocol.H2_PRIOR_KNOWLEDGE))
+        .build()
+    return GrpcClient.Builder()
+        .client(okClient)
+        .baseUrl("http://0.0.0.0:$port")
+        .build()
+}

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

@@ -0,0 +1,14 @@
+plugins {
+    id("com.squareup.wire") version "5.3.1"
+}
+
+dependencies {
+    runtimeOnly("com.squareup.wire:wire-runtime:5.3.1")
+}
+
+wire {
+    protoLibrary = true
+    kotlin {
+        rpcRole = "none"
+    }
+}

jacodb-ets/wire-protos/src/main/proto/greeter.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+package greeter2;
+
+option java_multiple_files = true;
+
+// The greeter service definition.
+service Greeter {
+  // Sends a greeting
+  rpc SayHello(HelloRequest) returns (HelloReply);
+}
+
+// The request message containing the user's name.
+message HelloRequest {
+  string name = 1;
+}
+
+// The response message containing the greetings
+message HelloReply {
+  string message = 1;
+}

jacodb-ets/wire-protos/src/main/proto/manager.proto

@@ -0,0 +1,15 @@
+syntax = "proto3";
+package manager2;
+
+option java_multiple_files = true;
+
+import "model.proto";
+
+service Manager {
+  rpc GetScene(GetSceneRequest) returns (model2.Scene);
+}
+
+message GetSceneRequest {
+  string path = 1;
+  optional bool infer_types = 2;
+}