Method acceptClients

src/fl/net/http/stream_server.cpp.hpp:65–116

}

void HttpStreamServer::acceptClients() {
    if (!isConnected()) {
        return;
    }

    // Accept new clients (non-blocking)
    mNativeServer->acceptClients();

    // Get list of all client IDs
    fl::vector<u32> clientIds = mNativeServer->getClientIds();

    // Process each client's HTTP header if not already done
    for (u32 clientId : clientIds) {
        ClientState* state = getOrCreateClientState(clientId);
        if (!state) {
            continue;
        }

        // If HTTP headers not exchanged yet, do it now
        if (!state->httpHeaderReceived) {
            if (readHttpRequestHeader(clientId)) {
                // Send HTTP response header
                if (!sendHttpResponseHeader(clientId)) {
                    // Failed to send response, disconnect client
                    disconnectClient(clientId);
                }
            }
        }
    }

    // Clean up disconnected clients
    fl::vector<u32> activeClientIds = mNativeServer->getClientIds();
    fl::vector<u32> toRemove;

    for (auto& pair : mClientStates) {
        u32 clientId = pair.first;
        bool found = false;
        for (u32 activeId : activeClientIds) {
            if (activeId == clientId) {
                found = true;
                break;
            }
        }
        if (!found) {
            toRemove.push_back(clientId);
        }
    }

    for (u32 clientId : toRemove) {
        removeClientState(clientId);
    }
}

size_t HttpStreamServer::getClientCount() const {
    return mNativeServer ? mNativeServer->getClientCount() : 0;