Function go_process_call

internal/cbm/extract_channels.c:574–626

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

static void go_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, "selector_expression") != 0) {
        return;
    }
    TSNode field = ts_node_child_by_field_name(func, TS_FIELD("field"));
    TSNode operand = ts_node_child_by_field_name(func, TS_FIELD("operand"));
    if (ts_node_is_null(field) || ts_node_is_null(operand)) {
        return;
    }

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

    /* gorilla/nhooyr websocket patterns */
    CBMChannelDirection direction;
    if (strcmp(method, "WriteMessage") == 0 || strcmp(method, "WriteJSON") == 0 ||
        strcmp(method, "Write") == 0) {
        direction = CBM_CHANNEL_EMIT;
    } else if (strcmp(method, "ReadMessage") == 0 || strcmp(method, "ReadJSON") == 0 ||
               strcmp(method, "Read") == 0) {
        direction = CBM_CHANNEL_LISTEN;
    } else {
        return;
    }

    /* Verify receiver looks like a websocket connection */
    char *recv = cbm_node_text(ctx->arena, operand, ctx->source);
    if (!recv) {
        return;
    }
    const char *tail = recv;
    const char *dot = strrchr(tail, '.');
    if (dot) {
        tail = dot + SKIP_ONE;
    }
    if (strcmp(tail, "conn") != 0 && strcmp(tail, "wsConn") != 0 && strcmp(tail, "ws") != 0 &&
        strcmp(tail, "c") != 0 && strcmp(tail, "Conn") != 0 && strcmp(tail, "connection") != 0) {
        return;
    }

    /* Go WebSocket uses connection-level send/receive, not named channels.
     * Use the enclosing function name as a pseudo-channel for cross-repo matching. */
    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_go(CBMExtractCtx *ctx) {
    TSNodeStack stack;