Function ruby_process_call

internal/cbm/extract_channels.c:815–855

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

static void ruby_process_call(CBMExtractCtx *ctx, TSNode call) {
    const char *kind = ts_node_type(call);
    TSNode method_node;

    if (strcmp(kind, "call") == 0) {
        method_node = ts_node_child_by_field_name(call, TS_FIELD("method"));
    } else {
        return;
    }

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

    /* ActionCable.server.broadcast("channel", data) */
    if (strcmp(method, "broadcast") == 0) {
        TSNode args = ts_node_child_by_field_name(call, TS_FIELD("arguments"));
        if (!ts_node_is_null(args)) {
            const char *channel_name = extract_channel_name(ctx, args, NULL);
            if (channel_name) {
                push_channel(ctx, channel_name, "actioncable", CBM_CHANNEL_EMIT, call);
            }
        }
        return;
    }

    /* stream_from "channel" — listener registration */
    if (strcmp(method, "stream_from") == 0 || strcmp(method, "stream_for") == 0) {
        TSNode args = ts_node_child_by_field_name(call, TS_FIELD("arguments"));
        if (!ts_node_is_null(args)) {
            const char *channel_name = extract_channel_name(ctx, args, NULL);
            if (channel_name) {
                push_channel(ctx, channel_name, "actioncable", CBM_CHANNEL_LISTEN, call);
            }
        }
    }
}

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