// 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 "cbtservice.h"

class CMySCOService;
class CMyService: public CBase, MConnectionObserver, MBluetoothSocketNotifier
	{
	public:
		void ConstructL();
		~CMyService();
		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);
		CBtService* iBtService;
		RSdp iSdpSession;
		RSocketServ iSocketServ;
		CBluetoothSocket* iConnection;
		CMySCOService* iSCOConnection;
	};

class CMySCOService: MBluetoothSynchronousLinkNotifier
	{
	public:
		void ConstructL();
		CMySCOService(RSocketServ& aSocketServ);
		~CMySCOService();
		//virtual functions from MBluetoothSynchronousLinkNotifier
		virtual void HandleSetupConnectionCompleteL(TInt aErr);
		virtual void HandleDisconnectionCompleteL(TInt aErr);
		virtual void HandleAcceptConnectionCompleteL(TInt aErr);
		virtual void HandleSendCompleteL(TInt aErr);
		virtual void HandleReceiveCompleteL(TInt aErr);
		CBluetoothSynchronousLink *iConnection;
		RSocketServ& iSocketServ;
	};

RTest test(_L("tservice"));
CMyService *TheService;

void CMyService::ConstructL()
	{
	User::LeaveIfError(iSocketServ.Connect());
	iSCOConnection = new(ELeave) CMySCOService(iSocketServ);
	iSCOConnection->ConstructL();
	User::LeaveIfError(iSdpSession.Connect());
	TBTServiceSecurity sec;
	sec.SetAuthentication(EMitmNotRequired);
	sec.SetAuthorisation(EFalse);
	sec.SetEncryption(EFalse);
	sec.SetDenied(EFalse);
	iBtService = CBtService::NewL(TUUID(KSerialPortUUID), //register as a serial port so we can be easily seen
								iSdpSession,
								iSocketServ,
								*this,
								KRFCOMM,
								&sec);
	iConnection = CBluetoothSocket::NewL(*this, iSocketServ);
	iBtService->AcceptConnection(*iConnection);
	}

CMyService::~CMyService()
	{
	delete iBtService;
	delete iConnection;
	delete iSCOConnection;
	iSdpSession.Close();
	iSocketServ.Close();
	}

void CMyService::HandleNewConnection(CBluetoothSocket* aConnection)
	{
	test(aConnection==iConnection);
	delete iConnection;
	iConnection = NULL;
	CActiveScheduler::Stop();
	}

void CMyService::HandleConnectFailed(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleConnectCompleteL(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleAcceptCompleteL(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleShutdownCompleteL(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleSendCompleteL(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleReceiveCompleteL(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleIoctlCompleteL(TInt /*aErr*/)
	{
	test(0);
	}

void CMyService::HandleActivateBasebandEventNotifierCompleteL(TInt /*aErr*/, TBTBasebandEventNotification& /*aEventNotification*/)
	{
	test(0);
	}

CMySCOService::CMySCOService(RSocketServ& aSS) :
	iSocketServ(aSS)
	{
	}

CMySCOService::~CMySCOService()
	{
	delete iConnection;
	}

void CMySCOService::ConstructL()
	{
	iConnection = CBluetoothSynchronousLink::NewL(*this, iSocketServ);
	iConnection->AcceptConnection();
	}

void CMySCOService::HandleSetupConnectionCompleteL(TInt /*aErr*/)
	{
	test(0);
	}
void CMySCOService::HandleDisconnectionCompleteL(TInt /*aErr*/)
	{
	}
void CMySCOService::HandleAcceptConnectionCompleteL(TInt aErr)
	{
	test(aErr == KErrNone);
	}
void CMySCOService::HandleSendCompleteL(TInt /*aErr*/)
	{
	test(0);
	}
void CMySCOService::HandleReceiveCompleteL(TInt /*aErr*/)
	{
	test(0);
	}


void RunTestL()
	{
	CActiveScheduler *sched = new(ELeave)CActiveScheduler;
	CleanupStack::PushL(sched);
	CActiveScheduler::Install(sched);
	TheService = new(ELeave) CMyService;
	CleanupStack::PushL(TheService);
	TheService->ConstructL();
	CActiveScheduler::Start();
	CleanupStack::PopAndDestroy(TheService);
	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")
// #define ETNA_PDD_NAME _L("EUART2") // for debugging over com2
#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;
	}