Function java_process_call

internal/cbm/extract_channels.c:649–684

 * ══════════════════════════════════════════════════════════════════ */

static void java_process_call(CBMExtractCtx *ctx, TSNode call) {
    TSNode func = ts_node_child_by_field_name(call, TS_FIELD("name"));
    TSNode object = ts_node_child_by_field_name(call, TS_FIELD("object"));
    if (ts_node_is_null(func)) {
        return;
    }

    char *method = cbm_node_text(ctx->arena, func, ctx->source);
    if (!method) {
        return;
    }

    /* Spring STOMP: template.convertAndSend("/topic/...", msg) */
    if (strcmp(method, "convertAndSend") == 0 || strcmp(method, "convertAndSendToUser") == 0) {
        TSNode args = ts_node_child_by_field_name(call, TS_FIELD("arguments"));
        if (ts_node_is_null(args)) {
            return;
        }
        const char *channel_name = extract_channel_name(ctx, args, NULL);
        if (channel_name) {
            push_channel(ctx, channel_name, "spring_websocket", CBM_CHANNEL_EMIT, call);
        }
        return;
    }

    /* JSR 356: session.getBasicRemote().sendText(msg) — detect sendText/sendObject */
    if (strcmp(method, "sendText") == 0 || strcmp(method, "sendObject") == 0 ||
        strcmp(method, "sendBinary") == 0) {
        const char *func_name = enclosing_function_qn(ctx, call);
        const char *channel_name = func_name ? func_name : "(websocket)";
        push_channel(ctx, channel_name, "websocket", CBM_CHANNEL_EMIT, call);
        return;
    }

    (void)object;
}

/* Detect Java annotation-based WebSocket listeners: @OnMessage, @MessageMapping */
static void java_process_annotation(CBMExtractCtx *ctx, TSNode annotation) {