// Copyright (c) 2005-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>

#ifdef __EPOC32__

#include <c32comm.h>

#endif

#include "cbtclient.h"

class CMyClient: public CBase, MConnectionObserver, MBluetoothSocketNotifier

	{

	public:

		void ConstructL();

		~CMyClient();

		virtual void HandleNewConnection(CBluetoothSocket* aConnection);

		virtual void HandleConnectFailed(TInt aError);

		//Virtual functions from MBluetoothSocketNotifier

		virtual void HandleConnectCompleteL(TInt aErr);

		virtual void HandleAcceptCompleteL(TInt aErr);

		virtual void HandleShutdownCompleteL(TInt aErr);

		virtual void HandleSendCompleteL(TInt aErr);

		virtual void HandleReceiveCompleteL(TInt aErr);

		virtual void HandleIoctlCompleteL(TInt aErr);

		virtual void HandleActivateBasebandEventNotifierCompleteL(TInt aErr, TBTBasebandEventNotification& aEventNotification);

		CBtClient* iBtClient;

		RSdp iSdpSession;

		RSocketServ iSocketServ;

		CBluetoothSocket* iConnection;

	};

RTest test(_L("tClient"));

CMyClient *TheClient;

void CMyClient::ConstructL()

	{

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

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

	TBTServiceSecurity sec;

	sec.SetAuthentication(EMitmNotRequired);

	sec.SetAuthorisation(EFalse);

	sec.SetEncryption(EFalse);

	sec.SetDenied(EFalse);

	iBtClient = CBtClient::NewL(TUUID(KSerialPortUUID), //register as a serial port so we can be easily seen

								iSocketServ,

								*this,

								&sec);

	iBtClient->ConnectToRemoteDeviceL(*this);

	}

CMyClient::~CMyClient()

	{

	delete iBtClient;

	delete iConnection;

	iSdpSession.Close();

	iSocketServ.Close();

	}

void CMyClient::HandleNewConnection(CBluetoothSocket* aConnection)

	{

	test(iConnection==NULL);

	iConnection = aConnection;

	}

void CMyClient::HandleConnectFailed(TInt /*aErr*/)

	{

	test(0);

	}

_LIT8(KTestData, "tclient 12345678");

void CMyClient::HandleConnectCompleteL(TInt aErr)

	{

	test(aErr == KErrNone);

	iConnection->Send(KTestData, 0);

	}

void CMyClient::HandleAcceptCompleteL(TInt /*aErr*/)

	{

	test(0);

	}

void CMyClient::HandleShutdownCompleteL(TInt /*aErr*/)

	{

	delete iConnection;

	iConnection = NULL;

	User::After(10000000);

	CActiveScheduler::Stop();

	}

void CMyClient::HandleSendCompleteL(TInt aErr)

	{

	test(aErr == KErrNone);

	iConnection->Shutdown(RSocket::EImmediate);

	}

void CMyClient::HandleReceiveCompleteL(TInt /*aErr*/)

	{

	test(0);

	}

void CMyClient::HandleIoctlCompleteL(TInt /*aErr*/)

	{

	test(0);

	}

void CMyClient::HandleActivateBasebandEventNotifierCompleteL(TInt /*aErr*/, TBTBasebandEventNotification& /*aEventNotification*/)

	{

	test(0);

	}

void RunTestL()

	{

	CActiveScheduler *sched = new(ELeave)CActiveScheduler;

	CleanupStack::PushL(sched);

	CActiveScheduler::Install(sched);

	TheClient = new(ELeave) CMyClient;

	CleanupStack::PushL(TheClient);

	TheClient->ConstructL();

	CActiveScheduler::Start();

	CleanupStack::PopAndDestroy(TheClient);

	CleanupStack::PopAndDestroy(sched);

	}

#if defined (__WINS__)

#define PDD_NAME _L("ECDRV")

#define LDD_NAME _L("ECOMM")

#else  // __GCC32__

#define PDD_NAME _L("EUART1")

#define LDD_NAME _L("ECOMM")

#endif

//this is not needed with a UI, only text shell

void LoadLDD_PDD()

	{

	TInt r;

#ifdef __EPOC32__

	r=StartC32();

	if (r!=KErrNone && r!=KErrAlreadyExists)

		{

		test.Printf(_L("Failed %d!\n\r"),r);

		test(r==KErrNone);

		}

	else

		test.Printf(_L("Started C32\n"));

#endif

	test.Printf(_L("Loading PDD\n"));

	r=User::LoadPhysicalDevice(PDD_NAME);

	if (r!=KErrNone && r!=KErrAlreadyExists)

		{

		test.Printf(_L("Failed %d!\n\r"),r);

		test(r==KErrNone);

		}

	else 

		test.Printf(_L("Loaded LDD\n"));

	test.Printf(_L("Loading LDD\n"));

	r=User::LoadLogicalDevice(LDD_NAME);

	if (r!=KErrNone && r!=KErrAlreadyExists)

		{

		test.Printf(_L("Failed %d!\n\r"),r);

		test(r==KErrNone);

		}

	else

		test.Printf(_L("Loaded PDD\n"));

	}

TInt E32Main()

	{

	User::SetJustInTime(ETrue);

	__UHEAP_MARK;

	CTrapCleanup* cleanupStack=CTrapCleanup::New();

	LoadLDD_PDD();

	TRAPD(err,RunTestL());	//	Ignore err

	if (err != KErrNone)

		{

		test.Printf(_L("Error %d"), err);

		test.Getch();

		}

	test.Close();

	delete cleanupStack;

	__UHEAP_MARKEND;

	return err;

	}