/*

* Copyright (c) 2004 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:  Implementation

*

*/

#include <es_enum.h>

#include <in_sock.h>

#include "CTcTcpManager.h"

#include "TTcTcpFactory.h"

#include "debuglog.h"

CTcTcpManager* CTcTcpManager::NewL( const TTcTcpFactory& aFactory )

	{

	CTcTcpManager* self = new( ELeave ) CTcTcpManager( aFactory );

	CleanupStack::PushL( self );

	self->ConstructL( );

	CleanupStack::Pop( self );

	return self;

	}

CTcTcpManager::~CTcTcpManager()

	{

	LOG( _L("CTcTcpManager::~CTcTcpManager()") );

	// Close connection

	Close();

	iConnServ.Close();

	iSockServ.Close();

	delete iRemoteAddr;

	}

CTcTcpManager::CTcTcpManager( const TTcTcpFactory& aFactory )

	: CActive( CActive::EPriorityStandard ),

	  iConn( aFactory.iPort ), iIAPId( aFactory.iIAPId )

	{

	CActiveScheduler::Add( this );

	}

void CTcTcpManager::ConstructL()

	{

	LOG( _L("CTcTcpManager::ConstructL()") );

	// Open a session to socket server and connection server

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

	User::LeaveIfError( iConnServ.Open( iSockServ ) );

	iConn.SetObserver( this );

	iConn.SetConnection( &iSockServ, &iConnServ );

	iPrefs.SetDialogPreference( ECommDbDialogPrefDoNotPrompt );

    iPrefs.SetDirection( ECommDbConnectionDirectionOutgoing );

    iPrefs.SetIapId( iIAPId );

	}

void CTcTcpManager::RunL()

	{

	LOG( _L("CTcTcpManager::RunL() start") );

	// Report any intermediate connection errors

	TInt status( iStatus.Int() );

	if( status != KErrNone )

		{

		BearerCompletion( MTcBearerObserver::EConnect, status );

		}

	else

		{

		TInt err( KErrNone );

		// Start waiting for connections

		if ( iRemoteAddr )

		    {

		    TRAP( err, iConn.ConnectL( *iRemoteAddr ) );

		    }

		else

		    {

		    TRAP( err, iConn.ConnectL() );

		    }

		// Catch and report errors

		if( err )

			{

			BearerCompletion( MTcBearerObserver::EConnect, err );

			}

		}

	LOG( _L("CTcTcpManager::RunL() end") );

	}

void CTcTcpManager::DoCancel()

	{

	LOG( _L("CTcTcpManager::DoCancel()") );

	// Cannot use Stop() as it forces the whole IAP connection down

	// even if somebody else is still using it.

	iConnServ.Close();

	}

void CTcTcpManager::ConnectL( TInetAddr* aRemoteAddr )

	{

	LOG( _L("CTcTcpManager::ConnectL() start, IAP = %d"), iIAPId );

	delete iRemoteAddr;

	iRemoteAddr = NULL;

	if ( aRemoteAddr )

	    {

	    iRemoteAddr = new ( ELeave ) TInetAddr( *aRemoteAddr );

	    }

	// Fire up a net connection, use the defined IAP if any

	if( iIAPId )

		{

		iConnServ.Start( iPrefs, iStatus );

		}

    else

		{

		// This will query the user for an IAP

		iConnServ.Start( iStatus );

		}

	SetActive();

	LOG( _L("CTcTcpManager::ConnectL() end") );

	}

void CTcTcpManager::Close()

	{

	LOG( _L("CTcTcpManager::Close()") );

	Cancel();

	// Shut down the service port

	iConn.Close();

	}

void CTcTcpManager::Send( const TDesC8& aDes )

	{

	iConn.Send( aDes );

	}

void CTcTcpManager::Receive( TDes8& aDes )

	{

	iConn.Receive( aDes );

	}

void CTcTcpManager::ReceiveOneOrMore( TDes8& aDes )

	{

	iConn.ReceiveOneOrMore( aDes );

	}

void CTcTcpManager::SetObserver( MTcBearerObserver* aObserver )

	{

	iObserver = aObserver;

	}

void CTcTcpManager::GetLocalAddressL( TDes& aDes )

	{ 

	// Array for addresses 

	RArray< TBuf<40> > addresses;

	// Open socket for querying socket options

	RSocket socket;

	User::LeaveIfError(socket.Open(

			iSockServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnServ));

	// Get IAP id from CommDb for the active connection

	TUint32 iapId;

	User::LeaveIfError(iConnServ.GetIntSetting(_L("IAP\\Id"), iapId));

	// Get address from socket options

	TInt err = socket.SetOpt(KSoInetEnumInterfaces, KSolInetIfCtrl);

	if (err == KErrNone)

		{

		TPckgBuf<TSoInetInterfaceInfo> info;

		err = socket.GetOpt(KSoInetNextInterface,KSolInetIfCtrl,info);

		while (err == KErrNone)

			{

			TPckgBuf<TSoInetIfQuery> query;

			query().iName = info().iName;

			err = socket.GetOpt(KSoInetIfQueryByName,KSolInetIfQuery,query);

			if (err == KErrNone)

				{

					if (!info().iAddress.IsUnspecified() && 

							!info().iAddress.IsLoopback() &&

							!info().iAddress.IsLinkLocal())

					{

						TInetAddr addr;

						// Initialize address for both ipv4 and ipv6

						addr.Init(KAfInet6);

						addr = info().iAddress; 

						TBuf<40> addrDesc;

						addr.Output( addrDesc );

						TInt oldIndex = addresses.Find(addrDesc);

						// Address of current IAP is shown first

						if (query().iZone[1] == iapId)

						{

							// remove the old one

							if(KErrNotFound != oldIndex){

								addresses.Remove(oldIndex);

							}

							addresses.Insert(addrDesc,0);

						}

						else

						{

							if(KErrNotFound == oldIndex){

								addresses.Append(addrDesc);

							}

						}       

					}

				err = socket.GetOpt(KSoInetNextInterface,KSolInetIfCtrl,info);

			}

		}

	}

	socket.Close();

	if (err == KErrNoMemory)

			{

			User::LeaveNoMemory();

			}

	_LIT(KLineFeed,"\n");

	// append address from the array to descriptor

	for(TInt i=0;i<addresses.Count();i++)

	{

		aDes.Append(addresses[i]);

		aDes.Append(KLineFeed);

	}

	addresses.Close();

	}

void CTcTcpManager::BearerCompletion( MTcBearerObserver::TOperation aOp,

									  TInt aStatus )

	{

	LOG( _L("CTcTcpManager::BearerCompletion( %d, %d ) start"), aOp, aStatus );

	if( iObserver )

		{

		iObserver->BearerCompletion( aOp, aStatus );

		}

	LOG( _L("CTcTcpManager::BearerCompletion() end") );

	}