fix: Generate Java Code from plugin-pb (#115)

This PR was created by a scheduled workflow to regenerate the Java code from `plugin-pb`.

Author: cq-bot

build/generated/source/proto/main/grpc/io/cloudquery/plugin/v3/PluginGrpc.java

@@ -301,7 +301,7 @@ io.cloudquery.plugin.v3.Transform.Response> getTransformMethod() {
       fullMethodName = SERVICE_NAME + '/' + "TransformSchema",
       requestType = io.cloudquery.plugin.v3.TransformSchema.Request.class,
       responseType = io.cloudquery.plugin.v3.TransformSchema.Response.class,
-      methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
+      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
   public static io.grpc.MethodDescriptor<io.cloudquery.plugin.v3.TransformSchema.Request,
       io.cloudquery.plugin.v3.TransformSchema.Response> getTransformSchemaMethod() {
     io.grpc.MethodDescriptor<io.cloudquery.plugin.v3.TransformSchema.Request, io.cloudquery.plugin.v3.TransformSchema.Response> getTransformSchemaMethod;
@@ -310,7 +310,7 @@ io.cloudquery.plugin.v3.TransformSchema.Response> getTransformSchemaMethod() {
         if ((getTransformSchemaMethod = PluginGrpc.getTransformSchemaMethod) == null) {
           PluginGrpc.getTransformSchemaMethod = getTransformSchemaMethod =
               io.grpc.MethodDescriptor.<io.cloudquery.plugin.v3.TransformSchema.Request, io.cloudquery.plugin.v3.TransformSchema.Response>newBuilder()
-              .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
+              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
               .setFullMethodName(generateFullMethodName(SERVICE_NAME, "TransformSchema"))
               .setSampledToLocalTracing(true)
               .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
@@ -533,9 +533,9 @@ default io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.Transform.Request> t
      * Transform schemas.
      * </pre>
      */
-    default io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.TransformSchema.Request> transformSchema(
+    default void transformSchema(io.cloudquery.plugin.v3.TransformSchema.Request request,
         io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.TransformSchema.Response> responseObserver) {
-      return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getTransformSchemaMethod(), responseObserver);
+      io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getTransformSchemaMethod(), responseObserver);
     }
 
     /**
@@ -693,10 +693,10 @@ public io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.Transform.Request> tr
      * Transform schemas.
      * </pre>
      */
-    public io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.TransformSchema.Request> transformSchema(
+    public void transformSchema(io.cloudquery.plugin.v3.TransformSchema.Request request,
         io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.TransformSchema.Response> responseObserver) {
-      return io.grpc.stub.ClientCalls.asyncBidiStreamingCall(
-          getChannel().newCall(getTransformSchemaMethod(), getCallOptions()), responseObserver);
+      io.grpc.stub.ClientCalls.asyncUnaryCall(
+          getChannel().newCall(getTransformSchemaMethod(), getCallOptions()), request, responseObserver);
     }
 
     /**
@@ -813,6 +813,16 @@ public java.util.Iterator<io.cloudquery.plugin.v3.Read.Response> read(
           getChannel(), getReadMethod(), getCallOptions(), request);
     }
 
+    /**
+     * <pre>
+     * Transform schemas.
+     * </pre>
+     */
+    public io.cloudquery.plugin.v3.TransformSchema.Response transformSchema(io.cloudquery.plugin.v3.TransformSchema.Request request) {
+      return io.grpc.stub.ClientCalls.blockingUnaryCall(
+          getChannel(), getTransformSchemaMethod(), getCallOptions(), request);
+    }
+
     /**
      * <pre>
      * Send signal to flush and close open connections
@@ -907,6 +917,17 @@ public com.google.common.util.concurrent.ListenableFuture<io.cloudquery.plugin.v
           getChannel().newCall(getGetTablesMethod(), getCallOptions()), request);
     }
 
+    /**
+     * <pre>
+     * Transform schemas.
+     * </pre>
+     */
+    public com.google.common.util.concurrent.ListenableFuture<io.cloudquery.plugin.v3.TransformSchema.Response> transformSchema(
+        io.cloudquery.plugin.v3.TransformSchema.Request request) {
+      return io.grpc.stub.ClientCalls.futureUnaryCall(
+          getChannel().newCall(getTransformSchemaMethod(), getCallOptions()), request);
+    }
+
     /**
      * <pre>
      * Send signal to flush and close open connections
@@ -937,11 +958,11 @@ public com.google.common.util.concurrent.ListenableFuture<io.cloudquery.plugin.v
   private static final int METHODID_GET_TABLES = 4;
   private static final int METHODID_SYNC = 5;
   private static final int METHODID_READ = 6;
-  private static final int METHODID_CLOSE = 7;
-  private static final int METHODID_TEST_CONNECTION = 8;
-  private static final int METHODID_WRITE = 9;
-  private static final int METHODID_TRANSFORM = 10;
-  private static final int METHODID_TRANSFORM_SCHEMA = 11;
+  private static final int METHODID_TRANSFORM_SCHEMA = 7;
+  private static final int METHODID_CLOSE = 8;
+  private static final int METHODID_TEST_CONNECTION = 9;
+  private static final int METHODID_WRITE = 10;
+  private static final int METHODID_TRANSFORM = 11;
 
   private static final class MethodHandlers<Req, Resp> implements
       io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
@@ -988,6 +1009,10 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
           serviceImpl.read((io.cloudquery.plugin.v3.Read.Request) request,
               (io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.Read.Response>) responseObserver);
           break;
+        case METHODID_TRANSFORM_SCHEMA:
+          serviceImpl.transformSchema((io.cloudquery.plugin.v3.TransformSchema.Request) request,
+              (io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.TransformSchema.Response>) responseObserver);
+          break;
         case METHODID_CLOSE:
           serviceImpl.close((io.cloudquery.plugin.v3.Close.Request) request,
               (io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.Close.Response>) responseObserver);
@@ -1012,9 +1037,6 @@ public io.grpc.stub.StreamObserver<Req> invoke(
         case METHODID_TRANSFORM:
           return (io.grpc.stub.StreamObserver<Req>) serviceImpl.transform(
               (io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.Transform.Response>) responseObserver);
-        case METHODID_TRANSFORM_SCHEMA:
-          return (io.grpc.stub.StreamObserver<Req>) serviceImpl.transformSchema(
-              (io.grpc.stub.StreamObserver<io.cloudquery.plugin.v3.TransformSchema.Response>) responseObserver);
         default:
           throw new AssertionError();
       }
@@ -1088,7 +1110,7 @@ public static final io.grpc.ServerServiceDefinition bindService(AsyncService ser
                 service, METHODID_TRANSFORM)))
         .addMethod(
           getTransformSchemaMethod(),
-          io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+          io.grpc.stub.ServerCalls.asyncUnaryCall(
             new MethodHandlers<
               io.cloudquery.plugin.v3.TransformSchema.Request,
               io.cloudquery.plugin.v3.TransformSchema.Response>(

build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java

@@ -30,7 +30,7 @@ service Plugin {
   // Transform resources.
   rpc Transform(stream Transform.Request) returns (stream Transform.Response);
   // Transform schemas.
-  rpc TransformSchema(stream TransformSchema.Request) returns (stream TransformSchema.Response);
+  rpc TransformSchema(TransformSchema.Request) returns (TransformSchema.Response);
   // Send signal to flush and close open connections
   rpc Close(Close.Request) returns (Close.Response);
   // Validate and test the connections used by the plugin