package de.juplo.kafka.chat.backend.api;
import de.juplo.kafka.chat.backend.domain.MessageMutationException;
+import de.juplo.kafka.chat.backend.domain.UnknownChatroomException;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpStatus;
import org.springframework.http.ProblemDetail;
@Value("${server.context-path:/}")
String contextPath;
+ @ExceptionHandler(UnknownChatroomException.class)
+ public final ProblemDetail handleException(
+ UnknownChatroomException e,
+ ServerWebExchange exchange,
+ UriComponentsBuilder uriComponentsBuilder)
+ {
+ final HttpStatus status = HttpStatus.NOT_FOUND;
+ ProblemDetail problem = ProblemDetail.forStatus(status);
+
+ problem.setProperty("timestamp", new Date());
+
+ problem.setProperty("requestId", exchange.getRequest().getId());
+
+ problem.setType(uriComponentsBuilder.replacePath(contextPath).path("/problem/unknown-chatroom").build().toUri());
+ StringBuilder stringBuilder = new StringBuilder();
+ stringBuilder.append(status.getReasonPhrase());
+ stringBuilder.append(" - ");
+ stringBuilder.append(e.getMessage());
+ problem.setTitle(stringBuilder.toString());
+
+ stringBuilder.setLength(0);
+ stringBuilder.append("Chatroom unknown: ");
+ stringBuilder.append(e.getChatroomId());
+ problem.setDetail(stringBuilder.toString());
+
+ problem.setProperty("chatroomId", e.getChatroomId());
+
+ return problem;
+ }
+
@ExceptionHandler(MessageMutationException.class)
public final ProblemDetail handleException(
MessageMutationException e,
stringBuilder.append(" cannot be mutated!");
problem.setDetail(stringBuilder.toString());
- problem.setProperty("mutatedMessage", e.getMutated());
+ problem.setProperty("existingMessage", MessageTo.from(e.getExisting()));
- problem.setProperty("existingMessage", e.getExisting());
+ problem.setProperty("mutatedText", e.getMutatedText());
return problem;
}