- add basic ErrorHandler logic

- ref #3863

Author: jknack

jooby/src/main/java/io/jooby/StatusCode.java

@@ -738,6 +738,14 @@ public final class StatusCode {
   public static final StatusCode REQUEST_HEADER_FIELDS_TOO_LARGE =
       new StatusCode(REQUEST_HEADER_FIELDS_TOO_LARGE_CODE, "Request Header Fields Too Large");
 
+  /** {@code 499 The client aborted the request before completion}. */
+  public static final int CLIENT_CLOSED_REQUEST_CODE = 499;
+
+  /** {@code 499 The client aborted the request before completion}. */
+  public static final StatusCode CLIENT_CLOSED_REQUEST =
+      new StatusCode(
+          CLIENT_CLOSED_REQUEST_CODE, "The client aborted the request before completion");
+
   // --- 5xx Server Error ---
 
   /**
@@ -1025,6 +1033,7 @@ public static StatusCode valueOf(final int statusCode) {
       case PRECONDITION_REQUIRED_CODE -> PRECONDITION_REQUIRED;
       case TOO_MANY_REQUESTS_CODE -> TOO_MANY_REQUESTS;
       case REQUEST_HEADER_FIELDS_TOO_LARGE_CODE -> REQUEST_HEADER_FIELDS_TOO_LARGE;
+      case CLIENT_CLOSED_REQUEST_CODE -> CLIENT_CLOSED_REQUEST;
       case SERVER_ERROR_CODE -> SERVER_ERROR;
       case NOT_IMPLEMENTED_CODE -> NOT_IMPLEMENTED;
       case BAD_GATEWAY_CODE -> BAD_GATEWAY;

jooby/src/main/java/io/jooby/trpc/TrpcError.java

@@ -7,6 +7,8 @@
 
 import java.util.Map;
 
-public record TrpcError(ErrorDetail error) {
-  public record ErrorDetail(String message, int code, Map<String, Object> data) {}
+public class TrpcError extends RuntimeException {
+  public TrpcError(String message, int code, Map<String, Object> data) {
+    super(message);
+  }
 }

jooby/src/main/java/io/jooby/trpc/TrpcErrorCode.java

@@ -0,0 +1,51 @@
+/*
+ * Jooby https://jooby.io
+ * Apache License Version 2.0 https://jooby.io/LICENSE.txt
+ * Copyright 2014 Edgar Espina
+ */
+package io.jooby.trpc;
+
+import io.jooby.StatusCode;
+
+public enum TrpcErrorCode {
+  PARSE_ERROR(-32700, StatusCode.BAD_REQUEST),
+  BAD_REQUEST(-32600, StatusCode.BAD_REQUEST),
+  INTERNAL_SERVER_ERROR(-32603, StatusCode.SERVER_ERROR),
+  UNAUTHORIZED(-32001, StatusCode.UNAUTHORIZED),
+  FORBIDDEN(-32003, StatusCode.FORBIDDEN),
+  NOT_FOUND(-32004, StatusCode.NOT_FOUND),
+  METHOD_NOT_SUPPORTED(-32005, StatusCode.METHOD_NOT_ALLOWED),
+  TIMEOUT(-32008, StatusCode.REQUEST_TIMEOUT),
+  CONFLICT(-32009, StatusCode.CONFLICT),
+  PRECONDITION_FAILED(-32012, StatusCode.PRECONDITION_FAILED),
+  PAYLOAD_TOO_LARGE(-32013, StatusCode.REQUEST_ENTITY_TOO_LARGE),
+  UNPROCESSABLE_CONTENT(-32022, StatusCode.UNPROCESSABLE_ENTITY),
+  TOO_MANY_REQUESTS(-32029, StatusCode.TOO_MANY_REQUESTS),
+  CLIENT_CLOSED_REQUEST(-32099, StatusCode.CLIENT_CLOSED_REQUEST);
+
+  private final int rpcCode;
+  private final StatusCode statusCode;
+
+  TrpcErrorCode(int rpcCode, StatusCode statusCode) {
+    this.rpcCode = rpcCode;
+    this.statusCode = statusCode;
+  }
+
+  public int getRpcCode() {
+    return rpcCode;
+  }
+
+  public StatusCode getStatusCode() {
+    return statusCode;
+  }
+
+  /** Helper to map a standard Jooby HTTP status code to the closest tRPC equivalent. */
+  public static TrpcErrorCode of(StatusCode status) {
+    for (var code : values()) {
+      if (code.statusCode.value() == status.value()) {
+        return code;
+      }
+    }
+    return INTERNAL_SERVER_ERROR; // Fallback
+  }
+}

jooby/src/main/java/io/jooby/trpc/TrpcErrorHandler.java

@@ -0,0 +1,35 @@
+/*
+ * Jooby https://jooby.io
+ * Apache License Version 2.0 https://jooby.io/LICENSE.txt
+ * Copyright 2014 Edgar Espina
+ */
+package io.jooby.trpc;
+
+import java.util.Map;
+
+import edu.umd.cs.findbugs.annotations.NonNull;
+import io.jooby.Context;
+import io.jooby.ErrorHandler;
+import io.jooby.StatusCode;
+
+public class TrpcErrorHandler implements ErrorHandler {
+  @Override
+  public void apply(@NonNull Context ctx, @NonNull Throwable cause, @NonNull StatusCode code) {
+    if (ctx.getRequestPath().startsWith("/trpc/")) {
+
+      var trpcCode = TrpcErrorCode.of(code);
+
+      Map<String, Object> errorData =
+          Map.of(
+              "code", trpcCode.name(),
+              "httpStatus", code.value(),
+              "path", ctx.getRequestPath().replace("/trpc/", ""));
+
+      var errorDetail =
+          new TrpcError.ErrorDetail(cause.getMessage(), trpcCode.getRpcCode(), errorData);
+      var trpcResponse = new TrpcError(errorDetail);
+
+      ctx.setResponseCode(code).render(trpcResponse);
+    }
+  }
+}

jooby/src/main/java/io/jooby/trpc/TrpcModule.java

@@ -0,0 +1,17 @@
+/*
+ * Jooby https://jooby.io
+ * Apache License Version 2.0 https://jooby.io/LICENSE.txt
+ * Copyright 2014 Edgar Espina
+ */
+package io.jooby.trpc;
+
+import edu.umd.cs.findbugs.annotations.NonNull;
+import io.jooby.Extension;
+import io.jooby.Jooby;
+
+public class TrpcModule implements Extension {
+  @Override
+  public void install(@NonNull Jooby application) throws Exception {
+    application.error(new TrpcErrorHandler());
+  }
+}