// Copyright (c) 2008-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 "WapMessageApiAgent.h"

#include "WapMsgUtils.h"

#include "CLWSPPduHandler.h"

#include <es_wsms.h>

#include <wapmsgerr.h>

#include "WapSwsLog.h"

CWapAsyncCallBack::CWapAsyncCallBack( const TCallBack& aCallBack, TInt aPriority )

:   CActive( aPriority ), iCallBack( aCallBack )

	{

	CActiveScheduler::Add( this );

	}

CWapAsyncCallBack::~CWapAsyncCallBack()

	{

	Cancel();

	}

void CWapAsyncCallBack::CallBack()

	{

	if  ( !IsActive() )

		{

		TRequestStatus* status = &iStatus;

		User::RequestComplete( status, KErrNone );

		SetActive();

		}

	}

void CWapAsyncCallBack::RunL()

	{

	iCallBack.CallBack();

	}

void CWapAsyncCallBack::DoCancel()

	{

	// Empty - request already completed in CallBack()

	}

//

//CWapMessageApiAgent class Method

//

CWapMessageApiAgent::CWapMessageApiAgent(TWapMessageType aMessageType):iMessageType(aMessageType)

/**

Constuctor.

@internalComponent

@released since v8.0

@param aMessageType the message type that handled by this agent

*/

	{

	}

CWapMessageApiAgent::~CWapMessageApiAgent()

/**

Destrutor

@internalComponent.

@released since v8.0

*/

	{

	TInt count=iBearers.Count();

	for (TInt i=0; i<count; i++)

		{

		iBearers[i]->Cancel();

		iBearers[i]->CleanUpData();

		}

	iBearers.ResetAndDestroy();

	iSocketServ.Close();

	if (iTimeoutTimer)

		{

		iTimeoutTimer->Cancel();		

		delete iTimeoutTimer;

		}

	if (iAsyncReadCompletion)

		{

		delete iAsyncReadCompletion;

		}

	}

TInt CWapMessageApiAgent::CompleteReading(TAny* aAgent)

	{

	CWapMessageApiAgent* agent = reinterpret_cast<CWapMessageApiAgent*>(aAgent);

	return agent->DoCompleteReading();

	}

TInt CWapMessageApiAgent::DoCompleteReading()

	{

	iRequestActive=EFalse;

	User::RequestComplete(iRequestStatus, iLastReadingError);

	return KErrNone;

	}

void CWapMessageApiAgent::ConstructL()

/**

Second Phase Constructor

@internalComponent.

@released since v8.0

*/

	{

	iTimeoutTimer = CTimeOutTimer::NewL(*this);

	TCallBack callback = TCallBack(CompleteReading, this);

	iAsyncReadCompletion = new (ELeave) CWapAsyncCallBack(callback, CActive::EPriorityHigh);

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

 	}

CActiveSocket* CWapMessageApiAgent::GetActiveSocketByBearer(Wap::TBearer aBearer)

/**

To Get the CActiveSocket from the Array by Bearer type. 

@internalComponent.

@released since v8.0

@param aBearer (in)the bearer type of the CActiveSocket

@returns the pointer of CAtiveSocket

*/

	{

	TInt count=iBearers.Count();

	for (TInt i=0; i<count; i++)

		{

		Wap::TBearer bearer=iBearers[i]->GetBearerType();

		if (bearer==aBearer)

			{

			return iBearers[i];

			}

		else

			{

			if ((aBearer>=Wap::ESMS7 && aBearer<=Wap::EWAPSMS) && (bearer>=Wap::ESMS7 && bearer<=Wap::EWAPSMS))

				{

				return iBearers[i];

				}

			}

		}

	return NULL;

	}

CActiveSocket* CWapMessageApiAgent::GetActiveSocketByStatus(TWapMessageState aState)

/**

To Get the CActiveSocket from the Array by Data State. 

@internalComponent.

@released since v8.0

@param aState (in)the Data state of the CActiveSocket

@returns the pointer of CAtiveSocket

*/

	{

	TInt count=iBearers.Count();

	for (TInt i=0; i<count; i++)

		{

		if (iBearers[i]->GetDataState()==aState)

			{

			return iBearers[i];

			}

		}

	return NULL;

	}

void CWapMessageApiAgent::TimerExpired()

/**

To handle the receive time out.

@internalComponent.

@released since v8.0

*/

	{

	TInt count=iBearers.Count();

	for (TInt i=0; i<count; i++)

		{

		iBearers[i]->Cancel();

		iBearers[i]->CleanUpData();

		}

	iRequestActive=EFalse;

	User::RequestComplete(iRequestStatus, KErrTimedOut);

	}

TInt CWapMessageApiAgent::GetLocalPort(Wap::TPort& aLocalPort)

/**

To Get local port of the last received packet

@internalComponent.

@released since v8.0

@param aLocalPort (out)the reference of the localPort.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (!iIsOpen)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalPort: Trying to GetLocalPort on unconnected API."));)

		return KErrNotReady;

		}

	CActiveSocket* sock=GetActiveSocketByBearer(iLastPduBearer);

	if (!sock)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalPort: Can not find Last Bearer."));)

		return Wap::EBearerError;

		}

	sock->GetLocalPort(aLocalPort);

	return KErrNone;

	}

TInt CWapMessageApiAgent::GetLocalAddress(HBufC8*& aLocalHost)

/**

To Get local Address of the last received Packet

@internalComponent.

@released since v8.0

@param aLocalHost (out)the reference of the localHost.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (!iIsOpen)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalAddress: Trying to GetLocalAddress on unconnected API."));)

		return KErrNotReady;

		}

	CActiveSocket* sock=GetActiveSocketByBearer(iLastPduBearer);

	if (!sock)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalAddress: Can not find Last Bearer"));)

		return Wap::EBearerError;

		}

	TSockAddr& localHost=sock->GetLocalAddress();

	TInt err=KErrNone;

	TRAP(err, aLocalHost=localHost.AllocL())

	if (err)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetLocalAddress: Alloc Memory Err=%d"), err);)

		}

	return err;

	}

TInt CWapMessageApiAgent::GetBearer(Wap::TBearer& aBearer)

/**

To Get Bearer of the last received packet

@internalComponent.

@released since v8.0

@param aBearer (out)the reference of the Bearer.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (!iIsOpen)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetBearer: Trying to GetBearer on unconnected API."));)

		return KErrNotReady;

		}

	aBearer=iLastPduBearer;

	return KErrNone;

	}

TInt CWapMessageApiAgent::GetServerAddress(HBufC8*& aServerHost)

/**

To Get Server Host of the last received packet

@internalComponent.

@released since v8.0

@param aServerHost (out)the reference of the Server Host.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (!iIsOpen)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetServerAddress: Trying to GetServerAddress on unconnected API."));)

		return KErrNotReady;

		}

	CActiveSocket* sock=GetActiveSocketByBearer(iLastPduBearer);

	if (!sock)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::GetServerAddress: Can not find last error."));)

		return Wap::EBearerError;

		}

	return sock->GetRemoteAddress(aServerHost);

	}

void CWapMessageApiAgent::CancelRequest()

/**

To Cancel the client's request

@internalComponent.

@released since v8.0

*/

	{

	if (iIsOpen)

		{

		TInt count=iBearers.Count();

		for (TInt i=0; i<count; i++)

			{

			iBearers[i]->Cancel();

			iBearers[i]->CleanUpData();

			}

		iTimeoutTimer->Cancel();

		if (iRequestActive)

			{

			iRequestActive=EFalse;

			iAsyncReadCompletion->Cancel();

			User::RequestComplete(iRequestStatus, KErrCancel);

			}

		}

	}

TInt CWapMessageApiAgent::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool aSecure)

/**

Opening an endpoint that can be used to listen for subsequent incoming datagrams.

@internalComponent.

@released since v8.0

@param aBearer (In) the bearer to listen on

@param aPort (In) the port to listen on.

@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	TInetAddr inetAddr( KInetAddrAny, 0);

	return (Connect(aBearer, aPort, aSecure, inetAddr));

	}

TInt CWapMessageApiAgent::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool /*aSecure*/, TInetAddr /*aInetAddr*/)

/**

Opening an endpoint that can be used to listen for subsequent incoming datagrams.

@internalComponent.

@released since v8.0

@param aBearer (In) the bearer to listen on

@param aPort (In) the port to listen on.

@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)

@param aInetAddr (In) Not In Use.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	TInt ret=KErrNone;

	if (!iIsOpen)

		{

		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, aPort))

		if (ret!=KErrNone)

			{

			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."),ret);)

			return ret;

			}

		iIsOpen=ETrue;

		}

	else

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Trying Connect twice to the API."));)

		ret=KErrInUse;

		}

	return ret;

	}

TInt CWapMessageApiAgent::Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool /*aSecure*/, TInt aSocketServHandle, RConnection* aConnection)

/**

Opening an endpoint that can be used to listen for subsequent incoming datagrams.

@internalComponent.

@released since v8.0

@param aBearer (In) the bearer to listen on

@param aPort (In) the port to listen on.

@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)

@param aSocketServHandle (In) The Socket Server ID.

@param aConnection (In) The RConnection that shared with the client.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (aSocketServHandle==0 || !aConnection)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Parameter Error"));)

		return KErrArgument;

		}

	TInt ret=KErrNone;

	if (!iIsOpen)

		{

		iSocketServ.SetHandle(aSocketServHandle);

		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, aPort, aConnection))

		if (ret!=KErrNone)

			{

			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."), ret);)

			return ret;

			}

		iIsOpen=ETrue;

		}

	else

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Trying to Connect twice to the API."));)

		ret=KErrInUse;

		}

	return ret;

	}

TInt CWapMessageApiAgent::Connect(const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer, TBool /*aSecure*/, TInetAddr /*aInetAddr*/)

/**

Opens a socket which is to be used only with a single, named remote host.

@internalComponent.

@released since v8.0

@param aRemoteHost (In) the name of the remote host to connect.

@param aRemotePort (In) the port of the remote host to connect.

@param aBearer (In) the bearer to be used

@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)

@param aInetAddr (In) Not In Use

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (aBearer==Wap::EAll)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Connect to EAll Error"));)

		return Wap::EBearerError;

		}

	TInt ret=KErrNone;

	if (!iIsOpen)

		{

		TSockAddr remoteAddr;

		TRAP(ret, CSWSWapMsgUtils::BuildAddrL(remoteAddr, aBearer, aRemoteHost, aRemotePort))

		if (ret!=KErrNone)

			{

			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: BuildAddress err=%d."), ret);)

			return ret;

			}

		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, remoteAddr))

		if (ret!=KErrNone)

			{

			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."), ret);)

			return ret;

			}

		iIsOpen=ETrue;

		}

	else

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Trying to Connect twice to the API."));)

		ret=KErrInUse;

		}

	return ret;

	}

TInt CWapMessageApiAgent::Connect(const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer, TBool aSecure)

/**

Opens a socket which is to be used only with a single, named remote host.

@internalComponent.

@released since v8.0

@param aRemoteHost (In) the name of the remote host to connect.

@param aRemotePort (In) the port of the remote host to connect.

@param aBearer (In) the bearer to be used

@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	TInetAddr inetAddr( KInetAddrAny, 0);

	return (Connect(aRemoteHost, aRemotePort, aBearer, aSecure, inetAddr));

	}

TInt CWapMessageApiAgent::Connect(const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer, TBool /*aSecure*/, TInt aSocketServHandle, RConnection* aConnection)

/**

Opens a socket which is to be used only with a single, named remote host.

@internalComponent.

@released since v8.0

@param aRemoteHost (In) the name of the remote host to connect.

@param aRemotePort (In) the port of the remote host to connect.

@param aBearer (In) the bearer to be used

@param aSecure (In) security flag indicates whether WTLS will be used or not (Not Supported)

@param aSocketServHandle (In) The Socket Server ID.

@param aConnection (In) The RConnection that shared with the client.

@returns KErrNone on successful completion, or one of the system error codes on failure.

*/

	{

	if (aBearer==Wap::EAll)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::SendWspMessage:Connect to EAll Error"));)

		return Wap::EBearerError;

		}

	if (aSocketServHandle==0 || !aConnection)

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Parameter Error"));)

		return KErrArgument;

		}

	TInt ret=KErrNone;

	if (!iIsOpen)

		{

		iSocketServ.SetHandle(aSocketServHandle);

		TSockAddr remoteAddr;

		TRAP(ret, CSWSWapMsgUtils::BuildAddrL(remoteAddr, aBearer, aRemoteHost, aRemotePort))

		if (ret!=KErrNone)

			{

			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: BuildAddress err=%d."),ret);)

			return ret;

			}

		TRAP(ret, CActiveSocket::NewL(iSocketServ, iBearers, aBearer, iMessageType, this, remoteAddr, aConnection))

		if (ret!=KErrNone)

			{

			LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect: CActiveSocket Instantiate err=%d."),ret);)

			return ret;

			}

		iIsOpen=ETrue;

		}

	else

		{

		LOG(SwsLog::Printf(_L("CWapMessageApiAgent::Connect:Connect to a connected API."));)

		ret=KErrInUse;

		}

	return ret;

	}

//

//CWspMessageApiAgent class Methods

//

CWspMessageApiAgent* CWspMessageApiAgent::NewL()

/**

Static NEWL()

@internalComponent

@released since v8.0

@returns CWspMessageApiAgent instance.

*/

	{

	CWspMessageApiAgent* me = new(ELeave) CWspMessageApiAgent();

	CleanupStack::PushL(me);

	me->ConstructL();

	CleanupStack::Pop(me);

	return me;

	}

CWspMessageApiAgent::CWspMessageApiAgent():CWapMessageApiAgent(EWapWsp)

/**

Constructor

@internalComponent

@released since v8.0

*/

	{

	}

CWspMessageApiAgent::~CWspMessageApiAgent()

/**

Destructor

@internalComponent

@released since v8.0