// Copyright (c) 1999-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 "t_schsendexe.h"

#include <msvids.h>

#include <msvuids.h>

CTrapCleanup* theCleanup;

void doMainL(RTest& aTest)

	{

	CActiveScheduler* scheduler = new (ELeave) CActiveScheduler;

	CleanupStack::PushL(scheduler);

	CActiveScheduler::Install( scheduler );

	CSchSendExeTest* schSendTest = CSchSendExeTest::NewL(aTest);

	CleanupStack::PushL(schSendTest);

	schSendTest->StartL();

	CleanupStack::PopAndDestroy(2); //schSendTest, scheduler

	aTest.Printf(_L("\nWaiting 5 seconds before closing...\n"));

	User::After(5000000);

	}

GLDEF_C TInt E32Main()

	{

	RTest test(_L("Scheduled Sending Test Harness"));

	__UHEAP_MARK;

	test.Title();

	test.Start(_L("Scheduled Sending Test Harness"));

	theCleanup = CTrapCleanup::New();

	test(theCleanup !=NULL);

	TRAPD(error,doMainL(test));

	test(error==KErrNone);

	delete theCleanup;

	test.Printf(_L("Completed with return code %d"),error);

	test.End();

	test.Close();

	__UHEAP_MARKEND;

	return KErrNone;

	}

CSchSendExeTest* CSchSendExeTest::NewL(RTest& aTest)

	{

	CSchSendExeTest* self = new (ELeave) CSchSendExeTest(aTest);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(); //self

	return self;

	}

CSchSendExeTest::CSchSendExeTest(RTest& aTest)

: CSchSendTestUtils(aTest)

	{

	}

void CSchSendExeTest::ShowMenuL()

	{

	RunAutoL();

	}

CSchSendExeTest::~CSchSendExeTest()

	{

	}

void CSchSendExeTest::RunAutoL()

	{

	TInt nextTest = 0;

	TestStart(++nextTest, _L("Operation Fail"));

	TestOperationFailureL();

	TestFinish(nextTest, KErrNone);

// DEF051316

	}

void CSchSendExeTest::TestOperationFailureL()

	{

	Printf(_L("TestOperationFailure\n"));

	TTime now;

	now.HomeTime();

	TMsvEntry entry;

	CreateMessageLC(entry, KMsvGlobalOutBoxIndexEntryId, now);

	iSelection->Reset();

	iSelection->AppendL(entry.Id());

	const TInt KTestOpFailError = -111;

	TPckgBuf<TInt> pkg(KTestOpFailError);

	iSchTestActive->TransferCommandSyncL(EScheduleOpFail, *iSelection, pkg, ETrue);

	CSchSendTestWaitForState* wait = CSchSendTestWaitForState::NewL(*this);

	CleanupStack::PushL(wait);

	wait->Reset();

	wait->AppendL(KMsvSendStateResend);

	wait->StartL(*iSelection, 1000000 * 60 * 4); //4 mins

	SetEntryL(entry.Id());

	entry = Entry();

	iRTest(entry.iError == KTestOpFailError);

	Printf(_L("Wait completed with %d\n"), wait->iStatus.Int());

	iRTest(wait->iStatus.Int() == KErrNone);

	CleanupStack::PopAndDestroy(wait);

	CleanupStack::PopAndDestroy(); //message

	}

void CSchSendExeTest::TestSessionFailureL()

	{

	Printf(_L("TestSessionFailure\n"));

	TTime now;

	now.HomeTime();

	TMsvEntry entry;

	CreateMessageLC(entry, KMsvGlobalOutBoxIndexEntryId, now);

	iSelection->Reset();

	iSelection->AppendL(entry.Id());

	// create a semaphore that causes CMsvSession construction to fail

	RSemaphore moving;

	User::LeaveIfError(moving.CreateGlobal(KMsvMovingSemaphore,0));

	CleanupClosePushL(moving);

	iSchTestActive->TransferCommandSyncL(EScheduleAllL, *iSelection, ETrue);

	CSchSendTestWaitForState* wait = CSchSendTestWaitForState::NewL(*this);

	CleanupStack::PushL(wait);

	Printf(_L("Waiting %d secs to check message scheduled\n"), 5);

	wait->AppendL(KMsvSendStateScheduled);

	wait->StartL(*iSelection, 1000000 * 5); //5 secs

	Printf(_L("Wait completed with %d\n"), wait->iStatus.Int());

	iRTest(wait->iStatus.Int() == KErrNone);

	Printf(_L("Closing Move Semaphore\n"));

	Printf(_L("Waiting %d secs for message to send\n"), 60 * 2);

	moving.Close();

	wait->Reset();

	wait->AppendL(KMsvSendStateSent);

	wait->StartL(*iSelection, 1000000 * 60 * 2); //2 mins

	Printf(_L("Wait completed with %d\n"), wait->iStatus.Int());

	iRTest(wait->iStatus.Int() == KErrNone);

	CleanupStack::PopAndDestroy(wait);

	CleanupStack::Pop(); //moving

	CleanupStack::PopAndDestroy(); //message

	}