Introduce GsonGrpcJsonMarshaller and catch JsonMarshaller initialization failure

grpc/src/main/java/com/linecorp/armeria/common/grpc/GrpcJsonMarshaller.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2020 LINE Corporation
+ * Copyright 2022 LINE Corporation
  *
  * LINE Corporation licenses this file to you under the Apache License,
  * version 2.0 (the "License"); you may not use this file except in compliance
@@ -39,19 +39,54 @@ public interface GrpcJsonMarshaller {
 
     /**
      * Returns a newly-created {@link GrpcJsonMarshaller} which serializes and deserializes a {@link Message}
-     * served by the {@linkplain ServiceDescriptor service}.
+     * served by the {@linkplain ServiceDescriptor service}. This implementation internally uses
+     * {@code protobuf-jackson} to serialize and deserialize messages.
      */
     static GrpcJsonMarshaller of(ServiceDescriptor serviceDescriptor) {
-        return builder().build(serviceDescriptor);
+        return ofJackson(serviceDescriptor);
     }
 
     /**
-     * Returns a new {@link GrpcJsonMarshallerBuilder}.
+     * Returns a new {@link GrpcJsonMarshallerBuilder}. This implementation internally uses
+     * {@code protobuf-jackson} to serialize and deserialize messages.
      */
     static GrpcJsonMarshallerBuilder builder() {
+        return builderForJackson();
+    }
+
+    /**
+     * Returns a newly-created {@link GrpcJsonMarshaller} which serializes and deserializes a {@link Message}
+     * served by the {@linkplain ServiceDescriptor service}. This implementation internally uses
+     * {@code protobuf-jackson} to serialize and deserialize messages.
+     */
+    static GrpcJsonMarshaller ofJackson(ServiceDescriptor serviceDescriptor) {
+        return builderForJackson().build(serviceDescriptor);
+    }
+
+    /**
+     * Returns a new {@link GrpcJsonMarshallerBuilder}. This implementation internally uses
+     * {@code protobuf-jackson} to serialize and deserialize messages.
+     */
+    static GrpcJsonMarshallerBuilder builderForJackson() {
         return new GrpcJsonMarshallerBuilder();
     }
 
+    /**
+     * Returns a newly-created {@link GrpcJsonMarshaller} which serializes and deserializes {@link Message}.
+     * This implementation internally uses {@code gson} to serialize and deserialize messages.
+     */
+    static GrpcJsonMarshaller ofGson() {
+        return builderForGson().build();
+    }
+
+    /**
+     * Returns a new {@link GrpcJsonMarshallerBuilder}. This implementation internally uses
+     * {@code gson} to serialize and deserialize messages.
+     */
+    static GsonGrpcJsonMarshallerBuilder builderForGson() {
+        return new GsonGrpcJsonMarshallerBuilder();
+    }
+
     /**
      * Serializes a gRPC message into JSON.
      */

grpc/src/main/java/com/linecorp/armeria/common/grpc/GsonGrpcJsonMarshallerBuilder.java

@@ -0,0 +1,92 @@
+/*
+ * Copyright 2020 LINE Corporation
+ *
+ * LINE Corporation licenses this file to you 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:
+ *
+ *   https://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 com.linecorp.armeria.common.grpc;
+
+import static java.util.Objects.requireNonNull;
+
+import java.util.function.Consumer;
+
+import com.google.protobuf.Message;
+import com.google.protobuf.util.JsonFormat;
+
+import com.linecorp.armeria.common.annotation.Nullable;
+import com.linecorp.armeria.internal.common.grpc.GsonGrpcJsonMarshaller;
+
+/**
+ * A builder for creating a new {@link GrpcJsonMarshaller} that serializes and deserializes a {@link Message}
+ * to and from JSON.
+ */
+public final class GsonGrpcJsonMarshallerBuilder {
+
+    @Nullable
+    private Consumer<JsonFormat.Parser> jsonParserCustomizer;
+
+    @Nullable
+    private Consumer<JsonFormat.Printer> jsonPrinterCustomizer;
+
+    GsonGrpcJsonMarshallerBuilder() {}
+
+    /**
+     * Sets a {@link Consumer} that can customize the {@link JsonFormat.Parser} for {@link Message}
+     * used when handling JSON payloads in the service.
+     */
+    public GsonGrpcJsonMarshallerBuilder jsonParserCustomizer(
+            Consumer<? super JsonFormat.Parser> jsonParserCustomizer) {
+        requireNonNull(jsonParserCustomizer, "jsonParserCustomizer");
+        if (this.jsonParserCustomizer == null) {
+            @SuppressWarnings("unchecked")
+            final Consumer<JsonFormat.Parser> cast = (Consumer<JsonFormat.Parser>) jsonParserCustomizer;
+            this.jsonParserCustomizer = cast;
+        } else {
+            this.jsonParserCustomizer = this.jsonParserCustomizer.andThen(jsonParserCustomizer);
+        }
+        return this;
+    }
+
+    /**
+     * Sets a {@link Consumer} that can customize the {@link JsonFormat.Printer} for {@link Message}
+     * used when handling JSON payloads in the service.
+     */
+    public GsonGrpcJsonMarshallerBuilder jsonPrinterCustomizer(
+            Consumer<? super JsonFormat.Printer> jsonPrinterCustomizer) {
+        requireNonNull(jsonPrinterCustomizer, "jsonPrinterCustomizer");
+        if (this.jsonPrinterCustomizer == null) {
+            @SuppressWarnings("unchecked")
+            final Consumer<JsonFormat.Printer> cast = (Consumer<JsonFormat.Printer>) jsonPrinterCustomizer;
+            this.jsonPrinterCustomizer = cast;
+        } else {
+            this.jsonPrinterCustomizer = this.jsonPrinterCustomizer.andThen(jsonPrinterCustomizer);
+        }
+        return this;
+    }
+
+    /**
+     * Returns a newly-created {@link GsonGrpcJsonMarshaller}.
+     */
+    public GrpcJsonMarshaller build() {
+        final JsonFormat.Printer printer = JsonFormat.printer().omittingInsignificantWhitespace();
+        if (jsonPrinterCustomizer != null) {
+            jsonPrinterCustomizer.accept(printer);
+        }
+
+        final JsonFormat.Parser parser = JsonFormat.parser().ignoringUnknownFields();
+        if (jsonParserCustomizer != null) {
+            jsonParserCustomizer.accept(parser);
+        }
+        return new GsonGrpcJsonMarshaller(printer, parser);
+    }
+}

grpc/src/main/java/com/linecorp/armeria/internal/common/grpc/GsonGrpcJsonMarshaller.java

@@ -0,0 +1,60 @@
+/*
+ * Copyright 2022 LINE Corporation
+ *
+ * LINE Corporation licenses this file to you 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:
+ *
+ *   https://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 com.linecorp.armeria.internal.common.grpc;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.nio.charset.StandardCharsets;
+
+import com.google.protobuf.Message;
+import com.google.protobuf.MessageOrBuilder;
+import com.google.protobuf.util.JsonFormat;
+
+import com.linecorp.armeria.common.grpc.GrpcJsonMarshaller;
+
+import io.grpc.MethodDescriptor.Marshaller;
+import io.grpc.MethodDescriptor.PrototypeMarshaller;
+
+public final class GsonGrpcJsonMarshaller implements GrpcJsonMarshaller {
+
+    final JsonFormat.Printer printer;
+    final JsonFormat.Parser parser;
+
+    public GsonGrpcJsonMarshaller(JsonFormat.Printer printer, JsonFormat.Parser parser) {
+        this.printer = printer;
+        this.parser = parser;
+    }
+
+    @Override
+    public <T> void serializeMessage(Marshaller<T> marshaller, T message, OutputStream os) throws IOException {
+        os.write(printer.print((MessageOrBuilder) message).getBytes(StandardCharsets.UTF_8));
+    }
+
+    @Override
+    public <T> T deserializeMessage(Marshaller<T> marshaller, InputStream is) throws IOException {
+        final PrototypeMarshaller<T> prototypeMarshaller = (PrototypeMarshaller<T>) marshaller;
+        final Message prototype = (Message) prototypeMarshaller.getMessagePrototype();
+        assert prototype != null;
+        final Message.Builder builder = prototype.newBuilderForType();
+        parser.merge(new InputStreamReader(is, StandardCharsets.UTF_8), builder);
+        @SuppressWarnings("unchecked")
+        final T cast = (T) builder.build();
+        return cast;
+    }
+}