/*
* Copyright (c) 2002 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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: 
*     This class provides connection/session related information.
*	  Both the requested and the stored AP's are here.
*
*
*/

#include <nifman.h>
#include <nifvar.h>
#include <es_enum.h>
#include <in_sock.h>

#include <connectionobservers.h>
#include "ConnectionManagerLogger.h"

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::NewL()
//--------------------------------------------------------------------------
EXPORT_C CConnectionStageNotifierWCB* CConnectionStageNotifierWCB::NewL( TInt aPriority )
	{
	CConnectionStageNotifierWCB* self = CConnectionStageNotifierWCB::NewLC( aPriority );
	CleanupStack::Pop();
	return self;
	}

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::NewLC()
//--------------------------------------------------------------------------
EXPORT_C CConnectionStageNotifierWCB* CConnectionStageNotifierWCB::NewLC( TInt aPriority )
	{
	CConnectionStageNotifierWCB* self = new ( ELeave ) CConnectionStageNotifierWCB( aPriority );	
	CleanupStack::PushL( self );
	return self;
	}

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::StartNotificationL()
//--------------------------------------------------------------------------
EXPORT_C void 
    CConnectionStageNotifierWCB::StartNotificationL( TInt /*aStageToObserve*/, 
                                                     MConnectionStageObserver* /*aObserver*/, 
                                                     TBool /*aCompleteIfAlreadyAtStage*/ )	
	{
    User::Leave( KErrNotSupported );
	}

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::~CConnectionStageNotifierWCB()
//--------------------------------------------------------------------------
EXPORT_C CConnectionStageNotifierWCB::~CConnectionStageNotifierWCB()
	{
	CLOG_WRITE("~CConnectionStageNotifierWCB");
	
	Cancel();
	
	CLOG_WRITE("Canceled");
    // if there's nothing to cancel
    // DoCancel is not called.
    // We need to close agent manually from here
    DoCloseAgent();
    
    CLOG_CLOSE;
	}

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::CConnectionStageNotifierWCB()
//--------------------------------------------------------------------------
CConnectionStageNotifierWCB::CConnectionStageNotifierWCB( TInt aPriority ) : CActive( aPriority )
	{
	CLOG_CREATE;
	CLOG_NAME_1( _L("StageNotifier_%x"), this );
	
	CActiveScheduler::Add( this );
	}

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::DoCancel()
//--------------------------------------------------------------------------
void CConnectionStageNotifierWCB::DoCancel()
	{
	CLOG_ENTERFN( "DoCancel()" );
	iConnection.CancelProgressNotification();
    DoCloseAgent();

    iMultiObserver = NULL;
    iStages = NULL;
    iNumOfStages = 0;
	}

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::RunL()
//--------------------------------------------------------------------------
void CConnectionStageNotifierWCB::RunL()
	{
	CLOG_ENTERFN("CConnectionStageNotifierWCB::RunL()");
    CLOG_WRITE_1( "CConnectionStageNotifierWCB Stage: %d", iProgressBuf().iStage );

    if( !iMultiObserver )
        {
	    if ( iProgressBuf().iStage == iStageToObserve )
		    {
            CLOG_WRITE( "Stage achived" );
		    DoCloseAgent();
		    iObserver->ConnectionStageAchievedL();
		    }
	    else//reissuing request
		    {
            CLOG_WRITE( "Restarting progress notif." );
		    iConnection.ProgressNotification(  iProgressBuf, iStatus );//reissuing request
		    SetActive();
		    }
        }
    else
        {
        if( IsAnyStageReached( iProgressBuf().iStage ) )
            {
            iMultiObserver->ConnectionStageAchievedL( iProgressBuf().iStage );
            }
		else{
			//reissuing request
			iConnection.ProgressNotification( iProgressBuf, iStatus );//issuing request
			SetActive();
			}
        }
	}


//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::StartNotificationL()
//--------------------------------------------------------------------------
EXPORT_C void 
    CConnectionStageNotifierWCB::StartNotificationL( TName* aConnName, 
                                                     TInt aStageToObserve, 
                                                     MConnectionStageObserver* aObserver, 
                                                     TBool aCompleteIfAlreadyAtStage )	
	{
    CLOG_ENTERFN( "StartNotificationL1" );

	__ASSERT_DEBUG( aObserver, User::Panic(  KNullDesC, KErrArgument ) );
	iObserver = aObserver;
	iStageToObserve = aStageToObserve;


    DoOpenAgentL( aConnName );
      
    TNifProgress progress;

    iConnection.Progress( progress );//initial progress may be important to save whether it is unconnected now
	if ( progress.iStage == aStageToObserve && aCompleteIfAlreadyAtStage )
		{
		DoCloseAgent();
		TRAP_IGNORE( iObserver->ConnectionStageAchievedL() );
		}
	else
		{
			
			/* No need to call Setactive() in the case if connection is already active, that is why checking isActive 
			connection, if not then only activating it, For instance Incase of Connection Change from real IAP to VPN on the 
			same real IAP using which VPN configurations were made then the existing connection would not be disconnected 
			but a new VPN tunnel will be created on top of it.So connection is already active, it should not call SetActive() 
			if the active object request has been issued already, new request should be issued only incase of a new connection altogether*/
			if(!IsActive())
			{
				iConnection.ProgressNotification( iProgressBuf, iStatus );//issuing request
				SetActive();
			}
		}
    }

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::StartNotificationL()
//--------------------------------------------------------------------------
EXPORT_C void 
    CConnectionStageNotifierWCB::StartNotificationL( TName* aConnName, 
                                                     TInt* aStages, 
                                                     TInt aNumOfStages,
                                                     MConnectionMultiStageObserver* aObserver,
                                                     TBool aCompleteIfAlreadyAtStage )	
	{
    CLOG_ENTERFN( "StartNotificationL2" );

    __ASSERT_DEBUG( aStages, User::Panic(  KNullDesC, KErrArgument ) );
    __ASSERT_DEBUG( aNumOfStages > 0 , User::Panic(  KNullDesC, KErrArgument ) );
    __ASSERT_DEBUG( aObserver, User::Panic(  KNullDesC, KErrArgument ) );

    iStages = aStages;
    iNumOfStages = aNumOfStages;
    iMultiObserver = aObserver;

    DoOpenAgentL( aConnName );

	TNifProgress progress;
	iConnection.Progress( progress );//initial progress may be important to save whether it is unconnected now
	if ( IsAnyStageReached( progress.iStage ) && aCompleteIfAlreadyAtStage )
		{
		DoCloseAgent();
		TRAP_IGNORE( iMultiObserver->ConnectionStageAchievedL( progress.iStage ) );
		}
	else
		{
		if(!IsActive())
			{
		    iConnection.ProgressNotification( iProgressBuf, iStatus );//issuing request
		    SetActive();
		    }
		}
    }

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::DoOpenAgent
//--------------------------------------------------------------------------
void CConnectionStageNotifierWCB::DoOpenAgentL( TName* aConnName )
    {
    CLOG_ENTERFN( "CConnectionStageNotifierWCB::DoOpenAgentL" );
    TInt err( KErrNone );
    if( (err = iServer.Connect()) == KErrNone )
        {
        err = iConnection.Open( iServer, *aConnName );
        if( !err )
            {
            TBuf<64> query;
            TUint32 apId;
            TUint32 netId;

            query.Format( _L("%s\\%s"), IAP, COMMDB_ID );
            if( iConnection.GetIntSetting( query, apId ) == KErrNone )
                {
                query.Format( _L("%s\\%s"), IAP, IAP_NETWORK );
                if( iConnection.GetIntSetting( query, netId ) == KErrNone )
                    {
                    TPckgBuf<TConnectionInfo> connInfo;

                    connInfo().iIapId = apId;
                    connInfo().iNetId = netId;
                    CLOG_WRITE_2( "IAP ID: %d, NET ID: %d", connInfo().iIapId, connInfo().iNetId );

                    iConnection.Close();
                    if( iConnection.Open( iServer, KAfInet ) == KErrNone )
                        {
                        err = iConnection.Attach( connInfo, RConnection::EAttachTypeMonitor );
                        CLOG_WRITE_1( "Attach result: %d", err );
                        }
                    }
                }
            }
        }

    if( err )
        {
        iConnection.Close();
        iServer.Close();
        User::Leave( err );
        }
    }

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::DoCloseAgent
//--------------------------------------------------------------------------
void CConnectionStageNotifierWCB::DoCloseAgent()
    {
    CLOG_ENTERFN( "CConnectionStageNotifierWCB::DoCloseAgent()" );
    iConnection.Close();
    iServer.Close();
    }

//--------------------------------------------------------------------------
//CConnectionStageNotifierWCB::IsAnyStageReached()
//--------------------------------------------------------------------------
TBool CConnectionStageNotifierWCB::IsAnyStageReached( TInt aCurrentStage )
    {
    for( TInt i = 0; i < iNumOfStages; ++i )
        {
        if( iStages[i] == aCurrentStage )
            {
            return ETrue;
            }
        }

    return EFalse;
    }

//EOF