// Copyright (c) 2004-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 the DHCP database access

// 

//

/**

 @file

 @internalTechnology

*/

#include "DHCPDb.h"

#include "DHCPStateMachine.h"

#include <nifman.h>

#include <f32file.h>

#include <comms-infras/metabuffer.h>

#include <metadatabase.h>

#include <commsdattypesv1_1.h>

#include <es_prot.h>

#include "DhcpIP6Msg.h"

using namespace CommsDat;

void CDHCPDb::OpenIAPViewLC(CMDBSession*& aSession, CCDIAPRecord*& aIapRecord)

	{

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

	aSession = CMDBSession::NewLC(KCDVersion1_2);

#else

	aSession = CMDBSession::NewLC(KCDVersion1_1);

#endif

	// 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.

	aSession->SetAttributeMask(ECDHidden | ECDPrivate);

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

	CleanupStack::PushL(aIapRecord);

    aIapRecord->SetRecordId(iIapId);

	aIapRecord->LoadL(*aSession);

	}

void CDHCPDb::GetAddressFamiliesL(RArray<int> & results)

	{

	CMDBSession* session;

	CCDIAPRecord* iap;

	// next call leaves session and iap object on cleanupstack

	OpenIAPViewLC(session, iap);

	CCDServiceRecordBase* service;

	InitialServiceLinkL(session, iap);

	service = static_cast<CCDServiceRecordBase *>(iap->iService.iLinkedRecord);

	TInt ignoreThis;

	CMDBField<TDesC>* cdbLoadStr = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameIfNetworks, ignoreThis));

	TPtrC readPtr(*cdbLoadStr);

	RSocketServ sockServ;

	User::LeaveIfError(sockServ.Connect());

	TLex lex(readPtr);

	while(!lex.Eos())

		{

		TPtrC token;

		lex.Mark();

		TChar ch;

		ch=lex.Peek();

		while(!lex.Eos() && (ch=lex.Peek())!=TChar(','))

			lex.Inc();

		token.Set(lex.MarkedToken());

		if(!token.Length())

			break;

		if(ch==TChar(','))

			lex.Inc();

		TServerProtocolDesc pinfo;

		User::LeaveIfError(sockServ.FindProtocol(token,pinfo));

		results.AppendL(pinfo.iAddrFamily);

		}

	CleanupStack::PopAndDestroy(iap);

	CleanupStack::PopAndDestroy(session);

	return;

	}

#ifdef SYMBIAN_NETWORKING_DHCPSERVER	

/** Checks if DHCP server implementation should be enabled.

  * Currently this is decided depending on if the NapServiceEnabled field is set 	 

  * to true in PAN NAP Service extension table.

  * PAN NAP is the only client for DHCP server implementation in DHCP component.

  * 

  * @internalTechnology

  */

TBool CDHCPDb::CheckIfDHCPServerImplEnabledL()

	{

	CMDBSession* session;

	CCDIAPRecord* iap;

	// next call leaves session and iap object on cleanupstack

	OpenIAPViewLC(session, iap);

	CCDServiceRecordBase* service;

	InitialServiceLinkL(session, iap);

	service = static_cast<CCDServiceRecordBase *>(iap->iService.iLinkedRecord);

	TInt ignoreThis;

	CMDBField<TDesC>* cdbLanServiceExtn = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameServiceExtensionTableName, ignoreThis));

	CMDBField<TInt>* cdbLanServiceExtnRecId = static_cast<CMDBField<TInt>*>(service->GetFieldByNameL(KCDTypeNameServiceExtensionTableRecordId, ignoreThis));

	TInt recId = *cdbLanServiceExtnRecId;

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

	CleanupStack::PushL(panServiceExtRecord);

	HBufC16* readBuffer = HBufC16::NewLC(KCommsDbSvrMaxFieldLength);

	TPtr16 readPtr = readBuffer->Des();

	readPtr.Copy(*cdbLanServiceExtn);

	iDHCPServerImpl = EFalse; // reset this, found it was set to some negative value by default though "this" is derived from CBase

	// DHCP server implementation at the moment is only used by PAN NAP imlpementation

	// Hence, check if the Lan service extension was PAN service extension 

	if(recId && ! readPtr.Compare(TPtrC(KCDTypeNamePANServiceExt))) 

		{

		panServiceExtRecord->SetRecordId(recId);

		panServiceExtRecord->LoadL(*session);

		// set the flag to indicate that this connection needs DHCP server implementation

		iDHCPServerImpl = panServiceExtRecord->iNapServiceEnabled;

		}

	CleanupStack::PopAndDestroy(readBuffer);

	CleanupStack::PopAndDestroy(panServiceExtRecord);	

	CleanupStack::PopAndDestroy(iap);

	CleanupStack::PopAndDestroy(session);

	return iDHCPServerImpl;

	}

#endif // SYMBIAN_NETWORKING_DHCPSERVER	

#ifdef SYMBIAN_DNS_PROXY	

void CDHCPDb::ReadHostNameL(CDHCPStateMachine& aDhcpStateMachine)

	{

	CMDBSession* session;

	CCDIAPRecord* iap;

	// next call leaves session and iap object on cleanupstack

	OpenIAPViewLC(session, iap);

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

       {

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

       }

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

    // load linked network record so we can get its id

    iap->iNetwork.iLinkedRecord->LoadL(*session); 

	CCDNetworkRecord* service;

    service = static_cast<CCDNetworkRecord *>(iap->iNetwork.iLinkedRecord);

	TInt ignoreThis;

	CMDBField<TDesC>* cdbHostName = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameHostName, ignoreThis));

	HBufC16* readHostName = HBufC16::NewLC(KMaxName);

	TPtr16 hostPtr = readHostName->Des();

	hostPtr.Copy(*cdbHostName);

	if(hostPtr.Length()>1)

		{ 

		TInt index = hostPtr.Locate('.');

		TPtrC16 host = hostPtr.Left(index);

		TPtrC16 domain = hostPtr.Right((hostPtr.Length()-1)-index);

		aDhcpStateMachine.iProxyHostName.Copy(hostPtr);

		aDhcpStateMachine.iProxyDomainName.Copy(domain);

		}

	CleanupStack::PopAndDestroy(readHostName);

	CleanupStack::PopAndDestroy(iap);

	CleanupStack::PopAndDestroy(session);

	}

#endif // SYMBIAN_DNS_PROXY	

TBool CDHCPDb::ReadL( CDHCPStateMachine& aDhcpStateMachine, Meta::SMetaData& aPersistent )

/**

  * Read the relevant CommDB entries.

  *

  * Primarily we are looking at the service tables

  * and reading ip address, subnet mask, gateway, 

  * dns address from server fields.  Reading these

  * fields give us connection specific configuration

  * for how to proceed with dhcp negotions...e.g if

  * ipAddress field has a value, then this is the static

  * ip address used in an inform message broadcast across

  * the network...or if dns address from server is true, then

  * dhcp will set the dns servers into the stack once address

  * acquisition is over.

  *

  * @internalTechnology

  */

	{

	TBool addrFromServer=EFalse;

	HBufC16* readBuffer;

	CMDBSession* session;

	CCDIAPRecord* iap;

	// next call leaves session and iap object on cleanupstack

	OpenIAPViewLC(session, iap);

	CCDServiceRecordBase* service;

	InitialServiceLinkL(session, iap);

	service = static_cast<CCDServiceRecordBase *>(iap->iService.iLinkedRecord);

	readBuffer = HBufC16::NewLC(KCommsDbSvrMaxFieldLength);

	TPtr16 readPtr = readBuffer->Des();

	TInt ignoreThis;

	CMDBField<TBool>* cdbLoadBool = static_cast<CMDBField<TBool>*>(service->GetFieldByNameL(KCDTypeNameIpAddrFromServer, ignoreThis));

	addrFromServer = *cdbLoadBool;

	CMDBField<TDesC>* cdbLoadStr = 0;

	if (addrFromServer)

		{//don't really want to leave

#ifdef DHCP_PERSISTENTDATA_INFILE

		TRAPD(err,ReadPersistentL( aDhcpStateMachine.iClientId, aPersistent ));

#else

		//assumes flat memory and byte addressing mode

		HBufC8* persist = HBufC8::NewLC(KCommsDbSvrMaxFieldLength * 2 * sizeof(TUint16));

		TPtr8 des = persist->Des();

		cdbLoadStr = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameIpAddrLeaseValidFrom, ignoreThis));

		des.Copy(*cdbLoadStr);

		cdbLoadStr = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameIpAddrLeaseValidTo, ignoreThis));

		des.Append(*cdbLoadStr);

		TPtrC8 ptr(des);

		if ( aPersistent.GetTypeId().Check( ptr ) == KErrNone )

			{//whatever we read is assumed ok, since TID matches and if not the confirm or reboot will fail

			aPersistent.Load( ptr );

			}

		CleanupStack::PopAndDestroy(persist);

#endif

		}

	else

		{

// DHCP shouldn't look at these values.. if they're static, it's down to the driver below to set them, we'll pick that up later.

		}

	cdbLoadBool = static_cast<CMDBField<TBool>*>(service->GetFieldByNameL(iIpDNSAddressFromServer, ignoreThis));

	aDhcpStateMachine.iNameServerAddressesFromServer = (*cdbLoadBool);

	if( ! aDhcpStateMachine.iNameServerAddressesFromServer )

		{

#ifdef SYMBIAN_DNS_PROXY		

		CMDBField<TDesC>* cdbLoadDns = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameIpNameServer1, ignoreThis));

		aDhcpStateMachine.iProxyDnsSrvAddr.Input(*cdbLoadDns);

#endif		

		}	

	// note the handling of cleanup here...as view and buffer swap positions on the cleanup

	// stack early in the function, forcing this pop and destroy, and the else...

	CleanupStack::PopAndDestroy(readBuffer);	

	CleanupStack::PopAndDestroy(iap);

	CleanupStack::PopAndDestroy(session);

	return addrFromServer;

	}

/* static */

void CDHCPDb::VerifyFieldReadSuccessL(TInetAddr& addr, const TDesC& input, TInt field)

	{

	TInt err;

	(void)field; // for UREL mode

	if(input.Length() == 0)

		{

		__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb: Can't find field %d - using null value"),field));

		TInetAddr nullAddr;  //creates unspecif. (null) address

		addr = nullAddr;

		}

	else if( (err=addr.Input(input)) != KErrNone)

		{

		__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb: Error %d: Can't read field %d as an IP address!"),err,field));

		User::Leave(err);

		}

	}

void CDHCPDb::WriteL( CDHCPStateMachine& aDhcpStateMachine, const Meta::SMetaData& aPersistent )

/**

  * Writes acquired settings into commDB.

  *

  * Stores the time the lease is valid from and to

  * and the configured IP address

  *

  * @internalTechnology

  */

	{

#ifdef DHCP_PERSISTENTDATA_INFILE

	WritePersistentL( aDhcpStateMachine.iClientId, aPersistent );

#else

	(void)aDhcpStateMachine;

	HBufC16* buffer;

	HBufC8* persist = HBufC8::NewLC(aPersistent.Length());

	TPtr8 des = persist->Des();

	aPersistent.Store( des );

#ifdef _DEBUG

	if ( (TUint)des.Length() > 2 * KCommsDbSvrMaxFieldLength * sizeof(TUint16) )

		{

	   __CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::WriteL - persistent data length 3 * KDefaultTextColumnWidth %d"), des.Length()));

		}

#endif

	CMDBSession* session;

	CCDIAPRecord* iap;

	// next call leaves session and iap object on cleanupstack

	OpenIAPViewLC(session, iap);

	CCDServiceRecordBase* service;

	InitialServiceLinkL(session, iap);

	service = static_cast<CCDServiceRecordBase *>(iap->iService.iLinkedRecord);

	buffer = HBufC16::NewLC(KCommsDbSvrMaxFieldLength);

	TPtr16 readWritePtr = buffer->Des();

		{//assumes flat memory and byte addressing mode

		TInt nStored = readWritePtr.MaxLength() * sizeof(TUint16);

		TPtr8 writePtr8( (TUint8*)readWritePtr.Ptr(), readWritePtr.MaxLength() * sizeof(TUint16));

		writePtr8.Copy( des.Mid( 0, Min(nStored, des.Length() )) );

		readWritePtr.SetLength( writePtr8.Length() / sizeof(TUint16) );

		// write the first part of the persistent data

		TInt ignoreThis;

		CMDBField<TDesC>* cdbLoadStr = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameIpAddrLeaseValidFrom, ignoreThis));

		cdbLoadStr->SetMaxLengthL(readWritePtr.Length());

		(*cdbLoadStr) = readWritePtr;

		if ( 	nStored < des.Length() )

			{

			writePtr8.Copy( des.Mid( nStored, Min(des.Length(), KCommsDbSvrMaxFieldLength * sizeof(TUint16)) ) );

			readWritePtr.SetLength( writePtr8.Length() / sizeof(TUint16) );

			// write the second part of the persistent data

			cdbLoadStr = static_cast<CMDBField<TDesC>*>(service->GetFieldByNameL(KCDTypeNameIpAddrLeaseValidTo, ignoreThis));

			cdbLoadStr->SetMaxLengthL(readWritePtr.Length());

			(*cdbLoadStr) = readWritePtr;

			}

		service->ModifyL(*session);

		}

	CleanupStack::PopAndDestroy(buffer);

	CleanupStack::PopAndDestroy(iap);

	CleanupStack::PopAndDestroy(session);

	CleanupStack::PopAndDestroy(persist);

#endif // DHCP_PERSISTENTDATA_INFILE

	}

#ifdef DHCP_PERSISTENTDATA_INFILE

void CDHCPDb::OpenFileLC( const TDesC8& aClientId, TAutoClose<RFs>& aFs, TAutoClose<RFile>& aFile, TBool aCreateNew )

	{

	User::LeaveIfError( aFs.iObj.Connect() );

	aFs.PushL();

	TInt result;

	if ( aCreateNew )

		{

		result = aFs.iObj.CreatePrivatePath (EDriveC);

		if ((result != KErrNone) && (result != KErrAlreadyExists)) 

			{

			User::Leave( result );

			}

		}

	Elements::TRBuf privatePath;

	privatePath.CreateL( 100 );

	CleanupClosePushL(privatePath);

	aFs.iObj.PrivatePath(privatePath);

	TInt toAdd = aClientId.Length() * 2 + 2 + 4;

	TInt space = privatePath.MaxLength() - privatePath.Length();

	if ( space < toAdd )

		{

		privatePath.ReAllocL(privatePath.Length() + toAdd);

		}

	// Get the correct system drive letter in a buffer.	

	TChar sysDriveLetter = RFs::GetSystemDriveChar();

	TBuf<2> sysDriveLetterBuf;

	sysDriveLetterBuf.Fill( sysDriveLetter, 1 );

	sysDriveLetterBuf.Append( _L( ":" ) );

 	privatePath.Insert (0, sysDriveLetterBuf);

	for (TInt n = 0; n < aClientId.Length(); n++)

		{

		privatePath.AppendNumFixedWidthUC( aClientId[n],EHex,2 );

		}

	privatePath.Append( _L(".dat") );

	result = aFile.iObj.Open(aFs.iObj,privatePath,EFileStream|EFileWrite);

	if ( result != KErrNone && aCreateNew )

		{

		result = aFile.iObj.Create (aFs.iObj, privatePath, EFileWrite);

		}

	User::LeaveIfError( result );

	CleanupStack::PopAndDestroy();

	aFile.PushL();

	}

#ifdef _DEBUG

const TInt KMaxPersistenDataLength = 512; //an arbitrarry nember to have some means to check the max store length

#endif

void CDHCPDb::WritePersistentL( const TDesC8& aClientId, const Meta::SMetaData& aPersistent )

	{

	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::WritePersistentL")));

	TAutoClose<RFs> fs;

	TAutoClose<RFile> file;

	OpenFileLC( aClientId, fs, file, ETrue );

	HBufC8* persist = HBufC8::NewLC(aPersistent.Length());

	TPtr8 des = persist->Des();

#ifdef _DEBUG

	if ( des.MaxLength() > KMaxPersistenDataLength )

		{

	   __CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::WriteL - persistent data suspiciously long %d"), des.MaxLength()));

		}

#endif

	aPersistent.Store( des );

	file.iObj.Write( des );

	CleanupStack::PopAndDestroy(persist);

	file.Pop();

	fs.Pop();

	}

void CDHCPDb::ReadPersistentL( const TDesC8& aClientId, Meta::SMetaData& aPersistent )

	{

	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::ReadPersistentL")));

	TAutoClose<RFs> fs;

	TAutoClose<RFile> file;

	OpenFileLC( aClientId, fs, file, EFalse );

	TInt data_size;

	User::LeaveIfError(file.iObj.Size(data_size));

#ifdef _DEBUG

	if ( data_size > KMaxPersistenDataLength )

		{

	   __CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::WriteL - persistent data suspiciously long %d"), data_size));

		}

#endif

	HBufC8* persist = HBufC8::NewLC(data_size);

	TPtr8 des = persist->Des();

	file.iObj.Read(des);

	TPtrC8 ptr( des );

	if ( aPersistent.GetTypeId().Check( ptr ) == KErrNone )

		{//whatever we read is assumed ok, since TID matches and if not the confirm or reboot will fail

		aPersistent.Load( ptr );

		}

	CleanupStack::PopAndDestroy(persist);

	file.Pop();

	fs.Pop();

	}

#endif

void CDHCPDb::InitialServiceLinkL(CMDBSession* aDbSession, CCDIAPRecord* aIapRecord)

	{

	__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::InitialServiceLinkL()")));

	// This will be made more simple quite soon when commsdat supports linked records

	//

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

		{

		const TDesC& servType = aIapRecord->iServiceType;

			{

			// Convert the service type to ASCII.

			TBuf8<KMaxName> tempBuf;

			tempBuf.Copy( servType );

			__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CDHCPDb::InitialServiceLinkL() service type = \"%S\""), &tempBuf));

			}

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

			{

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

			}

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

			{

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

			}

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

			{

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

			}

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

			{

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

			}

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

			{

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

			}

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

			{

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

			}

		else

			{

			__CFLOG_VAR((KLogSubSysDHCP, KLogCode, _L8("CCDHCPDb::InitialServiceLinkL() Invalid Service Type!!!")));

			User::Leave(KErrBadName);	

			}

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

		}