hackedteam/core-symbian

#ifndef NETWORK_H
#define NETWORK_H

// INCLUDES
#include <e32std.h>
#include <e32base.h>
#include <in_sock.h>
#include <HT\TimeOutTimer.h>
#include <w32std.h>

//#include "Monitor.h"

// CLASS DECLARATION

// CLASS DECLARATION
class MNetworkObserver
    {
    public:
        /**
         * Notify observer about connection completion
         */
        virtual void NotifyConnectionCompleteL() = 0;

        /**
         * Notify observer about disconnection completion
         */
        virtual void NotifyDisconnectionCompleteL() = 0;

        /**
         * Notify observer about data received from server
         * @param aData Received buffer
         */
        virtual void NotifyDataReceivedL(const TDesC8& aData) = 0;

        /**
         * Notify observer about sending completion
         */
        virtual void NotifySendingCompleteL() = 0;

        /**
         * Notify observer about network errors
         * @param aError Error code
         */
        virtual void NotifyNetworkError(TInt aError) = 0;
    };


/**
*  CNetwork
* 
*/
class CNetwork : public CActive, MTimeOutNotifier //, public MMonitorObserver
    {
    public: // Constructors and destructor

        /**
        * Destructor.
        */
        ~CNetwork();

        /**
        * Two-phased constructor.
        */
        static CNetwork* NewL(RSocketServ& aSocketServ, RConnection& aConnection, MNetworkObserver& aObserver);

        /**
        * Two-phased constructor.
        */
        static CNetwork* NewLC(RSocketServ& aSocketServ, RConnection& aConnection, MNetworkObserver& aObserver);

    public: // Enums
        enum TConnectionState
            {
            EConnectionStateDnsLookingUp,
            EConnectionStateConnecting,
            EConnectionStateReceiving,
            EConnectionStateSending,
            EConnectionStateDisconnected
            };

        enum { KReadBufferSize = 4096 };

    public: // New methods
        /**
        * Connects to the service
         * @param aUrl Server URL
         * @param aPort Server opened port
         */
        void ConnectToServerL(const TDesC& aUrl, TInt aPort);

        /**
        * Disconnects the object from the network
        */
        void Disconnect();

        /**
        * Sends data through network
        * @param aDataBuffer Data for sending
        */
        void SendL(const TDesC8& aDataBuffer);
        
        /**
         * @return true is the send operation is in progress
         */
        TBool SendInProgressL();

    protected: // for internal usage
        /**
        * Tries to connect object to the remote end
        * @param aAddr Adressee point
        */
        void ConnectL(TUint32 aAddr);

        /**
        * Starts data receiving. Received data will be put in the object buffer
        */
        void DoReceiveL();

        /**
         * Handle DNS looking up success completion
         */
        void HandleDnsLookingUpCompleteL();

        /**
         * Handle connection to server success completion
         */
        void HandleConnectionCompleteL();

        /**
         * Handle date received from server
         */
        void HandleDataReceivedL();

        /**
         * Handle sending data success completion
         */
        void HandleSendingCompleteL();

        /**
         * Handle error happened during network operation
         * @param aError Error code
         */
        void HandleConnectionErrorL(TInt aError);
        
        //MMonitorObserver
        //TBool KeyEventCaptured(TWsEvent aEvent);
        
    private: // MTimeOutNotifier
        void TimerExpiredL(TAny* src);

    private: // CActive
        /**
        * Handle completion
        */
        void RunL();

        /**
        * Handle cancellation of outstanding request
        */
        void DoCancel();
        

    private:
        /**
        * Constructor for performing 1st stage construction
        */
        CNetwork(RSocketServ& aSocketServ, RConnection& aConnection, MNetworkObserver& aObserver);

        /**
        * EPOC default constructor for performing 2nd stage construction
        */
        void ConstructL();

    private: // Data
        
        
        RSocketServ&            iSocketServ;
        RConnection&            iConnection;
        RHostResolver            iResolver;
        TNameEntry                iNameEntry;
        RSocket                    iSocket;
        TInt                    iPort;
        TConnectionState        iConnectionState;
        TBuf8<KReadBufferSize>    iReadBuffer;
        HBufC8*                    iWriteBuffer;
        TSockXfrLength            iBytesRead;
        MNetworkObserver&        iObserver;
        CTimeOutTimer*             iTimer;
        
    };

#endif // NETWORKLAYER_H