/*
* Copyright (c) 2002-2007 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:    Offers callback interface to Epg database update*
*/




#include <e32base.h>
#include "IptvDebug.h"
#include "CIptvMediaContent.h"
#include "CIptvEpgVodMsqQueue.h"
#include "CIptvEpgVodCallbackImpl.h"
#include "CIptvEpgCategory.h"
#include "CIptvEpgContent.h"
#include "CIptvEpgDb.h"
#include "CIptvEpgSession.h"


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

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::ConstructL
// Symbian 2nd phase constructor can leave.
// --------------------------------------------------------------------------
//
void CIptvEpgVodCallbackImpl::ConstructL()
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::ConstructL" );
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::NewL
// Two-phased constructor.
// Create instance of concrete interface implementation
// --------------------------------------------------------------------------
//
CIptvEpgVodCallbackImpl* CIptvEpgVodCallbackImpl::NewL(
    CIptvEpgDb& aVodEpgDb,
    CIptvEpgVodMsqQueue* aMsgQueue,
    CIptvEpgSession& aSession )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::NewL" );

    CIptvEpgVodCallbackImpl* self =
        new( ELeave ) CIptvEpgVodCallbackImpl(
            aVodEpgDb, aMsgQueue, aSession );
    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );
    return self;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::~CIptvEpgVodCallbackImpl
// Destructor
// --------------------------------------------------------------------------
//
CIptvEpgVodCallbackImpl::~CIptvEpgVodCallbackImpl()
    {
    IPTVLOGSTRING_LOW_LEVEL(
        "CIptvEpgVodCallbackImpl::~CIptvEpgVodCallbackImpl" );
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::CIptvEpgVodCallbackImpl
// C++ default constructor
// --------------------------------------------------------------------------
//
CIptvEpgVodCallbackImpl::CIptvEpgVodCallbackImpl(
    CIptvEpgDb& aVodEpgDb,
    CIptvEpgVodMsqQueue* aMsgQueue,
    CIptvEpgSession& aSession ) :
    iVodEpgDb( aVodEpgDb ),
    iMsgQueue( aMsgQueue ),
    iPluginRunning( EFalse ),
    iSession( aSession )
    {
    IPTVLOGSTRING_LOW_LEVEL(
        "CIptvEpgVodCallbackImpl::CIptvEpgVodCallbackImpl" );
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::ContentUpdateCompletedL
// --------------------------------------------------------------------------
//
void CIptvEpgVodCallbackImpl::ContentUpdateCompletedL()
    {
    IPTVLOGSTRING_LOW_LEVEL(
        "CIptvEpgVodCallbackImpl::ContentUpdateCompletedL" );

    iVodEpgDb.EndUpdateL( iSession );

    // Service id = 0 because we dont have to bring this information
    // over IPC. Service ID is already on the client side.
    if ( iMsgQueue )
        {
        iMsgQueue->SendMessageToClientL( KIptvContentUpdateCompleted, 0 );
        }
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::Started
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
void CIptvEpgVodCallbackImpl::StartedL()
    {
    IPTVLOGSTRING_LOW_LEVEL(
        "CIptvEpgVodCallbackImpl::StartedL -- EPG Plugin STARTED!" );

    iPluginRunning = ETrue;
    iVodEpgDb.StartUpdateL();
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::FinishedL
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::FinishedL( TTime& aUpdateInterval )
    {
    IPTVLOGSTRING_LOW_LEVEL(
        "CIptvEpgVodCallbackImpl::FinishedL -- EPG Plugin FINISHED!" );

    iVodEpgDb.FinishUpdateL();

    TInt error = KErrNone;
    if ( iPluginRunning )
        {
        TInt64 interval = aUpdateInterval.Int64();
        if ( interval != 0 )
            {
            TTime time;
            time.UniversalTime();
            iVodEpgDb.SetUpdateTimeToServiceManagerL( time );
            error = iVodEpgDb.UpdateServiceInformationL( time, aUpdateInterval );
            if ( error != KErrNone )
                {
                IPTVLOGSTRING_LOW_LEVEL(
                    "CIptvEpgVodCallbackImpl::FinishedL -- Failed to update service information" );
                }
            }
        }

    iPluginRunning = EFalse;
    return error;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::AddCategory
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::AddCategoryL(
    CIptvEpgCategory& aCategory,
    TUint32& aCategoryKey )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::AddCategoryL" );

    TInt error = iVodEpgDb.AddCategoryL( aCategory, aCategoryKey );
    if ( error != KErrNone )
        {
        IPTVLOGSTRING_LOW_LEVEL(
            "CIptvEpgVodCallbackImpl::AddCategoryL failed!" );
        }

    return error;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::AddContentL
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::AddContentL(
    CIptvEpgContent& aContent,
    RPointerArray<CIptvMediaContent> aMediaContents,
    TUint32& aContentKey )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::AddContentL" );

    TInt error = iVodEpgDb.AddContentL(
        aContent, aMediaContents, aContentKey );
    if ( error != KErrNone )
        {
        IPTVLOGSTRING_LOW_LEVEL(
            "CIptvEpgVodCallbackImpl::AddContentL failed!" );
        }

    return error;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::UpdateServiceThumbnailL
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::UpdateServiceThumbnailL(
    TDesC& aIconFilePath,
    const TBool aGrouped )
    {
    IPTVLOGSTRING_LOW_LEVEL(
        "CIptvEpgVodCallbackImpl::UpdateServiceThumbnailL" );
    iSession.UpdateServiceThumbnailL( aIconFilePath, aGrouped );

    return KErrNone;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::AddRelationL
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::AddRelationL(
    TUint32& aCategoryKey, TUint32& aContentKey )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::AddRelationL" );

    TInt error = iVodEpgDb.AddRelationL( aCategoryKey, aContentKey );
    if ( error != KErrNone )
        {
        IPTVLOGSTRING_LOW_LEVEL(
            "CIptvEpgVodCallbackImpl::AddRelationL failed!" );
        }

    return error;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::Error
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
void CIptvEpgVodCallbackImpl::ErrorL( TInt aError, TInt aInfo )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::ErrorL" );

    if ( iMsgQueue )
        {
        iMsgQueue->SendMessageToClientL( aError, aInfo );
        }
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::UpdateCategoryIconL
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::UpdateCategoryIconL(
    TUint32& aCategoryKey,
    TUint32& aIconFileId,
    TDesC& aIconFilePath, TBool aIsUrl )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::UpdateCategoryIconL" );

    TInt error = iVodEpgDb.UpdateCategoryIconL(
        aCategoryKey,
        aIconFileId,
        aIconFilePath,
        aIsUrl );
    if ( error != KErrNone )
        {
        IPTVLOGSTRING_LOW_LEVEL(
            "CIptvEpgVodCallbackImpl::UpdateCategoryIconL failed!" );
        }

    return error;
    }

// --------------------------------------------------------------------------
// CIptvEpgVodCallbackImpl::UpdateContentIconL
// From MIptvEpgPluginManager interface
// --------------------------------------------------------------------------
//
TInt CIptvEpgVodCallbackImpl::UpdateContentIconL(
    TUint32& aContentKey,
    TUint32& aIconFileId,
    TDesC& aIconFilePath,
    TBool aIsUrl )
    {
    IPTVLOGSTRING_LOW_LEVEL( "CIptvEpgVodCallbackImpl::UpdateContentIconL" );

    TInt error = iVodEpgDb.UpdateContentIconL(
        aContentKey, aIconFileId, aIconFilePath, aIsUrl );
    if ( error != KErrNone )
        {
        IPTVLOGSTRING_LOW_LEVEL(
            "CIptvEpgVodCallbackImpl::UpdateContentIconL failed!" );
        }

    return error;
    }