// Copyright (c) 2009 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:

// Implements a AT extension plugin

// 

//

// INCLUDES

#include <utf.h>

#include "atcmdpam_debug.h"

#include "pamengine.h"

#include "pamplugin.h"

#include "pamplugindebug.h"

// CONSTANTS

// ============================= LOCAL FUNCTIONS  =============================

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

/**

 Create a new instance

 */

CPamEngine* CPamEngine::NewL( CPamPlugin* aOwner )

	{

	CPamEngine* self = CPamEngine::NewLC( aOwner );

	self->ConstructL();

	CleanupStack::Pop();

    ATDEBUG( DebugPrint( _L( "CPamEngine::NewL()" )))

	return self;

	}

/**

 Create a new instance and push in cleanup stack

 */

CPamEngine* CPamEngine::NewLC( CPamPlugin* aOwner )

	{

	CPamEngine* self = new ( ELeave ) CPamEngine( aOwner );

	CleanupStack::PushL( self );

    ATDEBUG( DebugPrint( _L( "CPamEngine::NewLC()" )))

	return self;

	}

/**

 Destructor

 */

CPamEngine::~CPamEngine()

	{

	ATDEBUG( DebugPrint( _L( "CPamEngine::~CPamEngine()" ) ) )

    delete iTelephony;

    }

/**

 2nd phase Constructor

 (may leave)

 */

void CPamEngine::ConstructL()

	{

    ATDEBUG( DebugPrint( _L( "CPamEngine::ConstructL()" ) ) )

    CActiveScheduler::Add( this );

    iTelephony = CTelephony::NewL();

    }

/**

 C++ Contructror

 */

CPamEngine::CPamEngine( CPamPlugin* aOwner ) 

    : CActive( EPriorityNormal ), iOwner( aOwner )

	{

	ATDEBUG( DebugPrint( _L( "CPamEngine::CPamEngine()" )))

	return;

    }

/**

 Get the service provider name

 */

void CPamEngine::GetServiceProviderName()

    {

    TRACE_FUNC_ENTRY

    if ( !IsActive() )

        {

        CTelephony::TNetworkNameV1Pckg namePckg( iNWName );

        iTelephony->GetCurrentNetworkName( iStatus, namePckg );

        SetActive();

        }

	TRACE_FUNC_EXIT

    }

/**

 From CActive

 */

void CPamEngine::RunL()

	{

	TRACE_FUNC_ENTRY

	ATDEBUG( DebugPrint( _L( "CPamEngine::RunL()" ) ) )

    if ( iStatus.Int() != KErrNone )

        {

        iOwner->NameReqCallback( KNullDesC8() );

        return;

        }

    TBuf8<20> out;

    CnvUtfConverter::ConvertFromUnicodeToUtf8( out, iNWName.iNetworkName );

	iOwner->NameReqCallback( out );

	TRACE_FUNC_EXIT

    return;

    }

/**

 From CActive

 */

void CPamEngine::DoCancel()

	{

	ATDEBUG( DebugPrint( _L( "CPamEngine::DoCancel()" ) ) )

	iTelephony->CancelAsync( CTelephony::EGetCurrentNetworkNameCancel );

    return;

    }

/**

 Get Access point table by the specified access point type

 */

void CPamEngine::ReadAccessPointTableL(TInt aAccessPointType,  CDesC8ArrayFlat*& apArray )

    {

    TRACE_FUNC_ENTRY

    switch ( aAccessPointType )

        {

        case EINTERNETACCESSPOINT:      

            {

            //Internet access point;

            ReadPacketServicetableL( CMManager::EPacketDataInternetOnly, apArray );

            }

            break;

        case EWAPACCESSPOINT:

            {

            //Wap access point;

            ReadPacketServicetableL( CMManager::EPacketDataWAPOnly, apArray );

            break;

            }

        case EBOTHACCESSPOINT:

            {

            //Internet and wap access point only;

            ReadPacketServicetableL( CMManager::EPacketDataBoth, apArray );

            }

            break;

        default:

            {

            User::Leave( KErrArgument );

            }

            break;

        }

	TRACE_FUNC_EXIT

    return;

    }

/**

 Get supported access point type

 */

void CPamEngine::SupportedAccessPoints(HBufC16*& aBuf)

    {

    TRACE_FUNC_ENTRY

    _LIT( KAccessTypeString, "(%d,%d,%d)" );

    aBuf->Des().AppendFormat( KAccessTypeString, CMManager::EPacketDataInternetOnly, 

                                                 CMManager::EPacketDataWAPOnly, 

                                                 CMManager::EPacketDataBoth );

    TRACE_FUNC_EXIT

    return;

    }

/**

 Get service names by the specified access point type

 */

void CPamEngine::ReadPacketServicetableL( CMManager::TPacketDataApType aAccessPointType,  CDesC8ArrayFlat*& apArray  )

    {

    TRACE_FUNC_ENTRY

	ATDEBUG( DebugPrint( _L( "CPamEngine::ReadPacketServicetable()" ) ) )

    _LIT( KIP, "IP" );

    _LIT( KIPV6, "IPV6" );

    _LIT( KComma, "," );

    _LIT( KNumber, "%d" );

    TBuf<1> apsecure_auth;

    TBuf<3> apnumber;

    const TInt KBufsize = 256;

    RCmManager cmManager;

    cmManager.OpenL();

    CleanupClosePushL(cmManager);

    RArray<TUint32> destinations;

    cmManager.AllDestinationsL(destinations);

    CleanupClosePushL(destinations);

    RCmDestination destination;

    HBufC16 *tmpName = NULL;

    HBufC16* buf = HBufC16::NewLC( KBufsize );

    TBuf<4> apPDP_Type;

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

        {

        destination = cmManager.DestinationL(destinations[i]);

        CleanupClosePushL(destination);

        tmpName = destination.NameLC();

       	ATDEBUG( DebugPrint( _L( "CPamEngine::ReadPacketServicetable() destination.name: %S" ), tmpName ) )

        RCmConnectionMethod connectionMethod;

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

            {

            connectionMethod = destination.ConnectionMethodL(j);

            CleanupClosePushL(connectionMethod);

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

            if (bearerType == KUidPacketDataBearerType)

                {

                TUint32 connectionType = connectionMethod.GetIntAttributeL( CMManager::EPacketDataApType );

                if (connectionType == aAccessPointType)

                    {

                    // ap number

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

                    apnumber.Format( KNumber, id );

                    buf->Des().Copy( apnumber );

                    buf->Des().Append( KComma );

                    // IAP name

                    tmpName = connectionMethod.GetStringAttributeL(CMManager::ECmName);

                    AddQuotationmarks( *tmpName, buf );

                    buf->Des().Append( KComma );

                    // gprs_accesspointname

                    tmpName = connectionMethod.GetStringAttributeL(CMManager::EPacketDataAPName);

                    AddQuotationmarks( *tmpName, buf );

                    // PDP_type

                    TInt isIPv6Supported = connectionMethod.GetBoolAttributeL(CMManager::EPacketDataPDPType);

                    if ( isIPv6Supported )

                        {

                        apPDP_Type = KIPV6;

                        }

                    else

                        {

                        apPDP_Type = KIP;

                        }

                    buf->Des().Append( KComma );

                    AddQuotationmarks( apPDP_Type, buf );

                    // username

                    tmpName = connectionMethod.GetStringAttributeL(CMManager::ECmIFAuthName);

                    buf->Des().Append( KComma );

                    AddQuotationmarks( *tmpName, buf );

                    // password

                    tmpName = connectionMethod.GetStringAttributeL(CMManager::ECmIFAuthPass);

                    buf->Des().Append( KComma );

                    AddQuotationmarks( *tmpName, buf );

                    // secure_auth

                    TBool tmp_apsecure_auth = connectionMethod.GetBoolAttributeL(CMManager::ECmDisablePlainTextAuth);

                    if ( tmp_apsecure_auth )

                        {

                        apsecure_auth.Format( KNumber, 1 );

                        }

                    else

                        {

                        apsecure_auth.Format( KNumber, 0 );

                        }

                    buf->Des().Append( KComma );

                    buf->Des().Append( apsecure_auth );

                	ATDEBUG( DebugPrint( _L( "CPamEngine::ReadPacketServicetable() ATCommand items fetched" ) ) )

                    TBuf8<KBufsize> text8;

                    if ( CnvUtfConverter::ConvertFromUnicodeToUtf8( text8, *buf ) )

                        {

                        ATDEBUG( DebugPrint( _L( "CnvUtfConverter::ConvertFromUnicodeToUtf8 failed" ) ) )

                        }

                    else

                        {

                        // Conversion succeeded

                        // Add data to sending table

                        apArray->AppendL(text8);

                        }

                    }

                }

            CleanupStack::PopAndDestroy(); // connectionMethod

            }

        tmpName = NULL;

        }

    TRACE_FUNC_EXIT

    return;

    }

/**

 Add quotation marks

 */

void CPamEngine::AddQuotationmarks( const TDesC& aString, HBufC16*& aBuf )

    {

    TRACE_FUNC_ENTRY

    _LIT( KQuotationmark, "\"" );

    if ( aString.Length() > 0 )

        {

        aBuf->Des().Append( KQuotationmark );

        aBuf->Des().Append( aString );

        aBuf->Des().Append( KQuotationmark );

        }

	TRACE_FUNC_EXIT

    return;

    }

// End of File