/*

* 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 <e32def.h>

#include <inet.h>

#include "CTCPTransport.h"

#include "assert.h"

#include <CommDbConnPref.h>

CTCPTransport::CTCPTransport()

	{

	}

CTCPTransport::~CTCPTransport()

	{

	iSocket.Close();

	iServer.Close();

	}

TInt CTCPTransport::InitialiseL()

	{

	return KErrNone;

	}

TInt CTCPTransport::Release( void )

	{

	iSocket.Close();

	iServer.Close();

	return KErrNone;

	}

TInt CTCPTransport::ConnectL( TDesC* aRemoteHost )

	{

	// Retrieve the destination port location

	TInt colonPos = aRemoteHost->Locate( TChar(':') );

	if(colonPos != KErrNotFound)

		{

		// Set the destination port

		TPtrC host( aRemoteHost->Left(colonPos) );

		TLex portLex( aRemoteHost->Mid(colonPos + 1) );

		TInt port = 0;

		portLex.Val( port );

		iDestAddr.SetPort( port );

		// Retrieve and set the destination ip address

		TBuf<20> ipAddress;

		ipAddress.Copy( host.Ptr(), colonPos );

		iDestAddr.Input( ipAddress );

		}

	else

		{

		iDestAddr.SetPort( KUCCTCPPort );

		}

	// pick out the iap/snap index..

	TInt index=0;

	TPtrC mode;

	TInt pipePos = aRemoteHost->Locate( TChar('|') );

	if( pipePos != KErrNotFound )

		{

		TPtrC tempstr( aRemoteHost->Ptr() + pipePos + 1 );

		TInt indexPos = tempstr.Locate( TChar(':') );

		if( indexPos != KErrNotFound )

			{

			mode.Set( tempstr.Left(indexPos) );

			TLex iapLex( tempstr.Mid(indexPos + 1) );

			iapLex.Val( index );

			}

		}

	// Connect to the server - need to retry as the first few attepts seem to fail over PPP

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

	User::LeaveIfError( iConnection.Open(iServer) );

	if( index > 0 && mode.Compare( _L("IAP") ) == 0 )

		{

		TCommDbConnPref pref;

		pref.SetIapId(index);

		pref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

		User::LeaveIfError(iConnection.Start(pref));

		}

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

	else if( index > 0 && mode.Compare( _L("SNAP") ) == 0 )

		{

		TConnSnapPref pref(index);

		User::LeaveIfError(iConnection.Start(pref));

		}

#endif // SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

	else

		{

		User::LeaveIfError(iConnection.Start());

		}

	TInt ret = -1;

	while( ret )

		{

		User::LeaveIfError( iSocket.Open(iServer, KAfInet, KSockStream, KProtocolInetTcp, iConnection) );

		TRequestStatus status;

		iSocket.Connect( iDestAddr, status );

		User::WaitForRequest( status );

		ret = status.Int();

		}

	return KErrNone;

	}

TInt CTCPTransport::Disconnect( void )

	{

	iSocket.Close();

	iServer.Close();

	return KErrNone;

	}

TInt CTCPTransport::RequestSend( TDesC8 *aData, const TUint aDataLength )

	{

	assert( aData->Length() == aDataLength );

	// Write to the socket

	TRequestStatus status;

	iSocket.Write( *aData, status );

	User::WaitForRequest( status );

	return status.Int();

	}

TInt CTCPTransport::RequestReceive( TPtr8 *aRecvBufferPtr, TUint aByteCount )

	{

	assert( aRecvBufferPtr->MaxLength() == aByteCount );

	// Read from the socket

	TRequestStatus status;

	iSocket.Read( *aRecvBufferPtr, status );

	User::WaitForRequest( status );

	return status.Int();

	}

TText8 *CTCPTransport::Error( void )

	{

	return NULL;

	}