codeql/java/ql/test/library-tests/frameworks/micronaut/MicronautWebSocketTest.java

import io.micronaut.websocket.annotation.*;
import io.micronaut.websocket.CloseReason;
import io.micronaut.websocket.WebSocketSession;

@ServerWebSocket("/chat/{room}")
class MicronautWebSocketTest {

    void sink(Object o) {}

    @OnMessage
    void onMessage(String message, WebSocketSession session) {
        sink(message); // $hasTaintFlow
    }

    @OnOpen
    void onOpen(String room, WebSocketSession session) {
        sink(room); // $hasTaintFlow
    }

    @OnClose
    void onClose(String room, CloseReason reason, WebSocketSession session) {
        sink(room); // $hasTaintFlow
        sink(reason);
        sink(session);
    }
}