/*

* Copyright (c) 2006-2007 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:      UPnP Connection Monitor class implementation.

*

*/

// INCLUDE FILES

#include <nifvar.h>

#include "mdhconnectionmonitor.h"

// ========================== MEMBER FUNCTIONS ===============================

// ---------------------------------------------------------------------------

// CMdHConnectionMonitor::CMdHConnectionMonitor

// C++ default constructor can NOT contain any code, that

// might leave.

// ---------------------------------------------------------------------------

//

CMdHConnectionMonitor::CMdHConnectionMonitor(

    MMdHConnectionMonitorObserver& aObserver, TInt aAccessPoint ) :

    iObserver( aObserver ),

    iAccessPoint( aAccessPoint )

    {

    }

// ---------------------------------------------------------------------------

// CMdHConnectionMonitor::NewL

// Two-phased constructor.

// ---------------------------------------------------------------------------

//

EXPORT_C CMdHConnectionMonitor* CMdHConnectionMonitor::NewL(

    MMdHConnectionMonitorObserver& aObserver, TInt aAccessPoint )

    {

    CMdHConnectionMonitor* self = new(ELeave) CMdHConnectionMonitor(

        aObserver, aAccessPoint );

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;    

    }

// ---------------------------------------------------------------------------

// CMdHConnectionMonitor::ConstructL

// Symbian 2nd phase constructor can leave.

// ---------------------------------------------------------------------------

//

void CMdHConnectionMonitor::ConstructL()

    {    

    iConnectionMonitor.ConnectL();

    iConnectionMonitor.NotifyEventL( *this );

    // Get the count of connections

    TRequestStatus status = KRequestPending;

    TUint connectionCount = 0;

    iConnectionMonitor.GetConnectionCount(connectionCount, status);

    User::WaitForRequest( status ); 

    // Go through available connections and check to see

    // if connection with iAccessPoint IAP is already running

    if( status == KErrNone )

        {

        for( TUint i=1; i < connectionCount+1;  i++ )

            {

            TUint connectionId;

            TUint subConnectionCount;

            TUint iapId = 0;

            iConnectionMonitor.GetConnectionInfo( 

                                            i,

                                            connectionId, 

                                            subConnectionCount);

            TRequestStatus status = KRequestPending;

            iConnectionMonitor.GetUintAttribute( 

                                            connectionId, 

                                            0, 

                                            KIAPId, 

                                            (TUint &) iapId,

                                            status );

            User::WaitForRequest( status ); 

            // Save connectionId if same iap

            if( status == KErrNone && iAccessPoint == iapId )

                {

                iConnectionId = connectionId;

                }

            }    

        }    

    }

// ---------------------------------------------------------------------------

// CMdHConnectionMonitor::~CMdHConnectionMonitor()

// Destructor

// ---------------------------------------------------------------------------

//

CMdHConnectionMonitor::~CMdHConnectionMonitor()

    {

    iConnectionMonitor.CancelNotifications();

    // Disconnect from CM server

    iConnectionMonitor.Close();

    }

// ---------------------------------------------------------------------------

// CMdHConnectionMonitor::EventL()

// Connection monitor observer

// ---------------------------------------------------------------------------

//

void CMdHConnectionMonitor::EventL( const CConnMonEventBase& aConnMonEvent )

    {

    TUint connectionId = 0;

    switch ( aConnMonEvent.EventType() )

        {

        case EConnMonCreateConnection:

            {

            TUint iapId = 0;

            const CConnMonCreateConnection* eventCreate; 

            eventCreate = (const CConnMonCreateConnection*)&aConnMonEvent;

            connectionId = eventCreate->ConnectionId();

            TRequestStatus status = KRequestPending;

            // Get IAP id

            iConnectionMonitor.GetUintAttribute( 

                                            eventCreate->ConnectionId(), 

                                            0, 

                                            KIAPId, 

                                            iapId, 

                                            status );

            User::WaitForRequest( status ); 

            // Save connectionId if same iap

            if( iAccessPoint == iapId )

                {

                iConnectionId = connectionId;

                }

            break;

            }

        // Connection is deleted

        case EConnMonDeleteConnection:

            {

            const CConnMonDeleteConnection* eventDelete; 

            eventDelete = 

                    ( const CConnMonDeleteConnection* ) &aConnMonEvent;

            connectionId = eventDelete->ConnectionId();

            // If connection id same as in createConnection

            if( connectionId == iConnectionId )

                {

                // Callback function

                iObserver.ConnectionLost();

                }

            break;

            }

         default:

            {

            break;

            }

        }

    }

// end of file