/** @file
* Copyright (c) 2005-2006 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:  CUpnpHttpChunkFileTransferReader is a class responsible for 
*                asynchronous TCP reading and controlling the encoded data
*
*/



#ifndef C_CUPNPHTTPCHUNKFILETRANSFERREADER_H
#define C_CUPNPHTTPCHUNKFILETRANSFERREADER_H


#include <e32base.h>
#include <in_sock.h>
#include <f32file.h>


class CUpnpTcpSession;
class CUpnpHttpFileTransferBuffer;
class CUpnpHttpFileAccess;
class CUpnpHttpFileTransferReader;
class CUpnpHttpChunkParser;

/**
 *  CUpnpHttpChunkFileTransferReader is responsible for asynchronous reading.
 *  It reads chunked-encoded data and process it  
 *  @lib DLNAWebServer.lib
 *  @since Series60 3.2
 */
NONSHARABLE_CLASS (CUpnpHttpChunkFileTransferReader) : public CUpnpHttpFileTransferReader
    {

public: // Constructors and destructors
    
    /**
    * CUpnpHttpChunkFileTransferReader factory method.
    * @since Series60 3.2
    * @param aSession session that runs and supervises reader.
    * @param aSocket socket from which data will be read.
    * @param aPriority priority with which the reader will be working.
    * @param aReadPortion - size of the buffer to read from the socket
    * @param aBufferSize - the buffer size
    * @return new CUpnpHttpChunkFileTransferReader object's instance.
    */
    static CUpnpHttpChunkFileTransferReader* NewL( CUpnpTcpSession& aSession,
                                        RSocket& aSocket,
                                        TThreadPriority aPriority,                                        
                                        TInt aReadPortion,
                                        TInt aBufferSize);
    
    /**
    * Virtual destructor.
    * @since Series60 3.2
    */                             
    virtual ~CUpnpHttpChunkFileTransferReader();             
     

private: // Constructors and destructors

    /**
    * CUpnpHttpChunkFileTransferReader constructor.
    * @since Series60 3.2
    * @param aSession session that runs and supervises reader.
    * @param aSocket socket from which data will be read.
    * @param aPriority priority with which the reader will be working.
    * @param aHandle handle for logging for this thread.
    * @param aPriority priority with which the reader will be working.
    * @param aReadPortion - size of the buffer to read from the socket
    * @param aBufferSize - the buffer size
    */
    CUpnpHttpChunkFileTransferReader( CUpnpTcpSession& aSession,
                           RSocket& aSocket,
                           TThreadPriority aPriority,
                           TInt aReadPortion,
                           TInt aBufferSize);
    /**
    * By default Symbian 2nd phase constructor is private.
    * @since Series60 3.2
    */
    void ConstructL();
    
    /**
    * Remaing number of bytes to read.
    * @since Series60 3.2    
    * @return TInt
    */
    TInt RemainingBytes();
    
    /**
    * Starts reading in asynchronous mode.
    * @since Series60 3.2
    */
    void StartL();   

private:

    /**
    * Issues reading in asynchronous mode.
    * @since Series60 3.2
    */
    void RunL();
    
    /**
    * Invoked when RunL leaves.
    */
    TInt RunError( TInt aErr );
    
    /**
     * Parse - decodes chunked-encoding     
     * @since S60 3.2
     * @param buffer
     * @param position in the buffer
     * @return error code
     */
    TInt Parse( TDes8& aBuffer, TInt& aPos );
   
protected:

	/**
    * Bytes to be read from the socket
    * @since Series60 3.2    
    * @return TInt
    */
    TInt ReadBufferSize();   
    
    /**
    * Handle buffer of data
    * @since Series60 3.2    
    * @return TBool if all data handled
    */
    TBool HandleL();   
    
    /**
    * Finish the session
    * @since Series60 3.2
    */
    void Finish();  
    
    
    /**
    * Reads from socket
    * @since Series60 3.2    
    */
    void ReadFromSocket();
    
    /**
    * Resets the reader
    * @since Series60 3.2    
    */
    void Reset();

    /**
    * Handles read data - trims the buffer and save data to file
    * @since Series60 5.0
    * @return TInt 
    */
    TInt HandleReadDataL( TInt aPieceToRead );
                      
private: 

	//parser for chunked-encoding
    CUpnpHttpChunkParser* iParser;

    //decoded data
    TInt iDecoded;    
    };


#endif // C_CUPNPHTTPCHUNKFILETRANSFERREADER_H

// End Of File