// Copyright (c) 2003-2010 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:

//

#include  <httpservice.h>

#include <es_enum.h>

#include "CConnectionMonitor.h"

CHttpNetworkConnection::CHttpNetworkConnection()

    {

    }

CHttpNetworkConnection::~CHttpNetworkConnection()

    {

    if (iConnInfo)

        {

        iConnInfo->iConnection.Close();

        iConnInfo->iSocketServ.Close();

        delete iConnInfo;

        }

    if (iConnectionMonitor)

        {

        delete iConnectionMonitor;

        }

    }

CHttpNetworkConnection* CHttpNetworkConnection::New( )

    {

    CHttpNetworkConnection* self = new (ELeave)  CHttpNetworkConnection() ;

    self->ConstructL();

    return self;

    }

void CHttpNetworkConnection::ConstructL()

    {

    iConnInfo = new (ELeave) CConnectionInfo();

    }

void CHttpNetworkConnection::SetHttpService(CHttpService *aService)

    {

    iHttpService = aService;

    }

/**

 * Start the network connection for  HTTP transactions.

 * Default connection prefernces will be used.

 * 

 * @return KErrNone if connection opening is successful, otherwise relevant errors.

 */

EXPORT_C TInt CHttpNetworkConnection::Start()

    {

    TRequestStatus requestStatus;

    TInt status;

    if (! iConnInfo->iConnectionStatus)

        {

        status = SetupConnection();

        if (status == KErrNone)

            {

            iConnInfo->iConnection.Start( requestStatus);

            User::WaitForRequest(requestStatus);

            status = requestStatus.Int();

            }

        }

    else

        {

        status = KErrAlreadyExists;

        }

    if (status == KErrNone)

        {

        AssociateConnectionWithHttpSession();

        }

    return status;

    }

/**

 * Start the network connection for  HTTP transactions.

 * 

 * @param aConnPref - connection prefernces can be specified.

 * @param aAttachType - EFalse 

 * 

 * @return KErrNoMemory incase of failure otherwise KErrNone for success

 * 

 */

EXPORT_C TInt CHttpNetworkConnection::Start(TCommDbConnPref aConnPref, TBool aAttachType)

    {

    TInt status;

    iConnInfo->iConnPref = aConnPref;

    if (aAttachType && !iConnInfo->iConnectionStatus )

        {

        TUint count;

        TConnectionInfoBuf connInfoPckg;

        status = SetupConnection();

        if ( status == KErrNone && iConnInfo->iConnection.EnumerateConnections(count) == KErrNone )

            {

            for (TUint i=1; i<=count; i++)

                {

                // Note  GetConnectionInfo expects 1-based index

                if ( iConnInfo->iConnection.GetConnectionInfo( i, connInfoPckg ) == KErrNone )

                    {

                    if ( connInfoPckg().iIapId == iConnInfo->iConnPref.IapId() )

                        {

                        status= iConnInfo->iConnection.Attach(iConnInfo->iConnPref, RConnection::EAttachTypeNormal);

                        return status;

                        }

                    }   

                }

            }

        return KErrNotFound;

        }

    else

        {

        if (!iConnInfo->iConnectionStatus)

            {

            status = SetupConnection();

            if (status == KErrNone)

                {

                TRequestStatus requestStatus;

                iConnInfo->iConnection.Start(iConnInfo->iConnPref,requestStatus);

                User::WaitForRequest(requestStatus);

                status = requestStatus.Int();

                }

            }

        else

            {

            status = KErrAlreadyExists;

            }

        if (status == KErrNone)

            {

            AssociateConnectionWithHttpSession();

            }

        return status;

        }

    }

/**

 * To Stop the network connection 

 * 

  */

EXPORT_C void CHttpNetworkConnection::Stop()

    {

    if (iConnInfo->iConnectionStatus)

        {

        iConnInfo->iConnectionStatus = EFalse;

        iConnInfo->iConnection.Close();

        iConnInfo->iSocketServ.Close();

        }

    }

void CHttpNetworkConnection::AssociateConnectionWithHttpSession()

    {

    RStringPool strP = iHttpService->Session().StringPool();

    RHTTPConnectionInfo connInfo = iHttpService->Session().ConnectionInfo();

    connInfo.SetProperty(strP.StringF(HTTP::EHttpSocketServ,RHTTPSession::GetTable()), THTTPHdrVal(iConnInfo->iSocketServ.Handle()));

    TInt connPtr = reinterpret_cast<TInt>(&(iConnInfo->iConnection));

    connInfo.SetProperty(strP.StringF(HTTP::EHttpSocketConnection,RHTTPSession::GetTable()), THTTPHdrVal(connPtr));

    }

TInt CHttpNetworkConnection::SetupConnection()

    {

    TInt status = KErrAlreadyExists;

    if (!iConnInfo->iConnectionStatus )

        {

        status = iConnInfo->iSocketServ.Connect() ;

        if (status == KErrNone)

            {

            status = iConnInfo->iConnection.Open ( iConnInfo->iSocketServ ) ;

            if (status != KErrNone)

                {

                iConnInfo->iSocketServ.Close();

                }

            else

                {

                iConnectionMonitor = CConnectionMonitor::NewL(this); 

                iConnInfo->iConnectionStatus = ETrue;

                }

            }

        }

    return status;

    }

void CHttpNetworkConnection::HandleConnectionEvent(TInt aError)

    {

    if (aError == KLinkLayerClosed || aError == KLinkLayerClosed)

        {

        iConnInfo->iConnectionStatus = EFalse;

        }

    }