/****************************************************************************
**
** Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies).
** All rights reserved.
** Contact: Nokia Corporation (qt-info@nokia.com)
**
** This file is part of the QtNetwork module of the Qt Toolkit.
**
** $QT_BEGIN_LICENSE:LGPL$
** No Commercial Usage
** This file contains pre-release code and may not be distributed.
** You may use this file in accordance with the terms and conditions
** contained in the Technology Preview License Agreement accompanying
** this package.
**
** GNU Lesser General Public License Usage
** Alternatively, this file may be used under the terms of the GNU Lesser
** General Public License version 2.1 as published by the Free Software
** Foundation and appearing in the file LICENSE.LGPL included in the
** packaging of this file.  Please review the following information to
** ensure the GNU Lesser General Public License version 2.1 requirements
** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
**
** In addition, as a special exception, Nokia gives you certain additional
** rights.  These rights are described in the Nokia Qt LGPL Exception
** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
**
** If you have questions regarding the use of this file, please contact
** Nokia at qt-info@nokia.com.
**
**
**
**
**
**
**
**
** $QT_END_LICENSE$
**
****************************************************************************/

#include "qnetworkconfigmanager_p.h"
#include "qbearerplugin.h"

#include <QtCore/private/qfactoryloader_p.h>

#include <QtCore/qdebug.h>
#include <QtCore/qtimer.h>
#include <QtCore/qstringlist.h>

QT_BEGIN_NAMESPACE

Q_GLOBAL_STATIC_WITH_ARGS(QFactoryLoader, loader,
                          (QBearerEngineFactoryInterface_iid, QLatin1String("/bearer")))

QNetworkConfigurationManagerPrivate::~QNetworkConfigurationManagerPrivate()
{
    while (!sessionEngines.isEmpty())
        delete sessionEngines.takeFirst();
}

void QNetworkConfigurationManagerPrivate::registerPlatformCapabilities()
{
    capFlags = QNetworkConfigurationManager::ForcedRoaming;
}

void QNetworkConfigurationManagerPrivate::configurationAdded(QNetworkConfigurationPrivatePointer ptr)
{
    if (!firstUpdate) {
        QNetworkConfiguration item;
        item.d = ptr;
        emit configurationAdded(item);
    }

    if (ptr->state == QNetworkConfiguration::Active) {
        ++onlineConfigurations;
        if (!firstUpdate && onlineConfigurations == 1)
            emit onlineStateChanged(true);
    }
}

void QNetworkConfigurationManagerPrivate::configurationRemoved(QNetworkConfigurationPrivatePointer ptr)
{
    ptr.data()->isValid = false;

    if (!firstUpdate) {
        QNetworkConfiguration item;
        item.d = ptr;
        emit configurationRemoved(item);
    }

    if (ptr.data()->state == QNetworkConfiguration::Active) {
        --onlineConfigurations;
        if (!firstUpdate && onlineConfigurations == 0)
            emit onlineStateChanged(false);
    }
}

void QNetworkConfigurationManagerPrivate::configurationChanged(QNetworkConfigurationPrivatePointer ptr)
{
    if (!firstUpdate) {
        QNetworkConfiguration item;
        item.d = ptr;
        emit configurationChanged(item);
    }

    qDebug() << "Need to recalculate online state.";
    QNetworkConfiguration::StateFlags oldState = ptr->state;

    if (ptr->state == QNetworkConfiguration::Active && oldState != ptr->state) {
        // configuration went online
        ++onlineConfigurations;
        if (!firstUpdate && onlineConfigurations == 1)
            emit onlineStateChanged(true);
    } else if (ptr->state != QNetworkConfiguration::Active && oldState == QNetworkConfiguration::Active) {
        // configuration went offline
        --onlineConfigurations;
        if (!firstUpdate && onlineConfigurations == 0)
            emit onlineStateChanged(false);
    }
}

void QNetworkConfigurationManagerPrivate::updateInternetServiceConfiguration()
{
#if 0
    if (!generic->snapConfigurations.contains(QLatin1String("Internet Service Network"))) {
        QNetworkConfigurationPrivate *serviceNetwork = new QNetworkConfigurationPrivate;
        serviceNetwork->name = tr("Internet");
        serviceNetwork->isValid = true;
        serviceNetwork->id = QLatin1String("Internet Service Network");
        serviceNetwork->state = QNetworkConfiguration::Defined;
        serviceNetwork->type = QNetworkConfiguration::ServiceNetwork;

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr(serviceNetwork);

        generic->snapConfigurations.insert(serviceNetwork->id, ptr);

        if (!firstUpdate) {
            QNetworkConfiguration item;
            item.d = ptr;
            emit configurationAdded(item);
        }
    }

    QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr =
        generic->snapConfigurations.value(QLatin1String("Internet Service Network"));

    QList<QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> > serviceNetworkMembers;

    QHash<QString, QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> >::const_iterator i =
        generic->accessPointConfigurations.constBegin();

    QNetworkConfiguration::StateFlags state = QNetworkConfiguration::Defined;
    while (i != generic->accessPointConfigurations.constEnd()) {
        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> child = i.value();

        if (child.data()->internet && ((child.data()->state & QNetworkConfiguration::Defined)
                    == QNetworkConfiguration::Defined)) {
            serviceNetworkMembers.append(child);

            state |= child.data()->state;
        }

        ++i;
    }


    if (ptr.data()->state != state || ptr.data()->serviceNetworkMembers != serviceNetworkMembers) {
        ptr.data()->state = state;
        ptr.data()->serviceNetworkMembers = serviceNetworkMembers;

        QNetworkConfiguration item;
        item.d = ptr;
        emit configurationChanged(item);
    }
#endif
}

void QNetworkConfigurationManagerPrivate::updateConfigurations()
{
    if (firstUpdate) {
        onlineConfigurations = 0;

        QFactoryLoader *l = loader();
        QStringList keys = l->keys();

        if (keys.contains(QLatin1String("corewlan"))) {
            QBearerEnginePlugin *coreWlanPlugin =
                qobject_cast<QBearerEnginePlugin *>(l->instance(QLatin1String("corewlan")));
            if (coreWlanPlugin) {
                QNetworkSessionEngine *coreWifi = coreWlanPlugin->create(QLatin1String("corewlan"));
                if (coreWifi) {
                    sessionEngines.append(coreWifi);
                }
            }
        }

        if (keys.contains(QLatin1String("networkmanager"))) {
            QBearerEnginePlugin *nmPlugin =
                qobject_cast<QBearerEnginePlugin *>(l->instance(QLatin1String("networkmanager")));
            if (nmPlugin) {
                QNetworkSessionEngine *nmWifi = nmPlugin->create(QLatin1String("networkmanager"));
                if (nmWifi) {
                    sessionEngines.append(nmWifi);
                }
            }
        }

        if (keys.contains(QLatin1String("generic"))) {
            QBearerEnginePlugin *genericPlugin =
                qobject_cast<QBearerEnginePlugin *>(l->instance(QLatin1String("generic")));
            if (genericPlugin) {
                QNetworkSessionEngine *generic = genericPlugin->create(QLatin1String("generic"));
                if (generic) {
                    sessionEngines.append(generic);
                    connect(generic, SIGNAL(updateCompleted()),
                            this, SIGNAL(configurationUpdateComplete()));
                    connect(generic, SIGNAL(configurationAdded(QNetworkConfigurationPrivatePointer)),
                            this, SLOT(configurationAdded(QNetworkConfigurationPrivatePointer)));
                    connect(generic, SIGNAL(configurationRemoved(QNetworkConfigurationPrivatePointer)),
                            this, SLOT(configurationRemoved(QNetworkConfigurationPrivatePointer)));
                    connect(generic, SIGNAL(configurationChanged(QNetworkConfigurationPrivatePointer)),
                            this, SLOT(configurationChanged(QNetworkConfigurationPrivatePointer)));
                }
            }
        }

        if (keys.contains(QLatin1String("nla"))) {
            QBearerEnginePlugin *nlaPlugin =
                qobject_cast<QBearerEnginePlugin *>(l->instance(QLatin1String("nla")));
            if (nlaPlugin) {
                QNetworkSessionEngine *nla = nlaPlugin->create(QLatin1String("nla"));
                if (nla) {
                    sessionEngines.append(nla);
                }
            }
        }

        if (keys.contains(QLatin1String("nativewifi"))) {
            QBearerEnginePlugin *nativeWifiPlugin =
                qobject_cast<QBearerEnginePlugin *>(l->instance(QLatin1String("nativewifi")));
            if (nativeWifiPlugin) {
                QNetworkSessionEngine *nativeWifi = nativeWifiPlugin->create(QLatin1String("nativewifi"));
                if (nativeWifi) {
                    sessionEngines.append(nativeWifi);

                    capFlags |= QNetworkConfigurationManager::CanStartAndStopInterfaces;
                }
            }
        }
    }

    QNetworkSessionEngine *engine = qobject_cast<QNetworkSessionEngine *>(sender());
    if (!updatingEngines.isEmpty() && engine) {
        int index = sessionEngines.indexOf(engine);
        if (index >= 0)
            updatingEngines.remove(index);
    }

    if (updating && updatingEngines.isEmpty()) {
        updating = false;
        emit configurationUpdateComplete();
    }

    if (firstUpdate)
        firstUpdate = false;
}

/*!
    Returns the first active configuration found, if one exists; otherwise returns the first
    discovered configuration found, if one exists; otherwise returns an empty configuration.

    \internal
*/
QNetworkConfiguration QNetworkConfigurationManagerPrivate::defaultConfiguration()
{
    QNetworkConfigurationPrivatePointer firstActive;
    QNetworkConfigurationPrivatePointer firstDiscovered;

    foreach (QNetworkSessionEngine *engine, sessionEngines) {
        QHash<QString, QNetworkConfigurationPrivatePointer>::const_iterator i =
                engine->accessPointConfigurations.constBegin();

        while (i != engine->accessPointConfigurations.constEnd()) {
            QNetworkConfigurationPrivatePointer priv = i.value();

            if (!firstActive && priv->isValid &&
                (priv->state & QNetworkConfiguration::Active) == QNetworkConfiguration::Active)
                firstActive = priv;
            if (!firstDiscovered && priv->isValid &&
                (priv->state & QNetworkConfiguration::Discovered) == QNetworkConfiguration::Discovered)
                firstDiscovered = priv;

            ++i;
        }
    }

    QNetworkConfiguration item;

    if (firstActive)
        item.d = firstActive;
    else if (firstDiscovered)
        item.d = firstDiscovered;

    return item;
}

void QNetworkConfigurationManagerPrivate::performAsyncConfigurationUpdate()
{
    updating = true;

    for (int i = 0; i < sessionEngines.count(); ++i) {
        updatingEngines.insert(i);
        sessionEngines.at(i)->requestUpdate();
    }
}

QT_END_NAMESPACE