/*

* Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:  Implementation of CPushMtmCacheSupply

*

*/

// INCLUDE FILES

#include "PushMtmCacheSupply.h"

#include "HttpCacheManager.h"

#include "PushMtmCacheDataSupplier.h"

#include <http/RHTTPTransaction.h>

#include <http/mhttpdatasupplier.h>

#include <http/rhttpsession.h>

#include <httperr.h>

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES

// CONSTANTS

const TInt KResponseTimeout = 0;

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

// ============================ MEMBER FUNCTIONS ===============================

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

// CPushMtmCacheSupply::CPushMtmCacheSupply

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CPushMtmCacheSupply::CPushMtmCacheSupply(MCacheSupplyCallbacks* aCacheSupplyCallbacks ):

      // closed by default

      iReponseState( THTTPEvent::EClosed )

    {

    iCacheEntry.iCacheHandler = NULL;

    iCacheEntry.iCacheEntry = NULL;

    iCacheSupplyCallbacks = aCacheSupplyCallbacks;

    }

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

// CPushMtmCacheSupply::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CPushMtmCacheSupply::ConstructL(CHttpCacheManager* aCacheMgr)

    {

    iCacheManager = aCacheMgr;

    }

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

// CPushMtmCacheSupply::NewL

// Two-phased constructor.

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

//

CPushMtmCacheSupply* CPushMtmCacheSupply::NewL(CHttpCacheManager* aCacheMgr, MCacheSupplyCallbacks* aCacheSupplyCallbacks  )

    {

    CPushMtmCacheSupply* self = new( ELeave ) CPushMtmCacheSupply( aCacheSupplyCallbacks);

    CleanupStack::PushL( self );

    self->ConstructL(aCacheMgr);

    CleanupStack::Pop();

    return self;

    }

// Destructor

CPushMtmCacheSupply::~CPushMtmCacheSupply()

    {

    delete iDataSupplier;

    CloseRequest();

    if (iResponseTimer)

        {

        iResponseTimer->Cancel();

        }

    delete iResponseTimer;

    }

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

// CPushMtmCacheSupply::StartRequestL

//

//

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

//

TInt CPushMtmCacheSupply::StartRequestL( )

    {

    TInt status;

    status = iCacheManager->RequestL( *(iCacheSupplyCallbacks->Transaction()), 

    TBrCtlDefs::ECacheModeNormal , iCacheEntry );

    // start a timer that feeds the content to the transaction

    if( status == KErrNone )

        {

        iClosed = EFalse;

        // set response state. start with the http headers.

        iReponseState = THTTPEvent::EGotResponseHeaders;

        //

        iResponseTimer = CPeriodic::NewL( CActive::EPriorityHigh );

        iResponseTimer->Start( KResponseTimeout, KResponseTimeout, TCallBack( &ResponseCallbackL, this ) );

        }

    return status;

    }

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

// CPushMtmCacheSupply::CloseRequest

//

//

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

//

void CPushMtmCacheSupply::CloseRequest()

    {

    if( !iClosed )

	    {

	    iCacheManager->RequestClosed( (iCacheSupplyCallbacks->Transaction()), iCacheEntry );

	    iClosed = ETrue;

	    }

    }

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

// CPushMtmCacheSupply::HeadersReceived

//

//

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

//

void CPushMtmCacheSupply::HeadersReceivedL()

    {

    // do not cache content we just sent off

    if( iReponseState == THTTPEvent::EClosed )

        {

        RHTTPTransaction* trans = iCacheSupplyCallbacks->Transaction();

        iCacheManager->ReceivedResponseHeadersL( *(iCacheSupplyCallbacks->Transaction()), iCacheEntry );

        //

        iNotModified = trans->Response().StatusCode() == HTTPStatus::ENotModified;

        if( iNotModified )

            {

            // change from 304 to 200 -otherwise trans exits with EFailed

            trans->Response().SetStatusCode( HTTPStatus::EOk );

            }

        }

    }

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

// CPushMtmCacheSupply::BodyReceivedL

//

//

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

//

void CPushMtmCacheSupply::BodyReceivedL()

    {

    // do not cache content we just sent off

    if( iReponseState == THTTPEvent::EClosed )

        {

        RHTTPTransaction* trans = iCacheSupplyCallbacks->Transaction();

        MHTTPDataSupplier* supplier = trans->Response().Body();

        //

        iCacheManager->ReceivedResponseBodyDataL( *trans, *supplier, iCacheEntry );

        }

    }

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

// CPushMtmCacheSupply::ResponseComplete

//

//

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

//

void CPushMtmCacheSupply::ResponseCompleteL()

    {

    if( iReponseState == THTTPEvent::EClosed )

        {

        RHTTPTransaction* trans = iCacheSupplyCallbacks->Transaction();

        // not modified needs body before response complete

        if( iNotModified )

            {

            // use cache

            // close response first

            iCacheManager->ResponseComplete( *trans, iCacheEntry );

            // request the item from cache

            if( iCacheManager->RequestL( *trans, TBrCtlDefs::ECacheModeOnlyCache, iCacheEntry ) == KErrNone )

                {

                // ser

                iReponseState = THTTPEvent::EGotResponseBodyData;

                //

                SendBodyL();

                CloseRequest();

                }

            }

        else

            {

            // normal response complete

            iCacheManager->ResponseComplete( *trans, iCacheEntry );

            }

        }

    }

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

// CPushMtmCacheSupply::ResponseCallbackL

//

//

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

//

TInt CPushMtmCacheSupply::ResponseCallbackL(

    TAny* aAny )

    {

    //

    CPushMtmCacheSupply* thisObj = (CPushMtmCacheSupply*)aAny;

    thisObj->SupplyResponseL();

    return KErrNone;

    }

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

// CPushMtmCacheSupply::SupplyResponseL

//

//

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

//

void CPushMtmCacheSupply::SupplyResponseL()

    {

    RHTTPTransaction* trans = iCacheSupplyCallbacks->Transaction();

    //

    switch( iReponseState )

        {

        case THTTPEvent::EGotResponseHeaders:

            {

            //

            iFailed = EFalse;

            if( iCacheManager->RequestHeadersL( *trans, iCacheEntry ) == KErrNone )

                {

                //

                trans->Response().SetStatusCode( HTTPStatus::EOk );

                //

                iCacheSupplyCallbacks->HandleEventL( THTTPEvent::EGotResponseHeaders );

                // move to the next state

                iReponseState = THTTPEvent::EGotResponseBodyData;

                }

            else

                {

                // move to the next state

                iFailed = ETrue;

                // move to the next state

                iReponseState = THTTPEvent::EResponseComplete;

                }

            break;

            }

        case THTTPEvent::EGotResponseBodyData:

            {

            //

            SendBodyL();

            // move to the next state

            iReponseState = THTTPEvent::EResponseComplete;

            break;

            }

        case THTTPEvent::EResponseComplete:

            {

            iCacheSupplyCallbacks->HandleEventL( THTTPEvent::EResponseComplete );

            // move to the next state

            iReponseState = !iFailed ? THTTPEvent::ESucceeded : THTTPEvent::EFailed;

            break;

            }

        case THTTPEvent::ESucceeded:

            {

            // move to the next state

            iReponseState = THTTPEvent::EClosed;

            // cancel timer

            iResponseTimer->Cancel();

            //

            iCacheSupplyCallbacks->HandleEventL( THTTPEvent::ESucceeded );

            // this obj is destroyed at this point

            break;

            }

        case THTTPEvent::EFailed:

            {

            // move to the next state

            iReponseState = THTTPEvent::EClosed;

            // cancel timer

            iResponseTimer->Cancel();

            //

            iCacheSupplyCallbacks->HandleEventL( THTTPEvent::EFailed );

            // this obj is destroyed at this point

            break;

            }

        default:

            {

            //

            }

        }

    }

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

// CPushMtmCacheSupply::SendBodyL

//

//

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

//

void CPushMtmCacheSupply::SendBodyL()

    {

    RHTTPTransaction* trans = iCacheSupplyCallbacks->Transaction();

    //

    TBool lastChunk;

    // currently it is always the last chunk

    HBufC8* body = iCacheManager->RequestNextChunkL( *trans, lastChunk, iCacheEntry );

    if( body )

        {

        CleanupStack::PushL( body );

        // create datasupplier and attach it to the transaction

        if( !iDataSupplier )

            iDataSupplier = CPushMtmCacheDataSupplier::NewL( body );

        trans->Response().SetBody( *iDataSupplier );

        CleanupStack::Pop(); // body

        //

        iCacheSupplyCallbacks->HandleEventL( THTTPEvent::EGotResponseBodyData );

        }

    else

        {

        // move to the next state

        iFailed = ETrue;

        }

    }

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

// CPushMtmCacheSupply::PauseSupply

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

void CPushMtmCacheSupply::PauseSupply()

	{

	if( iResponseTimer && iResponseTimer->IsActive() )

		iResponseTimer->Cancel();

	}

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

// CPushMtmCacheSupply::ResumeSupply

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

void CPushMtmCacheSupply::ResumeSupply()

	{

	if( iResponseTimer && !iResponseTimer->IsActive() )

		iResponseTimer->Start( KResponseTimeout, KResponseTimeout, TCallBack( &ResponseCallbackL, this ) );

	}

//  End of File