/****************************************************************************

**

** Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies).

** All rights reserved.

** Contact: Nokia Corporation (qt-info@nokia.com)

**

** This file is part of the Qt Mobility Components.

**

** $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_s60_p.h"

#include <commdb.h>

#include <cdbcols.h>

#include <d32dbms.h>

#include <nifvar.h>

#include <QTimer>

#include <QTime>  // For randgen seeding

#include <QtCore> // For randgen seeding

#ifdef QT_BEARERMGMT_SYMBIAN_DEBUG

#include <QDebug>

#endif

#ifdef SNAP_FUNCTIONALITY_AVAILABLE

    #include <cmdestination.h>

    #include <cmconnectionmethod.h>

    #include <cmconnectionmethoddef.h>

    #include <cmpluginwlandef.h>

    #include <cmpluginpacketdatadef.h>

    #include <cmplugindialcommondefs.h>

#else

    #include <apaccesspointitem.h>

    #include <apdatahandler.h>

    #include <aputils.h> 

#endif

QTM_BEGIN_NAMESPACE

static const int KUserChoiceIAPId = 0;

QNetworkConfigurationManagerPrivate::QNetworkConfigurationManagerPrivate()

    : QObject(0), CActive(CActive::EPriorityHigh), capFlags(0),

    iFirstUpdate(true), iInitOk(true), iUpdatePending(false),

    iTimeToWait(0)

{

    CActiveScheduler::Add(this);

    // Seed the randomgenerator

    qsrand(QTime(0,0,0).secsTo(QTime::currentTime()) + QCoreApplication::applicationPid());

    registerPlatformCapabilities();

    TRAPD(error, ipCommsDB = CCommsDatabase::NewL(EDatabaseTypeIAP));

    if (error != KErrNone) {

        iInitOk = false;

        return;

    }

    TRAP_IGNORE(iConnectionMonitor.ConnectL());

#ifdef SNAP_FUNCTIONALITY_AVAILABLE    

    TRAP_IGNORE(iConnectionMonitor.SetUintAttribute(EBearerIdAll, 0, KBearerGroupThreshold, 1));

#endif    

    TRAP_IGNORE(iConnectionMonitor.NotifyEventL(*this));

#ifdef SNAP_FUNCTIONALITY_AVAILABLE    

    TRAP(error, iCmManager.OpenL());

    if (error != KErrNone) {

        iInitOk = false;

        return;

    }

#endif

    QNetworkConfigurationPrivate* cpPriv = new QNetworkConfigurationPrivate();

    cpPriv->name = "UserChoice";

    cpPriv->bearer = QNetworkConfigurationPrivate::BearerUnknown;

    cpPriv->state = QNetworkConfiguration::Discovered;

    cpPriv->isValid = true;

    cpPriv->id = QString::number(qHash(KUserChoiceIAPId));

    cpPriv->numericId = KUserChoiceIAPId;

    cpPriv->connectionId = 0;

    cpPriv->type = QNetworkConfiguration::UserChoice;

    cpPriv->purpose = QNetworkConfiguration::UnknownPurpose;

    cpPriv->roamingSupported = false;

    cpPriv->manager = this;

    QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr(cpPriv);

    userChoiceConfigurations.insert(cpPriv->id, ptr);

    updateConfigurations();

    updateStatesToSnaps();

    updateAvailableAccessPoints(); // On first time updates synchronously (without WLAN scans)

    // Start monitoring IAP and/or SNAP changes in Symbian CommsDB

    startCommsDatabaseNotifications();

    iFirstUpdate = false;

}

QNetworkConfigurationManagerPrivate::~QNetworkConfigurationManagerPrivate() 

{

    Cancel();

    foreach (const QString &oldIface, snapConfigurations.keys()) {

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv = snapConfigurations.take(oldIface);

        priv->isValid = false;

        priv->id.clear();

    }

    foreach (const QString &oldIface, accessPointConfigurations.keys()) {

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv = accessPointConfigurations.take(oldIface);

        priv->isValid = false;

        priv->id.clear();

    }

    foreach (const QString &oldIface, userChoiceConfigurations.keys()) {

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv = userChoiceConfigurations.take(oldIface);

        priv->isValid = false;

        priv->id.clear();

        priv->manager = 0;

    }

    iConnectionMonitor.CancelNotifications();

    iConnectionMonitor.Close();

#ifdef SNAP_FUNCTIONALITY_AVAILABLE    

    iCmManager.Close();

#endif

    delete ipAccessPointsAvailabilityScanner;

    // CCommsDatabase destructor uses cleanup stack. Since QNetworkConfigurationManager

    // is a global static, but the time we are here, E32Main() has been exited already and

    // the thread's default cleanup stack has been deleted. Without this line, a

    // 'E32USER-CBase 69' -panic will occur.

    CTrapCleanup* cleanup = CTrapCleanup::New();

    delete ipCommsDB;

    delete cleanup;

}

void QNetworkConfigurationManagerPrivate::delayedConfigurationUpdate()

{

    if (iUpdatePending) {

#ifdef QT_BEARERMGMT_SYMBIAN_DEBUG

        qDebug("QNCM delayed configuration update (ECommit or ERecover occurred).");

#endif

        TRAPD(error, updateConfigurationsL());

        if (error == KErrNone) {

            updateStatesToSnaps();

        }

        iUpdatePending = false;

        // Start monitoring again.

        if (!IsActive()) {

            SetActive();

            // Start waiting for new notification

            ipCommsDB->RequestNotification(iStatus);

        }

    }

}

void QNetworkConfigurationManagerPrivate::registerPlatformCapabilities()

{

    capFlags |= QNetworkConfigurationManager::CanStartAndStopInterfaces;

    capFlags |= QNetworkConfigurationManager::DirectConnectionRouting;

    capFlags |= QNetworkConfigurationManager::SystemSessionSupport;

#ifdef SNAP_FUNCTIONALITY_AVAILABLE

    capFlags |= QNetworkConfigurationManager::ApplicationLevelRoaming;

    capFlags |= QNetworkConfigurationManager::ForcedRoaming;

#endif

    capFlags |= QNetworkConfigurationManager::DataStatistics;

    capFlags |= QNetworkConfigurationManager::NetworkSessionRequired;

}

void QNetworkConfigurationManagerPrivate::performAsyncConfigurationUpdate()

{

    if (!iInitOk || iUpdateGoingOn) {

        return;

    }

    iUpdateGoingOn = true;

    stopCommsDatabaseNotifications();

    updateConfigurations(); // Synchronous call

    updateAvailableAccessPoints(); // Asynchronous call

}

void QNetworkConfigurationManagerPrivate::updateConfigurations()

{

    if (!iInitOk) {

        return;

    }

    TRAP_IGNORE(updateConfigurationsL());

}

void QNetworkConfigurationManagerPrivate::updateConfigurationsL()

{

    QList<QString> knownConfigs = accessPointConfigurations.keys();

    QList<QString> knownSnapConfigs = snapConfigurations.keys();

    // S60 version is >= Series60 3rd Edition Feature Pack 2

    TInt error = KErrNone;

    // Loop through all IAPs

    RArray<TUint32> connectionMethods; // IAPs

    CleanupClosePushL(connectionMethods);

    iCmManager.ConnectionMethodL(connectionMethods);

    for(int i = 0; i < connectionMethods.Count(); i++) {

        RCmConnectionMethod connectionMethod = iCmManager.ConnectionMethodL(connectionMethods[i]);

        CleanupClosePushL(connectionMethod);

        TUint32 iapId = connectionMethod.GetIntAttributeL(CMManager::ECmIapId);

        QString ident = QT_BEARERMGMT_CONFIGURATION_IAP_PREFIX+QString::number(qHash(iapId));

        if (accessPointConfigurations.contains(ident)) {

            knownConfigs.removeOne(ident);

        } else {

            QNetworkConfigurationPrivate* cpPriv = NULL;

            TRAP(error, cpPriv = configFromConnectionMethodL(connectionMethod));

            if (error == KErrNone) {

                QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr(cpPriv);

                accessPointConfigurations.insert(cpPriv->id, ptr);

                if (!iFirstUpdate) {

                    QNetworkConfiguration item;

                    item.d = ptr;

                    // Emit configuration added. Connected slots may throw execptions

                    // which propagate here --> must be converted to leaves (standard

                    // std::exception would cause any TRAP trapping this function to terminate

                    // program).

                    QT_TRYCATCH_LEAVING(emit configurationAdded(item));

                }

            }

        }

        CleanupStack::PopAndDestroy(&connectionMethod);

    }

    CleanupStack::PopAndDestroy(&connectionMethods);

    // Loop through all SNAPs

    RArray<TUint32> destinations;

    CleanupClosePushL(destinations);

    iCmManager.AllDestinationsL(destinations);

    for(int i = 0; i < destinations.Count(); i++) {

        RCmDestination destination;

        CleanupClosePushL(destination);

        QString ident = QT_BEARERMGMT_CONFIGURATION_SNAP_PREFIX+QString::number(qHash(destination.Id()));

        if (snapConfigurations.contains(ident)) {

            knownSnapConfigs.removeOne(ident);

        } else {

            QNetworkConfigurationPrivate* cpPriv = new QNetworkConfigurationPrivate();

            HBufC *pName = destination.NameLC();

            QT_TRYCATCH_LEAVING(cpPriv->name = QString::fromUtf16(pName->Ptr(),pName->Length()));

            CleanupStack::PopAndDestroy(pName);

            pName = NULL;

            cpPriv->isValid = true;

            cpPriv->id = ident;

            cpPriv->numericId = destination.Id();

            cpPriv->connectionId = 0;

            cpPriv->state = QNetworkConfiguration::Defined;

            cpPriv->type = QNetworkConfiguration::ServiceNetwork;

            cpPriv->purpose = QNetworkConfiguration::UnknownPurpose;

            cpPriv->roamingSupported = false;

            cpPriv->manager = this;

            QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr(cpPriv);

            snapConfigurations.insert(ident, ptr);

            if (!iFirstUpdate) {

                QNetworkConfiguration item;

                item.d = ptr;

                QT_TRYCATCH_LEAVING(emit configurationAdded(item));

            }

        }

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> privSNAP = snapConfigurations.value(ident);

        for (int j=0; j < destination.ConnectionMethodCount(); j++) {

            RCmConnectionMethod connectionMethod = destination.ConnectionMethodL(j);

            CleanupClosePushL(connectionMethod);

            TUint32 iapId = connectionMethod.GetIntAttributeL(CMManager::ECmIapId);

            QString iface = QT_BEARERMGMT_CONFIGURATION_IAP_PREFIX+QString::number(qHash(iapId));

            // Check that IAP can be found from accessPointConfigurations list

            QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv = accessPointConfigurations.value(iface);

            if (priv.data() == 0) {

                QNetworkConfigurationPrivate* cpPriv = NULL; 

                TRAP(error, cpPriv = configFromConnectionMethodL(connectionMethod));

                if (error == KErrNone) {

                    QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr(cpPriv);

                    ptr.data()->serviceNetworkPtr = privSNAP;

                    accessPointConfigurations.insert(cpPriv->id, ptr);

                    if (!iFirstUpdate) {

                        QNetworkConfiguration item;

                        item.d = ptr;

                        QT_TRYCATCH_LEAVING(emit configurationAdded(item));

                    }

                }

            } else {

                knownConfigs.removeOne(iface);

                // Check that IAP can be found from related SNAP's configuration list

                bool iapFound = false;

                for (int i=0; i<privSNAP->serviceNetworkMembers.count(); i++) {

                    if (privSNAP->serviceNetworkMembers[i]->numericId == iapId) {

                        iapFound = true;

                        break;

                    }

                }

                if (!iapFound) {

                    priv.data()->serviceNetworkPtr = privSNAP; 

                    privSNAP->serviceNetworkMembers.append(priv);

                }

            }

            CleanupStack::PopAndDestroy(&connectionMethod);

        }

        if (privSNAP->serviceNetworkMembers.count() > 1) {

            // Roaming is supported only if SNAP contains more than one IAP

            privSNAP->roamingSupported = true;

        }

        CleanupStack::PopAndDestroy(&destination);

    }

    CleanupStack::PopAndDestroy(&destinations);

#else

    // S60 version is < Series60 3rd Edition Feature Pack 2

    CCommsDbTableView* pDbTView = ipCommsDB->OpenTableLC(TPtrC(IAP));

    // Loop through all IAPs

    TUint32 apId = 0;

    TInt retVal = pDbTView->GotoFirstRecord();

    while (retVal == KErrNone) {

        pDbTView->ReadUintL(TPtrC(COMMDB_ID), apId);

        QString ident = QT_BEARERMGMT_CONFIGURATION_IAP_PREFIX+QString::number(qHash(apId));

        if (accessPointConfigurations.contains(ident)) {

            knownConfigs.removeOne(ident);

        } else {

            QNetworkConfigurationPrivate* cpPriv = new QNetworkConfigurationPrivate();

            if (readNetworkConfigurationValuesFromCommsDb(apId, cpPriv)) {

                QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> ptr(cpPriv);

                accessPointConfigurations.insert(ident, ptr);

                if (!iFirstUpdate) {

                    QNetworkConfiguration item;

                    item.d = ptr;

                    QT_TRYCATCH_LEAVING(emit configurationAdded(item));

                }

            } else {

                delete cpPriv;

            }

        }

        retVal = pDbTView->GotoNextRecord();

    }

    CleanupStack::PopAndDestroy(pDbTView);

#endif

    QT_TRYCATCH_LEAVING(updateActiveAccessPoints());

    foreach (const QString &oldIface, knownConfigs) {

        //remove non existing IAP

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv = accessPointConfigurations.take(oldIface);

        priv->isValid = false;

        if (!iFirstUpdate) {

            QNetworkConfiguration item;

            item.d = priv;

            QT_TRYCATCH_LEAVING(emit configurationRemoved(item));

        }

        // Remove non existing IAP from SNAPs

        foreach (const QString &iface, snapConfigurations.keys()) {

            QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv2 = snapConfigurations.value(iface);

            // => Check if one of the IAPs of the SNAP is active

            for (int i=0; i<priv2->serviceNetworkMembers.count(); i++) {

                if (priv2->serviceNetworkMembers[i]->numericId == priv->numericId) {

                    priv2->serviceNetworkMembers.removeAt(i);

                    break;

                }

            }

        }    

    }

    foreach (const QString &oldIface, knownSnapConfigs) {

        //remove non existing SNAPs

        QExplicitlySharedDataPointer<QNetworkConfigurationPrivate> priv = snapConfigurations.take(oldIface);

        priv->isValid = false;

        if (!iFirstUpdate) {

            QNetworkConfiguration item;

            item.d = priv;

            QT_TRYCATCH_LEAVING(emit configurationRemoved(item));

        }

    }

}

#ifdef SNAP_FUNCTIONALITY_AVAILABLE

QNetworkConfigurationPrivate* QNetworkConfigurationManagerPrivate::configFromConnectionMethodL(

        RCmConnectionMethod& connectionMethod)

{

    QNetworkConfigurationPrivate* cpPriv = new QNetworkConfigurationPrivate();

    TUint32 iapId = connectionMethod.GetIntAttributeL(CMManager::ECmIapId);

    QString ident = QT_BEARERMGMT_CONFIGURATION_IAP_PREFIX+QString::number(qHash(iapId));

    HBufC *pName = connectionMethod.GetStringAttributeL(CMManager::ECmName);

    CleanupStack::PushL(pName);

    QT_TRYCATCH_LEAVING(cpPriv->name = QString::fromUtf16(pName->Ptr(),pName->Length()));

    CleanupStack::PopAndDestroy(pName);

    pName = NULL;

    TUint32 bearerId = connectionMethod.GetIntAttributeL(CMManager::ECmCommsDBBearerType);

    switch (bearerId) {

    case KCommDbBearerCSD:

        cpPriv->bearer = QNetworkConfigurationPrivate::Bearer2G;

        break;

    case KCommDbBearerWcdma:

        cpPriv->bearer = QNetworkConfigurationPrivate::BearerWCDMA;

        break;

    case KCommDbBearerLAN:

        cpPriv->bearer = QNetworkConfigurationPrivate::BearerEthernet;

        break;

    case KCommDbBearerVirtual:

        cpPriv->bearer = QNetworkConfigurationPrivate::BearerUnknown;

        break;

    case KCommDbBearerPAN:

        cpPriv->bearer = QNetworkConfigurationPrivate::BearerUnknown;

        break;

    case KCommDbBearerWLAN:

        cpPriv->bearer = QNetworkConfigurationPrivate::BearerWLAN;

        break;

    default:

        cpPriv->bearer = QNetworkConfigurationPrivate::BearerUnknown;

        break;

    }

    TInt error = KErrNone;

    TUint32 bearerType = connectionMethod.GetIntAttributeL(CMManager::ECmBearerType);

    switch (bearerType) {

    case KUidPacketDataBearerType:

        // "Packet data" Bearer => Mapping is done using "Access point name"

        TRAP(error, pName = connectionMethod.GetStringAttributeL(CMManager::EPacketDataAPName));

        break;

    case KUidWlanBearerType:

        // "Wireless LAN" Bearer => Mapping is done using "WLAN network name" = SSID

        TRAP(error, pName = connectionMethod.GetStringAttributeL(CMManager::EWlanSSID));

        break;

    }

    if (!pName) {

        // "Data call" Bearer or "High Speed (GSM)" Bearer => Mapping is done using "Dial-up number"

        TRAP(error, pName = connectionMethod.GetStringAttributeL(CMManager::EDialDefaultTelNum));

    }

    if (error == KErrNone && pName) {

        CleanupStack::PushL(pName);

        QT_TRYCATCH_LEAVING(cpPriv->mappingName = QString::fromUtf16(pName->Ptr(),pName->Length()));

        CleanupStack::PopAndDestroy(pName);

        pName = NULL;

    }

    cpPriv->state = QNetworkConfiguration::Defined;

    TBool isConnected = connectionMethod.GetBoolAttributeL(CMManager::ECmConnected);

    if (isConnected) {

        cpPriv->state = QNetworkConfiguration::Active;

    }

    cpPriv->isValid = true;

    cpPriv->id = ident;

    cpPriv->numericId = iapId;

    cpPriv->connectionId = 0;

    cpPriv->type = QNetworkConfiguration::InternetAccessPoint;

    cpPriv->purpose = QNetworkConfiguration::UnknownPurpose;

    cpPriv->roamingSupported = false;

    cpPriv->manager = this;

    return cpPriv;

}

#else

bool QNetworkConfigurationManagerPrivate::readNetworkConfigurationValuesFromCommsDb(

        TUint32 aApId, QNetworkConfigurationPrivate* apNetworkConfiguration)

{

    TRAPD(error, readNetworkConfigurationValuesFromCommsDbL(aApId,apNetworkConfiguration));

    if (error != KErrNone) {