/*

* Copyright (c) 2010 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: 

 *

*/

#include "ccalendarplugin.h"

#include "harvesterserverlogger.h"

#include <common.h>

#include <csearchdocument.h>

#include <ccpixindexer.h>

#include <calsession.h>

#include <calentry.h>

#include <caliterator.h>

#include <calentryview.h>

#include <mmfcontrollerpluginresolver.h>

#include "OstTraceDefinitions.h"

#ifdef OST_TRACE_COMPILER_IN_USE

#include "ccalendarpluginTraces.h"

#endif

 // CleanupResetAndDestroyPushL

_LIT(KMimeTypeField, CPIX_MIMETYPE_FIELD);

_LIT(KMimeTypeCalendar, CALENDAR_MIMETYPE);

_LIT(KExcerptDelimiter, " ");

/** The delay between harvesting chunks. */

const TInt KHarvestingDelay = 2000;

_LIT(KCalendarTimeFormat,"%04d %02d %02d %02d %02d");

_LIT(KExcerptTimeFormat,"%04d/%02d/%02d %02d:%02d");

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

// CMessagePlugin::NewL

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

//  

CCalendarPlugin* CCalendarPlugin::NewL()

	{

	CCalendarPlugin* instance = CCalendarPlugin::NewLC();

    CleanupStack::Pop(instance);

    return instance;

	}

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

// CCalendarPlugin::NewLC

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

//  

CCalendarPlugin* CCalendarPlugin::NewLC()

	{

	CCalendarPlugin* instance = new (ELeave) CCalendarPlugin();

    CleanupStack::PushL(instance);

    instance->ConstructL();

    return instance;

	}

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

// CCalendarPlugin::CCalendarPlugin

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

//  

CCalendarPlugin::CCalendarPlugin()

	{

	}

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

// CCalendarPlugin::~CCalendarPlugin

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

//  

CCalendarPlugin::~CCalendarPlugin()

	{

    if (iAsynchronizer)

        iAsynchronizer->CancelCallback();

	delete iAsynchronizer;

	delete iIndexer;

	delete iEntryView;

	delete iCalIterator;

	iJobQueue.Reset();

	iJobQueue.Close();

//#ifdef USE_HIGHLIGHTER	

	if(iExcerpt)

	    delete iExcerpt;

	iExcerpt = NULL;

//#endif

	if( iSession )

		{

		iSession->StopChangeNotification();

		}

	delete iSession;

	}

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

// CCalendarPlugin::ConstructL

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

//  

void CCalendarPlugin::ConstructL()

	{

    iIndexState = ETrue;

	iAsynchronizer = CDelayedCallback::NewL( CActive::EPriorityIdle );

	iSession = CCalSession::NewL();	

	TRAPD ( err , iSession->OpenL( iSession->DefaultFileNameL() ) );

	if ( err == KErrNotFound)

	    {

	    iSession->CreateCalFileL( iSession->DefaultFileNameL() );

	    iSession->OpenL( iSession->DefaultFileNameL() );

	    }

	iCalIterator = CCalIter::NewL( *iSession );

	iEntryView = CCalEntryView::NewL( *iSession, *this );

	}

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

// CCalendarPlugin::StartPluginL

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

//  

void CCalendarPlugin::StartPluginL()

	{

	// Define this base application class, use default location

	User::LeaveIfError(iSearchSession.DefineVolume( _L(CALENDAR_QBASEAPPCLASS), KNullDesC ));

	// Open the database

	iIndexer = CCPixIndexer::NewL(iSearchSession);

	iIndexer->OpenDatabaseL( _L(CALENDAR_QBASEAPPCLASS) ); 

	// Start harvester for this plugin

	iObserver->AddHarvestingQueue(this, iIndexer->GetBaseAppClass());

	// Start monitoring calendar events

	TTime startTime( TDateTime( 1980, EJanuary, 0, 0, 0, 0, 0 ) );

	TTime endTime( startTime + TTimeIntervalYears( 40 ) );

	TCalTime startTimeCal;

	TCalTime endTimeCal;

	startTimeCal.SetTimeUtcL( startTime );

	endTimeCal.SetTimeUtcL( endTime );

	CCalChangeNotificationFilter* filter = CCalChangeNotificationFilter::NewL( MCalChangeCallBack2::EChangeEntryAll, ETrue, CalCommon::TCalTimeRange( startTimeCal, endTimeCal ) );

	iSession->StartChangeNotification( *this, *filter );

	}	

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

// CCalendarPlugin::StartHarvestingL

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

//  

void CCalendarPlugin::StartHarvestingL(const TDesC& /*aQualifiedBaseAppClass*/)

    {

    iIndexer->ResetL();

    iStartHarvesting = ETrue;

    iHarvestState = EHarvesterStartHarvest;

#ifdef __PERFORMANCE_DATA

    iStartTime.UniversalTime();

#endif  

    if (iFirstEntry)

        {

        iAsynchronizer->Start( 0, this, KHarvestingDelay );

        }

    }

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

// CCalendarPlugin::Progress

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

//

void CCalendarPlugin::Progress( TInt /*aPercentageCompleted*/ )

	{

	// No implementation needed

	}

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

// CCalendarPlugin::Completed

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

//

void CCalendarPlugin::Completed( TInt aError )

	{

	// No error code and harvesting is needed start harvesting.

	iFirstEntry = ETrue;

	if (aError == KErrNone && iStartHarvesting)

		{

		// Calendar entry view constructed successfully, start harvesting

		iAsynchronizer->Start( 0, this, KHarvestingDelay );

		}

	}

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

// CCalendarPlugin::NotifyProgress

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

//

TBool CCalendarPlugin::NotifyProgress()

	{

	return EFalse;

	}

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

// CContactsPlugin::DelayedCallbackL

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

//

void CCalendarPlugin::DelayedCallbackL( TInt /*aCode*/ )

    {

    if(!iIndexState)

        return;

    // Harvest items on each call

	TPtrC8 uid( KNullDesC8 );

    if( iFirstEntry )

        {

        uid.Set( iCalIterator->FirstL() );

        iFirstEntry = EFalse;

        }

    else

        {

        uid.Set( iCalIterator->NextL() );

        }

    if( uid != KNullDesC8 )

        {

        RPointerArray<CCalEntry> entryArray;

        CleanupResetAndDestroyPushL(entryArray);

        iEntryView->FetchL( uid, entryArray );

        // Handle only the first (i.e. parent entry)

        if( entryArray.Count() > 0 )

            {

            CCalEntry* entry = (CCalEntry*)entryArray[ 0 ];

            OstTrace1( TRACE_NORMAL, CCALENDARPLUGIN_DELAYEDCALLBACKL, "CCalendarPlugin::DelayedCallbackL();Harvesting id=%d", entry->LocalUidL() );

            CPIXLOGSTRING2("CCalendarPlugin::DelayedCallbackL(): Harvesting id=%d.", entry->LocalUidL());

            CreateEntryL( entry->LocalUidL(), ECPixAddAction );

            }

        CleanupStack::PopAndDestroy(&entryArray);

        // Request next entry.

        iAsynchronizer->Start( 0, this, KHarvestingDelay );

        }

    else

        {

        // Harvesting was successfully completed

        iFirstEntry = ETrue; // Make sure we can harvest next time as well...

        Flush(*iIndexer);

#ifdef __PERFORMANCE_DATA

    UpdatePerformaceDataL();

#endif

        iHarvestState = EHarvesterIdleState;

        iObserver->HarvestingCompleted(this, iIndexer->GetBaseAppClass(), KErrNone);		

        }

	}

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

// CCalendarPlugin::DelayedError

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

//  

void CCalendarPlugin::DelayedError(TInt aError)

	{

	// Harvesting was completed

	iFirstEntry = ETrue; // Make sure we can harvest next time as well...

	Flush(*iIndexer);

	iHarvestState = EHarvesterIdleState;

	iObserver->HarvestingCompleted(this, iIndexer->GetBaseAppClass(), aError);

	}

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

// CCalendarPlugin::CalChangeNotification

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

//  

void CCalendarPlugin::CalChangeNotification( RArray< TCalChangeEntry >& aChangeItems )

	{

	const TInt count(aChangeItems.Count());

	OstTrace1( TRACE_NORMAL, CCALENDARPLUGIN_CALCHANGENOTIFICATION, "CCalendarPlugin::CalChangeNotification();changed item count=%d", count );

	CPIXLOGSTRING2("CCalendarPlugin::CalChangeNotification(): changed item count =%d.", count);

	for( TInt i = 0; i < count; ++i )

		{

		TCalChangeEntry changedEntry = aChangeItems[ i ];

		TRAP_IGNORE(HandleChangedEntryL(changedEntry));

		}

	}

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

// CCalendarPlugin::HandleChangedEntryL

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

//  

void CCalendarPlugin::HandleChangedEntryL(const TCalChangeEntry& changedEntry)

	{

	switch( changedEntry.iChangeType )

		{		

		case EChangeAdd:

			{

			OstTrace1( TRACE_NORMAL, CCALENDARPLUGIN_HANDLECHANGEDENTRYL, "CCalendarPlugin::HandleChangedEntryL();Monitored add id=%d", changedEntry.iEntryId );

			CPIXLOGSTRING2("CCalendarPlugin::HandleChangedEntryL(): Monitored add id=%d.", changedEntry.iEntryId);

#ifdef __PERFORMANCE_DATA

            iStartTime.UniversalTime();

			CreateEntryL( changedEntry.iEntryId, ECPixAddAction );

			UpdatePerformaceDataL(ECPixAddAction);

#else

			if( iIndexState )

			    CreateEntryL( changedEntry.iEntryId, ECPixAddAction );

			else

			    OverWriteOrAddToQueueL(changedEntry.iEntryId, ECPixAddAction);

#endif

			break;

			}

		case EChangeDelete:

			{	

			OstTrace1( TRACE_NORMAL, DUP1_CCALENDARPLUGIN_HANDLECHANGEDENTRYL, "CCalendarPlugin::HandleChangedEntryL();Monitored delete id=%d", changedEntry.iEntryId );

			CPIXLOGSTRING2("CCalendarPlugin::HandleChangedEntryL(): Monitored delete id=%d.", changedEntry.iEntryId);

#ifdef __PERFORMANCE_DATA

            iStartTime.UniversalTime();

			CreateEntryL( changedEntry.iEntryId, ECPixAddAction );

			UpdatePerformaceDataL(ECPixAddAction);

#else

			if( iIndexState )

			    CreateEntryL( changedEntry.iEntryId, ECPixRemoveAction );

			else

			    OverWriteOrAddToQueueL(changedEntry.iEntryId, ECPixRemoveAction);

#endif

			break;

			}

		case EChangeModify:

			{

			OstTrace1( TRACE_NORMAL, DUP2_CCALENDARPLUGIN_HANDLECHANGEDENTRYL, "CCalendarPlugin::HandleChangedEntryL();Monitored update id=%d", changedEntry.iEntryId );

			CPIXLOGSTRING2("CCalendarPlugin::HandleChangedEntryL(): Monitored update id=%d.", changedEntry.iEntryId);

#ifdef __PERFORMANCE_DATA

            iStartTime.UniversalTime(); 

			CreateEntryL( changedEntry.iEntryId, ECPixUpdateAction );

			UpdatePerformaceDataL(ECPixUpdateAction);

#else

			if( iIndexState )

			    CreateEntryL( changedEntry.iEntryId, ECPixUpdateAction );

			else

			    OverWriteOrAddToQueueL(changedEntry.iEntryId, ECPixUpdateAction);

#endif

			break;

			}

		/* TCalChangeEntry documentation:

			If iChangeType is EChangeUndefined or EChangeOverflowError, iEntryId and

			iEntryType are undefined and should not be used by clients.

		 */

		case EChangeUndefined:

			{

			OstTrace0( TRACE_NORMAL, DUP3_CCALENDARPLUGIN_HANDLECHANGEDENTRYL, "CCalendarPlugin::HandleChangedEntryL(): EChangeUndefined." );

			CPIXLOGSTRING("CCalendarPlugin::HandleChangedEntryL(): EChangeUndefined.");

			// This event could be related to synchronization.

			// Mark harvesting as cancelled.

			// Remove it from the harvesting queue to cause it to enter 

			// EHarvesterStatusHibernate state.

			// Now add it to the harvesting queue and force a reharvest.

			iFirstEntry = ETrue; // Make sure we can harvest next time as well...

			Flush(*iIndexer);

			iJobQueue.Reset();

			iObserver->HarvestingCompleted(this, iIndexer->GetBaseAppClass(), KErrCancel);

			iObserver->RemoveHarvestingQueue(this, iIndexer->GetBaseAppClass());

			iObserver->AddHarvestingQueue(this, iIndexer->GetBaseAppClass(), ETrue);

			break;

			}

		default:

			// Ignore other events

			break;

		}	

	}

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

// CCalendarPlugin::CreateEntryL

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

//  

void CCalendarPlugin::CreateEntryL( const TCalLocalUid& aLocalUid, TCPixActionType aActionType )

	{

	if (!iIndexer)

    	return;

//#ifdef USE_HIGHLIGHTER	

	//Reset Excerpt

	ResetExcerpt();

//#endif

	OstTrace1( TRACE_NORMAL, CCALENDARPLUGIN_CREATEENTRYL, "CCalendarPlugin::CreateEntryL();Uid=%d", aLocalUid );

	CPIXLOGSTRING2("CCalendarPlugin::CreateEntryL():  Uid = %d.", aLocalUid);	

	// creating CSearchDocument object with unique ID for this application

	TBuf<20> docid_str;

	docid_str.AppendNum(aLocalUid);

	if (aActionType == ECPixAddAction || aActionType == ECPixUpdateAction)

		{

		CSearchDocument* index_item = CSearchDocument::NewLC(docid_str, _L(CALENDARAPPCLASS)); 

		// Return the entry that has been fetched, this will be NULL if there are 

		// no entries with the cal unique id

		CCalEntry* entry = iEntryView->FetchL(aLocalUid);

		if ( entry == NULL ) {

            CleanupStack::PopAndDestroy(index_item);

            return;

		}

		// TODO leave if entry is NULL

		CleanupStack::PushL(entry);

		// TODO Uncomment below portion of code when the latest Organiser code in MCL

		if( CCalEntry::ENote == entry->EntryTypeL() )

		    {

            CleanupStack::PopAndDestroy(entry);

            CleanupStack::PopAndDestroy(index_item);

            OstTrace0( TRACE_NORMAL, DUP1_CCALENDARPLUGIN_CREATEENTRYL, "CCalendarPlugin::CreateEntryL(): Donot harvest Note item." );

            CPIXLOGSTRING("CCalendarPlugin::CreateEntryL(): Donot harvest Note item.");

            return;

		    }

		OstTrace0( TRACE_NORMAL, DUP3_CCALENDARPLUGIN_CREATEENTRYL, "CCalendarPlugin:: Indexing Calender" );

		// Add fields

		index_item->AddFieldL(KCalendarSummaryField, entry->SummaryL());

		index_item->AddFieldL(KCalendarDescriptionField, entry->DescriptionL());

		index_item->AddFieldL(KCalendarLocationField, entry->LocationL());

//#ifdef USE_HIGHLIGHTER

		index_item->AddHLDisplayFieldL(entry->SummaryL());

		AddToFieldExcerptL(entry->DescriptionL());

		AddToFieldExcerptL(entry->LocationL());

//#endif

		TBuf<30> dateString;

		TDateTime datetime = entry->StartTimeL().TimeLocalL().DateTime();

		GetDateTimeDescriptorL(datetime, KCalendarTimeFormat, dateString);

		index_item->AddFieldL(KCalendarStartTimeField, dateString, CDocumentField::EStoreYes | CDocumentField::EIndexUnTokenized);

//#ifdef USE_HIGHLIGHTER

		GetDateTimeDescriptorL(datetime, KExcerptTimeFormat, dateString);

		AddToFieldExcerptL(dateString);

//#endif

		TDateTime endTime = entry->EndTimeL().TimeLocalL().DateTime();

		GetDateTimeDescriptorL(endTime, KCalendarTimeFormat, dateString);

		index_item->AddFieldL(KCalendarEndTimeField, dateString, CDocumentField::EStoreYes | CDocumentField::EIndexUnTokenized);

//#ifdef USE_HIGHLIGHTER

        GetDateTimeDescriptorL(endTime, KExcerptTimeFormat, dateString);

        AddToFieldExcerptL(dateString);

//#endif

		if( CCalEntry::ETodo == entry->EntryTypeL())

		    {

            TUint priority = entry->PriorityL();        

            switch(priority)

                {

                case 1:

                    index_item->AddFieldL(KCalendarPriorityField, KCalendarPriorityHigh);

                    break;

                case 2:

                    index_item->AddFieldL(KCalendarPriorityField, KCalendarPriorityMedium);

                    break;

                case 3:

                    index_item->AddFieldL(KCalendarPriorityField, KCalendarPriorityLow);

                    break;

                default:

                    index_item->AddFieldL(KCalendarPriorityField, KNullDesC);

                    break;

                }

            TTime completedTime = entry->CompletedTimeL().TimeLocalL();

            if( completedTime != Time::NullTTime())

                {

                TDateTime compTime = completedTime.DateTime();

                GetDateTimeDescriptorL(compTime, KCalendarTimeFormat, dateString);                

                index_item->AddFieldL(KCalenderCompletedField, dateString, CDocumentField::EStoreYes | CDocumentField::EIndexUnTokenized);

//#ifdef USE_HIGHLIGHTER

        GetDateTimeDescriptorL(compTime, KExcerptTimeFormat, dateString);

        AddToFieldExcerptL(dateString);

//#endif

                }

		    }

		index_item->AddFieldL(KMimeTypeField, KMimeTypeCalendar, CDocumentField::EStoreYes | CDocumentField::EIndexUnTokenized);

//#ifdef USE_HIGHLIGHTER

		if(iExcerpt)

		index_item->AddExcerptL(*iExcerpt);

/*

#else

    	TInt excerptLength = 1 single 1-character delimiters + entry->DescriptionL().Length() + entry->LocationL().Length();

		HBufC* excerpt = HBufC::NewLC(excerptLength);

		TPtr excerptDes = excerpt->Des();

		excerptDes.Append(entry->DescriptionL());

		excerptDes.Append(KExcerptDelimiter);

		excerptDes.Append(entry->LocationL());

	    index_item->AddExcerptL(*excerpt);

        CleanupStack::PopAndDestroy(excerpt);

#endif

*/

        CleanupStack::PopAndDestroy(entry);