/*
* 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:  NativeHttpSession
*
*/


#include "nativehttpsession.h"
#include "nativehttptransaction.h"
#include <http/thttpfilteriterator.h>
#include "httpsessionclient.h"
#include <e32svr.h>
#include "logger.h"
#include <flogger.h>

#include "javajniutils.h"

using namespace java::util;

#include "s60commonutils.h"
#include "fs_methodcall.h"


NativeHttpSession::NativeHttpSession(): java::util::FunctionServer("Myhttp1Server")
{
    JELOG2(ESOCKET);
    createServerToNewThread();
    iMonitor = java::util::Monitor::createMonitor();
}


NativeHttpSession::~NativeHttpSession()
{
    JELOG2(ESOCKET);

    //delete iHttpSessionClient;
    TInt handle = reinterpret_cast<TInt>(this);

    CallMethod(this, &NativeHttpSession::ExecuteCloseHttpSessionL,handle, this);

    if (iMonitor != NULL)
        iMonitor->wait();

    iHttpSessionClient = NULL;
    stopServer();

    delete iMonitor;
    iMonitor = NULL;

}

void NativeHttpSession::ExecuteCloseHttpSessionL(int /*aSelfhandle*/)
{
    if (iHttpSessionClient !=NULL)
    {
        delete iHttpSessionClient;
        iHttpSessionClient = NULL;
    }

    iMonitor->notify();

}
/**
 * This uses the TConstructor class to ensure safe construction of the CJavaEventSource
 * subclass, and then returns the Java handle to the object directly, hence the
 * somewhat different NewL method.
 */

TInt NativeHttpSession::NewL(JNIEnv& aJni, jobject aPeer,/* TJavaEventServer aServer,*/ TInt aType, TInt aAPNId, TInt * aErr, TInt * apnerr)
{
    NativeHttpSession* self =   new(ELeave) NativeHttpSession();
    // Cleanup the event source object if a leave occurs during construction:
    //TConstructor selfCleanup(self, aJni);
//  FeatureManager::InitializeLibL();
    // TBool isSupported = false; //FeatureManager::FeatureSupported( KFeatureIdJavaApiEnhancementsIap );//KFeatureIdJavaAPIEnhancementsIAP
//   FeatureManager::UnInitializeLib();
    //  if( isSupported )
    //      {
    *aErr = self->ConstructL(aJni, aPeer  /* aServer*/, aType, aAPNId, apnerr);
    LOG1(ESOCKET,EInfo,"NativeHttpSession::NewL - aErr : %d",*aErr);
    //    }
    //else
    //    {
    //  self->ConstructL(aJni, aPeer, /*aServer,*/ aType, -1 );
    // }
    self->attachToVm(aJni,aPeer);
    // Pop the cleanup of the object and create a handle:
    return reinterpret_cast<TInt>(self); //selfCleanup.GetHandle();
}

void NativeHttpSession::vmAttached()
{
    LOG(ESOCKET,EInfo,"+vmAttached");
    jclass httpNativeClass = NULL;
    httpNativeClass = mJniEnv->FindClass("com/nokia/mj/impl/http/HttpConnectionNative");

    iSubmitCallbackMethodID = NULL;
    iSubmitCallbackMethodID = mJniEnv->GetMethodID(httpNativeClass, "transactionSubmitCallback", "(I)V");

    iReadCallbackMethodID = NULL;
    iReadCallbackMethodID = mJniEnv->GetMethodID(httpNativeClass, "dataReadyForReadCallBack", "(I)V");

    // mJniEnv->CallVoidMethod(mJavaPeerObject,iSubmitCallbackMethodID,1);

    /*  httpNativeClass = mJniEnv->FindClass("com/nokia/mj/impl/gcf/protocol/http/Protocol");
       if ( httpNativeClass == NULL )
        {
           LOG(ESOCKET,EInfo,"+httpNativeClass is null");
        }
    iSubmitCallbackMethodID = NULL;
      iSubmitCallbackMethodID = mJniEnv->GetMethodID( httpNativeClass, "temp", "(I)V" );
      if ( iSubmitCallbackMethodID == NULL )
        {
           LOG(ESOCKET,EInfo,"+iMethodID is NULL");
        }
         mJniEnv->CallVoidMethod(mJavaPeerObject,iSubmitCallbackMethodID,1);*/
    LOG(ESOCKET,EInfo,"-vmAttached");
}

TInt NativeHttpSession::ConstructL(JNIEnv& /*aJni*/, jobject /*aPeer*/,/* TJavaEventServer aServer, */ TInt aType, TInt aAPNId, TInt * apnerr)
{
//  CJavaEventSourceBase::ConstructL(aJni, aPeer, aServer);
    //iSuiteId = aSuiteId;

    TInt err;
    TInt handle = reinterpret_cast<TInt>(this);
    CallMethodL(err, this, &NativeHttpSession::ExecuteCreateHttpSessionL,handle, aType, aAPNId,apnerr, this);

    return err;
}

TInt NativeHttpSession::CreateTransactionL(JNIEnv* aJni, jobject aPeer, jstring aUri,  jstring aRequestMethod)
{
    std::wstring uri2 = JniUtils::jstringToWstring(aJni,aUri);
    std::wstring  req2 = JniUtils::jstringToWstring(aJni,aRequestMethod);

    HBufC* t1 = S60CommonUtils::wstringToDes(uri2.c_str());
    HBufC* t2 = S60CommonUtils::wstringToDes(req2.c_str());

    //  RJString uri( *aJni, aUri );
    // RJString reqMethod( *aJni, aRequestMethod );
    //TInt handle= NativeHttpTransaction::NewL(*aJni,aPeer, Server(), *iHttpSessionClient, (const TDesC*)&uri, (const TDesC*)&reqMethod);
    TInt handle= NativeHttpTransaction::NewL(*aJni,aPeer,/* NULL, */*iHttpSessionClient, (const TDesC*)t1, (const TDesC*)t2,this);
    return handle;
}

TInt NativeHttpSession::ExecuteCreateHttpSessionL(int aSelfhandle, TInt aType, TInt aAPNId, TInt*  apnerr)
{
    LOG(ESOCKET,EInfo,"+ExecuteCreateHttpSessionL");
    TInt err = 0;
    NativeHttpSession *aSelf = reinterpret_cast<NativeHttpSession*>(aSelfhandle);

    LOG1(ESOCKET,EInfo,"NativeHttpSession uses APN: %d", aAPNId);
    if (aAPNId != -1)
    {
        LOG1(ESOCKET,EInfo,"NativeHttpSession creates client with APN: %d", aAPNId);
        TRAP(err,aSelf->iHttpSessionClient  = HttpSessionClient::NewL(aType, aAPNId, apnerr));
    }
    else
    {
        LOG(ESOCKET,EInfo,"NativeHttpSession creates client no APN");
        TRAP(err,aSelf->iHttpSessionClient  = HttpSessionClient::NewL(-1,-1, apnerr));
    }

    LOG1(ESOCKET,EInfo,"ExecuteCreateHttpSessionL : err :  %d",err);
    LOG(ESOCKET,EInfo,"-ExecuteCreateHttpSessionL ");
    return err;
}

//RHTTPSession&  NativeHttpSession::Session()
//  {
//  return iHttpSessionClient->Session();
//  }




void NativeHttpSession::doSubmitCallback(TInt aStatus,jobject &aPeer)
{
    LOG(ESOCKET,EInfo,"+doSubmitCallback1");
    //mJniEnv->CallVoidMethod(mJavaPeerObject,iSubmitCallbackMethodID,aStatus);
    mJniEnv->CallVoidMethod(aPeer,iSubmitCallbackMethodID,aStatus);
    LOG(ESOCKET,EInfo,"-doSubmitCallback1");
}

void NativeHttpSession::doReadCallback(TInt aStatus,jobject &aPeer)
{
    LOG(ESOCKET,EInfo,"+doReadCallback1");
//  mJniEnv->CallVoidMethod(mJavaPeerObject,iReadCallbackMethodID,aStatus);
    mJniEnv->CallVoidMethod(aPeer,iReadCallbackMethodID,aStatus);
    LOG(ESOCKET,EInfo,"-doReadCallback1");
}