/*
* 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 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: 
*
*/




#include "IptvDebug.h"
#include <mpxmedia.h>
#include <vcxmyvideosdefs.h>
#include <mpxmediageneraldefs.h>

#include "vcxnsdownloadupdater.h"
#include "vcxnscontent.h"

const TInt KUpdateDelay = 3000000; // 3 seconds

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

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CVcxNsDownloadUpdater::CVcxNsDownloadUpdater( MVcxNsDownloadUpdaterObserver* aObserver ):
    iObserver( aObserver )
    {
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CVcxNsDownloadUpdater::ConstructL()
    {
    iTimer = CPeriodic::NewL( EPriorityNormal );
    }

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
CVcxNsDownloadUpdater* CVcxNsDownloadUpdater::NewL( MVcxNsDownloadUpdaterObserver* aObserver )
    {
    CVcxNsDownloadUpdater* self = new( ELeave ) CVcxNsDownloadUpdater( aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CVcxNsDownloadUpdater::~CVcxNsDownloadUpdater()
    {
    if( iTimer )
        {
        iTimer->Cancel();
        }
    
    delete iTimer;
    
    iDownloadArray.Close();
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CVcxNsDownloadUpdater::AddDownload( CVcxNsContent* aContent )
    {
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::AddDownload IN");
    
    if ( !aContent )
        {
        return;
        }
    
    CMPXMedia* media = aContent->GetMpxMedia();
    
    if( !media )
        {
        IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::AddDownload OUT, media == NULL");
        return;
        }

    TInt index( KErrNotFound );
    
    if( !FindDownload( aContent, &index ) )
        {
        TDownloadItem item;
        item.iContent = aContent;
        
        TUint32 status = media->ValueTObjectL<TUint8>( KVcxMediaMyVideosDownloadState );
        TInt8 progress = media->ValueTObjectL<TInt8>( KVcxMediaMyVideosDownloadProgress );

        item.iProgress = progress;
        item.iState = status;
        
        iDownloadArray.Append( item );
        }
    
    if( !iTimer->IsActive() )
        {
        TCallBack callback = TCallBack( Callback, this );
        const TTimeIntervalMicroSeconds32 KUpdateInterval( KUpdateDelay );
        iTimer->Start( KUpdateInterval, KUpdateInterval, callback );
        }
    
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::AddDownload OUT");
    }
// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void CVcxNsDownloadUpdater::RemoveDownload( CVcxNsContent* aContent )
    {
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::RemoveDownload IN");

    if ( !aContent )
        {
        return;
        }
    
    TInt index( KErrNotFound );
    
    if( FindDownload( aContent, &index ) )
        {
        iDownloadArray.Remove( index );
        }
    
    if( iDownloadArray.Count() < 1 )
        {
        iTimer->Cancel();        
        } 

    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::RemoveDownload OUT");
    }

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void CVcxNsDownloadUpdater::RemoveAllDownloads()
    {
    iDownloadArray.Reset();
    
    iTimer->Cancel(); 
    }

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
TInt CVcxNsDownloadUpdater::Callback( TAny *aPtr )
    {
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::Callback IN");
    
    CVcxNsDownloadUpdater* ptr = static_cast<CVcxNsDownloadUpdater*>( aPtr );
    
    TInt err ( KErrNotFound );
    
    if ( ptr )
        {
        TRAP( err, ptr->UpdateDownloadsL() ); 
        }

#ifdef _DEBUG
    if( err )
        {
        IPTVLOGSTRING2_LOW_LEVEL("CVcxNsDownloadUpdater::Callback leaved with %d", err);
        }
#endif // _DEBUG
    
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::Callback OUT");
    
    return 0;
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CVcxNsDownloadUpdater::UpdateDownloadsL()
    {
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::UpdateDownloadsL IN");
    
    for ( TInt i = 0; i < iDownloadArray.Count(); i++ )
        {
        UpdateDownloadL( iDownloadArray[i] );
        }
    
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::UpdateDownloadsL OUT");
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CVcxNsDownloadUpdater::UpdateDownloadL( TDownloadItem& aDownload )
    {
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::UpdateDownloadL IN");
    
    CMPXMedia* media = aDownload.iContent->GetMpxMedia();
    
    if ( !media )
        {
        return;
        }
    
    TUint32 status = media->ValueTObjectL<TUint8>( KVcxMediaMyVideosDownloadState );
    TInt8 progress = media->ValueTObjectL<TInt8>( KVcxMediaMyVideosDownloadProgress );
    TUint32 mpxId  = media->ValueTObjectL<TMPXItemId>( KMPXMediaGeneralId ).iId1;

    if ( progress == 0 && aDownload.iProgress > 0 )
        {
        IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::UpdateDownloadL: Resume started from beginning.");
        iObserver->ResumeStartedFromBeginningL( mpxId );
        }
    if ( progress != aDownload.iProgress || status != aDownload.iState )
        {
        IPTVLOGSTRING2_LOW_LEVEL("CVcxNsDownloadUpdater:: dl state    = %d", status );
        IPTVLOGSTRING2_LOW_LEVEL("CVcxNsDownloadUpdater:: dl progress = %d", progress );
        
        IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::UpdateDownloadL: updating video");
        aDownload.iProgress = progress;
        aDownload.iState = status;        

        iObserver->UpdateVideoObject( mpxId );
        }

    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::UpdateDownloadL OUT");
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
TBool CVcxNsDownloadUpdater::FindDownload( CVcxNsContent* aContent, TInt* aIndex )
    {
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::FindDownload IN");
    
    for ( TInt i = iDownloadArray.Count()-1; i >= 0; i-- )
        {
        if ( iDownloadArray[i].iContent == aContent )
            {
            *aIndex = i;
            
            IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::FindDownload OUT: found");
            
            return ETrue;
            }
        }
    
    IPTVLOGSTRING_LOW_LEVEL("CVcxNsDownloadUpdater::FindDownload OUT: NOT found");
    
    return EFalse;
    }