/*

* Copyright (c) 2008-2008 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:  Tracks data transmitted through a network connection.

*

*/

#ifndef C_CIRDATATRANSFERTRACKER_H

#define C_CIRDATATRANSFERTRACKER_H

#include <mhttpfilter.h>

#include "irdatatransferobserver.h"

/**

 * Tracks data transmitted through a network connection.

 *

 * Data sent or received over HTTP sessions are logged with the implemented HTTP filter.

 * For raw sockets, the implementation requires that the user of the socket notifies

 * him of data transfer explicitly.

 */

NONSHARABLE_CLASS( CIRDataTransferTracker )

    : public CBase, public MIRDataTransferTracker, public MHTTPFilter

    {

public:

    /**

     * Two-phased constructor.

     *

     * @return  The created object. Transfers ownership.

     */

    static CIRDataTransferTracker*  NewL( );

    /**

     * Destructor.

     */

    ~CIRDataTransferTracker();

// from base class MIRDataTransferTracker

   void SetObserver( MIRDataTransferObserver* );

    const TIRDataTransferPckg& TransferredData() const;

    void BindL( RHTTPSession , TIRTransferCategory );

    void RawDataTransferredL( TInt , TInt , TIRTransferCategory );

// from base class MHTTPFilter

    void MHFRunL( RHTTPTransaction aTransaction, const THTTPEvent& aEvent );

private:

    /**

     * Constructor.

     */

    CIRDataTransferTracker();

    /**

     * Second-phase constructor.

     */

    void ConstructL() const;

    /**

     * Calculates the header field sizes in bytes from the specified headers.

     *

     * @param   aTransaction        HTTP transaction for the headers.

     * @param   aHeaders            Headers to calculate the size from.

     * @return  Size of the headers in bytes.

     */

    TInt HeaderSize(const RHTTPTransaction aTransaction, RHTTPHeaders aHeaders );

    /**

     * Parses the header sizes (both request and response) of the supplied HTTP transaction,

     * logging it under the specified category.

     *

     * @param   aTransaction        Transaction to parse the headers from.

     * @param   aCategory           Transfer category to record the data under.

     */

    void ParseHeaderSizeL(const RHTTPTransaction aTransaction, TIRTransferCategory aCategory );

    /**

     * Parses the body size of the supplied HTTP transaction, logging it under the specified category.

     *

     * @param   aTransaction        Transaction to parse the headers from.

     * @param   aCategory           Transfer category to record the data under.

     */

    void ParseBodySizeL(const RHTTPTransaction aTransaction, TIRTransferCategory aCategory );

    /**

     * Processes raw data sent and/or received via the connection.

     *

     * @param   aBytesSent          The number of bytes that were sent.

     * @param   aBytesReceived      The number of bytes that were received.

     * @param   aCategory           Transfer category to record the data under.

     */

    void ProcessDataL( TInt aBytesSent, TInt aBytesReceived, TIRTransferCategory aCategory );

    /**

     * Dispatches the notification of the data transfer conditionally.

     *

     * If the threshold between the last notification's data transfer amount and the current

     * data transfer amount is not exceeded, then no notification is dispatched.

     */

    void DispatchNotificationL();

private:

    /**

     * Data transfer observer.

     * Not owned.

     */

    MIRDataTransferObserver* iObserver;

    /**

     * Persistent storage for the data amounts transferred.

     */

    MIRDataTransferTracker::TIRDataTransferPckg iPckg;

    /**

     * The amount of bytes transferred since last notification was dispatched.

     */

    TInt iBytesSinceLastNotification;

    /**

     * The flag to determine Byte Counter crossed first threshold

     */

	TBool bThresholdCrossed;

    };

#endif // C_CIRDATATRANSFERTRACKER_H