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

#include "httpsessionclient.h"
#include "chttptransactionclient.h"
#include "javavalidationfilter.h"
#include <http/thttpfilteriterator.h>
#include <httpstringconstants.h>
#include <e32svr.h>
#include "logger.h"

#ifdef RD_JAVA_S60_RELEASE_9_2_ONWARDS
#include <extendedconnpref.h> // extended connection preference
#include <connpref.h>
#else
#include <commdbconnpref.h>
#endif

#include <http/cecomfilter.h>
#include <httpfilterproxyinterface.h>
#include <httpfiltercommonstringsext.h>


//const TUint32 KMIDletSuiteAPNNotSpecified   = KMaxTUint32;

HttpSessionClient::HttpSessionClient()
{

}


/*HttpSessionClient* HttpSessionClient::NewL()
    {
        LOG(ESOCKET,EInfo,"+HttpSessionClient::NewL ");
    return HttpSessionClient::NewL(-1, -1);
    }*/

HttpSessionClient* HttpSessionClient::NewL(TInt aType,TInt aAPNId,TInt * apnerr)
{
    HttpSessionClient* self =   new(ELeave) HttpSessionClient();
    CleanupStack::PushL(self);
    self->ConstructL(aType,aAPNId,apnerr);
    CleanupStack::Pop(self);
    return self;
}

/*
* -j2me expects the http stack to be able to post body data with no content type
*   the native stack default validation filter does not allow this.
* -j2me expects the http stack to allow post requests to have body data
*   the native stack default validation filter does not allow this.
*/

/**
 * To remove default Redirection filter.
 *
 * Preconditions. The following conditions must be true prior to calling
 * this method; otherwise, its operation is undefined.
 * - None.
 *
 * Postconditions. The following condition is true immediately after
 * returning from this method.
 * - Java HTTP session does not have Redirection filter.
 *
 * @param None.
 * @return None.
 * @exception None.
 */
void HttpSessionClient::RemoveRedirectionFilter()
{
    RHTTPFilterCollection filtColl = iHttpSession.FilterCollection();

    if (filtColl.CanChangeFilters())
    {

        // Remove default redirection filter.
        RStringF valFilter = iHttpSession.StringPool().StringF(HTTP::ERedirect, RHTTPSession::GetTable());
        filtColl.RemoveFilter(valFilter);
    }
}

void HttpSessionClient::ReplaceValidationFilterL()
{
    RHTTPFilterCollection filtColl = iHttpSession.FilterCollection();
    if (filtColl.CanChangeFilters())
    {
        RStringF valFilter = iHttpSession.StringPool().StringF(HTTP::EValidation,RHTTPSession::GetTable());
        //Remove default validation filter
        filtColl.RemoveFilter(valFilter);

        valFilter = iHttpSession.StringPool().StringF(HTTP::EDeflate, RHTTPSession::GetTable());
        //Remove default deflate filter
        filtColl.RemoveFilter(valFilter);

        valFilter = iHttpSession.StringPool().StringF(HTTP::EUserAgent, RHTTPSession::GetTable());
        //Remove default useragent filter
        filtColl.RemoveFilter(valFilter);

        //Install the java validation filter
        iValidationFilter = CJavaValidationFilter::InstallFilterL(&iHttpSession);
    }
}

void HttpSessionClient::ConstructL(TInt aType, TInt aAPNId, TInt * apnerr)
{
    LOG(ESOCKET,EInfo,"+HttpSessionClient::ConstructL ");

    /*CActiveScheduler * scheduler = new CActiveScheduler();
    CActiveScheduler::Install(scheduler);
    CActiveScheduler::Add(this);*/

    iHttpSession.OpenL();
    LOG(ESOCKET,EInfo,"+HttpSessionClient::ConstructL- RHttpSession opened ");
    //Update the exiting Http filter with a java rules based filter
    ReplaceValidationFilterL();

    RemoveRedirectionFilter();
    if (aType == 2) // SNAP ID
    {
        LOG(ESOCKET,EInfo,"type is snap id");
        if (aAPNId != -1)
        {
            iApnId = aAPNId;
            // Creates connection with selected SNAP ID
            int ret = iSocketServ.Connect();
            LOG1(ESOCKET,EInfo,"iSocketServ.Connect() returned %d",ret);
            if (ret < 0)
            {
                LOG(ESOCKET,EInfo,"+HttpSessionClient::iSocketServ.Connect() failed ");
                *apnerr = ret;
                return;
            }
            ret = iConnection.Open(iSocketServ);
            LOG1(ESOCKET,EInfo,"iConnection.Open returned %d",ret);
            if (ret < 0)
            {
                LOG(ESOCKET,EInfo,"+HttpSessionClient::iConnection.Open failed ");
                *apnerr = ret;
                return;
            }
#ifdef RD_JAVA_S60_RELEASE_9_2_ONWARDS
            TConnPrefList prefList;
            TExtendedConnPref prefs;
            prefs.SetSnapId(aAPNId);
            prefList.AppendL(&prefs);
            ret = iConnection.Start(prefList);
#else
            TCommSnapPref connPref;
            connPref.SetSnap(aAPNId);
            ret = iConnection.Start(connPref);
#endif

            LOG(ESOCKET,EInfo,"+HttpSessionClient:: using extended connection prefernce in snap case");
            LOG1(ESOCKET,EInfo,"iConnection.Start returned %d",ret);
            if (ret < 0)
            {
                *apnerr = ret;
                //   return;
            }
            else
            {
                RHTTPConnectionInfo connInfo = iHttpSession.ConnectionInfo();
                connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
                                          HTTP::EHttpSocketServ, RHTTPSession::GetTable()), THTTPHdrVal(iSocketServ.Handle()));
                TInt connPtr = REINTERPRET_CAST(TInt, &iConnection);
                connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
                                          HTTP::EHttpSocketConnection, RHTTPSession::GetTable()), THTTPHdrVal(connPtr));
            }
        } // end of if(apnid != -1)
        LOG1(ESOCKET,EInfo,"apnerr = %d",*apnerr);
    } // end of if(aType == 3 )
    else
    {
        if (aType == 3) // IAP Id
        {
            LOG(ESOCKET,EInfo,"+HttpSessionClient:: in iap case");
            if (aAPNId != -1)
            {
                // Creates connection with selected IAP ID
                int ret = iSocketServ.Connect();
                if (ret < 0)
                {
                    LOG(ESOCKET,EInfo,"+HttpSessionClient::iSocketServ.Connect() failed ");
                    *apnerr = ret;
                    return;
                }
                ret = iConnection.Open(iSocketServ);
                if (ret < 0)
                {
                    LOG(ESOCKET,EInfo,"+HttpSessionClient::iConnection.Open failed ");
                    *apnerr = ret;
                    return;
                }

#ifdef RD_JAVA_S60_RELEASE_9_2_ONWARDS
                // Create connection preferences
                TConnPrefList prefList;
                TExtendedConnPref prefs;
                prefs.SetIapId(aAPNId);
                prefList.AppendL(&prefs);
                ret = iConnection.Start(prefList);
                LOG(ESOCKET,EInfo,"+HttpSessionClient:: using extended connection prefernce in iap case");
#else
                TCommDbConnPref pref;
                pref.SetIapId(aAPNId);
                pref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);
                ret = iConnection.Start(pref);
#endif

                if (ret < 0)
                {
                    *apnerr = ret;
                    //return;
                }
                RHTTPConnectionInfo connInfo = iHttpSession.ConnectionInfo();
                //connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
                //                          HttpFilterCommonStringsExt::EAccessPointID, HttpFilterCommonStringsExt::GetTable()), aAPNId);
                connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
                                          HTTP::EHttpSocketServ, RHTTPSession::GetTable()), THTTPHdrVal(iSocketServ.Handle()));
                TInt connPtr = REINTERPRET_CAST(TInt, &iConnection);
                connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
                                          HTTP::EHttpSocketConnection, RHTTPSession::GetTable()), THTTPHdrVal(connPtr));
            } // end of if ( aAPNId != -1)
        } // end of if(aType == 4)
        else
        {
            // Creates connection with no selected Network Access.
        }

    } // end of else

    LOG1(ESOCKET,EInfo,"apnerr = %d",*apnerr);
    LOG(ESOCKET,EInfo,"now no re prompting");

    // This is special case when that IAP/SNAP is not found
    // Override the http stack's feaute of using device default
//    if (*apnerr < 0)
//    {
//        LOG(ESOCKET,EInfo,"ECommDbDialogPrefPrompt set for the http session");
//        int ret = iSocketServ.Connect();
//        ret = iConnection.Open(iSocketServ);
//#ifdef RD_JAVA_S60_RELEASE_9_2_ONWARDS
//        TConnPrefList prefList;
//        TExtendedConnPref prefs;
//        prefs.SetConnSelectionDialog(ETrue);
//        prefList.AppendL(&prefs);
//        ret = iConnection.Start(prefList);
//        LOG(ESOCKET,EInfo,"+HttpSessionClient:: using extended connection prefernce - error case ");
//#else
//        TCommDbConnPref pref;
//        pref.SetDialogPreference(ECommDbDialogPrefPrompt);
//        ret = iConnection.Start(pref);
//        LOG(ESOCKET,EInfo,"+HttpSessionClient:: using commdb con pref - error case ");
//#endif
//
//        RHTTPConnectionInfo connInfo = iHttpSession.ConnectionInfo();
//        connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
//                                  HTTP::EHttpSocketServ, RHTTPSession::GetTable()), THTTPHdrVal(iSocketServ.Handle()));
//        TInt connPtr = REINTERPRET_CAST(TInt, &iConnection);
//        connInfo.SetPropertyL(iHttpSession.StringPool().StringF(
//                                  HTTP::EHttpSocketConnection, RHTTPSession::GetTable()), THTTPHdrVal(connPtr));
//    }

    //Add proxy support
    TRAP_IGNORE(LoadProxyLibraryL(aAPNId));

    // Try to load the customiser plugin, which enables customisation
    // of the loaded filters and headers.
    /*    LoadCustomiserLibrary();
        if ( iCustomiser )
            {
            iCustomiser->CustomiseFiltersL(iHttpSession);
            }   */
}

//_LIT(KHttpClientCustomiserPath, "MIDP2HTTPClientCustomiser.dll");

//typedef MHttpClientCustomiser* (*GetCustomiser)(void);

/*void HttpSessionClient::LoadCustomiserLibrary()
{
    TInt err = iCustomiserLib.Load(KHttpClientCustomiserPath);
    if ( KErrNone == err )
        {
        iCustomiser = reinterpret_cast<GetCustomiser>(iCustomiserLib.Lookup(1))();
        }

}*/

void HttpSessionClient::LoadProxyLibraryL(TUint32 /*aAPNId*/)
{
    iHttpSession.StringPool().OpenL(HttpFilterCommonStringsExt::GetTable());
    CHttpFilterProxyInterface::InstallFilterL(iHttpSession) ;
}

HttpSessionClient::~HttpSessionClient()
{
    iHttpSession.Close();
    iConnection.Close();
    iSocketServ.Close();

    /* if ( iCustomiser )
         {
         delete iCustomiser;
         iCustomiser = NULL;
         iCustomiserLib.Close();
         }*/
}

/* RStringPool HttpSessionClient::StringPool() const
    {
    return iHttpSession.StringPool();
    }
*/
/*void HttpSessionClient::CustomiseHeadersL(RHTTPHeaders &aHeaders)
{
    if ( iCustomiser )
        {
        iCustomiser->CustomiseHeadersL(iHttpSession, aHeaders);
        }
}*/

void HttpSessionClient::RestartConnection()
{
    LOG(ESOCKET,EInfo,"+HttpSessionClient::RestartConnection12 + ");
    iConnection.Close();
    TInt ret = iConnection.Open(iSocketServ);

    //TCommSnapPref connPref;
#ifdef RD_JAVA_S60_RELEASE_9_2_ONWARDS
    TConnPrefList prefList;
    TExtendedConnPref prefs;

    if (iApnId!=-1)
        prefs.SetSnapId(iApnId);
    TRAPD(err,prefList.AppendL(&prefs));
    if (err == KErrNone)
        ret = iConnection.Start(prefList);
    else
        ret = iConnection.Start();
#else
    TCommSnapPref connPref;
    if (iApnId!=-1)
        connPref.SetSnap(iApnId);
    ret = iConnection.Start(connPref);

#endif
    LOG(ESOCKET,EInfo,"+HttpSessionClient::RestartConnection + ");

}