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

#include <cdbpreftable.h>

#include <commsdat.h>
#include <commsdattypesv1_1.h>
#include <commdbconnpref.h>
#include <miut_err.h>
#include <es_enum.h>		// For TConnectionInfo
#include <imutcon.h>
#include "IMSK.H"


#ifdef _DEBUG
#define __IMSK_SIMULATION
#include <etel.h>
#endif

#define __IMSK_LOGGING


CImConnect* CImConnect::NewL(const CImIAPPreferences& aIAPPreferences, CImTextServerSession &aTextSession)
	{
	CImConnect* self = new (ELeave) CImConnect(aIAPPreferences, &aTextSession, NULL);
	CActiveScheduler::Add(self);
	return self;
	}

EXPORT_C CImConnect* CImConnect::NewL(const CImIAPPreferences& aIAPPreferences, RSocketServ& aSocketServerHandle)
	{
	CImConnect* self = new (ELeave) CImConnect(aIAPPreferences, NULL, &aSocketServerHandle);
	CActiveScheduler::Add(self);
	return self;
	}

void CImConnect::RunL()
	{
	User::RequestComplete(iReportStatus, iStatus.Int());
	}

void CImConnect::DoCancel()
	{
	iConn.Close();
	User::RequestComplete(iReportStatus, KErrCancel);
	}

EXPORT_C void CImConnect::StartL(TRequestStatus& aStatus)
	{
	// Attempt the first connection using the appropriate IAP.
	iReportStatus = &aStatus;
	if (iTextSession != NULL)
		{
		User::LeaveIfError(iConn.Open(iTextSession->GetSocketServ()));
		}
	else
		{
		User::LeaveIfError(iConn.Open(*iSocketServerHandle));
		}
	ConnectL();
	SetActive();
	aStatus=KRequestPending;
	}

#ifdef __IMSK_SIMULATION
void CImConnect::SetIAPsToFail(TInt aIAPsToFail)
	{
	iIAPsToFail=aIAPsToFail;
	}
#endif

void CImConnect::ConnectL()
	{
	if (iIAPPreferences.SNAPDefined())
		{
		ConnectWithSNAP();
		}
	else
		{
		ConnectWithIAPListL();
		}
	}

void CImConnect::ConnectWithSNAP()
	{
	TConnSnapPref snapPref(iIAPPreferences.SNAPPreference());
	iConn.Start(snapPref, iStatus);
	}

void CImConnect::ConnectWithIAPListL()
	{
	TInt iapCount=iIAPPreferences.NumberOfIAPs();

	if(iapCount==0)
		{
#ifdef __IMSK_LOGGING
		_LIT8(KImConDefault,"CImConnect connecting with defaults");
		if (iTextSession != NULL)
			{
			iTextSession->LogText(KImConDefault);
			}
#endif
		iConn.Start(iStatus);
		}
	else
		{
#ifdef __IMSK_SIMULATION
		if(iapCount<=iIAPsToFail)
			{
#ifdef __IMSK_LOGGING
			_LIT8(KImConSimFail,"CImConnect simulated failure of all IAPs");
			if (iTextSession != NULL)
				{
				iTextSession->LogText(KImConSimFail);
				}
#endif
			TRequestStatus* status = &iStatus;
			// Just pick an etel error and pretend we failed
   			User::RequestComplete(status, KErrEtelModemNotDetected);  
			return;
			}
#endif
		// Set up the appropriate override
#ifdef __IMSK_LOGGING
		_LIT8(KImConOverride,"CImConnect trying overrides");
		if (iTextSession != NULL)
			{
			iTextSession->LogText(KImConOverride);
			}
#endif

		TInt rank=1;
#ifdef __IMSK_SIMULATION
		for(TInt i=iIAPsToFail;i<iapCount;i++)
#else
		for(TInt i=0;i<iapCount;i++)
#endif
			{
			TCommDbConnPref pref;
			pref.SetDirection(ECommDbConnectionDirectionOutgoing);
			
			// legacy code which restricted the type of bearer
			pref.SetBearerSet(KCommDbBearerCSD | KCommDbBearerWcdma | KCommDbBearerLAN |
			                  KCommDbBearerVirtual | KCommDbBearerPAN | KCommDbBearerWLAN);

			TImIAPChoice iapChoice = iIAPPreferences.IAPPreference(i);

			pref.SetIapId(iapChoice.iIAP);
			pref.SetDialogPreference(iapChoice.iDialogPref);

			User::LeaveIfError(iPrefs.SetPreference(rank, pref));

			rank++;
			}

		iPrefs.SetConnectionAttempts(rank-1);
		iConn.Start(iPrefs, iStatus);
		}
	}

CImConnect::~CImConnect()
	{
	Cancel();
	// Fix for DEF40210:
	// Although it is not necessary because the RSocketServ will delete all RConnection handles when it is closed, 
	// we call this for completeness as this class should tidy up all resources it creates
	iConn.Close();
	}

CImConnect::CImConnect(const CImIAPPreferences& aIAPPreferences, CImTextServerSession* aTextSession, RSocketServ* aSocketServerHandle) : 
		CActive(EPriorityStandard), iIAPPreferences(aIAPPreferences), iTextSession(aTextSession), iSocketServerHandle(aSocketServerHandle)
	{
	}

TInt CImConnect::RunError(TInt aError)
	{
	if (iReportStatus)
		User::RequestComplete(iReportStatus, aError);

	return KErrNone;
	}

EXPORT_C TInt CImConnect::GetIAPValue(TUint32& aIap)
	{
	// INC040630 - AV20 Panic while disconnecting a service.
	// Cancel closes the RConnection. Check we still have a valid subsession
	// handle.
	TInt iapValue = KErrBadHandle;
	if (iConn.SubSessionHandle() != KNullHandle)
		{		
		TBuf<KCommsDbSvrMaxColumnNameLength> settingName;
		settingName.Copy(KCDTypeNameIAP);
		settingName.Append('\\');
		settingName.Append(TPtrC(KCDTypeNameRecordTag));
		iapValue = iConn.GetIntSetting(settingName, aIap);
		}
	return iapValue;
	}

EXPORT_C TInt CImConnect::GetIAPBearer(TUint32& aBearer)
	{
	TInt err = KErrBadHandle;
	if (iConn.SubSessionHandle() != KNullHandle)
		{
		TBuf<KCommsDbSvrMaxColumnNameLength> iapservicename;	
		TBuf<KCommsDbSvrMaxColumnNameLength> settingName;
		settingName.Copy(KCDTypeNameIAP);
		settingName.Append('\\');
		settingName.Append(TPtrC(KCDTypeNameServiceType));
		
		// Get the current active IAP's service name
		err = iConn.GetDesSetting(settingName, iapservicename);
		if(err==KErrNone)
			{
			// Set the bearer corresponding to the service name
			if( iapservicename.Compare(TPtrC(KCDTypeNameDialOutISP))==0 ||
				iapservicename.Compare(TPtrC(KCDTypeNameDialInISP))==0)
				aBearer=KCommDbBearerCSD;
			else if( iapservicename.Compare(TPtrC(KCDTypeNameOutgoingWCDMA))==0 ||
					 iapservicename.Compare(TPtrC(KCDTypeNameIncomingWCDMA))==0)
				aBearer=KCommDbBearerWcdma;
			else if(iapservicename.Compare(TPtrC(KCDTypeNameLANService))==0)
				aBearer=KCommDbBearerLAN;	
			else 
				err = KErrNotFound;
			}	
		}
	return err;
	}

EXPORT_C RConnection& CImConnect::GetConnection()
	{
	return iConn;
	}

EXPORT_C TInt CImConnect::Progress(TNifProgress& aProgress)
	{
	if (iConn.SubSessionHandle() != KNullHandle)
		return iConn.Progress(aProgress);
	return KErrBadHandle;
	}

EXPORT_C TInt CImConnect::GetRConnectionName(TName &aName)
	{
	return iConn.Name(aName);
	}

EXPORT_C TInt CImConnect::GetLastSocketActivityTimeout(TUint32& aTimeout)
	{
	TInt err = KErrBadHandle;

	if (iConn.SubSessionHandle() != KNullHandle)
		{
		TBuf<KCommsDbSvrMaxColumnNameLength> settingName;
		TBuf<KCommsDbSvrMaxColumnNameLength> iapBearer;

		settingName.Copy(KCDTypeNameIAP);
		settingName.Append('\\');
		settingName.Append(TPtrC(KCDTypeNameBearerType));

		// Get the current active IAP's bearer table name
		err = iConn.GetDesSetting(settingName, iapBearer);

		if (err == KErrNone)
			{
			// Get the last socket activity timeout from the bearer table
			iapBearer.Append('\\');
			iapBearer.Append(TPtrC(KCDTypeNameLastSocketActivityTimeout));
			err = iConn.GetIntSetting(iapBearer, aTimeout);
			}
		}

	return err;
	}

// Continuing the Existing RConnection	
void CImConnect::SecondaryStartL(CImTextServerSession* aPrimaryTextServerSession)
	{
	// openign the connection from socketserver.
	User::LeaveIfError(iConn.Open(iTextSession->GetSocketServ()));

#ifdef __IMSK_LOGGING
	_LIT8(KImConDefault,"SecondarySession connecting with existing RConnection");
	iTextSession->LogText(KImConDefault);
#endif

	TConnectionInfo connInfo;
	TPckg<TConnectionInfo> connInfoPckg(connInfo);
	TUint count;
	// Enumerates the number of currently active interfaces
	User::LeaveIfError(aPrimaryTextServerSession->GetCImConnect()->GetConnection().EnumerateConnections(count));
	// Get the information about currently active connection	
	User::LeaveIfError(aPrimaryTextServerSession->GetCImConnect()->GetConnection().GetConnectionInfo(count, connInfoPckg) );
	// Attaches the RConnection object to an existing interface
	User::LeaveIfError(iConn.Attach(connInfoPckg, RConnection::EAttachTypeNormal));
	}