// Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the License "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:

// e32test\notifier\textnotifier1.cpp

// 

//

#ifndef V2_NOTIFIER

#endif

#include <twintnotifier.h>

#include "textnotifier.h"

#ifdef V2_NOTIFIER

#define KUidTestTextNotifier KUidTestTextNotifier2

#define KUidOtherTestTextNotifier KUidTestTextNotifier1

#define NOTIFIER_BASE MNotifierBase2

#else

#define KUidTestTextNotifier KUidTestTextNotifier1

#define KUidOtherTestTextNotifier KUidTestTextNotifier2

class MEikSrvNotifierBase : public MNotifierBase {};

#define NOTIFIER_BASE MEikSrvNotifierBase

#endif

// Give each notifers a different channel so they don't block each other

// (this is required for the MNotiferManager testing to be valid.)

#define KUidOutputChannel KUidTestTextNotifier

class CTestNotifier : public CBase, public NOTIFIER_BASE

	{

public:

	CTestNotifier(TNotifierPriority aPriority);

	virtual void Release();

	virtual TNotifierInfo RegisterL();

	virtual TNotifierInfo Info() const;

	virtual TPtrC8 StartL(const TDesC8& aBuffer);

#ifdef V2_NOTIFIER

	virtual void StartL(const TDesC8& aBuffer, TInt aReplySlot, const RMessagePtr2& aMessage);

#else

	virtual void StartL(const TDesC8& aBuffer, const TAny* aReturnVal, RMessage aMessage);

#endif

	virtual void Cancel();

	virtual TPtrC8 UpdateL(const TDesC8& aBuffer);

private:

	TBool iCancel;

	TBuf8<256> iResponse;

	TBool iNotifierManagerTested;

	TNotifierPriority iPriority;

	};

void CTestNotifier::Release()

	{

	delete this;

	}

CTestNotifier::CTestNotifier(TNotifierPriority aPriority)

	: iPriority(aPriority)

	{}

CTestNotifier::TNotifierInfo CTestNotifier::RegisterL()

	{

	CTestNotifier::TNotifierInfo info;

	info.iUid = KUidTestTextNotifier;

	info.iChannel = KUidOutputChannel;

	info.iPriority = iPriority;

	return info;

	}

CTestNotifier::TNotifierInfo CTestNotifier::Info() const

	{

	CTestNotifier::TNotifierInfo info;

	info.iUid = KUidTestTextNotifier;

	info.iChannel = KUidOutputChannel;

	info.iPriority = iPriority;

	return info;

	}

TPtrC8 CTestNotifier::StartL(const TDesC8& aBuffer)

	{

	iCancel = EFalse;

	if(aBuffer==KMNotifierManager)

		{

		iNotifierManagerTested = ETrue;

		iResponse.SetMax();

		iResponse.FillZ();

		iResponse.Zero();

		iManager->StartNotifierL(KUidOtherTestTextNotifier,KStartData,iResponse);

		return TPtrC8(iResponse);

		}

	if(aBuffer!=KStartData)

		User::Leave(KErrGeneral);

	return TPtrC8(KResponseData);

	}

#ifdef V2_NOTIFIER

void CTestNotifier::StartL(const TDesC8& aBuffer, TInt aReplySlot, const RMessagePtr2& aMessage)

#else

void CTestNotifier::StartL(const TDesC8& aBuffer, const TAny* aReturnVal, RMessage aMessage)

#endif

	{

	TBool cancelled=iCancel;

	iCancel = EFalse;

	TInt r=KErrNone;

	if(aBuffer==KMNotifierManager || aBuffer==KMNotifierManagerWithCancelCheck)

		{

		iNotifierManagerTested = ETrue;

		iResponse.SetMax();

		iResponse.FillZ();

		iResponse.Zero();

		iManager->StartNotifierL(KUidOtherTestTextNotifier,KStartData,iResponse);

		if(aBuffer==KMNotifierManagerWithCancelCheck)

			r = cancelled ? KTestNotifierWasPreviouselyCanceled : KErrGeneral;

		}

	else if(aBuffer==KStartData)

		iResponse.Copy(KResponseData);

	else if(aBuffer==KHeapData)

		{

		iResponse.Zero();

		TInt allocSize;

		r=User::AllocSize(allocSize); 

		iResponse.Format(_L8("%d"),allocSize);

		}

	else if(aBuffer==KStartWithCancelCheckData)

		{

		iResponse.Copy(KResponseData);

		r = cancelled ? KTestNotifierWasPreviouselyCanceled : KErrGeneral;

		}

	else

		User::Leave(KErrGeneral);

#ifdef V2_NOTIFIER

	aMessage.WriteL(aReplySlot,iResponse);

#else

	aMessage.WriteL(aReturnVal,iResponse);

#endif

	aMessage.Complete(r);

	}

void CTestNotifier::Cancel()

	{

	if(iNotifierManagerTested)

		{

		iNotifierManagerTested = EFalse;

		iManager->CancelNotifier(KUidOtherTestTextNotifier);

		}

	iCancel = ETrue;

	}

TPtrC8 CTestNotifier::UpdateL(const TDesC8& aBuffer)

	{

	if(aBuffer==KMNotifierManager)

		{

		iNotifierManagerTested = ETrue;

		iManager->UpdateNotifierL(KUidOtherTestTextNotifier,KUpdateData,iResponse);

		}

	else if(aBuffer==KUpdateData)

		iResponse.Copy(KResponseData);

	else

		User::Invariant();

	return TPtrC8(iResponse);

	}

EXPORT_C CArrayPtr<NOTIFIER_BASE>* NotifierArray()

	{

    CArrayPtrFlat<NOTIFIER_BASE>* array = new (ELeave) CArrayPtrFlat<NOTIFIER_BASE>(2);

	CleanupStack::PushL(array);

    CTestNotifier* notifier = new (ELeave) CTestNotifier(NOTIFIER_BASE::ENotifierPriorityLow);

    CleanupStack::PushL(notifier);

    array->AppendL(notifier);

    CleanupStack::Pop(2,array);

    return array;

	}