/*

* Copyright (c) 2009 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: Wrapper for mpx harvester framework utilities - private implementation.

*

*/

#include <QStringList>

#include <s32strm.h>

#include <s32mem.h>

#include <apgcli.h>

#include <apacmdln.h>

#include <mpxcollectionutility.h>

#include <mpxharvesterutility.h>

#include <mpxcollectionmessage.h>

#include <mpxmessagecontainerdefs.h>

#include <mpxmessagegeneraldefs.h>

#include <mpxcollectionmessagedefs.h>

#include <mpxlog.h>

#include "mpmpxharvesterframeworkwrapper.h"

#include "mpmpxharvesterframeworkwrapper_p.h"

#include "mptrace.h"

/*!

    \class MpMpxHarvesterFrameworkWrapperPrivate

    \brief Wrapper for mpx harvester framework utilities - private implementation.

    This is a private implementation of the mpx harvester framework wrapper utilties interface.

*/

const int NoPreviousBroadCastMsg = -1;

/*!

 \internal

 */

MpMpxHarvesterFrameworkWrapperPrivate::MpMpxHarvesterFrameworkWrapperPrivate( MpMpxHarvesterFrameworkWrapper *wrapper )

    : q_ptr(wrapper),

      iCollectionUtility(0),

      iHarvesterUtility(0),

      iNumItemsAdded(0),

      iScanning( EFalse ),

      iPreviousBroadCastMsg( NoPreviousBroadCastMsg )

{

    TX_LOG

}

/*!

 \internal

 */

MpMpxHarvesterFrameworkWrapperPrivate::~MpMpxHarvesterFrameworkWrapperPrivate()

{

    TX_ENTRY

    if ( iCollectionUtility ) {

        iCollectionUtility->Collection().CancelRequest();

        iCollectionUtility->Close();

    }

    if ( iHarvesterUtility ) {

        iHarvesterUtility->Close();

    }

    TX_EXIT

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::init( MpCommon::MpViewMode viewMode, TUid hostUid )

{

    iViewMode = viewMode;

    mHostUid = hostUid;

    TRAPD( err, DoInitL() );

    if ( err != KErrNone ) {

        TX_LOG_ARGS( "Error: " << err << "; should never get here." );

    }

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::scan()

{

    TRAPD( err, DoScanL() );

    if ( err != KErrNone ) {

        TX_LOG_ARGS( "Error: " << err << "; should never get here." );

    }

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::cancelScan()

{

    TRAPD( err, DoCancelScanL() );

    if ( err != KErrNone ) {

        TX_LOG_ARGS( "Error: " << err << "; should never get here." );

    }

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::checkForSystemEvents()

{

    TRAPD( err, DoCheckForSystemEventsL() );

    if ( err != KErrNone ) {

        TX_LOG_ARGS( "Error: " << err << "; should never get here." );

    }

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::HandleOpenL(

    const CMPXMedia& aEntries,

    TInt aIndex,

    TBool aComplete,

    TInt aError )

{

    Q_UNUSED( aIndex );

    Q_UNUSED( aComplete );

    Q_UNUSED( aError );

    Q_UNUSED( aEntries );

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::HandleOpenL(

    const CMPXCollectionPlaylist& aPlaylist,

    TInt aError )

{

    Q_UNUSED( aPlaylist );

    Q_UNUSED( aError );

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::HandleCollectionMediaL(

    const CMPXMedia& aMedia,

    TInt aError )

{

    Q_UNUSED( aMedia );

    Q_UNUSED( aError );

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::HandleCollectionMessage(

    CMPXMessage* aMsg,

    TInt aErr )

{

    TX_ENTRY_ARGS( "aErr=" << aErr );

    if ( aErr == KErrNone && aMsg ) {

        TRAP_IGNORE( DoHandleCollectionMessageL(*aMsg) );

    }

    TX_EXIT

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::DoInitL()

{

    TX_ENTRY

    if ( iViewMode == MpCommon::FetchView ) {

        iCollectionUtility = MMPXCollectionUtility::NewL( this, mHostUid );

    }

    else {

        iCollectionUtility = MMPXCollectionUtility::NewL( this, KMcModeDefault );

    }

    iHarvesterUtility = CMPXHarvesterFactory::NewL();

    iHarvesterUtility->CheckForSystemEventsL();

    TX_EXIT

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::DoScanL()

{

    TX_ENTRY

    iNumItemsAdded = 0;

    iHarvesterUtility->ScanL();

    TX_EXIT

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::DoCancelScanL()

{

    TX_ENTRY

    // If harvester crashes, restart it.

    TRAPD( err, iHarvesterUtility->CancelScanL() );

    if ( err != KErrNone ) {

        iHarvesterUtility->Close();

        iHarvesterUtility = NULL;

        iHarvesterUtility = CMPXHarvesterFactory::NewL();

        iHarvesterUtility->CheckForSystemEventsL();

    }

    TX_EXIT

}

/*!

 \internal

 */

void MpMpxHarvesterFrameworkWrapperPrivate::DoHandleCollectionMessageL(

    const CMPXMessage& aMsg )

{

    TX_ENTRY

    TMPXMessageId id( aMsg.ValueTObjectL<TMPXMessageId>( KMPXMessageGeneralId ) );

    if ( KMPXMessageGeneral == id ) {

        TInt event( aMsg.ValueTObjectL<TInt>( KMPXMessageGeneralEvent ) );

        TInt type( aMsg.ValueTObjectL<TInt>( KMPXMessageGeneralType ) );

        TInt data( aMsg.ValueTObjectL<TInt>( KMPXMessageGeneralData ) );

        TX_LOG_ARGS( "event=" << event << ", type=" << type << ", data=" << data );

        if ( event == TMPXCollectionMessage::EBroadcastEvent &&

            BroadcastEventFilter( type ) ) {

            switch ( type ) {

                case EMcMsgFormatStart:

                    emit q_ptr->diskEvent(DiskFormatStarted);

                    break;

                case EMcMsgFormatEnd:

                    emit q_ptr->diskEvent(DiskFormatEnded);

                    break;

                case EMcMsgDiskRemoved:

                    emit q_ptr->diskEvent(DiskRemoved);

                    break;

                case EMcMsgDiskInserted:

                    emit q_ptr->diskEvent(DiskInserted);

                    break;

                case EMcMsgUSBMassStorageStart:

                    emit q_ptr->usbEvent(UsbMassStorageStarted);

                    break;

                case EMcMsgUSBMassStorageEnd:

                    emit q_ptr->usbEvent(UsbMassStorageEnded);

                    break;

                case EMcMsgUSBMTPStart:

                    emit q_ptr->usbEvent(UsbMtpStarted);

                    break;

                case EMcMsgUSBMTPEnd:

                    emit q_ptr->usbEvent(UsbMtpEnded);

                    break;

                case EMcMsgUSBMTPNotActive:

                    emit q_ptr->usbEvent(UsbMtpNotActive);

                    break;

                case EMcMsgRefreshStart:

                    iScanning = ETrue;

                    emit q_ptr->scanStarted();

                    break;

                case EMcMsgRefreshEnd:

                    iScanning = EFalse;

                    emit q_ptr->scanEnded( iNumItemsAdded, data );

                    break;

                default:

                    break;

            }

        }

    }

    else if( KMPXMessageIdItemChanged == id && iScanning ) {

        if ( aMsg.IsSupported( KMPXMessageArrayContents ) ) {

            // Loop through messages for arrays

            const CMPXMessageArray* messageArray =

                        aMsg.Value<CMPXMessageArray>( KMPXMessageArrayContents );

            User::LeaveIfNull( const_cast<CMPXMessageArray*>( messageArray ) );

            for ( TInt i=0; i<messageArray->Count(); ++i ) {

                  HandleCollectionMessage( messageArray->AtL( i ), KErrNone );

            }

            emit q_ptr->scanCountChanged( iNumItemsAdded );

        }

        else {

            // Single item

            TMPXChangeEventType changeType( aMsg.ValueTObjectL<TMPXChangeEventType>( KMPXMessageChangeEventType ) );

            TMPXGeneralCategory cat( aMsg.ValueTObjectL<TMPXGeneralCategory>( KMPXMessageMediaGeneralCategory ) );

            if( changeType == EMPXItemInserted &&

                ( cat == EMPXSong || cat == EMPXPlaylist || cat == EMPXPodcast ) ) {

                iNumItemsAdded++;

            }

        }

    }

    TX_EXIT

}

/*!

 \internal

 Returns false if same event has been received more than once

 */

TBool MpMpxHarvesterFrameworkWrapperPrivate::BroadcastEventFilter( TInt aMsg )

{

    TX_ENTRY_ARGS( "New msg=" << aMsg << ", Prev. msg=" << iPreviousBroadCastMsg );

    if ( aMsg != iPreviousBroadCastMsg ) {

        iPreviousBroadCastMsg = aMsg;

        return true;

    }

    return false;    

}

/*!

 \internal

 Request Harvester to check if there are any system events active.

 */

void MpMpxHarvesterFrameworkWrapperPrivate::DoCheckForSystemEventsL()

{

    TX_ENTRY

    iPreviousBroadCastMsg = NoPreviousBroadCastMsg;    

    iHarvesterUtility->CheckForSystemEventsL();

    TX_EXIT

}