Function rust_process_call

internal/cbm/extract_channels.c:983–1033

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

static void rust_process_call(CBMExtractCtx *ctx, TSNode call) {
    TSNode func = ts_node_child_by_field_name(call, TS_FIELD("function"));
    if (ts_node_is_null(func)) {
        return;
    }
    const char *fk = ts_node_type(func);
    if (strcmp(fk, "field_expression") != 0) {
        return;
    }
    TSNode field = ts_node_child_by_field_name(func, TS_FIELD("field"));
    TSNode value = ts_node_child_by_field_name(func, TS_FIELD("value"));
    if (ts_node_is_null(field) || ts_node_is_null(value)) {
        return;
    }

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

    CBMChannelDirection direction;
    if (strcmp(method, "send") == 0 || strcmp(method, "send_all") == 0 ||
        strcmp(method, "feed") == 0) {
        direction = CBM_CHANNEL_EMIT;
    } else if (strcmp(method, "next") == 0 || strcmp(method, "try_next") == 0) {
        direction = CBM_CHANNEL_LISTEN;
    } else {
        return;
    }

    /* Verify receiver looks like a websocket sink/stream */
    char *recv = cbm_node_text(ctx->arena, value, ctx->source);
    if (!recv) {
        return;
    }
    const char *tail = recv;
    const char *dot = strrchr(tail, '.');
    if (dot) {
        tail = dot + SKIP_ONE;
    }
    if (strcmp(tail, "sink") != 0 && strcmp(tail, "ws_sender") != 0 &&
        strcmp(tail, "writer") != 0 && strcmp(tail, "write") != 0 && strcmp(tail, "stream") != 0 &&
        strcmp(tail, "ws_receiver") != 0 && strcmp(tail, "reader") != 0 &&
        strcmp(tail, "read") != 0 && strcmp(tail, "ws_stream") != 0 && strcmp(tail, "ws") != 0) {
        return;
    }

    const char *func_name = enclosing_function_qn(ctx, call);
    const char *channel_name = func_name ? func_name : "(websocket)";
    push_channel(ctx, channel_name, "websocket", direction, call);
}

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