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

//

/**

 @file

 @internalComponent

*/

#include <commsdattypesv1_1.h>

#include <commsdattypesv1_1_partner.h>

#include <metadatabase.h>

using namespace CommsDat;

#include <cdbpreftable.h>

#include <agentdialog.h>

#include "ND_DLGSL.H"

#include <es_ini.h>

#include <commsdattypeinfov1_1_internal.h>

/** Literal accepts the String */

_LIT(KSelectTitle,"Select %S");

/** Literal accepts the String */

_LIT(KSelectPrompt,"%S");

/** Literal accepts the Integer */

_LIT(KWarnPrompt,"Connection failed with %d");

/** Literal Specifies the New Connection */

_LIT(KWarnPromptNoError,"New connection");

/** Literal Conain the String trying to connect to server */

_LIT(KAttemptPrompt,"Attempt to connect to %S?");

/** Literal prompts to Select IAP */

_LIT(KIAP,"IAP");

/** Literal prompts to Select IAP */

_LIT(KAP, "Access Point");

/** Literal Specifies QoSWarning */

_LIT(KQoSWarnTitle,"The connection quality is lower than required");

/** Literal Specifies Disconnect option */

_LIT(KQoSWarnPrompt,"Do you wish to disconnect?");

namespace ND_DLDSL

	{

const TInt KOneSecond=1000000;			//< TimeInterval of OneSecond 

const TInt KTimeInterval=KOneSecond;	//< TimeInterval to start the CPctTimer

const TInt KNotifierLength=16;			//< NotifierLength

const TText KFullStop='.';				//< Constant to hold FullStop

	}

CDialogBase::CDialogBase(CNetDialDialogSession* aSession, TInt aPriority)

	: CActive(aPriority),

	iSession(aSession),

	iAgentDialogInput(iAgentDialogInputBuf()),

	iAgentDialogOutput(iAgentDialogOutputBuf())

/**

CDialogBase Constructor.

*/

	{

	__FLOG_OPEN(KDlgSvrLogSubsys, KDlgSvrLogComponent);

	}

void CDialogBase::ConstructL()

/**

Completes construction of the CDialogBase object.

*/

	{

	iNotifier = new(ELeave) RNotifier();

	User::LeaveIfError(iNotifier->Connect());

	_LIT(KAgentDialogIniFileName, "agentdialog.ini");

	_LIT(KNotifierUidTag, "NotifierUid");

	CESockIniData* cfgFile = NULL;

	// coverity[SYMBIAN.CLEANUP_STACK] coverity [alloc_fn]

    // coverity[SYMBIAN.CLEANUP_STACK] coverity [assign]

	TRAPD(err, cfgFile = CESockIniData::NewL(KAgentDialogIniFileName));

	// coverity[SYMBIAN.CLEANUP_STACK] coverity [leave_without_push]

	__FLOG_1(_L("Agent dialog config file for  - returned %d"),err);

        if (err == KErrNone)

		{

		// the file was opened correctly

		TInt val = 0;

		if (cfgFile->FindVar(KNotifierUidTag, val))

			{

			// the value was found, build a TUid to assign to the member variable

			iUidAgentDialogNotifier = TUid::Uid(val);

			__FLOG(_L("Uid Found in ini file"));

			}

		else

			{

			// value was not found, use the default UID for agent dialog notifiers

			iUidAgentDialogNotifier = KUidAgentDialogNotifier;

			}

		delete cfgFile;	

		}

	else

		{

		// the ini file was not found so use the default UID for agent dialog notifiers

		iUidAgentDialogNotifier = KUidAgentDialogNotifier;

		}

	__FLOG_1(_L("Uid Loaded ===>%x"),iUidAgentDialogNotifier.iUid);	

	}

CDialogBase::~CDialogBase()

/**

Destructor.

*/

	{

	if (iNotifier!=NULL)

		{

		iNotifier->Close();

		delete iNotifier;

		}

	delete iCallBack;

	__FLOG_CLOSE;

	}	

void CDialogBase::StartNotifierAndGetResponse()

/**

Utility function to start the dialog notifier

 */

	{

	__ASSERT_DEBUG(iNotifier!=NULL, User::Invariant());

	__FLOG_1(_L("CDialogBase::StartNotifierAndGetResponse - Openning Dialog - Uid Loaded ===>%x "),

		iUidAgentDialogNotifier.iUid);

	iNotifier->StartNotifierAndGetResponse( iStatus, iUidAgentDialogNotifier, iAgentDialogInputBuf, iAgentDialogOutputBuf );

	SetActive();

	}

void CDialogBase::CancelNotifier()

/**

 Utility function to cancel the dialog notifier

*/

	{

	__ASSERT_DEBUG(iNotifier!=NULL, User::Invariant());

	iCancelFlag=ETrue;

	iNotifier->CancelNotifier(iUidAgentDialogNotifier);

	}

void CDialogBase::DoCancel()

/**

 Cancel the outstanding request - most of the derived classes have a

 common DoCancel method, so it seems reasonable to factor it here

*/

	{

	CancelNotifier();

	}

CIAPSelection* CIAPSelection::NewL(CMDBSession* aDb,CNetDialDialogSession* aSession, TInt aPriority)

/**

IAP Selection

@param aDb pointer to communications database.

@param aSession pointer to NetDialDialogSession.

@param aPriority Priority.

@return Pointer to IAPSelection object.

*/

	{

	CIAPSelection* r=new(ELeave) CIAPSelection(aDb,aSession,aPriority);

	CleanupStack::PushL(r);

	r->ConstructL();

	CleanupStack::Pop();

	return r;

	}

CIAPSelection::CIAPSelection(CMDBSession* aDb,CNetDialDialogSession* aSession, TInt aPriority)

	: CDialogBase(aSession, aPriority),

	iDb(aDb)

/**

CIAPSelection Constructor

*/

	{}

void CIAPSelection::ConstructL()

/**

Completes construction of the CIAPSelection object.

@see CDialogBase::ConstructL().

*/

	{

	CDialogBase::ConstructL();

	CActiveScheduler::Add(this);

		InitRecordSetL();

	}

CIAPSelection::~CIAPSelection()

/**

CIAPSelection Destructor.

*/

	{

	Cancel();

	delete iTable;

	}

void CIAPSelection::InitRecordSetL()

	{

	delete iTable;

	iTable = NULL;

	iTable = new (ELeave)CMDBRecordSet<CCDConnectionPrefsRecord>(KCDTIdConnectionPrefsRecord);

	//CCDConnectionPrefsRecord* ptrTemplate = new (ELeave) CCDConnectionPrefsRecord();

	CCDConnectionPrefsRecord* ptrTemplate = static_cast<CCDConnectionPrefsRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdConnectionPrefsRecord));

	CleanupStack::PushL(ptrTemplate);

	User::LeaveIfError((iTable->iRecords).Append(ptrTemplate));

	CleanupStack::Pop(ptrTemplate);

	iRecordIndex = 0;

	}

void CIAPSelection::GetIAPL(TUint32& aIAPId, const TConnectionPrefs& aPrefs, TInt aError, TCallBack aCallBack)

/**

Gets the IAP.

@param aIAPId The id of the IAP service.

@param aPrefs Specifies the rank and desired direction of the connection and bearer.

@param aError Any error code, or KErrNone if no error.

@param aCallBack Encapsulates a general call-back function.

*/

	{

	iCancelFlag = EFalse;

	iCallBack = new(ELeave) CAsyncCallBack(aCallBack,CActive::EPriorityStandard);

	iIAPId = &aIAPId;

	iRecordsPresent = ETrue;

	if(iRecordIndex != 0)

		{

		InitRecordSetL();

		}

	static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex])->iBearerSet = aPrefs.iBearerSet;

	static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex])->iDirection = aPrefs.iDirection;

	if(iTable->FindL(*iDb))

		{

		CCDIAPRecord* ptrIapRecord = static_cast<CCDIAPRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdIAPRecord));

		CleanupStack::PushL(ptrIapRecord);

		CCDConnectionPrefsRecord* connpref = static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex]);

		ptrIapRecord->SetRecordId(connpref->iDefaultIAP);

		ptrIapRecord->LoadL(*iDb);

		connpref->iDefaultIAP.iLinkedRecord = ptrIapRecord;

		CleanupStack::Pop(ptrIapRecord);

		SelectL(aError);

		}

	else

	// else case is common part for failure

		{

		if (aError!=KErrNone)

			{

			iAgentDialogInput.iTitle.Format(KWarnPrompt,aError);

			}

		_LIT(noService,"No IAP Records Found");

		iAgentDialogInput.iTitle.Append(noService);

		iAgentDialogInput.iDialog = EContinueDialog;

		StartNotifierAndGetResponse();

		iRecordsPresent = EFalse;

		}

	}

void CIAPSelection::SelectL(TInt aError)

/**

@param aError Any error code, or KErrNone if no error.

*/

	{

	if (aError!=KErrNone)

		{

		iAgentDialogInput.iTitle.Format(KWarnPrompt,aError);

//		iAgentDialogInput.iTitle.Append(KCarriageReturn);

		}

	iAgentDialogInput.iTitle.AppendFormat(KSelectTitle,&KIAP);

	ReselectL();

	}

void CIAPSelection::ReselectL()

	{

	CCDIAPRecord* ptrIapRecord  = static_cast<CCDIAPRecord*>(static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex])->iDefaultIAP.iLinkedRecord);

	if(!ptrIapRecord)

		{

		CCDIAPRecord* ptrIapRecord = static_cast<CCDIAPRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdIAPRecord));

		CleanupStack::PushL(ptrIapRecord);

		CCDConnectionPrefsRecord* connpref = static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex]);

		ptrIapRecord->SetRecordId(connpref->iDefaultIAP);

		ptrIapRecord->LoadL(*iDb);

		connpref->iDefaultIAP.iLinkedRecord = ptrIapRecord;

		CleanupStack::Pop(ptrIapRecord);

		}

	TBuf<KCommsDbSvrDefaultTextFieldLength> tmpBuffer;

	tmpBuffer = ptrIapRecord->iRecordName;

	iAgentDialogInput.iLabel.Format(KSelectPrompt,&tmpBuffer);

	iAgentDialogInput.iDialog = ENoYesDialog;

	StartNotifierAndGetResponse();

	}

void CIAPSelection::RunL()

/**

Handles an active object’s request completion event.

*/

	{

	if (iStatus < KErrNone)

		{

		__FLOG_1(_L("Dialog returned with %d"),iStatus.Int());

		iResultStatus=iStatus.Int();

		if((iResultStatus==KErrNone)&&(iCancelFlag))

			{

			iResultStatus=KErrCancel;

			}

		iCallBack->Call();

		return;

		}

	if (iRecordsPresent)

		{

		if (iStatus.Int() == EAgentYesPressed)	//YES Pressed

			{

			__FLOG(_L("Dialog returned after \"Yes\" was pressed"));

			*iIAPId = static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex])->iDefaultIAP;

			iResultStatus=KErrNone;

			iCallBack->Call();	

			}

		else

			{

			__FLOG_1(_L("No pressed selecting next record - returned %d"),iStatus.Int());

			if(iRecordIndex < (iTable->iRecords.Count() - 1))

				{

				iRecordIndex++;

				}

			else

				{

				iRecordIndex = 0;

				}					

			CCDIAPRecord* ptrIapRecord  = static_cast<CCDIAPRecord*>(static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex])->iDefaultIAP.iLinkedRecord);

			if(!ptrIapRecord)

				{

				CCDIAPRecord* ptrIapRecord = static_cast<CCDIAPRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdIAPRecord));

				CCDConnectionPrefsRecord* connpref = static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex]);

				ptrIapRecord->SetRecordId(connpref->iDefaultIAP);

				connpref->iDefaultIAP.iLinkedRecord = ptrIapRecord;				

				}				

			static_cast<CCDIAPRecord*>(static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[iRecordIndex])->iDefaultIAP.iLinkedRecord)->LoadL(*iDb);

			ReselectL();

			}

		}

	else

		{

		iResultStatus=KErrCancel;

		iCallBack->Call();

		}

	}

TInt CIAPSelection::Status()

/**

Gets the Status

@return the status.

*/

	{

	return iResultStatus;

	}

CAccessPointSelection* CAccessPointSelection::NewL(CMDBSession* aDb,CNetDialDialogSession* aSession, TInt aPriority)

/**

AccessPoint Selection

@param aDb pointer to communications database.

@param aSession pointer to NetDialDialogSession.

@param aPriority Priority.

@return Pointer to AccessPointSelection object.

*/

	{

	CAccessPointSelection* r=new(ELeave) CAccessPointSelection(aDb,aSession,aPriority);

	CleanupStack::PushL(r);

	r->ConstructL();

	CleanupStack::Pop();

	return r;

	}

CAccessPointSelection::CAccessPointSelection(CMDBSession* aDb,CNetDialDialogSession* aSession, TInt aPriority)

	: CDialogBase(aSession, aPriority),

	iDb(aDb)

/**

CIAPSelection Constructor

*/

	{

	}

void CAccessPointSelection::ConstructL()

/**

Completes construction of the CAccessPointSelection object.

@see CDialogBase::ConstructL().

*/

	{

	CDialogBase::ConstructL();

	CActiveScheduler::Add(this);

	}

CAccessPointSelection::~CAccessPointSelection()

/**

CAccessPointSelection Destructor.

*/

	{

	Cancel();

	delete iTable;

	}

void CAccessPointSelection::InitRecordSetL(TUint32 aDefaultAP, TInt aTierId)

	{

	ASSERT(iTable==0);

	iTable = new (ELeave) CMDBRecordSet<CCDAccessPointRecord>(KCDTIdAccessPointRecord);

	iTable->LoadL(*iDb);

    //just to show the TableId and RecordId

    TInt bitMask = KCDMaskShowRecordType | KCDMaskShowRecordId;

	// sort with default SNAP first

	for (TInt i = 0; i < iTable->iRecords.Count(); i++)

		{

		//if (static_cast<CCDAccessPointRecord*>(iTable->iRecords[i])->iRecordTag == aDefaultAP)

		CCDAccessPointRecord* aprec = static_cast<CCDAccessPointRecord*>(iTable->iRecords[i]);

		TInt id = aprec->ElementId() & bitMask;

		if ( (static_cast<CCDAccessPointRecord*>(iTable->iRecords[i])->ElementId() & bitMask) == aDefaultAP)

			{

			CMDBRecordBase* t = iTable->iRecords[i];

			iTable->iRecords[i] = iTable->iRecords[0];

			iTable->iRecords[0] = t;

			break;

			}

		}

	// filter out all access points that do not belong to the specified group

    CMDBField<TInt>* tierTagId = new(ELeave) CMDBField<TInt>(KCDTIdTierRecord | KCDTIdRecordTag);

    CleanupStack::PushL(tierTagId);

	for (TInt i = iTable->iRecords.Count() - 1; i >= 0; i--)

		{

		ASSERT((iTable->iRecords[i]->TypeId() & KCDMaskShowRecordType) == KCDTIdAccessPointRecord);

        //this is the ElementId of the linked TierRec...

		TMDBElementId tierElementId = static_cast<CCDAccessPointRecord*>(iTable->iRecords[i])->iTier;	// was iAccessPointGID; tiers subsume groups concept

		TInt tierRecId = (tierElementId & KCDMaskShowRecordId) >> 8;

		tierTagId->SetRecordId(tierRecId);

		tierTagId->LoadL(*iDb);

		TInt tierId = *tierTagId;

		if (tierId != aTierId)

			{

			CMDBRecordBase* ptr = iTable->iRecords[i];

			iTable->iRecords.Remove(i);

			delete ptr;			

			}

		}

    CleanupStack::PopAndDestroy(tierTagId);

	}

void CAccessPointSelection::GetAccessPointL(TUint32& aAPId, TInt aTierId, TCallBack aCallBack)

/**

Gets the access point.

@param aAPId The id of the access point.

@param aTierId Specifies the tier id.

@param aError Any error code, or KErrNone if no error.

@param aCallBack Encapsulates a general call-back function.

*/

	{

	User::LeaveIfError(aTierId>0? KErrNone : KErrArgument);

	iCallBack = new(ELeave) CAsyncCallBack(aCallBack,CActive::EPriorityStandard);

	iCancelFlag = EFalse;

	iAPId = &aAPId;

	iRecordsPresent = ETrue;

	//Get UID of the tier's manager having the tier's id.

    CCDTierRecord* tierRec = static_cast<CCDTierRecord*>(CCDTierRecord::RecordFactoryL(KCDTIdTierRecord));

	CleanupStack::PushL(tierRec);

    tierRec->iRecordTag = aTierId;

	TBool found = tierRec->FindL(*iDb);

	if (!found)

    	{

    	User::Leave(KErrNotFound);

    	}

	ASSERT(tierRec->iTierManagerName.TypeId() == KCDTIdTierManagerName); // Panics if built against incorrect CommsDat.

	if (tierRec->iDefaultAccessPoint != 0)

		{

		TInt defaultAP = tierRec->iDefaultAccessPoint;

		InitRecordSetL(defaultAP,aTierId);

		if (iTable->iRecords.Count() > 0)

			{

			iAgentDialogInput.iTitle.AppendFormat(KSelectTitle, &KAP);

			ReselectL();

			}

		else

			{

			iAgentDialogInput.iTitle.Format(KWarnPrompt,KErrNotFound);

			_LIT(noService, "No Access Point Records Found");

			iAgentDialogInput.iTitle.Append(noService);