// Copyright (c) 1997-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 <cntdb.h>

#include <cntitem.h>

#include <cntfield.h>

#include <cntfilt.h>

#include <cntfldst.h>

RTest test(_L("t_contactdbevent"));

_LIT(KEventDbFileName,"c:t_contactdbevent.cdb");

const TInt KTimeMicroSec = 1000000;

class CPbObserver : public CTimer, public MContactDbObserver 

	{

public:

	static CPbObserver* NewL(TUint aConnectionId);

	void ConstructL();

	~CPbObserver(){}

public:

	//From MContactDbObserver

	void HandleDatabaseEventL(TContactDbObserverEvent aEvent);

protected:

	CPbObserver(TUint aConnectionId);

	void RunL();

protected:

	TUint iPbConnectionId;	

	};

class CPbTester : public CBase 

	{

public:

	static CPbTester* NewL();

	~CPbTester();

	void StartTestL();

protected:

	void ConstructL();

	TContactItemId AddEntryL();

	void EditEntryL(TContactItemId itemId);

protected:

	CPbObserver* ipbObSvr;

	CContactDatabase* ipbDb;

	CContactChangeNotifier* ipbNotifier;	

	};

CPbObserver* CPbObserver::NewL(TUint aConnectionId)

	{

	CPbObserver* self = new (ELeave) CPbObserver(aConnectionId);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

void CPbObserver::ConstructL()

	{

	CTimer::ConstructL();

	}

void CPbObserver::HandleDatabaseEventL(TContactDbObserverEvent aEvent)

	{

	if (aEvent.iType == EContactDbObserverEventContactChanged)

		{

		test.Printf(_L("Received a Contact changed event"));

		}

	if (aEvent.iType == EContactDbObserverEventContactDeleted)

		{

		test.Printf(_L("Received a Contact delete event"));

		}

	if (aEvent.iType == EContactDbObserverEventContactAdded) 

		{

		test.Printf(_L("Received a Contact added event"));

		}

	test (aEvent.iConnectionId == iPbConnectionId);

	}

CPbObserver::CPbObserver(TUint aConnectionId): CTimer(EPriorityStandard), 

                                               iPbConnectionId(aConnectionId)

	{

	CActiveScheduler::Add(this);

	}

void CPbObserver::RunL()

	{

	CActiveScheduler::Stop();

	}

CPbTester* CPbTester::NewL(void)

	{

	CPbTester *self = new(ELeave)CPbTester;

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

void CPbTester::ConstructL(void)

	{

	ipbDb=CContactDatabase::ReplaceL(KEventDbFileName);

	ipbObSvr = CPbObserver::NewL(ipbDb->ConnectionId());

	ipbNotifier = CContactChangeNotifier::NewL(*ipbDb, ipbObSvr);

	}

CPbTester::~CPbTester(void)

	{

	TRAP_IGNORE(ipbDb->DeleteDatabaseL(KEventDbFileName));

	delete ipbNotifier;

	delete ipbObSvr;

	delete ipbDb;

	}

void CPbTester::StartTestL()

	{

	TContactItemId id = AddEntryL();

	EditEntryL(id);

	ipbObSvr->After(KTimeMicroSec); //Allow CContactChangeNotifier to run

	CActiveScheduler::Start();

	}

TContactItemId CPbTester::AddEntryL()

	{

	_LIT(KForename,"Myname"); 

	_LIT(KSurname,"Mylastname"); 

	_LIT(KPhoneNumber,"+447700900700"); 

	// Create a  contact card to contain the data

	CContactCard* newCard = CContactCard::NewLC();

	// Create the firstName field and add the data to it

	CContactItemField* firstName = CContactItemField::NewLC(KStorageTypeText, KUidContactFieldGivenName);

	firstName->TextStorage()->SetTextL(KForename);

	newCard->AddFieldL(*firstName);

	CleanupStack::Pop(firstName);

	// Create the lastName field and add the data to it

	CContactItemField* lastName= CContactItemField::NewLC(KStorageTypeText, KUidContactFieldFamilyName);

	lastName ->TextStorage()->SetTextL(KSurname);

	newCard->AddFieldL(*lastName);

	CleanupStack::Pop(lastName);

	// Create the phoneNo field and add the data to it

	CContactItemField* phoneNumber = CContactItemField::NewLC(KStorageTypeText, KUidContactFieldPhoneNumber);

	phoneNumber->SetMapping(KUidContactFieldVCardMapTEL);

	phoneNumber ->TextStorage()->SetTextL(KPhoneNumber);

	newCard->AddFieldL(*phoneNumber);

	CleanupStack::Pop(phoneNumber);

	// Add newCard to the database

	const TContactItemId contactId = ipbDb->AddNewContactL(*newCard);

	CleanupStack::PopAndDestroy(newCard);

	return contactId;

	}

void CPbTester::EditEntryL(TContactItemId itemId)

	{

	_LIT(KEmailAddress,"myname.mylastname@symbianfoundation.test"); 

	CContactItem *item = ipbDb->OpenContactL(itemId);

	CContactCard* card = NULL;

	CleanupStack::PushL(item);

	card = (CContactCard*)item;

	// Create the emailAddress field and add the data to it

	CContactItemField* emailAddr = CContactItemField::NewLC(KStorageTypeText, KUidContactFieldEMail);

	emailAddr->SetMapping(KUidContactFieldVCardMapEMAILINTERNET);

	emailAddr ->TextStorage()->SetTextL(KEmailAddress);

	card->AddFieldL(*emailAddr);

	CleanupStack::Pop(emailAddr);

	ipbDb->CommitContactL(*item);

	CleanupStack::PopAndDestroy(item);

	}

void RunTestL()

	{

	CPbTester* tester = CPbTester::NewL();

	CleanupStack::PushL(tester);

	tester->StartTestL();

	CleanupStack::PopAndDestroy(tester);

	}

/**

@SYMTestCaseID     PIM-T-CONTACTDBEVENT-0001

*/

GLDEF_C TInt E32Main()

	{

	__UHEAP_MARK;

	CActiveScheduler* scheduler=new CActiveScheduler;

	CActiveScheduler::Install(scheduler);

	CTrapCleanup* cleanup = CTrapCleanup::New();

	test.Start(_L("@SYMTESTCaseID:PIM-T-CONTACTDBEVENT-0001 Testing Database event"));

	TRAPD(err,RunTestL());

	test(err==KErrNone);

	test.End();

	test.Close();

	delete cleanup;

    delete scheduler;

	__UHEAP_MARKEND;

	return KErrNone;

	}