/*

* Copyright (c) 2004 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: 

*     This file contains the declaration of the  receive handler of Download Mgr Server.

*

*/

// INCLUDE FILES

#include "DownloadMgrLogger.h"

#include "DownloadMgrHandler.h"

#include <downloadmgrclient.h>

#include "DownloadMgrDefAttrib.h"

// CONSTANTS

// GLOBAL FUNCTIONS

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

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

// CDownloadMgrHandler::CDownloadMgrHandler

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

//

CDownloadMgrHandler::CDownloadMgrHandler( MHttpDownloadMgrObserver* aHandler,

                                          RHttpDownload* aSubSession )

:CActive( EPriorityStandard + 2 ) /* EPriorityStandard + 2 is used until EHttpProgResponseBodyReceived

                                    event is received, then it must be set to EPriorityLow 

                                    until an other event arrives. Then it is set back to 

                                    EPriorityStandard + 2. */

,iPtr(0,0)                             

    {

    CLOG_CREATE;

    CLOG_ENTERFN( "CDownloadMgrHandler::CDownloadMgrHandler" )

    iHandler = aHandler;

    iDownloadSubSession = aSubSession;

    iDownloadSession = NULL;

    CActiveScheduler::Add( this );

    iClosed = NULL;

    iHandlerType = EHttpDownload;

    iPrevDlEvent.iDownloadState = THttpDownloadState(0); // None

    iPrevDlEvent.iProgressState = EHttpProgNone;

    //iPrevDlEvent.iMoIndex = 0;

    }

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

// CDownloadMgrHandler::CDownloadMgrHandler

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

//

CDownloadMgrHandler::CDownloadMgrHandler( RHttpDownloadMgr* aSession )

:CActive( EPriorityStandard ) /* Session-level event handler: priority remains 

                                 EPriorityStandard! */

,iPtr(0,0)                                 

    {

    CLOG_CREATE;

    CLOG_ENTERFN( "CDownloadMgrHandler::CDownloadMgrHandler" )

    iHandler = NULL;

    iDownloadSubSession = NULL;

    iDownloadSession = aSession;

    CActiveScheduler::Add( this );

    iClosed = NULL;

    iHandlerType = EHttpDownloadMgr;

    iPrevDlEvent.iDownloadState = THttpDownloadState(0); // None

    iPrevDlEvent.iProgressState = EHttpProgNone;

    //iPrevDlEvent.iMoIndex = 0;

    }

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

// CDownloadMgrHandler::CDownloadMgrHandler

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

//

CDownloadMgrHandler::~CDownloadMgrHandler()

    {

    CLOG_WRITE( "CDownloadMgrHandler::~CDownloadMgrHandler" )

    Cancel();

    CLOG_WRITE_FORMAT( "this: 0x%x", this );

    CLOG_WRITE_FORMAT( "~iClosed: 0x%x", iClosed );

    if( iClosed )

        {

        CLOG_WRITE( "*iClosed = ETrue;" );

        *iClosed = ETrue;

        }

    if( iPackedEventAttribs )

        {

        delete iPackedEventAttribs;

        }

    CLOG_CLOSE;

    }

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

// CDownloadMgrHandler::AdjustPriority

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

//

void CDownloadMgrHandler::AdjustPriority( THttpDownloadEvent& aCurrentDlEvent )

    {

    if( !iDownloadSubSession->EventPriorityFlag() )

    //The flag is zero if there is no cod AND client side download

        {

        if ( aCurrentDlEvent.iProgressState == EHttpProgCodDescriptorDownloaded )

            {

            // Cod download to be started in client side

            // Set priority to the original (EPriorityStandard + 2) value.

            CLOG_WRITE( "Setting EPriorityStandard + 2" );            

            }        

        else if( aCurrentDlEvent.iProgressState == EHttpProgResponseBodyReceived && 

            iPrevDlEvent.iProgressState != EHttpProgResponseBodyReceived )

            { // Progress changes to EHttpProgResponseBodyReceived

            // Set priority to a low value.

            CLOG_WRITE( "Setting EPriorityStandard + 1" );

            SetPriority( EPriorityStandard + 1 );

            }

        else if ( aCurrentDlEvent.iProgressState != EHttpProgResponseBodyReceived && 

                  iPrevDlEvent.iProgressState == EHttpProgResponseBodyReceived )

            { // Progress changes from EHttpProgResponseBodyReceived

            // Set priority to the original (EPriorityStandard + 2) value.

            CLOG_WRITE( "Setting EPriorityStandard + 2" );

            SetPriority( EPriorityStandard + 2 );

            }

        // Otherwise no changes in priority!

        iPrevDlEvent = aCurrentDlEvent; // Remember for the event

        }

    }

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

// CDownloadMgrHandler::RunL

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

//

void CDownloadMgrHandler::RunL()

    {

    CLOG_WRITE_FORMAT( " CDownloadMgrHandler::RunL DH-iStat: %d", iStatus.Int() );

    if ( iStatus.Int() == KErrNone )

        {

        THttpDownloadEvent event;

        event.iDownloadState = (THttpDownloadState)iDownloadState();

        event.iProgressState = (THttpProgressState)iProgressState();

        CLOG_WRITE_FORMAT( "DS: %d", event.iDownloadState );

        CLOG_WRITE_FORMAT( "PS: %d", event.iProgressState );

        CLOG_WRITE_FORMAT( "Handler Type: %d", iHandlerType );

        CLOG_WRITE_FORMAT( "this: 0x%x", this );

        switch( iHandlerType )

            {

            case EHttpDownload:

                {

                TBool closed( EFalse );

                iClosed = &closed;

                CLOG_WRITE_FORMAT( "iClosed before: %d", *iClosed );

                // *** Do active object priority adjustments here ***

                AdjustPriority( event );

                TPtr8 ptr = iPackedEventAttribs->Des();

                iDownloadSubSession->UnpackEventAttribL( ptr );

                // Media object index

                //event.iMoIndex = iDownloadSubSession->ActiveMoIndex();

                if( EHttpDlDeleting == event.iDownloadState )

                    {

                    iDownloadSubSession->Delete();

					iClosed = NULL;

                    }

                else

                    {

                    iHandler->HandleDMgrEventL( *iDownloadSubSession, event );

                    }

                // Check if the download subsession has been closed by the client

                CLOG_WRITE_FORMAT( "closed: %d", closed );

                iClosed = NULL;

                if( !closed )

                    {

                    StartL();

                    }

                break;

                }

            case EHttpDownloadMgr:

                {

                // Unmask iHandle into 'handle' and 'media index'

                TInt handle = (iHandle() & 0x0000FFFF);

                //event.iMoIndex = (iHandle() >> 16);

                TBool closed( EFalse );

                iClosed = &closed;

                iDownloadSession->HandleSessionEventL( handle, event );

                CLOG_WRITE_FORMAT( "closed: %d", closed );

                iClosed = NULL;

                if( !closed )

                    {

                    StartL();

                    }

                break;

                }

            default:

                {

                break;

                }

            }

        }

    else

        {

        //Should be got here!

        }

    }

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

// CDownloadMgrHandler::DoCancel

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

//

void CDownloadMgrHandler::DoCancel()

    {

    CLOG_ENTERFN( "CDownloadMgrHandler::DoCancel" )

    switch( iHandlerType )

        {

        case EHttpDownload:

            {

            iDownloadSubSession->CancelEventNotification();

            break;

            }

        case EHttpDownloadMgr:

            {

            iDownloadSession->CancelSessionEventNotification();

            break;

            }

        default:

            {

            break;

            }

        }

    }

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

// CDownloadMgrHandler::StartL

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

//

void CDownloadMgrHandler::StartL()

    {

    CLOG_ENTERFN( "CDownloadMgrHandler::StartL" )

    if( !IsActive() )

        {

        iStatus = KRequestPending;

        switch( iHandlerType )

            {

            case EHttpDownload:

                {

                //Use packer to alloc buffer

                HBufC8* temp_packer = TDMgrUtils::PackEventAttribL();

                if( iPackedEventAttribs )

                    {

                    delete iPackedEventAttribs;

                    }                

                iPackedEventAttribs = temp_packer;

                CLOG_WRITE( "EHttpDownload" );

                TInt length = iPackedEventAttribs->Des().Length();

                iPtr.Set( iPackedEventAttribs->Des() );

                iDownloadSubSession->StartEventNotification( iDownloadState,

                                                             iProgressState,

                                                             iPtr,

                                                             iStatus );

                break;

                }

            case EHttpDownloadMgr:

                {

                CLOG_WRITE( "EHttpDownloadMgr" );

                iDownloadSession->StartSessionEventNotification( iDownloadState,

                                                                 iProgressState,

                                                                 iHandle,

                                                                 iStatus );

                break;

                }

            default:

                {

                break;

                }

            }

        SetActive();

        }

    }