/*

* 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:  NativeTransaction - all jni calls made through here

*

*/

#include <e32def.h>

#include <centralrepository.h>

#ifdef RD_JAVA_S60_RELEASE_10_1_ONWARDS

#include <CUserAgent.h>

#else

#include <cuseragent.h>

#endif

#include "com_nokia_mj_impl_http_HttpConnectionNative.h"

#include "nativehttptransaction.h"

#include "nativehttpsession.h"

#include "monitor.h"

#include "logger.h"

#include "s60commonutils.h"

using namespace java::util;

// Constants for default User-Agent Header

const TUid KCRUidJ2MEConfiguration = {0x102823D3};

const TUint KHTTPUserAgentHeader = 2;

const TUint KHTTPUserAgentHeaderValue = 3;

const TInt KHTTPUserAgentS60Header = 0;

const TInt KHTTPUserAgentBrowserHeader = 1;

const TInt KHTTPUserAgentDefinedHeader = 2;

const TInt KMaxLength = 1024;

// Forward declaration

jstring GetUserAgentL(JNIEnv *aJni, jboolean aMidpRuntime);

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1createHttpSession(JNIEnv* aJni, jobject aPeer, jint /*aCommsServerHandle*/, jint aType, jint aAPNId, jintArray  aReturnValue)

{

    TInt err = -1, apnerr = 0;

    TRAPD(handle,   handle = NativeHttpSession::NewL(*aJni, aPeer,  aType, aAPNId, &err, &apnerr));

    ILOG1(ESOCKET, "createsession returned %d ",err);

    ILOG1(ESOCKET, "apn setting returned %d ",apnerr);

    aJni->SetIntArrayRegion(aReturnValue,0,1,&err);

    aJni->SetIntArrayRegion(aReturnValue,1,1,&apnerr);

    //DEBUGCOMP_INT( KLogFileHttp ,"Java_com_symbian_midp_io_protocol_http_Protocol__1CreateHttpSession: handle = %d", handle );

    return handle;

}

JNIEXPORT void JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1closeTransaction(

    JNIEnv* aJni,

    jobject aPeer,

    jint aNativeHttpTransaction)

{

    NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);

    tran->iJniPeer = aJni->NewWeakGlobalRef(aPeer);

    try

    {

        tran->Dispose();

    }

    catch (...)

    {

        // function server usage may throw an exception.

        // ignore, called when transcation is closed

        ELOG(ESOCKET,"Http JNI Error, exception caught!: _closeTransaction");

    }

    delete tran;

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1createNativeTransaction(

    JNIEnv* aJni,

    jobject aPeer,

    jint aNativeHttpSession,

    jstring aUri,

    jstring aRequestMethod)

{

    LOG(ESOCKET,EInfo,"http jni _createNativeTransaction()");

    NativeHttpSession* session = reinterpret_cast<NativeHttpSession*>(aNativeHttpSession);

    //tran->iJniPeer = aJni->NewGlobalRef(aPeer);

    try

    {

        TRAPD(handle,   handle = session->CreateTransactionL(aJni, aPeer , aUri, aRequestMethod););

        return handle;

    }

    catch (...)

    {

        // function server usage may throw an exception.

        ELOG(ESOCKET,"Http JNI Error, exception caught!: _createTransaction");

        return -1;

    }

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1submitTransaction(

    JNIEnv* aJni,

    jobject aPeer,

    jint aNativeHttpTransaction,

    jobjectArray aHeaders,

    jbyteArray aPostData,

    jint aPostDataLength,

    jint aResponseTimeout)

{

    LOG(ESOCKET,EInfo,"http jni _submitTransaction");

    NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);

    int respTimeOut = aResponseTimeout;

    tran->iJniPeer = aJni->NewWeakGlobalRef(aPeer);

    try

    {

        TRAPD(err,tran->SubmitL(aJni, &aPeer,aHeaders, aPostData, aPostDataLength, respTimeOut));

        return err;

    }

    catch (...)

    {

        ELOG(ESOCKET,"Http JNI Error, exception caught!: _submitTransaction");

        return -1;

    }

}

JNIEXPORT jobjectArray JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1getResponse(

    JNIEnv* aJni,

    jobject aPeer,

    jint aNativeHttpTransaction)

{

    LOG(ESOCKET,EInfo,"http jni _getResponse");

    jobjectArray rawHeaders=NULL;

    NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);

    tran->iJniPeer = aJni->NewWeakGlobalRef(aPeer);

    try

    {

        TRAPD(err, rawHeaders =  tran->GetResponseL(aJni));

        if (err!=KErrNone)

        {

            rawHeaders=NULL;

        }

    }

    catch (...)

    {

        rawHeaders=NULL;

        ELOG(ESOCKET,"Http JNI Error, exception caught!: _getResponse");

    }

    return rawHeaders;

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1getBytes(

    JNIEnv*     aEnv,

    jobject aPeer,

    jint        aNativeHttpTransaction,

    jbyteArray  aBytes,

    jint        aLength)

{

    LOG(ESOCKET,EInfo,"http jni _getBytes");

    jbyte* bytes = aEnv->GetByteArrayElements(aBytes, NULL);

    if (bytes == NULL)

    {

        return -1;

    }

    try

    {

        NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);

        tran->iJniPeer = aEnv->NewWeakGlobalRef(aPeer);

        TInt length = tran->ReadBytes(reinterpret_cast<TUint8*>(bytes), aLength);

        aEnv->ReleaseByteArrayElements(aBytes, bytes, NULL);

        return length;

    }

    catch (...)

    {

        ELOG(ESOCKET,"Http JNI Error, exception caught!: _getBytes");

        return -1;

    }

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1available(

    JNIEnv* aJni,

    jobject aPeer,

    jint aNativeHttpTransaction)

{

    NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);

    tran->iJniPeer = aJni->NewWeakGlobalRef(aPeer);

    try

    {

        return tran->Available();

    }

    catch (...)

    {

        ELOG(ESOCKET,"Http JNI Error, exception caught!: _available");

        return -1;

    }

}

JNIEXPORT jstring JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1getUserAgentHeaderValue(

    JNIEnv *aJni,

    jobject, jboolean aMidpRuntime)

{

    jstring header = NULL;

    TRAPD(err, header = GetUserAgentL(aJni, aMidpRuntime));

    if (err != KErrNone)

    {

        header = NULL;

    }

    return header;

}

jstring GetUserAgentL(JNIEnv *aJni, jboolean aMidpRuntime)

{

    jstring header = NULL;

    if (aMidpRuntime == false)

    {

        CUserAgent* userAgent = CUserAgent::NewL();

        CleanupStack::PushL(userAgent);

        HBufC8* agent8 = userAgent->UserAgentL();

        CleanupStack::PushL(agent8);

        HBufC* agent = HBufC::NewMaxLC(agent8->Length());

        agent->Des().Copy(*agent8);

        header = S60CommonUtils::NativeToJavaString(*aJni, agent->Des());

        CleanupStack::PopAndDestroy(agent);

        CleanupStack::PopAndDestroy(agent8);

        CleanupStack::PopAndDestroy(userAgent);

        return header;

    }

    CRepository* repository = NULL;

    repository = CRepository::NewL(KCRUidJ2MEConfiguration);

    if (repository)

    {

        CleanupStack::PushL(repository);

        TInt headerType;

        TInt ret = repository->Get(KHTTPUserAgentHeader, headerType);

        if (ret == KErrNone)

        {

            switch (headerType)

            {

            case KHTTPUserAgentBrowserHeader:

            {

                CUserAgent* userAgent = CUserAgent::NewL();

                CleanupStack::PushL(userAgent);

                HBufC8* agent8 = userAgent->UserAgentL();

                CleanupStack::PushL(agent8);

                HBufC* agent = HBufC::NewMaxLC(agent8->Length());

                agent->Des().Copy(*agent8);

                header = S60CommonUtils::NativeToJavaString(*aJni, agent->Des());

                CleanupStack::PopAndDestroy(agent);

                CleanupStack::PopAndDestroy(agent8);

                CleanupStack::PopAndDestroy(userAgent);

            }

            break;

            case KHTTPUserAgentDefinedHeader:

            {

                HBufC* headerValue = HBufC::NewLC(KMaxLength);

                TPtr ptr(headerValue->Des());

                ret = repository->Get(KHTTPUserAgentHeaderValue, ptr);

                header = S60CommonUtils::NativeToJavaString(*aJni, headerValue->Des());

                CleanupStack::PopAndDestroy(headerValue);

            }

            break;

            case KHTTPUserAgentS60Header:

            default:

                header = NULL;

                break;

            }

        }

        CleanupStack::PopAndDestroy(repository);

    }

    return header;

}