Function py_classify_receiver

internal/cbm/extract_channels.c:392–422

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

static const char *py_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;
    }
    /* python-socketio */
    if (strcmp(tail, "sio") == 0 || strcmp(tail, "socketio") == 0 || strcmp(tail, "socket") == 0) {
        return "socketio";
    }
    /* Django Channels */
    if (strcmp(tail, "channel_layer") == 0) {
        return "django_channels";
    }
    /* FastAPI/Starlette WebSocket */
    if (strcmp(tail, "websocket") == 0 || strcmp(tail, "ws") == 0) {
        return "websocket";
    }
    /* kafka-python */
    if (strcmp(tail, "producer") == 0) {
        return "kafka";
    }
    if (strcmp(tail, "consumer") == 0) {
        return "kafka";
    }
    return NULL;
}

/* Table-driven Python method→direction classification.
 * NULL transport matches any transport not matched by earlier rows. */