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

// All comms database access is performed through a CCommsDatabase object

// 

//

/**

 @file

*/

#include <nifvar.h>

#include <comms-infras/nifprvar.h>

#include <commdb.h>

#include "DbAccess.h"

#include "NetConError.h"

#include "AgentPanic.h"

#include "Ni_Log.h"

#include "DbAccessImplv2.h"

#include <commsdat.h>

#include <commsdatutils.h>

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <commsdattypesv1_1_partner.h>

#endif

/**

Label for retrieving active isp service type

@internalComponent

*/

#define SERVICE_TYPE									_S("ServiceType")

/**

@internalComponent

*/

namespace

	{

	_LIT(KPPPModemCsyName,"ModemBearer\\CSYName");

	_LIT(KPPPModemPortName,"ModemBearer\\PortName");

	const TUint32 KCommsDbMaxConnections = 2;

	}

//

// CCommsDatAccessImpl definitions

//

CCommsDatAccessImpl* CCommsDatAccessImpl::NewL()

  	{

	return CCommsDatAccessImpl::NewL( EFalse );

 	}

CCommsDatAccessImpl* CCommsDatAccessImpl::NewL(TBool aShowHidden)

  	{

	CCommsDatAccessImpl* p = new(ELeave) CCommsDatAccessImpl();

  	CleanupStack::PushL(p);

  	p->ConstructL(aShowHidden);

  	CleanupStack::Pop();

  	return p;

 	}

CCommsDatAccessImpl::CCommsDatAccessImpl():

	iNetworkMode(RMobilePhone::ENetworkModeUnknown)	

	{		

	}

void CCommsDatAccessImpl::ConstructL(TBool& aShowHidden)

	{

	iDb = CMDBSession::NewL(KCDVersion1_2);

	if(aShowHidden)

		{

		// Reveal hidden or private IAP records if a licensee has chosen to protect a record

		// using one of these flags - the API to do this is public so internal components

		// have to support the use of such records.

		iDb->SetAttributeMask(ECDHidden | ECDPrivate); 

		}

	//create a container for the iap record	

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

	}

CCommsDatAccessImpl::~CCommsDatAccessImpl()

	{

	Close();

	delete iDb;

	// NOTE! Do not delete iOverrides and iServiceChangeObserver as

	// they are owned by other objects and they are just used

	// throught the pointers in the DbAccess.cpp!

	}

void CCommsDatAccessImpl::Close()

	{

	if (iIAPSetting != NULL)

		{

		delete iIAPSetting->iService.iLinkedRecord;

		iIAPSetting->iService.iLinkedRecord = NULL;

		delete iIAPSetting->iBearer.iLinkedRecord;

		iIAPSetting->iBearer.iLinkedRecord = NULL;

		delete iIAPSetting->iLocation.iLinkedRecord;

		iIAPSetting->iLocation.iLinkedRecord = NULL;

		delete iIAPSetting->iNetwork.iLinkedRecord;

		iIAPSetting->iNetwork.iLinkedRecord = NULL;

		}

	delete iIAPSetting;

	iIAPSetting = NULL;

	delete iChargecardSetting;

	iChargecardSetting = NULL;

	delete iLanServiceExtensionTable;

	iLanServiceExtensionTable = NULL;

	iGotSettings=EFalse;

	}

void CCommsDatAccessImpl::SetOverridesL(CCommDbOverrideSettings* aOverrides)

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::SetOverridesL()"));)

	iOverrides = aOverrides;

	}

TBool CCommsDatAccessImpl::IsShowingHiddenRecords()

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::IsShowingHiddenRecords()"));)

	TMDBAttributeFlags attributeMask = iIAPSetting->Attributes();

	if(attributeMask & ECDHidden)

		{

		return ETrue;

		}

	else

		{

		return EFalse;

		}	

	}

void CCommsDatAccessImpl::CreateCacheL()

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::CreateCacheL()"));)

	// CreateCacheL loads the linked records only on condition that they are equal to NULL

	// This causes a wrong link when the iIAPSetting object's fields are assigned new values

	// The following section of deletes ensures that the corrwct links will be created in a case of reload.

	const TDesC& servType = iIAPSetting->iServiceType;

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::CreateCacheL() service type = \"%S\""), &servType);)

	delete iIAPSetting->iService.iLinkedRecord;

	iIAPSetting->iService.iLinkedRecord = NULL;	

	delete iIAPSetting->iBearer.iLinkedRecord;

	iIAPSetting->iBearer.iLinkedRecord = NULL;

	delete iIAPSetting->iLocation.iLinkedRecord;

	iIAPSetting->iLocation.iLinkedRecord = NULL;

	delete iIAPSetting->iNetwork.iLinkedRecord;

	iIAPSetting->iNetwork.iLinkedRecord = NULL;

	// service

	if (iIAPSetting->iService.iLinkedRecord == 0)

		{

		if (servType.CompareF(TPtrC(KCDTypeNameDialOutISP))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDDialOutISPRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdDialOutISPRecord));

			}

		else if (servType.CompareF(TPtrC(KCDTypeNameDialInISP))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDDialInISPRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdDialInISPRecord));

			}

		else if (servType.CompareF(TPtrC(KCDTypeNameLANService))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDLANServiceRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdLANServiceRecord));

			}

		else if (servType.CompareF(TPtrC(KCDTypeNameVPNService))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDVPNServiceRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVPNServiceRecord));

			}

		else if (servType.CompareF(TPtrC(KCDTypeNameOutgoingWCDMA))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDOutgoingGprsRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdOutgoingGprsRecord));

			}

		else if (servType.CompareF(TPtrC(KCDTypeNameIncomingWCDMA))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDIncomingGprsRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdIncomingGprsRecord));

			}

		/*else if (servType.CompareF(TPtrC(WHAT IS THIS NAME?))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDWCDMAPacketServiceRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdWCDMAPacketServiceRecord));

			}*/

		else if (servType.CompareF(TPtrC(KCDTypeNameDefaultWCDMA))==0)

			{

			iIAPSetting->iService.iLinkedRecord = static_cast<CCDDefaultWCDMARecord*>(CCDRecordBase::RecordFactoryL(KCDTIdDefaultWCDMARecord));

			}

		else

			{

			LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::CreateCacheL() service type does not match any supported type")));

			User::Leave(KErrCorrupt);

			}

		iIAPSetting->iService.iLinkedRecord->SetRecordId(iIAPSetting->iService);

		iIAPSetting->iService.iLinkedRecord->LoadL(*iDb);

		if (servType.CompareF(TPtrC(KCDTypeNameOutgoingWCDMA)) == 0)

			{

			// umts R99 and onwards table

			CCDOutgoingGprsRecord* outgoingGprs = static_cast<CCDOutgoingGprsRecord*>(iIAPSetting->iService.iLinkedRecord);

			if (outgoingGprs->iUmtsR99QoSAndOnTable.iLinkedRecord == 0 && outgoingGprs->iUmtsR99QoSAndOnTable != 0 )

				{

				outgoingGprs->iUmtsR99QoSAndOnTable.iLinkedRecord = static_cast<CCDUmtsR99QoSAndOnTableRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdUmtsR99QoSAndOnTableRecord));

				outgoingGprs->iUmtsR99QoSAndOnTable.iLinkedRecord->SetRecordId(outgoingGprs->iUmtsR99QoSAndOnTable);

				outgoingGprs->iUmtsR99QoSAndOnTable.iLinkedRecord->LoadL (*iDb);

				}

			}

		}

	// bearer

	if (iIAPSetting->iBearer.iLinkedRecord == 0)

		{

		const TDesC& bearType = iIAPSetting->iBearerType;

		LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::CreateCacheL() bearer type = \"%S\""), &bearType);)

		if (bearType.CompareF(TPtrC(KCDTypeNameModemBearer))==0)

			{

			iIAPSetting->iBearer.iLinkedRecord = static_cast<CCDModemBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdModemBearerRecord));

			}

		else if (bearType.CompareF(TPtrC(KCDTypeNameLANBearer))==0)

			{

			iIAPSetting->iBearer.iLinkedRecord = static_cast<CCDLANBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdLANBearerRecord));

			}

		else if (bearType.CompareF(TPtrC(KCDTypeNameVirtualBearer))==0)

			{

			iIAPSetting->iBearer.iLinkedRecord = static_cast<CCDVirtualBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdVirtualBearerRecord));

			}

		else if (bearType.CompareF(TPtrC(KCDTypeNameWAPSMSBearer))==0)

			{

			iIAPSetting->iBearer.iLinkedRecord = static_cast<CCDWAPSMSBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdWAPSMSBearerRecord));

			}

		else if (bearType.CompareF(TPtrC(KCDTypeNameWAPIPBearer))==0)

			{

			iIAPSetting->iBearer.iLinkedRecord = static_cast<CCDWAPIPBearerRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdWAPIPBearerRecord));

			}

		else

			{

			LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::CreateCacheL() bearer type does not match any supported type")));

			User::Leave(KErrCorrupt);

			}

		iIAPSetting->iBearer.iLinkedRecord->SetRecordId(iIAPSetting->iBearer);

		}

	// location

	if (iIAPSetting->iLocation.iLinkedRecord == 0)

		{

		iIAPSetting->iLocation.iLinkedRecord = static_cast<CCDLocationRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdLocationRecord));

		iIAPSetting->iLocation.iLinkedRecord->SetRecordId(iIAPSetting->iLocation);

		}

	// network

	if (iIAPSetting->iNetwork.iLinkedRecord == 0)

		{

		iIAPSetting->iNetwork.iLinkedRecord = static_cast<CCDNetworkRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdNetworkRecord));

		iIAPSetting->iNetwork.iLinkedRecord->SetRecordId(iIAPSetting->iNetwork);

		}

	// load everything from the database

	iIAPSetting->iBearer.iLinkedRecord->LoadL(*iDb);

	iIAPSetting->iLocation.iLinkedRecord->LoadL(*iDb);

	iIAPSetting->iNetwork.iLinkedRecord->LoadL(*iDb);

	}

void CCommsDatAccessImpl::GetCurrentSettingsL(TConnectionSettings& aSettings, TCommDbConnectionDirection aDirection, TUint32 aRank)

/**

Get default settings from overrides or database.

No checking that the default exists yet -

that's done in the SetCurrentSettingsL() function.

*/

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::GetCurrentSettingsL()"));)

	aSettings.iRank = aRank;

	aSettings.iDirection = aDirection;

	// Identify IAP associated with connection preference with ranking 1

	// and open IAP record in a table view

	//this is a workaround for the missing preference table entries (SNAP selection)

	TRAPD(err,GetIapConnectionPreferenceL(aSettings));

	if ((err==KErrNetConDatabaseDefaultUndefined || err==KErrNetConDatabaseNotFound) && aRank>1)

	    err=KErrNone;

    User::LeaveIfError(err);		

	iIAPSetting->SetRecordId(aSettings.iIAPId);

  	iIAPSetting->LoadL(*iDb);	

	CreateCacheL();

	aSettings.iBearerType = iIAPSetting->iBearerType;

	aSettings.iBearerId = iIAPSetting->iBearer;

	aSettings.iLocationId = iIAPSetting->iLocation;

	iGotSettings=ETrue;	

	}

void CCommsDatAccessImpl::GetServiceSettingsL(TConnectionSettings& aSettings)

/**

Get service settings from database.

No checking that the default exists yet -

that's done in the SetCurrentSettingsL() function.

*/

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::GetServiceSettingsL()"));)

	aSettings.iServiceId = iIAPSetting->iService;	

	aSettings.iServiceType = iIAPSetting->iServiceType;

	iIAPSetting->iService.iLinkedRecord->RefreshL(*iDb);

	// If this is a CSD connection get the chargecard ID

	if((aSettings.iServiceType).CompareF(TPtrC(DIAL_OUT_ISP))==0)//defect || ((aSettings.iServiceType).CompareF(TPtrC(DIAL_IN_ISP))==0))

		{  

		aSettings.iChargeCardId = ((CCDDialOutISPRecord*)(iIAPSetting->iService.iLinkedRecord))->iChargecard;

		if(aSettings.iChargeCardId)

			{

			// iChargecardSetting wasn't created on startup so create/recreate here

 			delete iChargecardSetting;

  			iChargecardSetting = 0;					

			iChargecardSetting = static_cast<CCDChargecardRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdChargecardRecord));

			iChargecardSetting->SetRecordId(aSettings.iChargeCardId);

  			iChargecardSetting->LoadL(*iDb);	

			}		

		}

	else

		{

  		// If this is a LAN-type connection, check to see whether there's an extension table (ie. it's a WLAN or BT PAN connection)

  		if((aSettings.iServiceType).CompareF(TPtrC(LAN_SERVICE))==0)

  			{

  			delete iLanServiceExtensionTable;

			CCDLANServiceRecord* lanRecord = static_cast<CCDLANServiceRecord*>(iIAPSetting->iService.iLinkedRecord);

  			const TDesC& extName = lanRecord->iServiceExtensionTableName;

			if(extName.CompareF(TPtrC(KCDTypeNamePANServiceExt)) == 0)

				{

				iLanServiceExtensionTable = static_cast<CCDPANServiceExtRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdPANServiceExtRecord));

				iLanServiceExtensionTable->SetRecordId(lanRecord->iServiceExtensionTableRecordId);

				iLanServiceExtensionTable->LoadL(*iDb);

				}

			else if(extName.CompareF(TPtrC(KCDTypeNameWLANServiceExt))==0)

				{

				iLanServiceExtensionTable = static_cast<CCDWLANServiceExtRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdWLANServiceExtRecord));

				iLanServiceExtensionTable->SetRecordId(lanRecord->iServiceExtensionTableRecordId);

				iLanServiceExtensionTable->LoadL(*iDb);

				}

			// else no extension table to initialize

			}

		}

		if(LocationRequiredL())

			{

			if (iIAPSetting->iLocation.iLinkedRecord == NULL)

				{

				iIAPSetting->iLocation.iLinkedRecord = static_cast<CCDLocationRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdLocationRecord));

				}

			iIAPSetting->iLocation.iLinkedRecord->SetRecordId(aSettings.iLocationId);

			if (!iIAPSetting->iLocation.iLinkedRecord->FindL(*iDb))

				{

				User::Leave(KErrNotFound);

				}

			}

	}

void CCommsDatAccessImpl::GetPreferedIapL(TUint32& aIapId, TCommDbConnectionDirection aDirection, TUint32 aRank)

/**

Get IapId for the connection preference of ranking aRank.

Leaves if not found

*/

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::GetPreferedIapL()"));)

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

	CleanupStack::PushL(ptrConnectionPref);

	ptrConnectionPref->iRanking = aRank;

	ptrConnectionPref->iDirection = aDirection;

	if (!ptrConnectionPref->FindL(*iDb))

		{

		User::Leave(KErrNotFound);

		}

	aIapId = ptrConnectionPref->iDefaultIAP;

	CleanupStack::PopAndDestroy(ptrConnectionPref);

	}

void CCommsDatAccessImpl::GetIapConnectionPreferenceL(TConnectionSettings& aSettings)

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::GetIapConnectionPreferenceL(TConnectionSettings& aSettings)"));)

	// set to defaults before we start

	aSettings.iDialogPref = ECommDbDialogPrefUnknown;

	aSettings.iBearerSet = 0;

	aSettings.iIAPId = 0;

	iDirection = aSettings.iDirection;

	// if we already have overrides stored here then use them

	if (iOverrides)

		{

		CCommsDbConnectionPrefTableView::TCommDbIapConnectionPref overPref;

		overPref.iRanking = aSettings.iRank;

		overPref.iDirection = aSettings.iDirection;

		iOverrides->GetConnectionPreferenceOverride(overPref);

		// write them back into the parameter we are to fill with data

		aSettings.iDialogPref = overPref.iDialogPref;

		aSettings.iBearerSet = overPref.iBearer.iBearerSet;

		aSettings.iIAPId = overPref.iBearer.iIapId;

		if (aSettings.iDialogPref != ECommDbDialogPrefPrompt)

			{

			iIAPOverridden = ETrue;

			}

		else

			{

			iIAPOverridden = EFalse;

			}

		}

	// if the overrides are not complete then we need to read the remaining settings from the database table

	TBool overridesComplete = (aSettings.iDialogPref != ECommDbDialogPrefUnknown) && (aSettings.iBearerSet != 0) && (aSettings.iIAPId != 0);

	if (!overridesComplete)

		{

		// create the connection preference, prefill it with stuff and then read from the database

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

		CleanupStack::PushL(connpref);

		connpref->iRanking = aSettings.iRank;

		connpref->iDirection = aSettings.iDirection;

		if(!connpref->FindL(*iDb))

			{

			User::Leave(KErrNetConDatabaseDefaultUndefined);

			}

		// now for each field which is currently unset overwrite it with whatever was in the appropriate table in the database

		if (aSettings.iDialogPref == ECommDbDialogPrefUnknown)

			{

			aSettings.iDialogPref = static_cast<TCommDbDialogPref>(static_cast<TUint32>(connpref->iDialogPref));

			}

		if (aSettings.iBearerSet == 0)

			{

			aSettings.iBearerSet = connpref->iBearerSet;

			}

		if (aSettings.iIAPId != 0)

			{

			if (aSettings.iDialogPref!=ECommDbDialogPrefPrompt)

				{

				iIAPOverridden = ETrue;

				}

			else

				{

				iIAPOverridden = EFalse;

				}

			}

		else

			{

			iIAPOverridden = EFalse;

			aSettings.iIAPId = connpref->iDefaultIAP;

			}

		CleanupStack::PopAndDestroy(connpref);

		}

	}

void CCommsDatAccessImpl::SetCurrentSettingsL(const TConnectionSettings& aSettings)

/**

Set current settings to aSettings and check that relevant

records exist in the databases. If the settings have been changed

(not overrides) write the new values back to the database.

*/

	{

	LOG(NifmanLog::Printf(_L("CCommsDatAccessImpl::SetCurrentSettingsL()"));)

	TInt serviceId = iIAPSetting->iService;

	//if the IAP is already overriden, just update the existing record

	if(iIAPOverridden)

		{

		iIAPSetting->RefreshL(*iDb);						

		}

	else

		{

		iIAPSetting->SetRecordId(aSettings.iIAPId);

  		iIAPSetting->LoadL(*iDb);

		}		

	CreateCacheL();		

	if(serviceId != iIAPSetting->iService)

		{

		CheckForServiceChange(ETrue);

		}

	// If this is a CSD connection get the chargecard ID

	if(((aSettings.iServiceType).CompareF(TPtrC(DIAL_OUT_ISP)) == 0) || ((aSettings.iServiceType).CompareF(TPtrC(DIAL_IN_ISP)) == 0))

		{

		// iChargecardSetting wasn't created on startup so create/recreate here

		if(aSettings.iChargeCardId)

			{

 			delete iChargecardSetting;

  			iChargecardSetting = 0;					

			iChargecardSetting = static_cast<CCDChargecardRecord*>(CCDRecordBase::RecordFactoryL(KCDTIdChargecardRecord));

			iChargecardSetting->SetRecordId(aSettings.iChargeCardId);

  			iChargecardSetting->LoadL(*iDb);