/*

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

*

*/

#ifndef NATIVEHTTPTRANSACTION_H

#define NATIVEHTTPTRANSACTION_H

#include <jni.h>

#include <e32cmn.h>

#include <e32def.h>

#include <mrefhttpclientobserver.h>

#include "functionserver.h"

//#include <mevents.h> // CJavaEventSource

class CX509Certificate;

class NativeHttpSession;

class CHttpsCertInfo;

class CHttpTransactionClient;

class HttpSessionClient;

//class CJavaEventSource;

using namespace java::util;

class NativeHttpTransaction :    public MRefHttpClientObserver //, public FunctionServer

{

public:

    static TInt NewL(JNIEnv& aJni, jobject aPeer,  HttpSessionClient& aSessionClient, const TDesC* aUri,  const TDesC* aRequestMethod,FunctionServer* aFuncServer);

    /*

    * After the headers and other details have been set up,

    * call this function to make the request.

    */

    /*

    * Get the response headers back from the transaction

    */

    jobjectArray GetResponseL(JNIEnv* aJni);

    /*

    * Call from Jave to attempt to read aLength of Bytes

    * Returns the total number of bytes read into the buffer,

    * or -1 if there is no more data because the end of the stream

    * has been reached.

    * Returns 0 if native buffer is empty but still more data to read;

    */

    TInt ReadBytes(TUint8* aBytes, TInt aLength);

    /*

    * Close the transaction and dispose

    */

    void Dispose();

    /*

    *   CloseTransaction

    */

    void CloseTransaction();

    /*

    * Get the secutiry information

    */

    OS_IMPORT TInt GetSecurityInfo();

    /*

    * Returns the amount of bytes avaible for read in our buffer.

    */

    TInt Available();

private: //from MRefHttpClientObserver

    void SubmitComplete(TInt aStatus);

    void DataReadyForRead(TInt aStatus);

private:

    NativeHttpTransaction(HttpSessionClient& aSession,FunctionServer* aFuncServer);

    void ConstructL(JNIEnv& aJni, jobject aPeer,/* TJavaEventServer aServer,*/ const TDesC* aUri, const TDesC* aRequestMethod);

private:

    //static void ExecuteCreateTransactionL(NativeHttpTransaction* aSelf, const TDesC* aUri, const TDesC* aRequestMethod);

    void ExecuteCreateTransactionL(int,int,int);

    //void ExecuteSubmitL(NativeHttpTransaction* aSelf , RPointerArray<HBufC8>* aRawHeaders, HBufC8* aPostBuf );

    //static void ExecuteGetResponseL(NativeHttpTransaction* aSelf, RPointerArray<HBufC8>* aRawHeaders);

    void ExecuteGetResponseL(int aSelf,int aRawHeaders);

    TInt ExecuteReadBytes(int aSelf, int aBytes, int aLength);

    //TInt ExecuteReadBytes(NativeHttpTransaction* aSelf, TUint8* aBytes, TInt aLength);

    //static void ExecuteCloseTransaction(NativeHttpTransaction* aSelf);

    void ExecuteCloseTransaction(int aSelfhandle);

private:

    HttpSessionClient& iSessionClient;

    CHttpTransactionClient* iTransactionClient;

    jmethodID iTransactionCallbackMethod;

    jmethodID iNotifyDataReadyForReadMethod;

    FunctionServer* iFuncServer;

    JNIEnv * iJniObject;

public:

    jobject  iJniPeer;

};

#endif // NATIVEHTTPTRANSACTION_H