/*

* Copyright (c) 2010 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: 

*

*/

/**

 * @file

 * @internalComponent

 */

#include <e32debug.h>

#include <commdb.h>

#ifdef OVERDUMMY_NCMCC

#include <usb/testncmcc/dummy_essock.h>

#else

#include <commdbconnpref.h>

#endif

#include <commsdattypesv1_1.h> 

#include "ncmiapreaderobserver.h"

#include "ncmiapreader.h"

// For OST Tracing

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "ncmiapreaderTraces.h"

#endif

_LIT(KNcmIapReaderPanic, "UsbNcmIapReader"); // must be <=16 chars

// Panic codes

enum TNcmIapReaderPanicCode

    {

    ENcmIapReaderPanicOutstandingRequest = 1,

    ENcmIapReaderPanicTooManyIAPs = 2,

    ENcmIapReaderEndMark

    };

// NCM configuration item names

_LIT(KBearerNifName, "ethint");

_LIT(KBearerLddFileName, "eusbcsc");

_LIT(KBearerPktDrvName, "ncmpkt.drv");

/**

 * Constructs a CNcmIapReader object.

 * @param aObserver An MNcmIAPReaderObserver instance which handles IAP reading completing

 * @param aConnPref The reference of the NCM connection aConnPref

 */

CNcmIapReader::CNcmIapReader(MNcmIAPReaderObserver& aObserver, TCommDbConnPref& aConnPref)

: CActive(CActive::EPriorityStandard),

      iObserver(aObserver),

      iConnPref(aConnPref)

	{

	OstTraceFunctionEntryExt( CNCMIAPREADER_CNCMIAPREADER_ENTRY, this );

	CActiveScheduler::Add(this);		

	OstTraceFunctionExit1( CNCMIAPREADER_CNCMIAPREADER_EXIT, this );

	}

/**

 * Destructor.

 */

CNcmIapReader::~CNcmIapReader()

	{

	OstTraceFunctionEntry0( CNCMIAPREADER_CNCMIAPREADER_ENTRY_DESTRUCTOR );

	Cancel();

	OstTraceFunctionExit0( CNCMIAPREADER_CNCMIAPREADER_ENTRY_DESTRUCTOR_EXIT );

	}

/**

 * Start the connection.

 */

void CNcmIapReader::Start()

	{

	OstTraceFunctionEntry0( CNCMIAPREADER_START_ENTRY );

	__ASSERT_ALWAYS(!IsActive(), 

	        User::Panic(KNcmIapReaderPanic, ENcmIapReaderPanicOutstandingRequest));

    SetActive();

    TRequestStatus* status = &iStatus;

    User::RequestComplete(status, KErrNone);

	OstTraceFunctionExit0( CNCMIAPREADER_START_EXIT );

	}

/**

 * Implements cancellation of an outstanding request.

 */

void CNcmIapReader::DoCancel()

	{

	OstTraceFunctionEntry0( CNCMIAPREADER_DOCANCEL_ENTRY );

    TRequestStatus* status = &iStatus;

    User::RequestComplete(status, KErrCancel);

	OstTraceFunctionExit0( CNCMIAPREADER_DOCANCEL_EXIT );

	}

/**

 * Simulate an async way and give

 * the scheduler a chance to schedule all AOs.

 */

void CNcmIapReader::RunL()

	{

	OstTraceFunctionEntry0( CNCMIAPREADER_RUNL_ENTRY );

	// Reading

	TRAPD(err, SearchNcmIapL())

	OstTrace1( TRACE_NORMAL, CNCMIAPREADER_RUNL_GETIAP, "Get NCM IAP with error code %d", err );

	// Complete connection manager

	iObserver.MicoHandleIAPReadingComplete(err);

	OstTraceFunctionExit0( CNCMIAPREADER_RUNL_EXIT );

	}

/**

 * Search NCM IAP in current commDB and set it into the ncm connection manager.

 */

void CNcmIapReader::SearchNcmIapL()

    {

    OstTraceFunctionEntry0( CNCMIAPREADER_GETNCMIAPIDL_ENTRY );

    using namespace CommsDat;

    CMDBSession* dbs = CMDBSession::NewLC(KCDLatestVersion); // Current version is 1.1

    CMDBRecordSet<CCDLANBearerRecord>* lanBearerTable = 

            new (ELeave) CMDBRecordSet<CCDLANBearerRecord>(KCDTIdLANBearerRecord);

    CleanupStack::PushL(lanBearerTable);

    // Load the table into memory

    lanBearerTable->LoadL(*dbs);

    TInt numLanBearers = lanBearerTable->iRecords.Count();    

    OstTrace1( TRACE_NORMAL, CNCMIAPREADER_GETNCMIAPIDL_COUNT_LAN_BEARER, "Found %d Lan Bearer!", numLanBearers );

    TInt chosenLanBearer = KErrNotFound;

    TInt i = 0;

    for(i = 0; i<numLanBearers; i++)

        {

        CCDLANBearerRecord* lanBearer = 

                static_cast<CCDLANBearerRecord*>(lanBearerTable->iRecords[i]);

        if ((lanBearer->iLanBearerNifName.GetL().Compare(KBearerNifName()) == 0) &&

            (lanBearer->iLanBearerLddFilename.GetL().Compare(KBearerLddFileName()) == 0) &&

            (lanBearer->iLanBearerPacketDriverName.GetL().Compare(KBearerPktDrvName()) == 0))

            {

            // Matched all check points. We found LAN bearer for NCM

            chosenLanBearer = lanBearer->RecordId();

            break;

            }

        }

    CleanupStack::PopAndDestroy(lanBearerTable); // lanBearerTable

    if (KErrNotFound == chosenLanBearer)

        {

        OstTrace0( TRACE_ERROR, CNCMIAPREADER_GETNCMIAPIDL, "Can not find NCM Lan Bearer!" );

        User::Leave(KErrNotFound);

        }

    OstTrace1( TRACE_NORMAL, CNCMIAPREADER_GETNCMIAPIDL_CHOSEN_LAN_BEARER, "Chosen Lan Bearer %d!", chosenLanBearer );

    CMDBRecordSet<CCDIAPRecord> * iapTable = 

            new (ELeave) CMDBRecordSet<CCDIAPRecord>(KCDTIdIAPRecord);

    CleanupStack::PushL(iapTable);

    // Load the table into memory

    iapTable->LoadL(*dbs);

    TInt numIaps = iapTable->iRecords.Count();

    TInt chosenIAP = KErrNotFound;

    TInt iapLanBearer = KErrNotFound;

    for (i = 0; i < numIaps; i++)

        {

        CCDIAPRecord* iap =

                static_cast<CCDIAPRecord*> (iapTable->iRecords[i]);

        OstTrace1( TRACE_NORMAL, CNCMIAPREADER_GETNCMIAPIDL_RECORD_ID, "Id of current IAP is %d!", iap->RecordId() );

        OstTrace1( TRACE_NORMAL, CNCMIAPREADER_GETNCMIAPIDL_RECORD_BEARER_ID, "Lan Bearer Id of current IAP is %d!", TMDBElementId(iap->iBearer) );

        iapLanBearer = TMDBElementId(iap->iBearer);

        if ((iap->iBearerType.GetL().Compare(TPtrC(KCDTypeNameLANBearer)) == 0) && 

                (iapLanBearer == chosenLanBearer))

            {

            // NCM IAP found!

            // Panic if there is more than NCM IAP found

            OstTrace1( TRACE_NORMAL, CNCMIAPREADER_SEARCHNCMIAPL_ONLY_ONE_NCM_IAP, "NCM IAP found: Current chosenIAP value is %d", chosenIAP );

            __ASSERT_ALWAYS(KErrNotFound == chosenIAP, User::Panic(KNcmIapReaderPanic, ENcmIapReaderPanicTooManyIAPs));

            chosenIAP = iap->RecordId();

            break;

            }

        }

    CleanupStack::PopAndDestroy(2, dbs); // iapTable, dbs    

    if(chosenIAP == KErrNotFound)

        {

        OstTrace0( TRACE_ERROR, CNCMIAPREADER_GETNCMIAPIDL_NOT_FOUND, "Can not find NCM IAP!" );

        User::Leave(KErrNotFound);

        }

    OstTrace1( TRACE_NORMAL, CNCMIAPREADER_GETNCMIAPIDL_CHOSEN_IAP_ID, "Chosen IAP is %d!", chosenIAP );

    iConnPref.SetIapId(chosenIAP);

    OstTraceFunctionExit0( CNCMIAPREADER_GETNCMIAPIDL_EXIT );

    }