Compare commits

..

1 commit

Author SHA1 Message Date
52616e6a6a
NOTICKET: Setup and Sepcify Websocket Structure
All checks were successful
Quality Check / Validate OAS (push) Successful in 37s
Quality Check / Validate OAS (pull_request) Successful in 36s
Quality Check / Linting (push) Successful in 1m14s
Quality Check / Testing (push) Successful in 1m17s
Quality Check / Static Analysis (push) Successful in 1m22s
Quality Check / Linting (pull_request) Successful in 1m7s
Quality Check / Static Analysis (pull_request) Successful in 1m11s
Quality Check / Testing (pull_request) Successful in 45s
2025-02-17 11:43:10 +01:00
3 changed files with 6 additions and 5 deletions

View file

@ -22,12 +22,11 @@ public class ConnectionWebsocketHandler extends JsonWebsocketHandler {
protected void handleTextMessage(WebSocketSession session, TextMessage message) {
try{
String payload = message.getPayload();
switch ( objectMapper.readTree(payload).get("$id").asText().toLowerCase()) {
case "requestconnectiontoken" -> handleRequestConnectionToken(session, payload);
switch ( objectMapper.readTree(payload).get("$id").asText()) {
case RequestConnectionTokenMessage.MESSAGE_ID -> handleRequestConnectionToken(session, payload);
default -> this.closeSession(session, CloseStatus.BAD_DATA);
}
} catch (Exception exception) {
System.out.println(exception.getMessage());
} catch (Exception ignored) {
this.closeSession(session, CloseStatus.BAD_DATA);
}
}

View file

@ -8,6 +8,8 @@ import lombok.*;
@Data
@NotNull
public class RequestConnectionTokenMessage {
public static final String MESSAGE_ID = "RequestConnectionToken";
@JsonProperty("$id")
private String messageId;
private Channel channel;

View file

@ -7,7 +7,7 @@ info:
Because of the limitations of Async API, we expect that the actual json,
which is send as payload to always contain a field called `$id` with
the corresponding `messageId`. <br>
The `messageId` should be handled case insensitive.
The `messageId` should be handled case sensitive.
defaultContentType: application/json
servers:
localhost: