// Copyright (c) 2003-2010 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 "ActiveSocket.h"

#include <es_wsms.h>

#include "CLWSPPduHandler.h"

#include "wapmsgerr.h"

#include <wap_sock.h>

#include "WapMessageApiAgent.h"

#include "WapMsgUtils.h"

using namespace Wap;

void CActiveSocket::NewL(RSocketServ& aSocketServ, RPointerArray<CActiveSocket>& aActiveSockets, Wap::TBearer aBearer, TWapMessageType aType, MProgressNotify* aNotify, Wap::TPort aLocalPort, RConnection* aConnection)

/**

The static new function instanciates corresponding Bearers in terms of the input bearer type.

This function is used by Bound Wap APIs which listen the incoming packet to a specific port. 

@internalComponent

@released

@since v8.0

@param aSocketServ the shared RSocketServ instance used in the Wap messaging API which owns this bearer

@param aActiveSockets the bearer array used in the Wap messaging API which owns the bearer

@param aBearer  the bearer to listen on (use EAll for all bearers)

@param aType  the type of the wap message that will received

@param aNotify  the instance to be notified when a wap message is received

@param aLocalPort  the port to listen on

@param aConnection the shared connection from Wap messaging API client

*/

	{

	//Instanciate the corresponding

	switch(aBearer)

		{

		case Wap::ESMS7:

		case Wap::ESMS:

		case Wap::EWAPSMS7:

		case Wap::EWAPSMS:

			{

			CActiveSocket* me = new(ELeave) CActiveSocketSMS(aSocketServ, aNotify, aBearer, aLocalPort);

			CleanupStack::PushL(me);

			me->ConstructL(aType);

			aActiveSockets.AppendL(me);

			CleanupStack::Pop(me);

			break;

			}

		case Wap::EIP:

			{

			CActiveSocket* me = new(ELeave) CActiveSocketUDP(aSocketServ, aNotify, aBearer, aLocalPort, aConnection);

			CleanupStack::PushL(me);

			me->ConstructL(aType);

			aActiveSockets.AppendL(me);

			CleanupStack::Pop(me);

			break;

			}

		case Wap::EAll:

			{

			CActiveSocket* me = new(ELeave) CActiveSocketUDP(aSocketServ, aNotify, Wap::EIP, aLocalPort, aConnection);

			CleanupStack::PushL(me);

			me->ConstructL(aType);          

			CActiveSocket* me1 = new(ELeave) CActiveSocketSMS(aSocketServ, aNotify, Wap::ESMS, aLocalPort);

			CleanupStack::PushL(me1);

			me1->ConstructL(aType);

			aActiveSockets.ReserveL(2); // pre-allocate the memory                                           

			aActiveSockets.AppendL(me1);

			CleanupStack::Pop(me1);

			aActiveSockets.AppendL(me);

			CleanupStack::Pop(me);

			break;

			}

		default:

		    {

			User::Leave(Wap::EBearerError);

		    }

		}

	}

void CActiveSocket::NewL(RSocketServ& aSocketServ, RPointerArray<CActiveSocket>& aActiveSockets, Wap::TBearer aBearer, TWapMessageType aType, MProgressNotify* aNotify, const TSockAddr& aRemoteAddr, RConnection* aConnection)

/**

The static new function instanciates corresponding Bearers in terms of the input bearer type.

This function is used by Fully specified Wap APIs which will open a socket with a single, named remote host. 

@internalComponent

@released

@since v8.0

@param aSocketServ the shared RSocketServ instance used in the Wap messaging API which owns this bearer

@param aActiveSockets the bearer array used in the Wap messaging API which owns the bearer

@param aBearer the bearer to listen on (use EAll for all bearers)

@param aType the type of the wap message that will received

@param aNotify the instance to be notified when a wap message is received

@param aRemoteAddr the remote host to be communicate with

@param aConnection the shared connection from Wap messaging API client

*/

	{

	//Instanciate the corresponding

	switch(aBearer)

		{

		case Wap::ESMS7:

		case Wap::ESMS:

		case Wap::EWAPSMS7:

		case Wap::EWAPSMS:

			{

			CActiveSocket* me = new(ELeave) CActiveSocketSMS(aSocketServ, aNotify, aBearer, aRemoteAddr);

			CleanupStack::PushL(me);

			me->ConstructL(aType);

            aActiveSockets.AppendL(me);

			CleanupStack::Pop(me);

			break;

			}

		case Wap::EIP:

			{

			CActiveSocket* me = new(ELeave) CActiveSocketUDP(aSocketServ, aNotify, aBearer, aRemoteAddr, aConnection);

			CleanupStack::PushL(me);

			me->ConstructL(aType);

            aActiveSockets.AppendL(me);

			CleanupStack::Pop(me);

			break;

			}

		case Wap::EAll:

			{

			CActiveSocket* me = new(ELeave) CActiveSocketUDP(aSocketServ, aNotify, aBearer, aRemoteAddr, aConnection);

			CleanupStack::PushL(me);

			me->ConstructL(aType);

			CActiveSocket* me1 = new(ELeave) CActiveSocketSMS(aSocketServ, aNotify, aBearer, aRemoteAddr);

			CleanupStack::PushL(me1);

			me1->ConstructL(aType);

            aActiveSockets.ReserveL(2); // pre-allocate the memory    

			aActiveSockets.AppendL(me1);

            CleanupStack::Pop(me1);

            aActiveSockets.AppendL(me);

            CleanupStack::Pop(me);

			break;

			}

		default:

		    {

			User::Leave(Wap::EBearerError);

		    }

		}

	}

CActiveSocket::CActiveSocket(RSocketServ& aSocketServ, Wap::TBearer aBearerType, MProgressNotify* aNotify, Wap::TPort aLocalPort)

:CActive(EPriorityStandard), iLocalAddr(0), iSocketServ(aSocketServ), iBearerType(aBearerType), iLocalPort(aLocalPort), iSocketState(ESocketIdle),iNotify(aNotify), iBuf(0,0), iRxlength(0), iBufCon(0,0)

/**

Constructor of bearer base class for Bound Wap APIs

@internalComponent

@released

@since v8.0

*/

	{

	CActiveScheduler::Add(this);

	}

CActiveSocket::CActiveSocket(RSocketServ& aSocketServ, Wap::TBearer aBearerType, MProgressNotify* aNotify, const TSockAddr& aRemoteAddr, Wap::TPort aLocalPort): CActive(EPriorityStandard), 

iRemoteAddr(aRemoteAddr), iLocalAddr(0), iSocketServ(aSocketServ), iBearerType(aBearerType), iLocalPort(aLocalPort), iSocketState(ESocketIdle), iNotify(aNotify), iBuf(0,0), iRxlength(0), iBufCon(0,0)

/**

Constructor of bearer base class for fully specified Wap APIs

@internalComponent

@released

@since v8.0

*/

	{

	CActiveScheduler::Add(this);

	}

CActiveSocket::~CActiveSocket()

/**

Destructor

@internalComponent

@released

@since v8.0

*/

	{

	Cancel();

	iSocket.Close();

	if (iMessageRecord) 

		{

		delete iMessageRecord;

		}

	}

void CActiveSocket::ConstructL(TWapMessageType aType)

/**

Second Phase Constructor

@internalComponent

@released

@param aType the type of Wap message which is received. 

@since v8.0

*/

	{

	iMessageRecord=CWapMessageRecord::NewL(aType);

	}

RSocket& CActiveSocket::Socket()

/**

To get the RSocket instance ownd by this bearer

@internalComponent

@released

@since v8.0

@returns the reference of the RSocket instance.

*/

	{

	return iSocket;

	}

Wap::TBearer CActiveSocket::GetBearerType()

/**

To get the bearer type of this bearer

@internalComponent

@released

@since v8.0

@returns the bearer type

*/

	{

	return iBearerType;

	}

TSockAddr& CActiveSocket::GetLocalAddress()

/**

To get the local address of this bearer

@internalComponent

@released

@since v8.0

@returns the lcoal address instance

*/

	{

	iSocket.LocalName(iLocalAddr);

	return iLocalAddr;

	}

TSockAddr& CActiveSocket::GetRemoteAddress()

/**

To get the remote address of the last received packet

@internalComponent

@released

@since v8.0

@returns the remote address instance

*/

	{

	return iRemoteAddr;

	}

TInt CActiveSocket::GetRemoteAddress(HBufC8*& aAddr)

/**

To get the remote address of the last received packet

@internalComponent

@released

@since v8.0

@param aAddr the remote host name

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

*/

	{

	TRAPD(err, aAddr=iRemoteAddr.AllocL())

	if (err==KErrNone)

		{

		Wap::TPort port;

		TPtr8 des=aAddr->Des();

		TRAP(err, CSWSWapMsgUtils::AnalyseAddrL(iRemoteAddr, iBearerType, des, port))

		}

	else

		{

		}

	return err;

	}

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

/**

To get the lcoal port of this bearer

@internalComponent

@released

@since v8.0

@param aLocalPort the local port of this bearer

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

*/

	{

	GetLocalAddress();

	aLocalPort=Wap::TPort(iLocalAddr.Port());

	return KErrNone;

	}

TUint32 CActiveSocket::GetPduSize()

/**

To get the received Wdp Pdu length

@internalComponent

@released

@since v8.0

@returns the length of the received Wdp pdu.

*/

	{

	return iMessageRecord->GetPduSize();

	}

TWapMessageState CActiveSocket::GetDataState()

/**

To get the state of the data that is being received

@internalComponent

@released

@since v8.0

@returns the state of the data that is being received

*/

	{

	return iMessageRecord->GetDataState();

	}

void CActiveSocket::SetDataState(TWapMessageState aState)

/**

To set the state of the data that is being received

@internalComponent

@released

@since v8.0

@param aState the state of the data that is being received

*/

	{

	iMessageRecord->SetDataState(aState);

	}

TInt CActiveSocket::GetPduData(TDes8& aBuffer, TBool& aTruncated)

/**

To get the received Wdp pdu.

@internalComponent

@released

@since v8.0

@param aBuffer the buffer to read the received WDP pdu

@param aTruncated the flag to represent if the data has be truncated or not

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

*/

	{

	return iMessageRecord->GetPduData(aBuffer, aTruncated);

	}

TInt CActiveSocket::GetWspData(TDes8& aWspHeader, TDes8& aWspBody, TUint8& aTransactionId, TWSPStatus& aStatus)

/**

To get the received Wsp header, body, tranaction ID and Wsp status.

@internalComponent

@released

@since v8.0

@param aWspHeader the buffer to read the received Wsp header

@param aWspBody the buffer to read the received Wsp body

@param aTransactionId the transaction ID of the received Wsp Message

@param aStatus the Wsp status of  the received Wsp Message

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

*/

	{

	return iMessageRecord->GetWspData(aWspHeader, aWspBody, aTransactionId, aStatus);

	}

void CActiveSocket::UnpackPduToWspDataL()

/**

To extract the Wsp header, body, transaction ID and status from the received WDP pdu

@internalComponent

@released

@since v8.0

*/

	{

	iMessageRecord->UnpackPduToWspDataL();

	}

void CActiveSocket::CleanUpData()

	{

	TPtr8 zero(0,0);

	iBuf.Set(zero);

	iBufCon.Set(zero);

	iMessageRecord->CleanUpData();

	}

/** SMS active socket

*/

CActiveSocketSMS::CActiveSocketSMS(RSocketServ& aSocketServ, MProgressNotify* aNotify, Wap::TBearer aBearer, Wap::TPort aLocalPort)

:CActiveSocket(aSocketServ, aBearer, aNotify, aLocalPort)

/**

Constructor of SMS bearer for Bound Wap APIs

@internalComponent

@released

@since v8.0

*/

	{

	}

CActiveSocketSMS::CActiveSocketSMS(RSocketServ& aSocketServ, MProgressNotify* aNotify, Wap::TBearer aBearer, const TSockAddr& aRemoteAddr)

:CActiveSocket(aSocketServ, aBearer, aNotify, aRemoteAddr, (Wap::TPort)EWapPortUnspecified)

/**

Constructor of SMS bearer for fully specified Wap APIs

@internalComponent

@released

@since v8.0

*/

	{

	}

CActiveSocketSMS::~CActiveSocketSMS() 

/**

Destructor of SMS bearer for fully specified Wap APIs

@internalComponent

@released

@since v8.0

*/

	{

	}

void CActiveSocketSMS::ConstructL(TWapMessageType aType)

/**

Second Phase Constructor

@internalComponent

@released

@param aType the type of Wap message which is received.

@since v8.0

*/

	{

	CActiveSocket::ConstructL(aType);

	User::LeaveIfError(iSocket.Open(iSocketServ, KWAPSMSAddrFamily, KSockDatagram, KWAPSMSDatagramProtocol));

	User::LeaveIfError(iSocket.SetOpt(KWapSmsOptionNewStyleClient,KWapSmsOptionLevel, 0));

	TWapAddr wapAddr;

	wapAddr.SetWapPort(TWapPortNumber(iLocalPort));

	TInt err=iSocket.Bind(wapAddr);

	if (err==KErrInUse)

		{

		User::Leave(Wap::EPortAlreadyBound);

		}

	}

TInt CActiveSocketSMS::AwaitRecvDataSize()

/**

Read the received Wdp pdu length.

@internalComponent

@released

@since v8.0

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

*/

	{

	TPckgBuf<TUint32>* length=iMessageRecord->GetPduSizeRef();

	iSocket.Ioctl(KSOGetLength, iStatus, length, KSolWapProv);

	iMessageRecord->SetDataState(ERequestingLength);

	iSocketState=ESocketWaitingForLength;

	SetActive();

	return KErrNone;

	}

TInt CActiveSocketSMS::Receive()

/**

Read the received Wdp pdu.

@internalComponent

@released

@since v8.0

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

*/

	{

	TInt err=KErrNone;

	TRAP(err, iMessageRecord->CreatePduBufferL(EFalse))

	if (err!=KErrNone)

		{

		return err;

		}

	HBufC8*& pdu=iMessageRecord->GetPduPtr();

	iBuf.Set(pdu->Des());

	iSocket.RecvFrom(iBuf, iRemoteAddr, 0, iStatus);

	iMessageRecord->SetDataState(ERequestingData);

	iSocketState=ESocketWaitingForData;

	SetActive();

	return KErrNone;

	}

void CActiveSocketSMS::RunL() 

/**

Overload the CActive virtual methods

@internalComponent

@released

@since v8.0

*/

	{

	switch (iSocketState)

		{

	case ESocketWaitingForLength:

			{

			iMessageRecord->SetDataState(EPendingLength);

			iSocketState=ESocketIdle;

			TWapNotificationInfo info(iBearerType, iStatus.Int());

			TWapNotificationInfoBuf infoBuf(info);

			iNotify->Notification(EPduLengthReceived, infoBuf);

			break;

			}

	case ESocketWaitingForData:

			{

			iMessageRecord->SetDataState(EPendingData);

			iSocketState=ESocketIdle;

			TWapNotificationInfo info(iBearerType, iStatus.Int());

			TWapNotificationInfoBuf infoBuf(info);

			iNotify->Notification(EPduReceived, infoBuf);

			iSocket.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0);

			break;

			}

	default:

		}

	}

void CActiveSocketSMS::DoCancel() 

/**

Overload the CActive virtual methods

@internalComponent

@released

@since v8.0

*/

	{

	switch (iSocketState)

		{

	case ESocketWaitingForLength:

			{

			iSocket.CancelIoctl();

			break;

			}

	case ESocketWaitingForData:

			{