// Copyright (c) 2003-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:

//

#ifndef __MSGAPIAGENT_H__

#define __MSGAPIAGENT_H__

#include "ActiveSocket.h"

#include "WapSwsTimeOut.h"

class MProgressNotify

/** 

Interface from the ActiveSocket to MessageApiAgent

@internalComponent

@released

@since v8.0

*/

	{

	public:

	/**

	The interface that will be called when WDP pdu length and data are received by CActiveSocket.

	@internalComponent

	@param aMessage the message type received from CActiveSocket

	@param aData the data received from CActiveSocket

	*/

	virtual void Notification(TInt aMessage, const TDesC8& aData) = 0;	

	};

class CWapAsyncCallBack : public CActive

	{

public:

	CWapAsyncCallBack( const TCallBack& aCallBack, TInt aPriority );

	~CWapAsyncCallBack();

public: // API

	void CallBack();

private:

	void RunL();

	void DoCancel();

private:

	TCallBack iCallBack;

	};

class CWapMessageApiAgent : public CBase, public MTimeOutNotify, public MProgressNotify

/** 

The base class of CWspMessageApiAgent and CWdpMessageApiAgent, which handle Wsp and Wdp

for SWS message APIs

@internalComponent

@released

@since v8.0

*/

{

public:

	virtual ~CWapMessageApiAgent();

	void ConstructL();

	CActiveSocket* GetActiveSocketByBearer(Wap::TBearer aBearer);

	CActiveSocket* GetActiveSocketByStatus(TWapMessageState aState);

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

	TInt Connect(Wap::TBearer aBearer, Wap::TPort aPort, TBool aSecure, TInetAddr aInetAddr);

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

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

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

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

	TInt GetLocalPort(Wap::TPort& aPort);

	TInt GetLocalAddress(HBufC8*& aLocalHost);

	TInt GetBearer(Wap::TBearer& aBearer);

	TInt GetServerAddress(HBufC8*& aRemoteHost);

	virtual void TimerExpired();

	void CancelRequest();

	static TInt CompleteReading(TAny* aAgent);

protected:

	CWapMessageApiAgent(TWapMessageType aMessageType);

	/**

	RSocketServ instance used by all the bearers.

	*/

	RSocketServ iSocketServ;

	/**

	The array to contain all the bearers

	*/

	RPointerArray<CActiveSocket> iBearers;

	/**

	The Wdp and Wsp receiving timer.

	*/

	CTimeOutTimer* iTimeoutTimer;

	/**

	Flag the show if there is outstanding request.

	*/

	TBool iRequestActive;

	/**

	The pointer to Wap message client's request status

	*/

	TRequestStatus* iRequestStatus;

	/**

	The last error code of active socket in reading state

	*/

	TInt iLastReadingError;

	/**

	The asynchronous completion of reading

	*/

	CWapAsyncCallBack* iAsyncReadCompletion;

	/**

	The bearer that receives that last PDU

	*/

	Wap::TBearer iLastPduBearer;

	/**

	Flag to show if the API has been connected or not

	*/

	TBool iIsOpen;

	/**

	The type of the Wap message handled by this API agent.

	*/

	TWapMessageType iMessageType;

private:

	TInt DoCompleteReading();

};

class CWspMessageApiAgent : public CWapMessageApiAgent

/** 

The class to handle Wsp PDU for SWS message APIs

@internalComponent

@released

@since v8.0

*/

{

public:

	static CWspMessageApiAgent* NewL();

	CWspMessageApiAgent();

	virtual ~CWspMessageApiAgent();

	void ConstructL();

	TInt SendWspMessage(Wap::TBearer aBearer, const TDesC8& aRemoteHost, Wap::TPort aRemotePort, TUint aMethod, const TDesC& aURI, const TDesC8& aReqHeaders, const TDesC8& aReqBody, TUint8 aTransactionId);

	TInt SendWspMessage(TUint aMethod, const TDesC& aURI, const TDesC8& aReqHeaders, const TDesC8& aReqBody, TUint8 aTransactionId);

	TInt ReceiveWspMessage(TDes8& aWspHeaders, TDes8& aWspBody, TPckgBuf<TUint8>& aPushIdPckg, TWSPStatus& aWspStatus, TRequestStatus& aReqStatus, TUint32 aTimeout);

	virtual void Notification(TInt aMessage, const TDesC8& aData);

private:

	/**

	The pointer to the WSP message client's requested header buffer

	*/

	TDes8* iClientReqHeaders;

	/**

	The pointer to the WSP message client's requested body buffer

	*/

	TDes8* iClientReqBody;

	/**

	The pointer to the WSP message client's requested transaction ID.

	*/

	TUint8*	iClientTransactionId;

	/**

	The pointer to the WSP message client's requested WSP status.

	*/

	TWSPStatus* iClientWspStatus;

};

class CWdpMessageApiAgent : public CWapMessageApiAgent

/** 

The class to handle Wdp PDU for SWS message APIs

@internalComponent

@released

@since v8.0

*/

{

public:

	static CWdpMessageApiAgent* NewL();

	CWdpMessageApiAgent();

	virtual ~CWdpMessageApiAgent();

	void ConstructL();

	TInt ReceiveWdpMessage(TDes8& aRemoteHost, Wap::TPort& aRemotePort, TDes8& aBuffer, TBool& aTruncated, TRequestStatus& aReqStatus, TUint32 aTimeout);

	TInt AwaitRecvDataSize(TPckg<TUint16>& aDataSizePckg, TRequestStatus& aReqStatus);

	TInt SendWdpMessage(const TDesC8& aBuffer, const TDesC8& aRemoteHost, Wap::TPort aRemotePort, Wap::TBearer aBearer);

	TInt SendWdpMessage(const TDesC8& aBuffer);

	virtual void Notification(TInt aMessage, const TDesC8& aData);

private:

	/**

	The pointer to Wdp message client's requested data buffer

	*/

	TDes8*	iClientPduBuffer;

	/**

	The pointer to Wdp message client's request data size

	*/

	TPckg<TUint16>* iClientDataSize;

	/**

	The pointer to client's requested remote host buffer

	*/

	TDes8* iClientRemoteHost;

	/**

	The pointer to client's requested remote port buffer

	*/

	Wap::TPort* iClientRemotePort;

	/**

	The pointer to client's requested flag.

	*/

	TBool* iClientTruncated;

};

#endif //__MSGAPIAGENT_H__