/*

* 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: Definition file for AgendaUtilPrivate class.

*

*/

// System includes

#include <calsession.h>

#include <calinstance.h>

#include <CalenImporter>

#include <calentry.h>

#include <calrrule.h>

#include <e32math.h>

#include <caluser.h>

#include <caldataexchange.h>

#include <caldataformat.h>

#include <f32file.h>

#include <s32file.h>

#include <asshddefs.h>

// User includes

#include "agendautil_p.h"

#include "agendaentry.h"

#include "agendaentry_p.h"

// Constants

//recognition string for ical

_LIT8(KVersionICal,		"VERSION:2.0");

//recognition string for vcal

_LIT8(KVersionVCal,		"VERSION:1.0");

const TInt KReadDataAmount = 256;

const TInt KGuidLength = 30;

static const int startDateArray[2] = { 1900, 1};

static const int endDateArray[2] = { 2100, 1};

AgendaUtilPrivate::AgendaUtilPrivate(AgendaUtil* parent)

:q(parent)

{

	mEntryViewCreated = false;

	mInstanceViewCreated = false;

	mIsDeleting = false;

	prepareSession();

}

bool AgendaUtilPrivate::prepareSession()

{

	if (iCalSession && mEntryViewCreated && mInstanceViewCreated)

		{

		// Everything is ready, nothing to be done

		return true;

		}

	// Create the cal session if not already there.

	if (!iCalSession)

		{

		TRAP(iError, iCalSession = CCalSession::NewL(););

		if (!iCalSession)

			{

			return false;

			}

		const TDesC& file = iCalSession->DefaultFileNameL();

		TRAPD(iError, iCalSession->OpenL(file));

		if (iError == KErrNotFound)

			{

			iCalSession->CreateCalFileL(file);

			iCalSession->OpenL(file);

			}

		else if (iError != KErrNone)

			{

			return false;

			}

		// Subscribe for notification on changes in the opened session (file).

		TCalTime startDate;

		TCalTime endDate;

		TDateTime startTime = TDateTime(

				startDateArray[0], static_cast<TMonth>(startDateArray[1]),

				0, 0, 0, 0, 0);

		TDateTime endTime = TDateTime(

				endDateArray[0], static_cast<TMonth>(endDateArray[1]),

				0, 0, 0, 0, 0);

		startDate.SetTimeLocalL(startTime);

		endDate.SetTimeLocalL(endTime);

		CalCommon::TCalTimeRange searchTimeRange(startDate, startDate);

		CCalChangeNotificationFilter* filter = 0;

		filter = CCalChangeNotificationFilter::NewL(

				EChangeEntryAll, true, searchTimeRange);

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

		// Cleanup.

		delete filter;

		}

	/*

	// If view creation is in progress, then wait till it gets completed

	if((iCalEntryView && !mEntryViewCreated)

			|| (iCalInstanceView && !mInstanceViewCreated))

	{

		if(!iWait)

		{

			TRAP(iError, iWait = new (ELeave) CActiveSchedulerWait;);

			if(!iWait->IsStarted())

			{

				iWait->Start();

			}

		}

	}

	*/

	// First construct the CCalEntryView if not already available.

	// The CCalInstanceView is constructed in ::CompletedL. We block the

	// thread here until everything is setup.

	if (!iCalEntryView)

		{

		TRAP(

				iError,

				iCalEntryView = CCalEntryView::NewL(*iCalSession, *this);

		);

		if (!iWait)

			{

			TRAP(

					iError,

					iWait = new (ELeave) CActiveSchedulerWait;

			)

			if (!iWait->IsStarted())

				{

				iWait->Start();

				}

			}

		}

	// Comes here only when timer is expired, hence one more

	// check is needed here.

	if (iCalSession && mEntryViewCreated && mInstanceViewCreated)

		{

		// Everything is ready.

		return true;

		}

	else

		{

		return false;

		}

}

AgendaUtilPrivate::~AgendaUtilPrivate()

{

	delete iCalEntryView;

	delete iCalInstanceView;

	if (iWait && iWait->IsStarted())

	{

		iWait->AsyncStop();

	}

	delete iWait;

	if (iCalSession)

	{

		iCalSession->StopChangeNotification();

	}

	delete iCalSession;

}

void AgendaUtilPrivate::Completed(TInt aError)

{

	iError = aError;

	if (mIsDeleting) {

		// If deletion was in progress, then it is completed now

		// emit the signal to the clients.

		mIsDeleting = false;

		emit q->entriesDeleted(iError);

	}

	if(KErrNone != iError)

	{

		// Something has gone wrong, return

		delete iCalEntryView;

		iCalEntryView = NULL;

		delete iCalInstanceView;

		iCalInstanceView = NULL;

		return;

	}

	if(iCalEntryView && !mEntryViewCreated)

	{

		mEntryViewCreated = true;

		// Start creating the instance view.

		if(!iCalInstanceView)

		{

			TRAP(iError, iCalInstanceView = CCalInstanceView::NewL(

					*iCalSession, *this);)

		}

	}

	else if(iCalInstanceView && !mInstanceViewCreated)

	{

		mInstanceViewCreated = true;

	}

	// Stop the wait timer

	if( iWait && iWait->IsStarted())

	{

		if(mEntryViewCreated &&  mInstanceViewCreated)

		{

			iWait->AsyncStop();

		}

	}

}

void AgendaUtilPrivate::CalChangeNotification(

		RArray<TCalChangeEntry>& aChangeItems)

{

	QList<ulong> ids;

	for (int i = 0; i < aChangeItems.Count(); i++) {

		ids.append(aChangeItems[i].iEntryId);

	}

	emit q->entriesChanged(ids);

}

/*!

	Adds a new entry with the calendar database.

	\param entry Reference to a new AgendaEntry to be added.

	\return ulong The local uid of the entry added in the db.

 */

ulong AgendaUtilPrivate::addEntry(const AgendaEntry& entry)

{

	// Will be filled with the lUID of the new entry created.

	TCalLocalUid localUid = 0;

	int success = 0;

	// First check if the session to the calendar database is prepared or not.

	if (!prepareSession()) {

		// Something went wrong

		return localUid;

	}

	if (AgendaEntry::TypeNote == entry.type()) {

		TRAP(

				iError,

				RPointerArray<CCalEntry> entryArray;

				CleanupClosePushL(entryArray);

				// Get the global uid.

				TTime homeTime;

				homeTime.HomeTime();

				TInt64 seed = homeTime.Int64();

				TInt randumNumber = Math::Rand(seed);

				HBufC8* globalUid = HBufC8::NewLC(KGuidLength);

				globalUid->Des().Num(randumNumber);

				// Construct a CCalEntry object and start filling the details.

				CCalEntry* newEntry = 0;

				newEntry = CCalEntry::NewL(

						static_cast<CCalEntry::TType>(entry.type()),

						globalUid,

						static_cast<CCalEntry::TMethod>(entry.method()),

						0);

				CleanupStack::Pop(globalUid);

				CleanupStack::PushL(newEntry);

				// Add description.

				TPtrC description(reinterpret_cast<const TUint16*>(

						entry.description().utf16()));

				newEntry->SetDescriptionL(description);

				// Set the favourite property.

				newEntry->SetFavouriteL(entry.favourite());

				// Set the last modification time.

				TCalTime calTime;

				QDateTime dateTime = entry.lastModifiedDateTime();

				TDateTime tempDateTime(

						dateTime.date().year(),

						static_cast<TMonth>(dateTime.date().month() - 1),

						dateTime.date().day() - 1, dateTime.time().hour(),

						dateTime.time().minute(), 0, 0);

				TTime tempTime(tempDateTime);

				calTime.SetTimeLocalL(tempTime);

				newEntry->SetLastModifiedDateL(calTime);

				// Finally set the entry to the database using the entry view.

				entryArray.AppendL(newEntry);

				iCalEntryView->StoreL(entryArray, success);

				localUid = newEntry->LocalUidL();

				// Cleanup.

				CleanupStack::PopAndDestroy(newEntry);

				CleanupStack::PopAndDestroy(&entryArray);

		)

	} else {

		TRAP(

				iError,

				RPointerArray<CCalEntry> entryArray;

				CleanupClosePushL(entryArray);

				// Get the global uid.

				TTime homeTime;

				homeTime.HomeTime();

				TInt64 seed = homeTime.Int64();

				TInt randumNumber = Math::Rand(seed);

				HBufC8* globalUid = HBufC8::NewLC(KGuidLength);

				globalUid->Des().Num(randumNumber);

				// Construct a CCalEntry object and start filling the details.

				CCalEntry* newEntry = 0;

				newEntry = CCalEntry::NewL(

						static_cast<CCalEntry::TType>(entry.type()),

						globalUid,

						static_cast<CCalEntry::TMethod>(entry.method()),

						0);

				CleanupStack::Pop(globalUid);

				CleanupStack::PushL(newEntry);

				// Add the summary.

				if (!entry.summary().isNull()) {

					TPtrC summary(reinterpret_cast<const TUint16*>(

							entry.summary().utf16()));

					newEntry->SetSummaryL(summary);

				}

				// Set the entry Start/End Date and time.

				QDate date = entry.startTime().date();

				QTime time = entry.startTime().time();

				TDateTime startDateTime(

						date.year(), static_cast<TMonth>(date.month() - 1),

						date.day() - 1, time.hour(), time.minute(), 0, 0);

				TTime entryStartTime(startDateTime);

				TCalTime calStartTime;

				calStartTime.SetTimeLocalL(entryStartTime);

				date = entry.endTime().date();

				time = entry.endTime().time();

				TDateTime endDateTime(

						date.year(), static_cast<TMonth>(date.month() - 1),

						date.day() - 1, time.hour(), time.minute(), 0, 0);

				TTime entryEndTime(endDateTime);

				TCalTime calEndTime;

				calEndTime.SetTimeLocalL(entryEndTime);

				newEntry->SetStartAndEndTimeL(calStartTime, calEndTime);

				// Add attendees to the entry.

				addAttendeesToEntry(entry.d->m_attendees, *newEntry);

				// Add categories to the entry.

				addCategoriesToEntry(entry.d->m_categories, *newEntry);

				// Add description to the entry.

				TPtrC description(reinterpret_cast<const TUint16*>(

						entry.description().utf16()));

				newEntry->SetDescriptionL(description);

				// Set the favourite property.

				newEntry->SetFavouriteL(entry.favourite());

				// Add Alarm to the entry.

				AgendaAlarm alarm = entry.alarm();

				if (!alarm.isNull()) {

					setAlarmToEntry(alarm, *newEntry);

				}

				// Set the priority.

				int priority = entry.priority();

				if (entry.priority() != -1) {

					newEntry->SetPriorityL(priority);

				}

				// Set the location.

				if (!entry.location().isNull()) {

					TPtrC location(reinterpret_cast<const TUint16*>(

							entry.location().utf16()));

					newEntry->SetLocationL(location);

				}

				// Set the repeat type if applicable.

				if (AgendaRepeatRule::InvalidRule

						!= entry.repeatRule().type()) {

					newEntry->SetRRuleL(repeatRule);

				}

				// Save the status of the entry.

				newEntry->SetStatusL((CCalEntry::TStatus) entry.status());

				newEntry->SetLastModifiedDateL();

				// Finally set the entry to the database using the entry view.

				entryArray.AppendL(newEntry);

				iCalEntryView->StoreL(entryArray, success);

				localUid = newEntry->LocalUidL();

				// Cleanup.

				CleanupStack::PopAndDestroy(newEntry);

				CleanupStack::PopAndDestroy(&entryArray);

		)

	}

	// Emit signal upon successful creation of entry.

	if (0 < localUid && 1 == success) {

		emit q->entryAdded(localUid);

	}

	return localUid;

}

/*!

	Clones the `entry' passed in the argument and saves it as type `type'.

	\param entry Entry which should be used for cloning.

	\param type The new type of the entry.

	\return ulong The local UID of the new entry.

	\sa deleteEntry()

 */

ulong AgendaUtilPrivate::cloneEntry(

		const AgendaEntry &entry, AgendaEntry::Type type)

{

	// First prepare the session with agenda server.

	if (!prepareSession()) {

		// Something went wrong.

		return 0;

	}

	if (entry.isNull()

			|| type == AgendaEntry::TypeUnknown) {

		return 0;

	}

	// Will be filled with the lUID of the new entry created.

	TCalLocalUid localUid = 0;

	int success = 0;

	CCalEntry *originalEntry = 0;

	HBufC8* globalUid = 0;

	// Get the stored entry first.

	TRAP(

			iError,

			originalEntry = iCalEntryView->FetchL(entry.id());

	)

	if (!originalEntry) {

		return 0;

	}

	// Now save the GUID of the saved entry.

	TRAP(

			iError,

			globalUid = HBufC8::NewL(KGuidLength);

			*globalUid = originalEntry->UidL();

	)

	delete originalEntry;

	// Now start cloning and create a new entry.

	if (AgendaEntry::TypeNote == type) {

		TRAP(

				iError,

				RPointerArray<CCalEntry> entryArray;

				CleanupClosePushL(entryArray);

				// Construct a CCalEntry object and start filling the details.

				CCalEntry* newEntry = 0;

				newEntry = CCalEntry::NewL(

						static_cast<CCalEntry::TType>(type),

						globalUid,

						static_cast<CCalEntry::TMethod>(entry.method()),

						0);

				CleanupStack::PushL(newEntry);

				// Add description.

				TPtrC description(reinterpret_cast<const TUint16*>(