/*

* 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:  Download manager class, handles file download events

*

*/

#include "upnpavcontroller.h"

#include "upnpfiledownloadsession.h"

#include "cmfmtransferobserver.h"

#include "cmfmdownloadmngr.h"

#include "msdebug.h"

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

// CCmFmDownloadMngr::NewL

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

//

CCmFmDownloadMngr* CCmFmDownloadMngr::NewL( MUPnPAVController* aAVController, 

    MCmFmTransferObserver* aObserver, const CUpnpAVDevice& aDevice,

    const TInt aDownloadId )

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::NewL() start"));    

    CCmFmDownloadMngr* self = CCmFmDownloadMngr::NewLC( aAVController, 

        aObserver, aDevice, aDownloadId );

    CleanupStack::Pop( self );

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::NewL() end"));

    return self;

    }

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

// CCmFmDownloadMngr::NewLC

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

//   

CCmFmDownloadMngr* CCmFmDownloadMngr::NewLC( MUPnPAVController* aAVController, 

    MCmFmTransferObserver* aObserver, const CUpnpAVDevice& aDevice,

    const TInt aDownloadId )

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::NewLC() start"));    

    CCmFmDownloadMngr* self = 

        new ( ELeave ) CCmFmDownloadMngr( aAVController, 

            aObserver, aDownloadId );

    CleanupStack::PushL( self );

    self->ConstructL( aDevice );

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::NewLC() end"));

    return self;  

    }    

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

// CCmFmDownloadMngr::~CCmFmDownloadMngr

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

//

CCmFmDownloadMngr::~CCmFmDownloadMngr()

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::~CCmFmDownloadMngr()"));

    CancelOperation();

    }

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

// CCmFmDownloadMngr::CCmFmDownloadMngr

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

//        

CCmFmDownloadMngr::CCmFmDownloadMngr( MUPnPAVController* aAVController, 

    MCmFmTransferObserver* aObserver, const TInt aDownloadId )

    : iAVController( aAVController ), iObserver( aObserver ), 

      iDownloadId( aDownloadId ) 

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::CCmFmDownloadMngr()"));

    }

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

// CCmFmDownloadMngr::ConstructL

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

// 

void CCmFmDownloadMngr::ConstructL( const CUpnpAVDevice& aDevice )

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::ConstructL()"));

    iDownloadSession = &( iAVController->

            StartDownloadSessionL( aDevice ) );

    iDownloadSession->SetObserver( *this );

    }    

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

// CCmFmDownloadMngr::FetchFileL

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

//  

void CCmFmDownloadMngr::FetchFileL( const CUpnpElement& aResElement, 

    const CUpnpItem& aItem, RFile& aFile, const TInt64 aInternalItemId )

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::FetchFileL()"));

    iDownloadSession->StartDownloadL( aResElement, aItem, 

        aFile, aInternalItemId );

    iDownloadSession->StartTrackingProgressL( aInternalItemId );                    

    iFileSize = 0;            

    }

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

// CCmFmDownloadMngr::CancelOperation

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

//     

void CCmFmDownloadMngr::CancelOperation()

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::CancelOperation() start"));

    if( iAVController )

        {

        if( iDownloadSession )

            {

            iAVController->StopDownloadSession( *iDownloadSession );

            }

        }

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::CancelOperation() end"));                

    }                

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

// CCmFmDownloadMngr::TransferStarted

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

//

void CCmFmDownloadMngr::TransferStarted( TInt aKey, TInt aStatus )

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::TransferStarted()"));

    iObserver->TransferStatus( ECmFmFileFetchStarted, iDownloadId, aKey, 

        aStatus, iFileSize );       

    }

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

// CCmFmDownloadMngr::TransferCompleted

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

//

void CCmFmDownloadMngr::TransferCompleted( TInt aKey, TInt aStatus,

        const TDesC& /*aFilePath*/ )

    {

    LOG(_L("[FILL MNGR]\t CCmFmDownloadMngr::TransferCompleted()"));

    iObserver->TransferStatus( ECmFmFileFetched, iDownloadId, aKey, aStatus, 

        iFileSize );           

    }

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

// CCmFmDownloadMngr::TransferProgress

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

//

void CCmFmDownloadMngr::TransferProgress( TInt /*aKey*/, TInt aBytes,

        TInt /*aTotalBytes*/ )              

    {

    TRACE(Print(_L("[FILL MNGR]\t aBytes= %d"), aBytes ));

	// Get the transferred bytes

    iFileSize = ( aBytes / KKilo );

    } 

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

// CCmFmDownloadMngr::MediaServerDisappeared

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

//

void CCmFmDownloadMngr::MediaServerDisappeared( 

    TUPnPDeviceDisconnectedReason /*aReason*/ )

    {

    TRACE(Print(_L("[FILL MNGR]\t MediaServerDisappeared = %d"), iDownloadId ));

    iObserver->TransferStatus( ECmFmFileFetched, iDownloadId, KErrNone, 

        KErrDisconnected, KErrNone );

    }

// End of file