/*
* Copyright (c) 2007-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:    Implementation of the scheduled download plugin*
*/



// INCLUDE FILES
#include <ipvideo/CCseScheduledProgram.h>
#include <ipvideo/CCseSchedulerAPI.h>
#include <ipvideo/MCsePluginObserver.h>
#include "IptvDebug.h"
#include "iptvscheduleddownloadlugin.h"
#include "vcnsscheduleddownloadpluginengine.h"

// CONSTANTS
const TInt KIptvRescheduleInterval( 15 );

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


// -----------------------------------------------------------------------------
// CIptvSchedulerPlugin::NewL
//
// -----------------------------------------------------------------------------
//
CIptvScheduledDownloadPlugin* CIptvScheduledDownloadPlugin::NewL()
	{
	CIptvScheduledDownloadPlugin* self =
            new (ELeave) CIptvScheduledDownloadPlugin();

    return self;		
	}

// -----------------------------------------------------------------------------
// CIptvScheduledDownloadPlugin::CIptvScheduledDownloadPlugin
//
// -----------------------------------------------------------------------------
//
CIptvScheduledDownloadPlugin::CIptvScheduledDownloadPlugin()
	{
	}

// -----------------------------------------------------------------------------
// CIptvScheduledDownloadPlugin::~CIptvScheduledDownloadPlugin
//
// -----------------------------------------------------------------------------
//	
CIptvScheduledDownloadPlugin::~CIptvScheduledDownloadPlugin()
	{
	IPTVLOGSTRING_HIGH_LEVEL(">>> CIptvScheduledDownloadPlugin::~CIptvScheduledDownloadPlugin");

	if ( iIsDead )
	    {
	    *iIsDead = ETrue;
	    }
    delete iEngine;
    iEngine = NULL;

    IPTVLOGSTRING_HIGH_LEVEL("<<< CIptvScheduledDownloadPlugin::~CIptvScheduledDownloadPlugin");
	}

// -----------------------------------------------------------------------------
// CIptvScheduledDownloadPlugin::RunTaskL
//
// -----------------------------------------------------------------------------
//	
void CIptvScheduledDownloadPlugin::RunTaskL( CCseScheduledProgram& aProg,
						 		             MCsePluginObserver* aObserver )
	{
    IPTVLOGSTRING_HIGH_LEVEL(">>> CIptvScheduledDownloadPlugin::RunTaskL");

    TBool isDead( EFalse );
    
    iIsDead = &isDead;
    
	//  Is there already a download going on
	if (iEngine)
	    {
        IPTVLOGSTRING_HIGH_LEVEL("CIptvScheduledDownloadPlugin::RunTaskL rescheduling");

	    //  Yes, reschedule this for later time
	    TRAP_IGNORE( RescheduleL(
	        aObserver,
	        aProg,
	        TTimeIntervalMinutes( KIptvRescheduleInterval ) ) );

        IPTVLOGSTRING_HIGH_LEVEL("CIptvScheduledDownloadPlugin::RunTaskL rescheduled");
	    return ;
	    }

	//  Create always new engine, we are not deleted because we might be reused
	//  Engine has callbacks which should not be left on when not needed
	iEngine = CIptvScheduledDownloadPluginEngine::NewL( *aObserver );

	// Pass it through to engine.
	TInt engineReturnValue = 0;	
	TRAPD( err, iEngine->RunTaskL( aProg, engineReturnValue ) );
			
	// When we come out from RunTaskL it might be that the operation was cancelled
	// by deleting ScheduledDownloadPlugin. In such case we are now running "dead code"
	// which means the class is already destroyed, but the stack is still around. We need
	// to get out from here as soon as possible and avoid changing class internal variables.
	if( isDead )
	    {
	    IPTVLOGSTRING_HIGH_LEVEL("CIptvScheduledDownloadPlugin::RunTaskL - RunTaskL aborted, GTFO from here");
	    return;
	    }

    if (err)
        {
        IPTVLOGSTRING2_HIGH_LEVEL("CIptvScheduledDownloadPlugin::RunTaskL engine finished with error %d ", err);

        aObserver->PluginCompleted( err );
        }

    //  Did the plugin ask for reschedule
    if ( engineReturnValue == CIptvScheduledDownloadPluginEngine::EReschedule)
        {
	    //  Yes, reschedule this for later time
        aObserver->PluginCompleted( KErrNone );
	    RescheduleL(
	        aObserver, aProg, TTimeIntervalMinutes( KIptvRescheduleInterval ) );
        }
    else if ( engineReturnValue == CIptvScheduledDownloadPluginEngine::EDontReschedule )
        {
	    //  Reschedule is no more possible
	    IPTVLOGSTRING_HIGH_LEVEL(
	        "CIptvScheduledDownloadPlugin::RunTaskL Plugin completed without reschedule" );

        aObserver->PluginCompleted( KErrNone );
        }
    else
        {
        if (engineReturnValue < KErrNone)
            {
            aObserver->PluginCompleted( engineReturnValue );
            }
        }

    delete iEngine;
    iEngine = NULL;

    IPTVLOGSTRING_HIGH_LEVEL("<<< CIptvScheduledDownloadPlugin::RunTaskL");
    }

// -----------------------------------------------------------------------------
// CIptvScheduledDownloadPlugin::RescheduleL
//
// -----------------------------------------------------------------------------
//	
void CIptvScheduledDownloadPlugin::RescheduleL(
            MCsePluginObserver* /*aObserver*/,
            CCseScheduledProgram& aProg,
            TTimeIntervalMinutes aDelay )
    {
    IPTVLOGSTRING_HIGH_LEVEL(">>> CIptvScheduledDownloadPlugin::RescheduleL");

    TTime start;
    start.UniversalTime();
    start += aDelay;

    //  Only reschedule if it fits the slot
    if (start < aProg.EndTime())
        {
        CCseSchedulerApi* scheduler = CCseSchedulerApi::NewL();
        CleanupStack::PushL( scheduler );

        CCseScheduledProgram* newSchedule = CCseScheduledProgram::NewL();
        CleanupStack::PushL( newSchedule );

        newSchedule->SetStartTime( start );
        newSchedule->SetEndTime( aProg.EndTime() );
        newSchedule->SetAppUid( aProg.AppUid() );
        newSchedule->SetPluginUid( aProg.PluginUid() );
        newSchedule->SetScheduleType( aProg.ScheduleType() );
        newSchedule->SetApplicationDataL( aProg.ApplicationData() );

        User::LeaveIfError( scheduler->AddSchedule( *newSchedule ) );

        IPTVLOGSTRING_HIGH_LEVEL("CIptvScheduledDownloadPlugin::RescheduleL Rescheduling done");

        CleanupStack::PopAndDestroy( newSchedule );

        CleanupStack::PopAndDestroy( scheduler );
        }

    IPTVLOGSTRING_HIGH_LEVEL("<<< CIptvScheduledDownloadPlugin::RescheduleL");
    }
// End of File