Function js_process_call

internal/cbm/extract_channels.c:314–368

}

static void js_process_call(CBMExtractCtx *ctx, TSNode call, const chan_const_table_t *consts) {
    TSNode func = ts_node_child_by_field_name(call, TS_FIELD("function"));
    if (ts_node_is_null(func) || strcmp(ts_node_type(func), "member_expression") != 0) {
        return;
    }
    TSNode object = ts_node_child_by_field_name(func, TS_FIELD("object"));
    TSNode property = ts_node_child_by_field_name(func, TS_FIELD("property"));
    if (ts_node_is_null(object) || ts_node_is_null(property)) {
        return;
    }

    char *method = cbm_node_text(ctx->arena, property, ctx->source);
    const char *transport = js_classify_receiver(ctx, object);
    if (!transport) {
        return;
    }

    CBMChannelDirection direction;
    if (strcmp(transport, "kafka") == 0) {
        if (js_is_kafka_send(method)) {
            direction = CBM_CHANNEL_EMIT;
        } else if (js_is_kafka_listen(method)) {
            direction = CBM_CHANNEL_LISTEN;
        } else {
            return;
        }
    } else if (strcmp(transport, "rabbitmq") == 0) {
        if (js_is_amqp_send(method)) {
            direction = CBM_CHANNEL_EMIT;
        } else if (js_is_amqp_listen(method)) {
            direction = CBM_CHANNEL_LISTEN;
        } else {
            return;
        }
    } else {
        /* socketio / event_emitter */
        if (js_is_emit_method(method)) {
            direction = CBM_CHANNEL_EMIT;
        } else if (js_is_listen_method(method)) {
            direction = CBM_CHANNEL_LISTEN;
        } else {
            return;
        }
    }

    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, consts);
    if (!channel_name) {
        return;
    }
    push_channel(ctx, channel_name, transport, direction, call);
}

static void extract_channels_js(CBMExtractCtx *ctx) {
    chan_const_table_t consts = {0};