allow non-standard http status codes in the http api

Signed-off-by: Johannes Schneider <johannes.schneider@bosch.io>
eclipse-ditto · May 3, 2022 · a565786 · a565786
1 parent 2967d5e
commit a565786
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ain/java/org/eclipse/ditto/gateway/service/endpoints/actors/AbstractHttpRequestActor.java b/...ain/java/org/eclipse/ditto/gateway/service/endpoints/actors/AbstractHttpRequestActor.java
@@ -211,7 +211,9 @@ public AbstractActor.Receive createReceive() {
     }
 
     private static HttpResponse createHttpResponse(final HttpStatus httpStatus) {
-        return HttpResponse.create().withStatus(httpStatus.getCode());
+        final var statusCode = StatusCodes.lookup(httpStatus.getCode())
+                .orElse(StatusCodes.custom(httpStatus.getCode(), "custom", "custom"));
+        return HttpResponse.create().withStatus(statusCode);
     }
 
     private void handleCommand(final Command<?> command) {
@@ -427,8 +429,6 @@ private HttpResponse handleMessageResponseMessage(final MessageCommandResponse<?
         final Optional<?> optionalPayload = message.getPayload();
         final Optional<ByteBuffer> optionalRawPayload = message.getRawPayload();
         final var responseStatus = Optional.of(messageCommandResponse.getHttpStatus())
-                .filter(httpStatus -> StatusCodes.lookup(httpStatus.getCode()).isPresent())
-                // only allow HTTP status which are known to akka-http
                 .filter(httpStatus -> !HttpStatus.BAD_GATEWAY.equals(httpStatus));
         // filter "bad gateway" 502 from being used as this is used Ditto internally for graceful HTTP shutdown