/*
* 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: 
*
*/



#ifndef T_RSOCKETDATA_H_
#define T_RSOCKETDATA_H_

//User Includes
#include "datawrapperbase.h"

//Epoc includes
#include <es_sock.h> // RSocketServ, RConnection
#include <in_sock.h> // KAfInet
#include <activecallback.h>
#include <f32file.h>


class CT_RSocketData: public CDataWrapperBase
	{
public:
	static CT_RSocketData* NewL();
	void RunL(CActive* aActive, TInt aIndex);
	virtual ~CT_RSocketData();

public:	
	virtual TAny* GetObject();
	void ErrorMessage(const TInt aMessage);
	virtual TBool DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);		

protected:
	CT_RSocketData();
	void ConstructL();

private:
	void DoCmdOpen(const TTEFSectionName& aSection);	
	void DoCmdConnect(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
	void DoCmdShutdown(const TInt aAsyncErrorIndex);			
	void DoCmdClose();
	void DoCmdHttpGet();
	void DoCmdCheckSupportedRates(const TTEFSectionName& aSection);
	void DoCmdUploadSendHTTPPost(const TTEFSectionName& aSection);
    void CreateHTTPHeaderStart(TDes8& aRequest, TInt aDataSize, TDesC& aFileServer,TDesC& clientID,TDesC& serverScript);
	void SendFileToSocketL(const TDesC& aFilename);
	TInt ReadFileSizeL(const TDesC& aFilename);
	void CreateHTTPHeaderEnd(TDes8& aRequest);
	TBool CheckSupportedRates(const TDesC8& aSupportedRates, const TUint8 aRate);
	void Shutdown();
	void DoCmdDownloadSendHTTPGet(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex );
	void DoCmdRecvOneOrMore(const TTEFSectionName& aSection);	
	void Close();	
	TReal ThroughputInMegaBits( TTimeIntervalMicroSeconds aDuration, TInt aTotalTransferred );
	void RecvOneOrMore(TRequestStatus& status);	

private:
	/**
	 * Wrapped object
	 */
	RSocket*			iSocket;
	/**
	 * Used in the command DoCmdDownloadSendHTTPGet for RSocket::Write
	 */
	CActiveCallback* 	iActiveCallback;
	/**
	 * Used in the command DoCmdConnect for RSocket::Connect
	 */
	CActiveCallback* 	iActCallConnectSocket;
	/**
	 * Used in the command DoCmdConnectSocket for RSocket::Connect
	 */
	CActiveCallback* 	iActCallShutDownSocket;		
	/**
	 * Flag to review if the Socket is Open with RSocket::Connect
	 */
	TBool 				iSocketOpened;
	/**
	 * flag to review if the Socket was shutdown
	 */
	TBool 				iSocketStarted;		
	/**
	 * Async data
	 */
	TInt 			    iAsyncErrorIndex;
	/**
	 * Buffer for Download in DoCmdReceiveHTTPResponse command
	 */
	HBufC8* 			iDownloadBuffer;
	/**
	 * Buffer for Upload in SendFileToSocket 
	 */
	HBufC8* 			iUploadBuffer;
	/**
	 * Header for response HTPP
	 */
	RBuf8   			iHttpResponseHeader;
	/**
	 * Download throughput
	 */
	TReal 				iDownloadThroughput;
	/**
	 * Handle for Filse server session
	 */
	RFs 				iFs;
	/**
	 * Upload throughput
	 */
	TReal               iUploadThroughput;
	/**
	 * Bytes received in DoCmdHttpGet
	 */
	TInt                itotalReceived;
	};

#endif /*T_RSOCKETDATA_H_*/