/*

* Copyright (c) 2005-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 "activeconnection.h"

CActiveConnection* CActiveConnection::NewL(const TDesC& ipAddress, TInt port)

{

	CActiveConnection* self=new(ELeave)CActiveConnection();

	CleanupStack::PushL(self);

	self->ConstructL(ipAddress,port);

	CleanupStack::Pop();

	return self;	

}

CActiveConnection::CActiveConnection(void) : CActive(0)

{

	;

}

void CActiveConnection::ConstructL(const TDesC& ipAddress, TInt port)

{

	iDstAddr.SetPort(port);		

    iDstAddr.Input(ipAddress);

	CActiveScheduler::Add(this);

}

CActiveConnection::~CActiveConnection()

{

	Cancel();

}

//Checks for user input to console.

void CActiveConnection::RunL()

{

	if(iStatus==KErrInUse)

	{

		Connect();

		SetActive();

	}

}

void CActiveConnection::DoCancel()

{

}

void CActiveConnection::Connect(TActiveConnectionMode aConnMode, TInt aConnIndex)

{

	//Wait 2 seconds before attempting to connect to NTRAS

	//It solves 8, randomly failing to connect to NTRAS

	User::After(KDelay);

#if defined(__WINS__)

    // WinTap IAP

	TUint32 lIAP = 0;

	_LIT16(KWIN_TAP, "WinTAP");

	/****************** CommsDat Soloution ************************

		CMDBSession* iDb = CMDBSession::NewL(CMDBSession::LatestVersion());

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

		TPtrC recordname(KWIN_TAP);

		ptrIAPRecord->iRecordName.SetMaxLengthL(recordname.Length());

		ptrIAPRecord->iRecordName = recordname;

		if(ptrIAPRecord->FindL(*iDb))

	    {

		    // Found a matching record

	//	    ptrIAPRecord->iService.LoadL(*iDb);

		    delete ptrIAPRecord;  

	    }

	***************************************************************/

	if (aConnMode == EModeIAP && aConnIndex == 0)

	{

		// Open CommDB IAP table

		CCommsDatabase* lCommsDb = CCommsDatabase::NewL();

    	CleanupStack::PushL(lCommsDb);

		CCommsDbTableView* lIapTable = lCommsDb->OpenTableLC(TPtrC(IAP));

		TBuf<52> lIapName;

		// Point to the first entry

		User::LeaveIfError(lIapTable->GotoFirstRecord());

		lIapTable->ReadTextL(TPtrC(COMMDB_NAME), lIapName);

		if (lIapName.Find(KWIN_TAP) != KErrNotFound) 

		{

			lIapTable->ReadUintL(TPtrC(COMMDB_ID), lIAP);

		}

		else

		{

			// Point to the rest of the entries

			TInt err = KErrNone;

			while (err = lIapTable->GotoNextRecord(), err == KErrNone)

			{

				lIapTable->ReadTextL(TPtrC(COMMDB_NAME), lIapName);

				if (lIapName.Find(KWIN_TAP) != KErrNotFound) 

				{

					lIapTable->ReadUintL(TPtrC(COMMDB_ID), lIAP);

				}

			}

		}

		CleanupStack::PopAndDestroy(lIapTable);

    	CleanupStack::PopAndDestroy(lCommsDb);

		aConnIndex = lIAP;

	}

#endif

	// Create Connection with IAP

	TInt lErr = iSocketServer.Connect();

	if (lErr != KErrNone) 

		return;

	RConnection lConn;

    lErr = lConn.Open(iSocketServer);

    if (lErr == KErrNone && aConnIndex > 0)

    {

    	if (aConnMode == EModeIAP)

    	{

	    	// Set IAP Preferences

			TCommDbConnPref lPrefs;

			lPrefs.SetIapId(aConnIndex);

			lPrefs.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

			lErr = lConn.Start(lPrefs);

    	}

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

    	else if (aConnMode == EModeSnap)

    	{

    		TConnSnapPref lPrefs(aConnIndex);

    		lErr = lConn.Start(lPrefs);

    	}

#endif // SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

    	else

    	{

    		// use default mode

    		lErr = KErrNotSupported;

    	}

		if (lErr == KErrNone) 

		{

			RHostResolver lHostResolver;

			lErr = lHostResolver.Open(iSocketServer, KAfInet, KProtocolInetTcp, lConn);

			if (lErr == KErrNone) 

			{

				lErr = iSocket.Open(iSocketServer, KAfInet, KSockStream, KProtocolInetTcp, lConn);

			}

		}

    }

    if (aConnIndex == 0 || lErr != KErrNone)

    {

    	iSocket.Open(iSocketServer, KAfInet, KSockStream, KProtocolInetTcp);

    }

    // Connect

	iSocket.Connect(iDstAddr, iStatus);

}

//Initial request

void CActiveConnection::Start(TActiveConnectionMode aConnMode, TInt aConnIndex)

{    

	Connect(aConnMode, aConnIndex);

	SetActive();

}

void CActiveConnection::CloseSocket()

{    

	iSocket.CancelConnect();

	iSocket.Close();

}