/*

* Copyright (c) 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:  Queues commands to MDS.

*

*/

// INCLUDE FILES

#include <e32base.h>

#include <mpxlog.h>

#include "vcxmyvideosmdscmdqueue.h"

#include "vcxmyvideosmdsdb.h"

#include "vcxmyvideosmdsalbums.h"

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

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

// Constructor

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

//

CVcxMyVideosMdsCmdQueue::CVcxMyVideosMdsCmdQueue( CVcxMyVideosMdsDb& aMdsDb )

: iMdsDb( aMdsDb )

    {

    }

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

// 2nd-phase constructor

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

//

void CVcxMyVideosMdsCmdQueue::ConstructL()

    {

    iQueue.Reset();    

    }

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

// Two-Phase Constructor

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

//

CVcxMyVideosMdsCmdQueue* CVcxMyVideosMdsCmdQueue::NewL( CVcxMyVideosMdsDb& aMdsDb )

    {

    CVcxMyVideosMdsCmdQueue* self = new(ELeave) CVcxMyVideosMdsCmdQueue( aMdsDb );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// Destructor

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

//

CVcxMyVideosMdsCmdQueue::~CVcxMyVideosMdsCmdQueue()

    {

    for ( TInt i = 0; i < iQueue.Count(); i++ )

        {

        delete iQueue[i];

        }

    iQueue.Close();

    }

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

// CVcxMyVideosMdsCmdQueue::Cancel

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

//

void CVcxMyVideosMdsCmdQueue::Cancel( CVcxMyVideosMdsDb::TRequestType aType )

    {

    TInt count = iQueue.Count()-1;

    for ( TInt i = count; i >= 0; i-- )

        {

        if ( iQueue[i]->iCmdType == aType || aType == CVcxMyVideosMdsDb::EAll )

            {

            delete iQueue[i];

            iQueue[i] = NULL;

            iQueue.Remove( i );

            }

        }    

    iQueue.Compress();

    }

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

// CVcxMyVideosMdsCmdQueue::ExecuteCmdL

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

//

void CVcxMyVideosMdsCmdQueue::ExecuteCmdL( CVcxMyVideosMdsCmd* aCmd )

    {    

    if ( iQueue.Count() == 0 && !iCmdInProgress )

        {

        DoExecuteCmdL( aCmd ); //ownership does not move

        delete aCmd;

        }

    else

        {

        iQueue.AppendL( aCmd );

        }    

    }

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

// CVcxMyVideosMdsCmdQueue::CmdFinished

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

//

void CVcxMyVideosMdsCmdQueue::CmdFinished()

    {

    iCmdInProgress = EFalse;

    TInt err( KErrGeneral );

    while ( err != KErrNone )

        {

        if ( iQueue.Count() == 0 )

            {

            break;

            }

        TInt cmdIndexToExecute;

        // Let other commads bypass EGetVideoList

        if ( iQueue.Count() > 1 && iQueue[0]->iCmdType == CVcxMyVideosMdsDb::EGetVideoList )

            {

            cmdIndexToExecute = 1;

            }

        else

            {

            cmdIndexToExecute = 0;

            }

        TRAP( err, DoExecuteCmdL( iQueue[cmdIndexToExecute] ) ); //ownership does not move

        delete iQueue[cmdIndexToExecute];

        iQueue[cmdIndexToExecute] = NULL;

        iQueue.Remove( cmdIndexToExecute );

        iQueue.Compress();

#ifdef _DEBUG

        if ( err != KErrNone )

            {

            MPX_DEBUG2("CVcxMyVideosMdsCmdQueue:: MDS cmd failed: %d", err);

            }

#endif

        }

    }

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

// CVcxMyVideosMdsCmdQueue::DoExecuteCmdL

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

//

void CVcxMyVideosMdsCmdQueue::DoExecuteCmdL( CVcxMyVideosMdsCmd* aCmd )

    {    

    switch ( aCmd->iCmdType )

        {

        case CVcxMyVideosMdsDb::EGetVideoList:

            {

            CVcxMyVideosMdsCmdGetVideoList* cmd =

                    static_cast<CVcxMyVideosMdsCmdGetVideoList*>( aCmd );

            iMdsDb.DoCreateVideoListL( cmd->iSortingOrder,

                    cmd->iAscending,

                    cmd->iFullDetails,

                    *cmd->iVideoList );

            iCmdInProgress = ETrue;

            }

            break;

        case CVcxMyVideosMdsDb::EGetAlbums:

            {

            CVcxMyVideosMdsCmdGetAlbums* cmd = static_cast<CVcxMyVideosMdsCmdGetAlbums*>( aCmd );

            iMdsDb.iAlbums->DoGetAlbumsL( cmd->iAlbumList, *cmd->iClient );

            iCmdInProgress = ETrue;

            }

            break;

        case CVcxMyVideosMdsDb::EGetAlbumContentIds:

            {

            CVcxMyVideosMdsCmdGetAlbumContentIds* cmd =

                    static_cast<CVcxMyVideosMdsCmdGetAlbumContentIds*>( aCmd );

            iMdsDb.iAlbums->DoGetAlbumContentIdsL( cmd->iAlbumId, *cmd->iAlbumContent,

                    *cmd->iClient );

            iCmdInProgress = ETrue;

            }

            break;

        case CVcxMyVideosMdsDb::EGetAlbumContentVideos:

            {

            CVcxMyVideosMdsCmdGetAlbumContentVideos* cmd =

                    static_cast<CVcxMyVideosMdsCmdGetAlbumContentVideos*>( aCmd );

            iMdsDb.iAlbums->DoGetAlbumContentVideosL( cmd->iAlbumId, *cmd->iAlbumContentVideos,

                    *cmd->iClient );

            iCmdInProgress = ETrue;

            }

            break;

        case CVcxMyVideosMdsDb::EAddVideosToAlbum:

            {

            CVcxMyVideosMdsCmdAddVideosToAlbum* cmd =

                    static_cast<CVcxMyVideosMdsCmdAddVideosToAlbum*>( aCmd );

            iMdsDb.iAlbums->DoAddVideosToAlbumL( cmd->iMpxCmd,

                    *cmd->iClient );

            iCmdInProgress = ETrue;

            }

            break;

        case CVcxMyVideosMdsDb::ERemoveRelations:

            {

            CVcxMyVideosMdsCmdRemoveRelations* cmd =

                    static_cast<CVcxMyVideosMdsCmdRemoveRelations*>( aCmd );

            iMdsDb.iAlbums->DoRemoveRelationsL( *cmd->iRelationIds, *cmd->iResults,

                    *cmd->iClient );

            iCmdInProgress = ETrue;

            }

            break;

        case CVcxMyVideosMdsDb::ERemoveAlbums:

            {

            CVcxMyVideosMdsCmdRemoveAlbums* cmd =

                    static_cast<CVcxMyVideosMdsCmdRemoveAlbums*>( aCmd );

            iMdsDb.iAlbums->DoRemoveAlbumsL( cmd->iMpxCmd, *cmd->iClient );

            iCmdInProgress = ETrue;

            }

            break;

        default:

            break;

        }    

    }    

// END OF FILE