/*

* Copyright (c) 2006 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:  harvester server session

*

*/

#include <e32std.h>

#include <e32svr.h>

#include <bamdesca.h>

#include <mpxlog.h>

#include <mpxuser.h>

#include <mpxcmn.h>

#include <mpxmedia.h>

#include "mpxharvestercommon.h"

#include "mpxharvestersession.h"

#include "mpxharvesterserver.h"

#include "mpxharvesterengine.h"

// ============================ LOCAL FUNCTIONS ==============================

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

// Panic client

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

//

LOCAL_C void PanicClient(const RMessage2 &aMessage,TInt aPanic)

    {

    _LIT(KTxtServer,"Harvester Server Session");

    aMessage.Panic(KTxtServer,aPanic);

    }

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

// Two-phased constructor.

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

//

CMPXHarvesterSession* CMPXHarvesterSession::NewL(

    CMPXHarvesterServer& aServer,

    CMPXHarvesterEngine& aEngine)

    {

    CMPXHarvesterSession* s = new(ELeave)CMPXHarvesterSession(aServer, aEngine);

    CleanupStack::PushL(s);

    s->ConstructL();

    CleanupStack::Pop(s);

    return s;

    }

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

// C++ constructor can NOT contain any code that might leave.

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

//

CMPXHarvesterSession::CMPXHarvesterSession(CMPXHarvesterServer& aServer,

                                           CMPXHarvesterEngine& aEngine)

    : iServer(aServer), iEngine(aEngine)

    {

    iServer.AddClient();

    }

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

// Symbian 2nd phase constructor can leave.

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

//

void CMPXHarvesterSession::ConstructL()

    {

    }

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

// Destructor

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

//

CMPXHarvesterSession::~CMPXHarvesterSession()

    {

    iServer.RemoveClient();

    delete iDes;

    delete iDes8;

    delete iBuffer;

    delete iMedia;

    iMessages.ResetAndDestroy();

    iMessages.Close();

    }

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

// Service request

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

//

void CMPXHarvesterSession::ServiceL(const RMessage2& aMessage)

    {

    // Default ServiceErrorL() will complete the message if ServiceL() leaves

    DispatchMessageL(aMessage);

    }

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

// Handle Import Complete

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

//

void CMPXHarvesterSession::HandleImportCompleteL( CMPXMedia* aMedia,

                                                  TInt aErr,

                                                  RHvsMsg* aMsg )

    {

    TInt r(0);

    if( aErr == KErrNone )

        {

        // Keep media alive

        delete iMedia;

        iMedia = NULL;

        iMedia = CMPXMedia::NewL( *aMedia );

        // Serialize the media property to iBuffer

        ::CreateBufferL<CMPXMedia>( *aMedia, iBuffer );

        r = iBuffer->Size();

        }

    CompleteMessage( aMsg, aErr < 0 ? aErr : r );

    }

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

// Handle Export Complete

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

//

void CMPXHarvesterSession::HandleExportCompleteL( CMPXMedia* aMedia,

                                                  TInt aErr,

                                                  RHvsMsg* aMsg )

    {

    TInt r(0);

    if( aErr == KErrNone )

        {

         // Keep media alive

        delete iMedia;

        iMedia = NULL;

        iMedia = CMPXMedia::NewL( *aMedia );

        // Serialize the media property to iBuffer

        ::CreateBufferL<CMPXMedia>( *aMedia, iBuffer );

        r = iBuffer->Size();

        }

    CompleteMessage( aMsg, aErr < 0 ? aErr : r );

    }

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

// Handles task completion with error

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

//

void CMPXHarvesterSession::CompleteTask( RHvsMsg* aMsg, TInt aErr )

    {

    CompleteMessage( aMsg, aErr );

    }

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

// Message dispatcher

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

//

void CMPXHarvesterSession::DispatchMessageL(const RMessage2& aMessage)

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DispatchMessageL <---"));

    TInt op(aMessage.Function());

    switch(op)

        {

        case EHvsServerGetBuffer:

            {

            ASSERT( iBuffer );

            aMessage.WriteL(0,iBuffer->Ptr(0));

            delete iBuffer;

            iBuffer = NULL;

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerScan:

            {

            DoScanL();

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerCancelScan:

            {

            aMessage.Complete( KErrNone );

            DoCancelScan();

            break;

            }

        case EHvsServerShutdown:

            {

            DoShutdown();

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerAddFile:

            {

            ReadDesL( aMessage, 0 ); // file path

            RHvsMsg* msg = SetAsyncL( aMessage, (TMPXHarvesterServerOp) op );

            DoAddFileL( msg );

            break;

            }

        case EHvsServerAddFileMedia:

            {

            TInt r = DoAddMediaPropL( aMessage );

            aMessage.Complete( r );

            break;

            }

        case EHvsServerGetMedia:

            {

            ReadDesL( aMessage, 0 ); // file path

            RHvsMsg* msg = SetAsyncL( aMessage, (TMPXHarvesterServerOp) op );

            DoGetMediaL( msg );

            break;

            }

        case EHvsServerGetColUid:

            {

            TInt r = DoGetColUidL( aMessage );

            aMessage.Complete( r );

            break;

            }

        case EHvsServerRemoveFile:

            {

            ReadDesL( aMessage, 0 ); // file path

            TPckgBuf<TInt> del;

            aMessage.Read( 1, del);

            TInt r = iEngine.RemoveFileL( *iDes, del() );

            aMessage.Complete( r );

            break;

            }

        case EHvsServerRemoveFiles:

            {

            DoRemoveMultipleFilesL( aMessage );

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerRemoveAllFiles:

            {

            iEngine.RemoveAllFilesL();

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerUpdateFile:

            {

            DoUpdateFileL( aMessage );

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerRenameFile:

            {

            DoRenameFileL( aMessage );

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerExportPlaylist:

            {

            // Async, complete later

            RHvsMsg* msg = SetAsyncL( aMessage, (TMPXHarvesterServerOp) op );

            TRAPD( err,  iEngine.ExportPlaylistL( msg, this ) );

            if( err != KErrNone )

                {

                CompleteMessage( msg, err );

                }

            break;

            }

        case EHvsServerImportPlaylist:

            {

            RHvsMsg* msg = SetAsyncL( aMessage, (TMPXHarvesterServerOp) op );

            TRAPD( err, iEngine.ImportPlaylistL( msg, this ) );

            if( err != KErrNone )

                {

                CompleteMessage( msg, err );

                }

            break;

            }

        case EHvsServerFindColID:

            {

            ReadDesL( aMessage, 0 ); // file path

            TInt r=iEngine.FindCollectionIdL( *iDes );

            aMessage.Complete( r );

            break;

            }

        case EHvsServerReqAttr:

            {

            TPckgBuf<TInt> playlistType;

            aMessage.Read(0, playlistType );

            TArray<TMPXAttribute> requiredAttributes=iEngine.RequiredAttributesL( playlistType() );

            ::CreateBufferL<TMPXAttribute>( requiredAttributes, iBuffer ); //lint !e1024 !e1703 !e1514 !e64

            aMessage.Complete( iBuffer->Size() );

            break;

            }

        case EHvsServerOptAttr:

            {

            TPckgBuf<TInt> playlistType;

            aMessage.Read(0, playlistType );

            TArray<TMPXAttribute> optionalAttributes=iEngine.OptionalAttributesL( playlistType() );

            ::CreateBufferL<TMPXAttribute>( optionalAttributes, iBuffer ); //lint !e1024 !e1703 !e1514 !e64

            aMessage.Complete( iBuffer->Size() );

            break;

            }

        case EHvsServerPlaylistFileExt:

            {

            TPckgBuf<TInt> playlistType;

            aMessage.Read(0, playlistType );

            const TDesC& fileExtension=iEngine.PlaylistFileExtensionL( playlistType() );

            aMessage.WriteL(1,fileExtension);

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerIsPlaylist:

            {

            ReadDesL( aMessage, 0 ); // file path

            TBool r=iEngine.IsPlaylistL( *iDes );

            aMessage.Complete( r );

            break;

            }

        case EHvsServerImportFile:

            {

            RHvsMsg* msg = SetAsyncL( aMessage, (TMPXHarvesterServerOp) op );

            TRAPD( err, iEngine.ImportFileL( msg, this ) );

            if( err != KErrNone )

                {

                CompleteMessage( msg, err );

                }

            break;

            }

        case  EHvsServerReCreateDB:

            {

            iEngine.RecreateDatabases();

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerCheckSystemEvent:

            {

            iEngine.CheckForSystemEvents();

            aMessage.Complete( KErrNone );

            break;

            }

        case EHvsServerCloseTransaction:

            {

            TRAPD( err, iEngine.CloseTransactionL() );

            aMessage.Complete( err );

            break;

            }

        default:

            PanicClient(aMessage, KErrNotFound);

            break;

        }

    MPX_DEBUG1(_L("CMPXHarvesterSession::DispatchMessageL --->"));

    }

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

// Start scanning for new files

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

//

void CMPXHarvesterSession::DoScanL()

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoScanL <---"));

    iEngine.ScanL();

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoScanL --->"));

    }

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

// Cancel a scanning operation

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

//

void CMPXHarvesterSession::DoCancelScan()

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoCancelScanL <---"));

    iEngine.CancelScan();

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoCancelScanL --->"));

    }

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

// Shutdown the server, only used for memory leak testing

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

//

void CMPXHarvesterSession::DoShutdown()

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoShutdown <---"));

    CActiveScheduler::Stop();

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoShutdown --->"));

    }

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

// Handles adding a file

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

//

void CMPXHarvesterSession::DoAddFileL( RHvsMsg* aMsg )

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoAddFileL <---"));

    iEngine.AddFileL( aMsg ,*iDes, this );

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoAddFileL <---"));

    }

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

// Handle adding a media property

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

//

TInt CMPXHarvesterSession::DoAddMediaPropL( const RMessage2& aMessage )

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoAddMediaPropL <---"));

    CMPXMedia* prop( NULL );

    ::NewFromMessageL<CMPXMedia>( aMessage, 0, prop );

    CleanupStack::PushL( prop );

    TInt r = iEngine.AddFileL( prop );

    CleanupStack::PopAndDestroy( prop );

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoAddMediaPropL --->"));

    return r;

    }

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

// Handles media creation for a file

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

//

void CMPXHarvesterSession::DoGetMediaL( RHvsMsg* aMsg )

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoGetMediaL <---"));

    iEngine.GetMediaL( aMsg ,*iDes, this );

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoGetMediaL --->"));

    }

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

// Handle getting collection id

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

//

TInt CMPXHarvesterSession::DoGetColUidL( const RMessage2& aMessage )

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoGetColUidL <---"));

    HBufC* buf = HBufC::NewLC(aMessage.GetDesLengthL(0));

    TPtr ptr = buf->Des();

    aMessage.Read(0,ptr);

    TInt r = iEngine.GetColUidL( *buf );

    CleanupStack::PopAndDestroy( buf );

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoGetColUidL --->"));

    return r;

    }

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

// Remove multiple songs from the harvester db

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

//

void CMPXHarvesterSession::DoRemoveMultipleFilesL( const RMessage2& aMessage )

    {

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoRemoveMultipleSongsL <---"));

    // Buffer with the array

    //

    CDesCArray* array( NULL );

    CBufBase* buffer( NULL );

    MPXUser::RecreateBufferL(aMessage.GetDesLengthL(0), buffer);

    CleanupStack::PushL( buffer );

    TPtr8 ptr = buffer->Ptr(0);

    User::LeaveIfError( aMessage.Read( 0, ptr ) );

    MPXUser::CreateFromBufferL( *buffer, array );

    CleanupStack::PopAndDestroy( buffer );

    if( array )

        {

        CleanupStack::PushL( array );

        // Check if we want to delete the files

        //

        TPckgBuf<TInt> del;

        aMessage.Read( 1, del );

        TPckgBuf<TInt> endTransaction;

        TInt error = aMessage.Read( 2, endTransaction );

        TInt endDbTransaction(1); // If endTranscation is not sent, assume True to commit the db.

        if ( !error )

            {

            endDbTransaction = endTransaction();

            }

        // Engine to do the work

        //

        iEngine.RemoveMultipleFilesL(*array, del(), endDbTransaction );

        CleanupStack::PopAndDestroy( array );

        }

    else

        {

        // Array was NULL;

        User::Leave( KErrArgument );

        }

    MPX_DEBUG1(_L("CMPXHarvesterSession::DoRemoveMultipleSongsL --->"));

    }

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

// Unpacks an RMessage2 and calls update functions in the engine

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

//

void CMPXHarvesterSession::DoUpdateFileL( const RMessage2& aMessage )

    {

     // Path of the object

    HBufC* buf = HBufC::NewLC(aMessage.GetDesLengthL(0));

    TPtr ptr = buf->Des();

    aMessage.Read(0,ptr);

    // New collection ID

    TPckgBuf<TInt> collection;

    aMessage.Read(1, collection );

    iEngine.UpdateFileL( *buf, collection() );

    CleanupStack::PopAndDestroy( buf );

    }

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

// Unpacks an RMessage2 and calls rename function in the engine

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

//

void CMPXHarvesterSession::DoRenameFileL( const RMessage2& aMessage )

    {

    // Path of the object

    HBufC* oldPath = HBufC::NewLC(aMessage.GetDesLengthL(0));

    TPtr oldPathPtr = oldPath->Des();

    aMessage.Read(0,oldPathPtr);

    // Path of the object

    HBufC* newPath = HBufC::NewLC(aMessage.GetDesLengthL(1));