/*

* Copyright (c) 2006-2007 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:  Thumbnail Auto Generate Daemon 

*

*/

#include <e32svr.h>

#include <centralrepository.h>

#include <mdesession.h>

#include <mdeconstants.h>

#include <mdequery.h>

#include <mdeobject.h>

#include "thumbagdaemon.h"

#include "thumbnaillog.h"

#include "thumbnailmanagerconstants.h"

#include "thumbnailmanagerprivatecrkeys.h"

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

// NewLC

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

//

CThumbAGDaemon* CThumbAGDaemon::NewLC()

    {

    TN_DEBUG1( "CThumbAGDaemon::NewLC() - begin" );

	CThumbAGDaemon* self = new (ELeave) CThumbAGDaemon();

	CleanupStack::PushL( self );

	self->ConstructL();

	return self;

	}

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

// NewL

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

//

CThumbAGDaemon* CThumbAGDaemon::NewL()

	{

	TN_DEBUG1( "CThumbAGDaemon::NewL() - begin" );

	CThumbAGDaemon* self = CThumbAGDaemon::NewLC();

	CleanupStack::Pop( self );

	return self;

	}

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

// CThumbAGDaemon

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

//

CThumbAGDaemon::CThumbAGDaemon()

 	: CServer2( CActive::EPriorityStandard, CServer2::EUnsharableSessions ), iShutdownObserver(NULL), 

 	       iMDSShutdownObserver(NULL), iMdESession(NULL), iProcessor(NULL)

 	{

 	// No implementation required

 	}

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

// ConstructL

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

//

void CThumbAGDaemon::ConstructL()

	{

	TN_DEBUG1( "CThumbAGDaemon::ConstructL() - begin" );

	StartL( KTAGDaemonName );

#ifdef _DEBUG

    iAddCounter = 0;

    iModCounter = 0;

    iDelCounter = 0;

#endif

    InitializeL();

	TN_DEBUG1( "CThumbAGDaemon::ConstructL() - end" );

	}

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

// ~CThumbAGDaemon

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

//

void CThumbAGDaemon::InitializeL()

    {

    TN_DEBUG1( "CThumbAGDaemon::InitializeL() - begin" );

    if (DaemonEnabledL())

        {

        TN_DEBUG1( "CThumbAGDaemon::InitializeL() - create observers" );

        // create shutdown observer

        if(iMDSShutdownObserver)

            {

            delete iMDSShutdownObserver;

            iMDSShutdownObserver = NULL;

            }     

        iMDSShutdownObserver = CTMShutdownObserver::NewL( *this, KMdSPSShutdown, KMdSShutdown, EFalse );

        if(iShutdownObserver)

            {

            delete iShutdownObserver;

            iShutdownObserver = NULL;

            }

        iShutdownObserver = CTMShutdownObserver::NewL( *this, KTAGDPSNotification, KShutdown, ETrue );  

        iShutdown = EFalse;

        // create processor

        if(iProcessor)

            {

            delete iProcessor;

            iProcessor = NULL; 

            }

        iProcessor = CThumbAGProcessor::NewL(); 

        // MDS session reconnect timer

        if (!iReconnect)

            {

            iReconnect = CPeriodic::NewL(CActive::EPriorityIdle);

            }

        TN_DEBUG1( "CThumbAGDaemon::InitializeL() - connect to MDS" );

        if(iMdESession)

            {

            TRAP_IGNORE( iMdESession->RemoveObjectObserverL( *this ) );

            TRAP_IGNORE( iMdESession->RemoveObjectObserverL( *this ) );

            TRAP_IGNORE( iMdESession->RemoveObjectObserverL( *this ) );

            TRAP_IGNORE( iMdESession->RemoveObjectPresentObserverL( * this  ));

            // connect to MDS

            delete iMdESession;

            iMdESession = NULL;

            }

        iMdESession = CMdESession::NewL( *this );

        }

    else

        {

        // no error here, but need to shutdown daemon neatly

        User::Leave(KErrNone);

        }

        TN_DEBUG1( "CThumbAGDaemon::InitializeL() - end" );

    }

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

// ~CThumbAGDaemon

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

//

CThumbAGDaemon::~CThumbAGDaemon()

    {

    TN_DEBUG1( "CThumbAGDaemon::~CThumbAGDaemon() - begin" );

    iShutdown = ETrue;    

    delete iMDSShutdownObserver;

    delete iShutdownObserver;

    if(iReconnect)

        {

        iReconnect->Cancel();

        delete iReconnect;

        iReconnect = NULL;

        }

    if (iProcessor)

        {

        delete iProcessor;

        iProcessor = NULL;

        }

    if (iMdESession)

        {

        // 2 observers

        TRAP_IGNORE( iMdESession->RemoveObjectObserverL( *this ) );

#ifdef MDS_URI_OBSERVER

        // remove observer with uri

        TRAP_IGNORE( iMdESession->RemoveObjectObserverWithUriL( *this ) );

#endif

        //present observer

        TRAP_IGNORE( iMdESession->RemoveObjectPresentObserverL( *this ) );

        delete iMdESession;

        iMdESession = NULL;

        }

    TN_DEBUG1( "CThumbAGDaemon::~CThumbAGDaemon() - end" );

    }

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

// CThumbnailServer::NewSessionL()

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

//

CSession2* CThumbAGDaemon::NewSessionL( const TVersion& /*aVersion*/,

                                        const RMessage2& /*aMessage*/ )const

    {

    // no services, no clients, no sessions

    User::Leave(KErrNotSupported);

    //just for getting rid of compiler warning about missing return value

    return NULL;

    }

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

// CThumbAGDaemon::ThreadFunctionL

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

//

void CThumbAGDaemon::ThreadFunctionL()

    {

	TN_DEBUG1( "CThumbAGDaemon::ThreadFunctionL() - begin" );

    User::LeaveIfError( User::RenameThread( KTAGDaemonName ) );

    CThumbAGDaemon* server = NULL;

    CActiveScheduler* scheduler = new( ELeave )CActiveScheduler();

    if ( scheduler )

        {

        CActiveScheduler::Install( scheduler );

        CleanupStack::PushL( scheduler );

        server = CThumbAGDaemon::NewL(); // Adds server in scheduler

        RProcess::Rendezvous( KErrNone );

        CActiveScheduler::Start();

        // comes here if server gets shut down

        delete server;

        CleanupStack::PopAndDestroy( scheduler );

        }

    TN_DEBUG1( "CThumbAGDaemon::ThreadFunctionL() - end" );

	}

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

// CThumbAGDaemon::HandleSessionOpened

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

//

void CThumbAGDaemon::HandleSessionOpened( CMdESession& /* aSession */, TInt aError )

    {

    TN_DEBUG1( "CThumbAGDaemon::HandleSessionOpened");

    if (aError == KErrNone)

        {

        iProcessor->SetMdESession(iMdESession);

        TRAPD( err, AddObserversL() );

        if (err != KErrNone)

            {

            TN_DEBUG2( "CThumbAGDaemon::HandleSessionOpened, AddObserversL error == %d", err );

            }

        }

    else

        {

        TN_DEBUG2( "CThumbAGDaemon::HandleSessionOpened error == %d", aError );

        }

    }

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

// CThumbAGDaemon::HandleSessionError

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

//

void CThumbAGDaemon::HandleSessionError( CMdESession& /*aSession*/, TInt aError )

    {

    TN_DEBUG2( "CThumbAGDaemon::HandleSessionError == %d", aError );

        {

        // kill processor right away, because it also has MdESession

        if(iProcessor)

            {

            delete iProcessor;

            iProcessor = NULL; 

            }

        if (!iShutdown)

            {

            if (!iReconnect->IsActive())

                {

                iReconnect->Start( KMdEReconnect, KMdEReconnect, 

                                   TCallBack(ReconnectCallBack, this));

                TN_DEBUG1( "CThumbAGDaemon::HandleSessionError() - reconnect timer started" );

                }

            }

        }   

    }

#ifdef MDS_URI_OBSERVER

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

// CThumbAGDaemon::HandleObjectNotification

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

//

void CThumbAGDaemon::HandleUriObjectNotification(CMdESession& /*aSession*/, 

        TObserverNotificationType aType,

        const RArray<TItemId>& aObjectIdArray,

        const RPointerArray<HBufC>& aObjectUriArray)

    {

    TN_DEBUG1( "CThumbAGDaemon::HandleUriObjectNotification() - begin" );

    if(aType == ENotifyRemove)

        {

        TN_DEBUG1( "CThumbAGDaemon::HandleUriObjectNotification() - removed");

        TInt err(0);

        TRAP(err, iProcessor->AddToQueueL(aType, aObjectIdArray, aObjectUriArray, EFalse));

        __ASSERT_DEBUG((err==KErrNone), User::Panic(_L("CThumbAGDaemon::HandleUriObjectNotification()"), err));

        err = KErrNone;

        }

    TN_DEBUG1( "CThumbAGDaemon::HandleUriObjectNotification() - end" );

    }

#endif

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

// CThumbAGDaemon::HandleObjectNotification

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

//

void CThumbAGDaemon::HandleObjectNotification( CMdESession& /*aSession*/, 

                                               TObserverNotificationType aType,

                                               const RArray<TItemId>& aObjectIdArray )

    {

    TN_DEBUG1( "CThumbAGDaemon::HandleObjectNotification() - begin" );

    // no processor or shutting down

    if (!iProcessor || iShutdown)

        {

        return;

        }

#ifdef _DEBUG

    if (aType == ENotifyAdd)

        {

        TN_DEBUG2( "CThumbAGDaemon::HandleObjectNotification() - ENotifyAdd %d", aObjectIdArray.Count() );

        iAddCounter = aObjectIdArray.Count();

        }

    else if (aType == ENotifyModify)

        {

        TN_DEBUG2( "CThumbAGDaemon::HandleObjectNotification() - ENotifyModify %d", aObjectIdArray.Count() );

        iModCounter = aObjectIdArray.Count();

        }

    else if (aType == ENotifyRemove)

        {

        TN_DEBUG2( "CThumbAGDaemon::HandleObjectNotification() - ENotifyRemove %d", aObjectIdArray.Count() );

        iDelCounter = aObjectIdArray.Count();

        }

#endif

    if ( (aType == ENotifyAdd || aType == ENotifyModify || aType == ENotifyRemove) &&

         (aObjectIdArray.Count() > 0) )

        {

        TN_DEBUG1( "CThumbAGDaemon::HandleObjectNotification() - AddToQueueL" );

        // If delete event, remove IDs from Modify and Add queues

        if ( aType == ENotifyRemove )

            {

            iProcessor->RemoveFromQueues( aObjectIdArray, EFalse);

            }

        // Add event to processing queue by type and enable force run        

        RPointerArray<HBufC> dummyArray;

        TRAPD(err, iProcessor->AddToQueueL(aType, aObjectIdArray, dummyArray, EFalse));

        if (err != KErrNone)

            {

            TN_DEBUG1( "CThumbAGDaemon::HandleObjectNotification() - error adding to queue" );

            }

        }

    else

        {

        TN_DEBUG1( "CThumbAGDaemon::HandleObjectNotification() - bad notification" );

        }

#ifdef _DEBUG

    TN_DEBUG4( "CThumbAGDaemon::IN-COUNTERS---------- Add = %d Modify = %d Delete = %d", 

               iAddCounter, iModCounter, iDelCounter );

    iModCounter = 0;

    iDelCounter = 0;

    iAddCounter = 0;

#endif

    TN_DEBUG1( "CThumbAGDaemon::HandleObjectNotification() - end" );

    }

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

// CThumbAGDaemon::HandleObjectPresentNotification

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

//

void CThumbAGDaemon::HandleObjectPresentNotification(CMdESession& /*aSession*/, 

               TBool aPresent, const RArray<TItemId>& aObjectIdArray)

    {

    TN_DEBUG3( "CThumbAGDaemon::HandleObjectPresentNotification() - aPresent == %d count == %d", aPresent, aObjectIdArray.Count() );

    // no processor or shutting down

    if (!iProcessor || iShutdown)

        {

        return;

        }

    TInt err = 0;

    //tread present objects as added

    if(aPresent)

        {

        if ( aObjectIdArray.Count() > 0) 

            {

		    // do not force run of these items

            RPointerArray<HBufC> dummyArray;

            TRAP(err, iProcessor->AddToQueueL(ENotifyAdd, aObjectIdArray, dummyArray, ETrue));

            TN_DEBUG2( "CThumbAGDaemon::HandleObjectPresentNotification() - ENotifyAdd %d", aObjectIdArray.Count() );     

           #ifdef _DEBUG

           iAddCounter = aObjectIdArray.Count();

           if (err != KErrNone)

               {

               TN_DEBUG1( "CThumbAGDaemon::HandleObjectPresentNotification() - error adding to queue" );

               }

           #endif

           }

        }

    else

        {

        TN_DEBUG1( "CThumbAGDaemon::HandleObjectPresentNotification() - handle not present" );

        #ifdef _DEBUG    

        if( iAddCounter < aObjectIdArray.Count() )

            {

            iAddCounter = 0;

            }

        else

            {

            iDelCounter = aObjectIdArray.Count();

            }

        #endif

        if ( aObjectIdArray.Count() > 0) 

            {

            iProcessor->RemoveFromQueues( aObjectIdArray, ETrue );

            }

        }

    #ifdef _DEBUG

    TN_DEBUG4( "CThumbAGDaemon::IN-COUNTERS---------- Add = %d Modify = %d Delete = %d", 

               iAddCounter, iModCounter, iDelCounter );

    iModCounter = 0;

    iDelCounter = 0;

    iAddCounter = 0;

    #endif

    TN_DEBUG1( "CThumbAGDaemon::HandleObjectPresentNotification() - end" );

    }

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

// CThumbAGDaemon::ShutdownNotification

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

//

void CThumbAGDaemon::ShutdownNotification()

    {

    TN_DEBUG1( "CThumbAGDaemon::ShutdownNotification()" );

    if (!iShutdown)

        {

        CActiveScheduler::Stop();

        iShutdown = ETrue;

        }

    }

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

// CThumbAGDaemon::AddObserversL

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

//

void CThumbAGDaemon::AddObserversL()

    {

    TN_DEBUG1( "CThumbAGDaemon::AddObserversL() - begin" );

    CMdENamespaceDef& defaultNamespace = iMdESession->GetDefaultNamespaceDefL();

    CMdEObjectDef& imageDef = defaultNamespace.GetObjectDefL( MdeConstants::Image::KImageObject );

    CMdEObjectDef& videoDef = defaultNamespace.GetObjectDefL( MdeConstants::Video::KVideoObject );

    CMdEObjectDef& audioDef = defaultNamespace.GetObjectDefL( MdeConstants::Audio::KAudioObject );

    // set observing conditions

    CMdELogicCondition* addCondition = CMdELogicCondition::NewLC( ELogicConditionOperatorOr );

    addCondition->AddObjectConditionL( imageDef );

    addCondition->AddObjectConditionL( videoDef );

    addCondition->AddObjectConditionL( audioDef );

    CleanupStack::Pop( addCondition );  

    CMdELogicCondition* modifyCondition = CMdELogicCondition::NewLC( ELogicConditionOperatorOr );

    modifyCondition->AddObjectConditionL( imageDef );

    modifyCondition->AddObjectConditionL( videoDef );

    modifyCondition->AddObjectConditionL( audioDef );

    CleanupStack::Pop( modifyCondition );