Function java_process_annotation

internal/cbm/extract_channels.c:687–723

Detect Java annotation-based WebSocket listeners: @OnMessage, @MessageMapping */

/* Detect Java annotation-based WebSocket listeners: @OnMessage, @MessageMapping */
static void java_process_annotation(CBMExtractCtx *ctx, TSNode annotation) {
    TSNode name_node = ts_node_child_by_field_name(annotation, TS_FIELD("name"));
    if (ts_node_is_null(name_node)) {
        return;
    }
    char *name = cbm_node_text(ctx->arena, name_node, ctx->source);
    if (!name) {
        return;
    }

    if (strcmp(name, "OnMessage") == 0 || strcmp(name, "OnOpen") == 0 ||
        strcmp(name, "OnClose") == 0) {
        const char *func_name = enclosing_function_qn(ctx, annotation);
        const char *channel_name = func_name ? func_name : "(websocket)";
        push_channel(ctx, channel_name, "websocket", CBM_CHANNEL_LISTEN, annotation);
    } else if (strcmp(name, "MessageMapping") == 0) {
        /* @MessageMapping("/path") — extract the path */
        TSNode args = ts_node_child_by_field_name(annotation, TS_FIELD("arguments"));
        if (!ts_node_is_null(args)) {
            const char *path = extract_channel_name(ctx, args, NULL);
            if (path) {
                push_channel(ctx, path, "spring_websocket", CBM_CHANNEL_LISTEN, annotation);
                return;
            }
        }
        push_channel(ctx, "(spring_ws)", "spring_websocket", CBM_CHANNEL_LISTEN, annotation);
    } else if (strcmp(name, "ServerEndpoint") == 0) {
        TSNode args = ts_node_child_by_field_name(annotation, TS_FIELD("arguments"));
        if (!ts_node_is_null(args)) {
            const char *path = extract_channel_name(ctx, args, NULL);
            if (path) {
                push_channel(ctx, path, "websocket", CBM_CHANNEL_LISTEN, annotation);
                return;
            }
        }
    }
}

static void extract_channels_java(CBMExtractCtx *ctx) {
    TSNodeStack stack;