/*

* 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;

    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)

            {

            iProcessor->Shutdown();

            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->RemoveObjectObserverWithUriL( *this ) );

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

            // connect to MDS

            delete iMdESession;

            iMdESession = NULL;

            }

        iMdESession = CMdESession::NewL( *this );

        iSessionError = EFalse;

        delete iImageObserver;

        iImageObserver = NULL;

        iImageObserver = CThumbAGImageObserver::NewL(iProcessor);

        delete iCameraObserver;

        iCameraObserver = NULL;

        iCameraObserver = CThumbAGCameraObserver::NewL(iProcessor);

        delete iAudioObserver;

        iAudioObserver = NULL;

        iAudioObserver = CThumbAGAudioObserver::NewL(iProcessor);

        delete iVideoObserver;

        iVideoObserver = NULL;

        iVideoObserver = CThumbAGVideoObserver::NewL(iProcessor);

        }

    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 iImageObserver;

    iImageObserver = NULL;

    delete iCameraObserver;

    iCameraObserver = NULL;

    delete iVideoObserver;

    iVideoObserver = NULL;

    delete iAudioObserver;

    iAudioObserver = NULL;

    delete iMDSShutdownObserver;

    delete iShutdownObserver;

    if(iReconnect)

        {

        iReconnect->Cancel();

        delete iReconnect;

        iReconnect = NULL;

        }

    if (iProcessor)

        {

        iProcessor->Shutdown();

        delete iProcessor;

        iProcessor = NULL;

        }

    if (iMdESession)

        {

#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)

        {

        TRAPD(err, iProcessor->SetMdESessionL(iMdESession));

        TRAP( 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 );

    if (aError != KErrNone && !iShutdown && !iSessionError)

        {

        iSessionError = ETrue;

	    delete iImageObserver;

	    iImageObserver = NULL;

	    delete iCameraObserver;

	    iCameraObserver = NULL;

	    delete iVideoObserver;

	    iVideoObserver = NULL;

	    delete iAudioObserver;

	    iAudioObserver = NULL;

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

        if(iProcessor)

            {

			iProcessor->Shutdown();

            delete iProcessor;

            iProcessor = NULL; 

            }

        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(!iProcessor || iShutdown)

        {

        return;

        }

    if(aType == ENotifyRemove)

        {

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

        TInt err(0);

        TRAP(err, iProcessor->AddToQueueL(aType, EGenerationItemTypeAny, 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 == ENotifyRemove)

        {

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

        iDelCounter = aObjectIdArray.Count();

        }

#endif

    if ( aType == ENotifyRemove && aObjectIdArray.Count() > 0 )

        {

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

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

        iProcessor->RemoveFromQueues( aObjectIdArray, EFalse);

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

        RPointerArray<HBufC> dummyArray;

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

        if (err != KErrNone)

            {

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

            }

        }

    else

        {

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

        }

#ifdef _DEBUG

    TN_DEBUG2( "CThumbAGDaemon::IN-COUNTERS---------- Delete = %d", iDelCounter );

    iDelCounter = 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, EGenerationItemTypeUnknown, aObjectIdArray, dummyArray, ETrue));

            TN_DEBUG2( "CThumbAGDaemon::HandleObjectPresentNotification() - ENotifyAdd unknown items %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_DEBUG3( "CThumbAGDaemon::IN-COUNTERS---------- Add = %d Delete = %d", iAddCounter, iDelCounter );

    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