/*

* Copyright (c) 2010 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: 

*

*/

#include <e32test.h>

#include <f32file.h>

#include <httpclientserver/mhttpauthenticationcallback.h>

#include <httpclientserver/mhttptransactioncallback.h>

#include <httpclientserver/mhttpdatasupplier.h>

#include <httpclientserver/framework/logging.h>

#include <httpclientserver/mhttpsessioneventcallback.h>

class CHttpExampleUtils;

class CHttpServerTransactionBase;

class MTransactionNotify

    {

    public:

    virtual void OnTransactionCompleted ( CHttpServerTransactionBase* iTrans ) =0;      

    };

class CHttpServer : public CBase,

                    public MHTTPTransactionCreationCallback,

                    public MTransactionNotify,

                    public MHTTPSessionEventCallback

    {

public:

    virtual ~CHttpServer();

    static CHttpServer* NewLC();

    static CHttpServer* NewL();

    //void StartClientL();

    void SetupClientL ();

    //virtual void StartHttpServer();

    void ProcessSelectionL ( TInt aSelection );

    TInt GetLocalHost ( TSockAddr& aAddr );

    TDesC8& GetIPAddress();

    void StartConnectionL(TInt aIapId);

protected:

    CHttpServer();

    void ConstructL();

private:

    enum TMenuItems

        {

        EStart = 1,

        EStop,

        EExit,

        };

    void ResetTimeElapsed();

    void DisplayTimeElapsed();

    //

    void SetHeaderL(RHTTPHeaders aHeaders, TInt aHdrField, const TDesC8& aHdrValue);

    void SetDefaults(TDes& aURL, TDes& aProxy, TDes& aHook, TDes& aSessionId);

    // From MHTTPTransactionCreationCallback

    RHTTPTransaction NewTransactionL ( const TUriC8& aUri, RStringF aMethod );

    void OnTransactionCompleted ( CHttpServerTransactionBase* iTrans );

    // From MHTTPSessionEventCallback

    virtual void MHFSessionRunL ( const THTTPSessionEvent& aEvent );

    virtual TInt MHFSessionRunError ( TInt aError, const THTTPSessionEvent& aEvent );

    void CleanupTransactions ();

private:

    TTime iLastTimeStamp;

    TInt iDataChunkCount;

    RHTTPClientServerSession     iSess;

    RFs iFileServ;

    TBool iManualPost;

    //CHttpExampleUtils* iUtils;

    RArray <CHttpServerTransactionBase*> iTransactions;

    RFile iLogFile;

    RBuf8 iIPAddr;

    // Connection

    RConnection iConnection;

    // SocketServer

    RSocketServ iSocketServ;

    __FLOG_DECLARATION_MEMBER;

    };

class CHttpServerTransactionBase : public CBase, public MHTTPTransactionCallback

    {

public:

    virtual ~CHttpServerTransactionBase ();

    RHTTPTransaction Transaction ()

        {

        return iTransaction;    

        }

protected:

    CHttpServerTransactionBase ( MTransactionNotify& aNotify, /*CHttpExampleUtils& aUtils,*/ RFs& aFileServ );

    void SetHeaderL(RStringPool& aStringPool, RHTTPHeaders aHeaders, TInt aHdrField, const TDesC8& aHdrValue);

    void ConstructL ( RHTTPClientServerSession& aSession, const TUriC8& aUri, RStringF aMethod );

    protected:

    //

    // methods from MHTTPTransactionCallback

    //

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

    virtual TInt MHFRunError(TInt aError, RHTTPTransaction aTransaction, const THTTPEvent& aEvent);

protected:

    MTransactionNotify& iNotify;

    RFs&                iFileServ;

    //CHttpExampleUtils&  iUtils; // not owned                

    RFile               iFile;

    RHTTPTransaction    iTransaction;

    __FLOG_DECLARATION_MEMBER;  

    };

class CHttpDataTransmitter : public CHttpServerTransactionBase, public MHTTPDataSupplier

    {

public: 

    static CHttpDataTransmitter* NewL ( MTransactionNotify& aNotify, /*CHttpExampleUtils& aUtils,*/ RFs& aFileServ, RHTTPClientServerSession& aSession, const TUriC8& aUri, RStringF aMethod );

    TInt OpenFile( const TDesC8& aHttpPath );

private:

    //

    // methods from MHTTPTransactionCallback

    //

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

    virtual TInt MHFRunError(TInt aError, RHTTPTransaction aTransaction, const THTTPEvent& aEvent);

    // From MHTTPDataSupplier

    virtual TBool GetNextDataPart(TPtrC8& aDataPart);

    virtual void ReleaseData();

    virtual TInt OverallDataSize();

    virtual TInt Reset();

private:    

    CHttpDataTransmitter (MTransactionNotify& aNotify,/*CHttpExampleUtils& aUtils,*/ RFs& aFileServ);

private:

    TBuf8 <4096>    iData;

    TInt            iDataToSend;

    TBuf8<32>       iContentType;

    TBool           iTransSubmitted;

    __FLOG_DECLARATION_MEMBER;

    };