/*
* 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_RSOCKET_DATA_H
#define T_RSOCKET_DATA_H

//	User Includes
#include "DataWrapperBase.h"
#include "BreathSaver.h"
//	EPOC includes
#include <datawrapper.h>
#include <w32std.h>
#include <e32std.h>

#include <es_sock.h> // TSockAddr address 
#include <in_sock.h> // TCP/IP Protocol and address family


// For ETel API.
#include <etelmm.h>


class CT_RSocketData: public CDataWrapperBase
	{
public:
	/**
	* Two phase constructor
	*/
	static CT_RSocketData*	NewL();
	
	virtual TAny*	GetObject();
	virtual TBool	DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
	
	~CT_RSocketData();

public:
	void RunL(CActive* aActive, TInt aIndex);

protected:
	/**
	* Protected constructor. First phase construction
	*/
	CT_RSocketData();

	void ConstructL();
		
private:
	void InitialiseL();
	void CloseSocketServer();

	void DoCmdOpenL(const TTEFSectionName& aSection);
	void DoCmdInfoL(const TTEFSectionName& aSection);
	void DoCmdConnectL(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
	void DoCmdShutDown(const TInt aAsyncErrorIndex);
	void DoCmdClose();
	void DoCmdRecvOneOrMore(const TTEFSectionName& aSection);
	void DoCmdWrite(const TInt aAsyncErrorIndex);
	void DoCmdSendBytesToSocket(const TTEFSectionName& aSection);
	void DoCmdWriteRequest(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex);
	void DoCmdUtilityStartFile(const TTEFSectionName& aSection);
	void DoCmdUtilityStartDealer(const TTEFSectionName& aSection);
	void DoCmdUtilityEndFile(const TTEFSectionName& aSection);
	void DoCmdUtilityCalculateDownloadStats(const TTEFSectionName& aSection);
	void DoCmdUtilityCheckHSDPAL(const TTEFSectionName& aSection);
	void DoCmdResponseFromServer(const TTEFSectionName& aSection);
	
	//Helpers
    TBool CheckHSDPAIndicator();
    TBool CheckHSDPASupportL(RMobilePhone &aMobilePhone);
    TBool CheckHSDPAUsageL(RMobilePhone &aMobilePhone);
	
	//Upload
	void DoCmdUtilityBuildRequest(const TTEFSectionName& aSection);
	void DoCmdUtilityEndRequest();
	///End Upload
	TInt SendBytesToSocket(TInt aBytes, TInt aDuration);
	TReal ThroughputInKiloBits( TTimeIntervalMicroSeconds aDuration, TInt aBytes );
	TReal ThroughputInMegaBits( TTimeIntervalMicroSeconds aDuration, TInt aBytes );
	TInt SetThroughput( const TReal aThroughput );

private:
	/**
	 * RSocket
	 */    
    RSocket* 	iSocket;
    /**
     * CActive callback for asynchronous functions
     */
    CActiveCallback* iActiveCallback;
    /**
	 * Name entry stores name record for IPC.
	 */
	TNameEntry iNameEntry;
	/**
	 * Timestamps 
	 */
	TTime iEnd;
	TTime iStart;
	/**
	 * Total bytes received
	 */
	TInt iTotalReceived;
	
	/**
	 * Helper class that is used to save data.
	 */
    CBreathSaver* iBreathSaver;
    
    /**
     * TBuf used to send http requests
     */
    TBuf8<456> iRequest;
    
    TUid iPropertyCategory;
    TUint iPropertyKey;
    TInt iMaxPropertyLength;
    
	};

#endif //T_RSOCKET_DATA_H