Ports helidon-microprofile-core module from 3.x and moves additional …

…classes to helidon-grpc module.

Signed-off-by: Santiago Pericas-Geertsen <[email protected]>

grpc/core/pom.xml

@@ -33,6 +33,10 @@
             <groupId>io.helidon.common</groupId>
             <artifactId>helidon-common</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.helidon.http</groupId>
+            <artifactId>helidon-http</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.grpc</groupId>
             <artifactId>grpc-api</artifactId>

grpc/core/src/main/java/io/helidon/grpc/core/GrpcHelper.java

@@ -0,0 +1,157 @@
+/*
+ * Copyright (c) 2019, 2024 Oracle and/or its affiliates.
+ *
+ * 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 io.helidon.grpc.core;
+
+import io.grpc.Status;
+import io.grpc.StatusException;
+import io.grpc.StatusRuntimeException;
+
+/**
+ * Helper methods for common gRPC tasks.
+ */
+public final class GrpcHelper {
+
+    /**
+     * Private constructor for utility class.
+     */
+    private GrpcHelper() {
+    }
+
+    /**
+     * Extract the gRPC service name from a method full name.
+     *
+     * @param fullMethodName  the gRPC method full name
+     *
+     * @return  the service name extracted from the full name
+     */
+    public static String extractServiceName(String fullMethodName) {
+        int index = fullMethodName.indexOf('/');
+        return index == -1 ? fullMethodName : fullMethodName.substring(0, index);
+    }
+
+    /**
+     * Extract the name prefix from a method full name.
+     * <p>
+     * The prefix is everything upto the but not including the last
+     * '/' character in the full name.
+     *
+     * @param fullMethodName  the gRPC method full name
+     *
+     * @return  the name prefix extracted from the full name
+     */
+    public static String extractNamePrefix(String fullMethodName) {
+        int index = fullMethodName.lastIndexOf('/');
+        return index == -1 ? fullMethodName : fullMethodName.substring(0, index);
+    }
+
+    /**
+     * Extract the gRPC method name from a method full name.
+     *
+     * @param fullMethodName  the gRPC method full name
+     *
+     * @return  the method name extracted from the full name
+     */
+    public static String extractMethodName(String fullMethodName) {
+        int index = fullMethodName.lastIndexOf('/');
+        return index == -1 ? fullMethodName : fullMethodName.substring(index + 1);
+    }
+
+    /**
+     * Convert a gRPC {@link StatusException} to a {@link io.helidon.http.Status}.
+     *
+     * @param ex  the gRPC {@link StatusException} to convert
+     *
+     * @return  the gRPC {@link StatusException} converted to a {@link io.helidon.http.Status}
+     */
+    public static io.helidon.http.Status toHttpResponseStatus(StatusException ex) {
+        return toHttpResponseStatus(ex.getStatus());
+    }
+
+    /**
+     * Convert a gRPC {@link StatusRuntimeException} to a {@link io.helidon.http.Status}.
+     *
+     * @param ex  the gRPC {@link StatusRuntimeException} to convert
+     *
+     * @return  the gRPC {@link StatusRuntimeException} converted to a {@link io.helidon.http.Status}
+     */
+    public static io.helidon.http.Status toHttpResponseStatus(StatusRuntimeException ex) {
+        return toHttpResponseStatus(ex.getStatus());
+    }
+
+    /**
+     * Convert a gRPC {@link Status} to a {@link io.helidon.http.Status}.
+     *
+     * @param status  the gRPC {@link Status} to convert
+     *
+     * @return  the gRPC {@link Status} converted to a {@link io.helidon.http.Status}
+     */
+    public static io.helidon.http.Status toHttpResponseStatus(Status status) {
+        io.helidon.http.Status httpStatus = switch (status.getCode()) {
+            case OK -> io.helidon.http.Status.create(200, status.getDescription());
+            case INVALID_ARGUMENT -> io.helidon.http.Status.create(400, status.getDescription());
+            case DEADLINE_EXCEEDED -> io.helidon.http.Status.create(408, status.getDescription());
+            case NOT_FOUND -> io.helidon.http.Status.create(404, status.getDescription());
+            case ALREADY_EXISTS -> io.helidon.http.Status.create(412, status.getDescription());
+            case PERMISSION_DENIED -> io.helidon.http.Status.create(403, status.getDescription());
+            case FAILED_PRECONDITION -> io.helidon.http.Status.create(412, status.getDescription());
+            case OUT_OF_RANGE -> io.helidon.http.Status.create(400, status.getDescription());
+            case UNIMPLEMENTED -> io.helidon.http.Status.create(501, status.getDescription());
+            case UNAVAILABLE -> io.helidon.http.Status.create(503, status.getDescription());
+            case UNAUTHENTICATED -> io.helidon.http.Status.create(401, status.getDescription());
+            default -> io.helidon.http.Status.create(500, status.getDescription());
+        };
+        return httpStatus;
+    }
+
+    /**
+     * Ensure that a {@link Throwable} is either a {@link StatusRuntimeException} or
+     * a {@link StatusException}.
+     *
+     * @param thrown  the {@link Throwable} to test
+     * @param status  the {@link Status} to use if the {@link Throwable} has to be converted
+     * @return  the {@link Throwable} if it is a {@link StatusRuntimeException} or a
+     *          {@link StatusException}, or a new {@link StatusException} created from the
+     *          specified {@link Status} with the {@link Throwable} as the cause.
+     */
+    public static Throwable ensureStatusException(Throwable thrown, Status status) {
+        if (thrown instanceof StatusRuntimeException || thrown instanceof StatusException) {
+            return thrown;
+        } else {
+            return status.withCause(thrown).asException();
+        }
+    }
+
+    /**
+     * Ensure that a {@link Throwable} is a {@link StatusRuntimeException}.
+     *
+     * @param thrown  the {@link Throwable} to test
+     * @param status  the {@link Status} to use if the {@link Throwable} has to be converted
+     * @return  the {@link Throwable} if it is a {@link StatusRuntimeException} or a new
+     *          {@link StatusRuntimeException} created from the specified {@link Status}
+     *          with the {@link Throwable} as the cause.
+     */
+    public static StatusRuntimeException ensureStatusRuntimeException(Throwable thrown, Status status) {
+        if (thrown instanceof StatusRuntimeException) {
+            return (StatusRuntimeException) thrown;
+        } else if (thrown instanceof StatusException) {
+            StatusException ex = (StatusException) thrown;
+            return new StatusRuntimeException(ex.getStatus(), ex.getTrailers());
+        } else {
+            return status.withCause(thrown).asRuntimeException();
+        }
+    }
+}

grpc/core/src/main/java/io/helidon/grpc/core/MarshallerSupplier.java

@@ -25,6 +25,16 @@
 @FunctionalInterface
 public interface MarshallerSupplier {
 
+    /**
+     * The name of the Protocol Buffer marshaller supplier.
+     */
+    String PROTO = "proto";
+
+    /**
+     * The name to use to specify the default marshaller supplier.
+     */
+    String DEFAULT = "default";
+
     /**
      * Obtain a {@link MethodDescriptor.Marshaller} for a type.
      *