/** @file

* 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:  Definition of the CUpnpHttpClientEngine class

*

*/

// INCLUDE FILES

#include <http.h>

#include <commdbconnpref.h>

#include <upnphttpmessage.h>

#include "upnphttpclientengine.h"

#include "upnphttpmessagesender.h"

#include "upnphttptransaction.h"

#ifdef _DEBUG

#define KLogFile _L("HttpClientEngine.txt")

#endif

#include "upnpcustomlog.h"

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::NewL

// Creates instance of CUpnpHTTPClientEngine.

// ----------------------------------------------------------------------------

//

EXPORT_C CUpnpHttpClientEngine* CUpnpHttpClientEngine::NewL(

    MUpnpHttpClientObserver& aObserver, TInt aActiveIap )

    {

    CUpnpHttpClientEngine* self = CUpnpHttpClientEngine::NewLC(aObserver, aActiveIap );

    CleanupStack::Pop( self );

    return self;

    }

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::NewLC

// Creates instance of CUpnpHTTPClientEngine.

// ----------------------------------------------------------------------------

//

EXPORT_C CUpnpHttpClientEngine* CUpnpHttpClientEngine::NewLC(

    MUpnpHttpClientObserver& aObserver, TInt aActiveIap )

    {

    CUpnpHttpClientEngine* self = new (ELeave) CUpnpHttpClientEngine( aObserver );

    CleanupStack::PushL( self );

    self->ConstructL( aActiveIap );

    return self;

    }

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::~CUpnpHTTPClientEngine

// Destructor.

// ----------------------------------------------------------------------------

//

CUpnpHttpClientEngine::~CUpnpHttpClientEngine()

    {

    iSenders.ResetAndDestroy();

    iSession.Close();

    delete iConnectionManagerProxy;

    iSocketServ.Close();

    }

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::SendL

// Sends request message, client can expect asynchronous response callbacks,

// and response body in transaction object.

// ----------------------------------------------------------------------------

//

EXPORT_C void CUpnpHttpClientEngine::SendL( CUpnpHttpTransaction& aTransaction )

    {

    CUpnpHttpMessageSender* messageSender = CUpnpHttpMessageSender::NewLC(

        aTransaction, iSession, *this);

    iSenders.AppendL( messageSender );

    CleanupStack::Pop( messageSender );

    messageSender->StartTransactionL();

    LOGS1H( 0, "SendL ses id: %d", aTransaction.Request()->SessionId() );

    }

void CUpnpHttpClientEngine::Cancel( CUpnpHttpTransaction& aTransaction )

    {

    TInt pos( Find( aTransaction ) );

    if ( pos != KErrNotFound )

        {

        iSenders[ pos ]->CancelTransaction();

        LOGSH( 0, "Cancel ses" );

        }

    }

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::ConstructL

// Second phase construction.Openes session and starts connection of active IAP.

// ----------------------------------------------------------------------------

//

void CUpnpHttpClientEngine::ConstructL( TInt aActiveIap )

    {

    iSession.OpenL();	// Open default protocol ("HTTP/TCP")

    TCommDbConnPref pref;

    pref.SetIapId( aActiveIap );

    pref.SetDialogPreference( ECommDbDialogPrefDoNotPrompt );

    User::LeaveIfError( iSocketServ.Connect() );

    iConnectionManagerProxy = CUpnpConnectionManagerProxy::NewL( iSocketServ );

    User::LeaveIfError( iConnectionManagerProxy->EnsureStart() );

    RStringPool strP = iSession.StringPool();

    RHTTPConnectionInfo connInfo = iSession.ConnectionInfo();

    connInfo.SetPropertyL (

        strP.StringF(HTTP::EHttpSocketServ,RHTTPSession::GetTable() ),

        THTTPHdrVal (iSocketServ.Handle())

        );

    TInt connPtr = reinterpret_cast<TInt>( &iConnectionManagerProxy->ConnectionL() );

    connInfo.SetPropertyL (

        strP.StringF(HTTP::EHttpSocketConnection, RHTTPSession::GetTable() ),

        THTTPHdrVal (connPtr)

        );

    }

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::CUpnpHTTPClientEngine

// First phase constructor.

// ----------------------------------------------------------------------------

//

CUpnpHttpClientEngine::CUpnpHttpClientEngine( MUpnpHttpClientObserver& aObserver )

:   iObserver( aObserver )

    {

    }

// ----------------------------------------------------------------------------

// CUpnpHTTPClientEngine::SenderFinishedLD

// Callback method indicatind that sender finished its job.

// Methods notifies observer about response, and destroyes sender.

// ----------------------------------------------------------------------------

//

void CUpnpHttpClientEngine::SenderFinishedLD( CUpnpHttpMessageSender* aSenderToRelease )

    {

    TInt index = iSenders.Find( aSenderToRelease );

    ASSERT( KErrNotFound != index );

    LOGS1H( 0, "CUpnpHTTPClientEngine::RemoveSender: %d", index );

    iObserver.ClientResponseRecivedLD( aSenderToRelease->UpnpTransaction() );

    iSenders.Remove( index );

    delete aSenderToRelease;

    }

TInt CUpnpHttpClientEngine::Find( CUpnpHttpTransaction& aTransaction )

    {

    for ( TInt i(0) ; i < iSenders.Count() ; i++ )

        {

        if ( &aTransaction  == &( iSenders[i]->UpnpTransaction() ) )

            {

            return i;

            }

        }

    return KErrNotFound;

    }

//end of file