// Copyright (c) 2007-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:
//

#include <e32test.h>
#include "T_UTILS.H"

CCntTest* CntTest=NULL;
LOCAL_D RTest test(_L("T_CntDelete"));

const TPtrC KDatabaseFileName=_L("C:T_CNTDELETE");

const TPtrC KTestName=_L("Test Name No%d");
const TPtrC KTestAddress=_L("Address %d");

const TInt KTotalNumRecordsFirstUnknown  = 10;
const TInt KTotalNumRecordsSecondUnknown = 1;
const TInt KTotalNumRecordsSingle  = 1;

const TInt KTotalUnknownEvents = 2;
const TInt KTotalDeleteEvents  = KTotalNumRecordsSingle;
const TInt KTotalAddedEvents = KTotalNumRecordsFirstUnknown + KTotalNumRecordsSecondUnknown + KTotalNumRecordsSingle;

static const TInt KTimeout = 3000000; 

TInt gUnknownChangesEvent = 0;
TInt gAddedContactsEvent = 0;
TInt gDeleteContactsEvent = 0;
TInt gInvalidEvents = 0;

class CMyObserver :  public CActive, public MContactDbObserver
		{
	public:
		CMyObserver() : CActive(EPriorityIdle)
			{
			iStart.UniversalTime();
			}
		void Activate();
				
	private: // From CActive.
		void RunL();
		void DoCancel();
		TInt RunError(TInt aError);

	private: // From MContactDbObserver
		void HandleDatabaseEventL(TContactDbObserverEvent aEvent);
		
	private:
		TTime 	iStart;
		TTime 	iEnd;
		};

void CMyObserver::RunL()
	{
	iEnd.UniversalTime();
	// Timeout has been excedeed, stop waiting
	if( iEnd.MicroSecondsFrom( iStart.Int64() ) > KTimeout )
		{		
		CActiveScheduler::Stop();
		}
	else // Waiting for next event
		{
		Activate();
		}
	}

void CMyObserver::DoCancel()
	{
	}

TInt CMyObserver::RunError(TInt aError)
	{
	test.Printf( _L("CMyObserver:: Error in runL: %d"), aError );
	return aError;
	}

void CMyObserver::Activate()
	{
	if(!IsActive())
		{
		TRequestStatus *pS=&iStatus;
		User::RequestComplete(pS,KErrNone);
		SetActive();
		}
	}


void CMyObserver::HandleDatabaseEventL(TContactDbObserverEvent aEvent)
	{  
	switch( aEvent.iType )
		{	
		case EContactDbObserverEventUnknownChanges:
			{
			gUnknownChangesEvent++;
			test.Printf( _L("Unknown Changes Event: id= %d\n"), aEvent.iContactId); 
			Activate();	
			break;
			}		
		case EContactDbObserverEventContactAdded:
			{
			gAddedContactsEvent++;
			test.Printf( _L("Added: id= %d\n"), aEvent.iContactId );
			Activate();			
			break;
			}
		case EContactDbObserverEventContactDeleted:
		    {
		    gDeleteContactsEvent++;
		    test.Printf( _L("Deleted: id= %d\n"), aEvent.iContactId );
		    Activate();	
		    break;
		    }
		default:
			{
			gInvalidEvents++;
			test.Printf( _L("Invalid event: %d, contact id: %d"), aEvent.iType, aEvent.iContactId );
			Activate();
			break;
			}
		}
	}


LOCAL_C void SetNameL(CContactItem& aItem,TUid aType,const TDesC& aName, TBool aAddField)
	{
	CContactItemFieldSet& fieldSet=aItem.CardFields();
	const TInt pos=fieldSet.Find(aType);
	if (!aAddField && pos!=KErrNotFound)
		fieldSet[pos].TextStorage()->SetTextL(aName);
	else
		{
		CContactItemField* field=CContactItemField::NewLC(KStorageTypeText,aType);
   		field->SetMapping(KUidContactFieldVCardMapUnusedN);
		field->TextStorage()->SetTextL(aName);
		aItem.AddFieldL(*field);
		CleanupStack::Pop(); // field
		}
	}


LOCAL_C void PopulateDatabaseL(TBool aPhoneNumbers, TInt aCount)
	{
	for (TInt ii=0;ii<aCount;ii++)
		{
		CContactItem* item=CContactCard::NewLC();
		TBuf<16> name;
		name.Format(KTestName,ii);
   		SetNameL(*item,KUidContactFieldFamilyName,name,ETrue);
		if (aPhoneNumbers)
			{
			TBuf<20> number;
			switch(ii%3)
				{
				case 0:
					number.Format(_L("0171-%03d %04d"),(ii*9)%1000,((ii+11)*23)%10000);
					break;
				case 1:
					number.Format(_L("%04d:%04d:%04d:%04d"),(ii*123)%10000,(ii*666)%10000,(ii*234)%10000);
					break;
				case 2:
					number.Format(_L("+00%d-%03d %04d"),(ii*123)%100,(ii*13)%1000,((ii+13)*17)%10000);
					break;
				}
   			SetNameL(*item,KUidContactFieldPhoneNumber,number,ETrue);
			if (!(ii%2))
				{
				number.Format(_L("0181-%03d %04d"),(ii*8)%1000,((ii+11)*22)%10000);
	   			SetNameL(*item,KUidContactFieldPhoneNumber,number,ETrue);
				number.Format(_L("01734-%06d"),(ii*123456)%1000000);
	   			SetNameL(*item,KUidContactFieldPhoneNumber,number,ETrue);
				}
			}
		if (ii%2)
			{
			TBuf<16> address;
			address.Format(KTestAddress,ii);
			CContactItemField* field=CContactItemField::NewLC(KStorageTypeText,KUidContactFieldAddress);
			field->SetMapping(KUidContactFieldVCardMapADR);
			field->TextStorage()->SetText(address.AllocL());
			field->SetTemplateField(ETrue);
			item->AddFieldL(*field);
			CleanupStack::Pop(); // field
			}
		if (ii%3)
			{
			CContactItemField* field=CContactItemField::NewLC(KStorageTypeDateTime,KUidContactFieldBirthday);
			field->DateTimeStorage()->SetTime(TDateTime(1990+ii,(TMonth)(ii%12),(ii*3)%28,1,2,3,4));
			field->SetTemplateField(ETrue);
			item->AddFieldL(*field);
			CleanupStack::Pop(); // field
			}
		if (ii%4)
			{
			CContactItemField* field=CContactItemField::NewLC(KStorageTypeStore,KUidContactFieldVCardMapAGENT);
    		field->SetMapping(KUidContactFieldVCardMapAGENT);
			field->SetTemplateField(ETrue);
			item->AddFieldL(*field);
			CleanupStack::Pop(); // field
			}
		if (ii%6)
			{
			CContactItemField* field=CContactItemField::NewLC(KStorageTypeContactItemId);
			field->SetMapping(KUidContactFieldVCardMapAGENT);
			field->SetTemplateField(ETrue);
			item->AddFieldL(*field);
			CleanupStack::Pop(); // field
			}
		CntTest->Db()->AddNewContactL(*item);
		CleanupStack::PopAndDestroy(); // item
		}
	CntTest->Db()->SetDateFormatTextL(_L("%E%D%X%N%Y %1 %2 %3"));
	}


LOCAL_C void WaitForNotificationsL(CContactDatabase &aDb)
	{
	CMyObserver *observe = new (ELeave) CMyObserver();
	CleanupStack::PushL( observe );
	CContactChangeNotifier *notifier = CContactChangeNotifier::NewL(aDb, observe);
	CleanupStack::PushL( notifier );
	CActiveScheduler::Add(observe);
	observe->Activate();
	CActiveScheduler::Start();
	CleanupStack::PopAndDestroy(notifier);
	CleanupStack::PopAndDestroy(observe);
	}
		
	
LOCAL_C void DeleteMultipleContactsL()
	{
	CContactIdArray* idArray = CntTest->Db()->ContactsChangedSinceL(TTime(0));
	CleanupStack::PushL(idArray);
	CntTest->Db()->DeleteContactsL(*idArray);		
	CleanupStack::PopAndDestroy(idArray);
	}
	
	
LOCAL_C void DeleteOneContactL()
    {
    CContactIdArray* idArray = CntTest->Db()->ContactsChangedSinceL(TTime(0));
	CleanupStack::PushL(idArray);
	if (idArray->Count() == 1)
	    {	    
	    CntTest->Db()->DeleteContactL((*idArray)[0]);		
	    }
	CleanupStack::PopAndDestroy(idArray);
    }
	

/**
@SYMTestCaseID PIM-T-CNTDELETE-0001
@SYMTestType UT
@SYMTestPriority Medium
@SYMDEF DEF103603
@SYMTestCaseDependencies CntModel CoreAppsTest
@SYMTestCaseDesc Check that deleting multiple contacts in one go will raise a EContactDbObserverEventUnknownChanges 
@SYMTestActions Create many contacts. Delete all and wait for the event. Create one contact
@SYMTestExpectedResults EContactDbObserverEventUnknownChanges should be the only 
event that will be sent to the client when deleting the contacts.
*/
	
void DoTestsL()
    {  
	test.Start(_L("@SYMTESTCaseID:PIM-T-CNTDELETE-0001 Create new database"));

	CntTest->CreateDatabaseL();	

    // Create many contacts, delete all, wait for Unknown Changes Event
	TRAPD(err,PopulateDatabaseL(ETrue, KTotalNumRecordsFirstUnknown));
	test(err==KErrNone);
	WaitForNotificationsL(*CntTest->Db());				
	DeleteMultipleContactsL();
	WaitForNotificationsL(*CntTest->Db());	
		
	// Create one contact, delete it, wait for Unknown Changes Event
	TRAP(err,PopulateDatabaseL(ETrue, KTotalNumRecordsSecondUnknown));
	test(err==KErrNone);
	WaitForNotificationsL(*CntTest->Db());				
	DeleteMultipleContactsL();
	WaitForNotificationsL(*CntTest->Db());		
	
	// Create one contact, delete it, wait for Contact Deleted Event
	TRAP(err,PopulateDatabaseL(ETrue, KTotalNumRecordsSingle));
	test(err==KErrNone);
	WaitForNotificationsL(*CntTest->Db());				
	DeleteOneContactL();
	WaitForNotificationsL(*CntTest->Db());		
	
	CntTest->CloseDatabase();
	test.Next(_L("Delete database"));

	CntTest->DeleteDatabaseL();
	
	test(
	gUnknownChangesEvent == KTotalUnknownEvents && 
	gAddedContactsEvent  == KTotalAddedEvents   &&
	gDeleteContactsEvent == KTotalDeleteEvents  &&
	gInvalidEvents       == 0
	);
	
	test.Printf( _L("Test complete!\n") );
    }
    

GLDEF_C TInt E32Main()
	{
	__UHEAP_MARK;
    CntTest=new(ELeave) CCntTest;
	CntTest->ConstructL(test,KDatabaseFileName);
    TRAPD(err,DoTestsL());
	CntTest->EndTestLib(err);	
	__UHEAP_MARKEND;
	return KErrNone;
    }