/*
* Copyright (c) 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:  Declares main application class.
 *
*/


#ifndef __SOCKETSREADER_H__
#define __SOCKETSREADER_H__

#include <es_sock.h>

class MSocketObserver;

/*!
 This class handles reading data from a socket.
 Any data read is simply passed back to the observer.
 */
class CSocketReader : public CActive
    {
public:
    /*!
     Create a CSocketReader object
     @param aSocketID ID given to the socket. Used when reporting back.
     @param aObserver an observer for status reporting
     @param aInitialBufSize the initial size to use for the read buffer
     @result A pointer to the created instance of CSocketReader
     */
    static CSocketReader* NewL(TUint aSocketID, MSocketObserver& aObserver,
            TInt aInitialBufSize);

    /*!
     Create a CSocketReader object
     @param aSocketID ID given to the socket. Used when reporting back.
     @param aObserver an observer for status reporting
     @param aInitialBufSize the initial size to use for the read buffer
     @result A pointer to the created instance of CSocketReader
     */
    static CSocketReader* NewLC(TUint aSocketID, MSocketObserver& aObserver,
            TInt aInitialBufSize);

    /*!
     Destroy the object and release all memory objects
     */
    ~CSocketReader();

    /*!
     Initiate reading from a socket
     @param aSocket socket to read from
     @param aMTU the bluetooth maximum transmission unit for the given socket.
     */
    void StartReadingL(RSocket* aSocket, TInt aMTU);

protected:
    // from CActive
    /*!
     Cancel any outstanding operation
     */
    void DoCancel();

    /*!
     Called when operation complete
     */
    void RunL();

private:
    /*!
     Perform the first phase of two phase construction 
     @param aSocketID ID given to the socket. Used when reporting back.
     @param aObserver an observer for status reporting
     */
    CSocketReader(TUint aSocketID, MSocketObserver& aObserver);

    /*!
     Perform the second phase construction of a CSocketReader 
     @param aInitialBufSize the initial size to use for the read buffer
     */
    void ConstructL(TInt aInitialBufSize);

    /*!
     Initiate a read from the socket.
     */
    void IssueRead();

private:
    // Member variables
    /*! The ID of the socket being read from */
    TUint iSocketID;

    /*! An observer for reporting data to */
    MSocketObserver& iObserver;

    /*! Socket to read data from */
    RSocket* iSocket;

    /*! Buffer for receiving data */
    HBufC8* iBuffer;

    /*! Pointer to the buffer to be used when reading */
    TPtr8 iBufferPtr;
    };

#endif // __SOCKETSREADER_H__