Function js_classify_receiver

internal/cbm/extract_channels.c:262–295

Classify receiver for Socket.IO / EventEmitter / WebSocket. */

/* Classify receiver for Socket.IO / EventEmitter / WebSocket. */
static const char *js_classify_receiver(CBMExtractCtx *ctx, TSNode object_node) {
    char *text = cbm_node_text(ctx->arena, object_node, ctx->source);
    if (!text) {
        return NULL;
    }
    const char *tail = text;
    const char *dot = strrchr(tail, '.');
    if (dot) {
        tail = dot + SKIP_ONE;
    }
    /* Socket.IO */
    if (strcmp(tail, "socket") == 0 || strcmp(tail, "io") == 0 || strcmp(tail, "ws") == 0 ||
        strcmp(tail, "client") == 0 || strcmp(tail, "server") == 0) {
        return "socketio";
    }
    /* Node.js EventEmitter */
    if (strcmp(tail, "emitter") == 0 || strcmp(tail, "eventEmitter") == 0 ||
        strcmp(tail, "events") == 0 || strcmp(tail, "bus") == 0 || strcmp(tail, "eventBus") == 0 ||
        strcmp(tail, "pubsub") == 0) {
        return "event_emitter";
    }
    /* Kafka */
    if (strcmp(tail, "producer") == 0) {
        return "kafka";
    }
    if (strcmp(tail, "consumer") == 0) {
        return "kafka";
    }
    /* RabbitMQ / AMQP */
    if (strcmp(tail, "channel") == 0 && !strcmp(text, "channel")) {
        return "rabbitmq";
    }
    return NULL;
}

/* Detect Kafka/RabbitMQ specific send/subscribe patterns. */
static bool js_is_kafka_send(const char *method) {