// Copyright (c) 1998-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:
// Name of test harness: T_BIO
// Component: SMOKE
// Owner: KP
// Brief description of test harness:
// Sends, receives and parses Internet Configuration messages.  An internet
// connection is made using the received settings.
// Detailed description of test harness:
// As above
// Input files required to run test harness:
// \MSG\TEST\SMOKE\BIO\SCRIPT\BIOTEST.SCRIPT	<DRIVE>:\msgtest\BIO\biotest.script
// Intermediate files produced while running test harness:
// None
// Output files produced by running test harness:
// <DRIVE>:\msglogs\T_BIO.<PLATFORM>.<VARIANT>.LOG.txt
// Description of how to build test harness:
// cd \msg\test\smoke\
// bldmake bldfiles
// abld test build
// Description of how to run test harness:
// The following instructions are the same for all platforms:
// 1. Build T_DB test harness from COMMDB component:
// cd \commdb\group
// bldmake bldfiles
// abld test build t_db
// 2. Build the test utilities:
// cd \msg\testutils\group\
// bldmake bldfiles
// abld build
// 3. Build the BIO test utilities:
// cd \biomsg\bits\
// bldmake bldfiles
// abld build
// WINS running instructions:
// 1. \epoc32\release\wins\<VARIANT>\T_BIO.exe can be used at the command prompt
// or executable can be run from Windows Explorer.
// All other platform running instructions:
// 1. Copy \epoc32\release\<PLATFORM>\<VARIANT>\T_BIO.exe onto the other platform
// 2. Copy \epoc32\release\<PLATFORM>\<VARIANT>\MSVTESTUTILS.DLL into 
// <DRIVE>:\system\libs on the other platform
// 3. Copy \epoc32\release\<PLATFORM>\<VARIANT>\EMAILTESTUTILS.DLL into 
// <DRIVE>:\system\libs on the other platform
// 4. Copy \epoc32\release\<PLATFORM>\<VARIANT>\SMSTESTUTILS.DLL into 
// <DRIVE>:\system\libs on the other platform
// 5. Copy \epoc32\release\<PLATFORM>\<VARIANT>\BITS.DLL into 
// <DRIVE>:\system\libs on the other platform
// 4. Run T_BIO.exe on the other platform
// 
//

#include <e32uid.h>
#include <e32test.h>
#include <watcher.h>
#include <txtrich.h>
#include <smuthdr.h>
#include <commdb.h>

#include "t_bio.h"
#include "sendrecv.h"
#include "parsertest.h"

const TTimeIntervalMicroSeconds32 KWaitForWatchersToStart = 40000000;
const TTimeIntervalMicroSeconds32 KWaitForWatchersToStartDisplayInterval = 5000000;
const TTimeIntervalMicroSeconds32 KWaitForWatchersToDie = 5000000;

RTest test(_L("T_Bio Biomsg SmokeTestrig"));
CTrapCleanup* theCleanup;


LOCAL_C void doMainL()
	{
	CActiveScheduler* scheduler = new (ELeave) CActiveScheduler;
	CleanupStack::PushL(scheduler);
	CActiveScheduler::Install( scheduler );

	CBioSmokeTest* bioSmokeTest = CBioSmokeTest::NewL(test);
	CleanupStack::PushL(bioSmokeTest);

	bioSmokeTest->StartL();

	CleanupStack::PopAndDestroy(2); //SmsTest, scheduler
	}

GLDEF_C TInt E32Main()
	{	
	__UHEAP_MARK;
	test.Start(_L("Setup"));
	theCleanup = CTrapCleanup::New();
	TRAPD(ret,doMainL());		
	test(ret==KErrNone);
	delete theCleanup;	
	test.Console()->SetPos(0, 13);
	test.End();
	test.Close();
	__UHEAP_MARKEND;
	return(KErrNone);
	}


// CEntryObserver
//
CEntryObserver::CEntryObserver(	CSmsTestUtils& aTestUtils, CMsvEntrySelection& aReceived, const TInt& aCurrentMessageNum)
: CBase(), iTestUtils(aTestUtils), iReceived(aReceived), iCurrentMessageNum(aCurrentMessageNum)
	{
	}


CEntryObserver::~CEntryObserver() 
	{
	delete iNew;
	}

void CEntryObserver::HandleEntryEventL(TMsvEntryEvent aEvent, TAny* aArg1, TAny* /*aArg2*/, TAny* /*aArg3*/)
	{
	if (aEvent == EMsvNewChildren && iCurrentMessageNum > -1)
		{
		delete iNew;
		iNew = NULL;
		iNew = ((CMsvEntrySelection*)aArg1)->CopyL();

		TInt count = iNew->Count();

		CSmsHeader* header = CSmsHeader::NewL(CSmsPDU::ESmsDeliver, *iTestUtils.iRichText);
		CleanupStack::PushL(header);

		TInt msgRecv = 0;

		while (count--)
			{
			TMsvId id = iNew->At(count);
			iTestUtils.SetEntryL(id);

			CMsvStore* store = iTestUtils.ReadStoreL();
			CleanupStack::PushL(store);
	
			header->RestoreL(*store);

			if (header->Type() == CSmsPDU::ESmsDeliver)
				{
				iReceived.AppendL(id);
				msgRecv++;
				}

			CleanupStack::PopAndDestroy(); //store
			}

		CleanupStack::PopAndDestroy(); //header

		if (msgRecv)	
			iTestUtils.Printf(_L("%d Messages Received in inbox\n"), msgRecv);
		
		}
	}

//
// CBioSmokeTest
//
CBioSmokeTest::~CBioSmokeTest()
	{
	CancelWatcher();
	// delete everything
	delete iTimer;
	
	delete iSendReceive;
	delete iParserTest;

	delete iEntryObserver;
	delete iReceived;
	delete iEntryForObserver;

	delete iSmsTestUtils;

	delete iWatcher;

	iSocket.Close();
	iSocketServ.Close();
	}

CBioSmokeTest::CBioSmokeTest()
	{
	}

CBioSmokeTest* CBioSmokeTest::NewL(RTest& aTest)
	{
	CBioSmokeTest* self = new (ELeave) CBioSmokeTest();
	CleanupStack::PushL(self);

	self->ConstructL(aTest);

	CleanupStack::Pop();
	return self;
	}

void CBioSmokeTest::StartL()
	{
	// fire up the watcher
	StartWatcherL();
	// send receive 

	iBioSmokeState = EBioSmokeSendRecv;
	
	// create the send receive 
	iSendReceive = CSendReceive::NewL(*iSmsTestUtils);
	iSendReceive->StartL(iReceived);

	delete iSendReceive;
	iSendReceive = NULL;

	// test parser
	iParserTest = CParserTest::NewL(*iSmsTestUtils);
	iParserTest->StartL(iReceived);
	}

void CBioSmokeTest::ConstructL(RTest& aTest)
	{
	iSmsTestUtils = CSmsTestUtils::NewL(aTest);
	iSmsTestUtils->SetLogToFile();

	iSmsTestUtils->NotifySaPhoneOnL();

	User::LeaveIfError(iSocketServ.Connect());
	TProtocolDesc protoinfo;
	TProtocolName protocolname(KSmsDatagram);
	User::LeaveIfError(iSocketServ.FindProtocol(protocolname,protoinfo));
	User::LeaveIfError(iSocket.Open(iSocketServ,protoinfo.iAddrFamily,protoinfo.iSockType,protoinfo.iProtocol));
	
	TSmsAddr smsaddr;
	smsaddr.SetSmsAddrFamily(ESmsAddrSendOnly);
	User::LeaveIfError(iSocket.Bind(smsaddr));

	iSmsTestUtils->WaitForInitializeL();
	}

void CBioSmokeTest::StartWatcherL()
	{
	test.Next(_L("Start the Watcher"));

	delete iReceived;
	iReceived = new (ELeave) CMsvEntrySelection();

	delete iEntryObserver;
	iEntryObserver = new (ELeave) CEntryObserver(*iSmsTestUtils, *iReceived, iCurrentMessageNum);

	delete iEntryForObserver;
	iEntryForObserver = Session().GetEntryL(KMsvGlobalInBoxIndexEntryId);
	iEntryForObserver->AddObserverL(*iEntryObserver);

	// Create the watcher
	delete iWatcher;
	iWatcher = NULL;
	iWatcher = CTestUtilsWatcherStarter::NewL(CActive::EPriorityStandard);

	TTimeIntervalMicroSeconds32 wait = KWaitForWatchersToStart;
	CTestTimer* timer = CTestTimer::NewL();

	while (wait.Int() > 0)
		{
		iSmsTestUtils->Printf(_L("Waiting %d secs for watchers to start...\n"), wait.Int() / 1000000);
		timer->After(KWaitForWatchersToStartDisplayInterval);
		wait = wait.Int() - KWaitForWatchersToStartDisplayInterval.Int();
		CActiveScheduler::Start();
		}

	delete timer;
	}

void CBioSmokeTest::CancelWatcher()
	{
	if (iWatcher)
		{
		iWatcher->Cancel();
		CActiveScheduler::Start();
		delete iWatcher;
		iWatcher = NULL;

		iSmsTestUtils->Printf(_L("Waiting %d seconds for the watchers to die\n"), KWaitForWatchersToDie.Int() / 1000000);

		CTestTimer* timer = NULL;
		TRAPD(ret,timer=CTestTimer::NewL());
		if (ret==KErrNone)
			{
			timer->After(KWaitForWatchersToDie);
			CActiveScheduler::Start();
			delete timer;
			}		
		iSmsTestUtils->TestHarnessCompleted();
		}
	}