--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javacommons/gcfprotocols/http/src.s60/nativetransaction.cpp	Mon May 03 12:27:20 2010 +0300
@@ -0,0 +1,251 @@
+/*
+* 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>
+#include <cuseragent.h>
+#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__1dispose(
+    JNIEnv*,
+    jobject,
+    jint aNativeHttpSessionHandle)
+{
+    LOG(ESOCKET,EInfo,"http jni _dispose()");
+    NativeHttpSession* session = reinterpret_cast<NativeHttpSession*>(aNativeHttpSessionHandle);
+    delete session;
+}
+
+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);
+
+    tran->Dispose();
+    delete tran;
+}
+
+JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1createNativeTransaction(
+    JNIEnv* aJni,
+    jobject aPeer,
+    jint aNativeHttpSession,
+    jstring aUri,
+    jstring aRequestMethod)
+{
+    NativeHttpSession* session = reinterpret_cast<NativeHttpSession*>(aNativeHttpSession);
+    //tran->iJniPeer = aJni->NewGlobalRef(aPeer);
+    TRAPD(handle,   handle = session->CreateTransactionL(aJni, aPeer , aUri, aRequestMethod););
+    return handle;
+}
+
+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)
+{
+    NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);
+    int respTimeOut = aResponseTimeout;
+    tran->iJniPeer = aJni->NewWeakGlobalRef(aPeer);
+    TRAPD(err,tran->SubmitL(aJni, &aPeer,aHeaders, aPostData, aPostDataLength, respTimeOut));
+    return err;
+}
+
+JNIEXPORT jobjectArray JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1getResponse(
+    JNIEnv* aJni,
+    jobject aPeer,
+    jint aNativeHttpTransaction)
+{
+    jobjectArray rawHeaders=NULL;
+//          java::util::Monitor *iMonitor2;
+//  iMonitor2 = java::util::Monitor::createMonitor();
+//  iMonitor2->wait();
+
+    NativeHttpTransaction* tran = reinterpret_cast<NativeHttpTransaction*>(aNativeHttpTransaction);
+    tran->iJniPeer = aJni->NewWeakGlobalRef(aPeer);
+    TRAPD(err, rawHeaders =  tran->GetResponseL(aJni));
+    if (err!=KErrNone)
+    {
+        rawHeaders=NULL;
+    }
+    return rawHeaders;
+}
+
+
+JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_http_HttpConnectionNative__1getBytes(
+    JNIEnv*     aEnv,
+    jobject aPeer,
+    jint        aNativeHttpTransaction,
+    jbyteArray  aBytes,
+    jint        aLength)
+{
+    jbyte* bytes = aEnv->GetByteArrayElements(aBytes, NULL);
+
+
+    if (bytes == NULL)
+    {
+        return -1;
+    }
+
+    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;
+}
+
+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);
+    return tran->Available();
+}
+
+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;
+}