/*

* 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 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: 

* Example Code

*

*/

#include "tmsgapp.h"

#include <e32debug.h>

#include <f32file.h>

// UPS client library is only included to allow the test application

// to reset its decision records.

#include <ups/upsclient.h>	

_LIT(KTo, "+442071541000");

_LIT_SECURE_ID(KMySecureId, 0x01000003);

// CAlarm ********************************************************************

inline CAlarm::CAlarm() :CTimer(-1) {CActiveScheduler::Add(this);}

inline void CAlarm::ConstructL() {CTimer::ConstructL();}

void CAlarm::RunL() 

	{

	iObserver->WakeupL();

	}

void CAlarm::After(MAlarmObserver* aObserver, TTimeIntervalMicroSeconds32 aInterval)

	{

	iObserver = aObserver;

	CTimer::After(aInterval);

	}

// CSendMessages *************************************************************

CSendMessages::CSendMessages() : CActive(EPriorityStandard) 

	{

	CActiveScheduler::Add(this);

	}

CSendMessages::~CSendMessages() 

	{

	Deque();

	iMsgCon.Close();

	}

CSendMessages* CSendMessages::NewLC()

	{

	CSendMessages* self = new(ELeave) CSendMessages();

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

void CSendMessages::ConstructL()

	{

	iAlarm.ConstructL();

	User::LeaveIfError(iMsgCon.Connect());

	TRequestStatus* status = &iStatus;

	*status = KRequestPending;

	SetActive();

	User::RequestComplete(status, KErrNone);

	}

TInt CSendMessages::RunError(TInt /* aError */)

	{

	CActiveScheduler::Stop(); // Non-recoverable error

	return KErrNone;

	}

void CSendMessages::DoCancel()

	{

	iMsgCon.CancelSendMsg();	

	iAlarm.Cancel();

	}

void CSendMessages::WakeupL()

/**

 * Timeout the pending message.

 */

	{

	iMsgCon.CancelSendMsg();

	}

void CSendMessages::RunL()

/**

 * Send a series of test messages and cancellations that should trigger

 * user prompts.

 * All test cases timeout after KDefaultTimeout to enable automated tests

 */

	{

	TInt err = iStatus.Int();

	if (iStatus != KErrNone && iStatus != KErrCancel && iStatus != KErrPermissionDenied) 

		{

		User::Leave(err);

		}

	iAlarm.Cancel();

	RDebug::Printf("Test %d completed with error %d", iTestNum, 0);

	++iTestNum;	// move on to next test case	

	switch (iTestNum)

		{

		case 1:

			{

			// Send message and wait for user prompt to complete			

			_LIT(KBody, "Hello");

			iMsgCon.SendMsg(KTo, KBody, iStatus);

			SetActive();

			iAlarm.After(this, KDefaultTimeout);

			break;

			}

		case 2:

			{

			// Send a message and cancel straight away, should be no user prompt

			_LIT(KBody, "Hello - Cancel immediate");

			iMsgCon.SendMsg(KTo, KBody, iStatus);

			SetActive();

			iAlarm.After(this, 1);

			break;

			}

		case 3:

			{

			// Send a message and attempt to cancel whilst the user prompt is being displayed.

			_LIT(KBody, "Hello - Cancel 5 secs");

			iMsgCon.SendMsg(KTo, KBody, iStatus);

			SetActive();

			iAlarm.After(this, 5 * 1000 * 1000);

			break;

			}

		case 4:

			{

			// Force the message server to exit

			iMsgCon.Close();

			_LIT(KInfo, "Waiting for messageserver to exit");

			User::InfoPrint(KInfo);

			User::After(5 * 1000 * 1000);	

			User::LeaveIfError(iMsgCon.Connect());	// reconnect

			// Send a message to the new server instance

			_LIT(KBody, "Hello again");

			iMsgCon.SendMsg(KTo, KBody, iStatus);

			SetActive();

			iAlarm.After(this, KDefaultTimeout);

			break;

			}

		default:

			// All done

			CActiveScheduler::Stop();

			break;

		}	

	}

void DeleteOldDecisionsL()

/**

 * Delete all decision records for this test application

 */

	{

	UserPromptService::RUpsManagement m;

	CleanupClosePushL(m);

	User::LeaveIfError(m.Connect());

	UserPromptService::CDecisionFilter* f = UserPromptService::CDecisionFilter::NewLC();

	f->SetClientSid(KMySecureId, UserPromptService::EEqual);

	m.RemoveDecisionsL(*f);

	CleanupStack::PopAndDestroy(2, &m); // m, f

	}

void MainL()

	{

	// Create active scheduler, reset UPS and start tests

	CActiveScheduler* s=new(ELeave) CActiveScheduler;	

	CleanupStack::PushL(s);

	CActiveScheduler::Install(s);

	DeleteOldDecisionsL();	// reset decision database

	CSendMessages* test = CSendMessages::NewLC();

	s->Start();

	CleanupStack::PopAndDestroy(2, s); // s, test

	// Add log file for automated test environment

	RFs fs;

	User::LeaveIfError(fs.Connect());

	CleanupClosePushL(fs);

	RFile log;

	CleanupClosePushL(log);

	User::LeaveIfError(log.Replace(fs, _L("c:\\tmsgapp.log"), EFileShareAny|EFileWrite));

	User::LeaveIfError(log.Write(_L8("\n\n0 tests failed out of 1\n")));

	CleanupStack::PopAndDestroy(2, &fs);

	}

GLDEF_C TInt E32Main()

	{

	CTrapCleanup* cleanup = CTrapCleanup::New();

	if(cleanup == NULL)

		{

		return KErrNoMemory;

		}

	TRAP_IGNORE(MainL());

	delete cleanup;

	return KErrNone;

	}