// btservices.cpp

// 

// Copyright (c) 2009 - 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the "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:

// Accenture - Initial contribution

//

#include <e32std.h>

#include <BTExtNotifiers.h>

#include <fshell/common.mmh>

#include <fshell/ioutils.h>

using namespace IoUtils;

#include "BtServicesEng.h"

#include "BtServiceView.h"

class CBTEngSettings;

#if FSHELL_PLATFORM_S60 >= 5

// This is an S60-only API

#define SUPPORT_ONOFF

#endif

#ifdef SUPPORT_ONOFF

#include <btengsettings.h>

#endif

CBtServiceView::CBtServiceView()

	{

	}

CBtServiceView::~CBtServiceView()

	{

	}

void CBtServiceView::PrintTextMsg(TInt /*aVerboseLevel*/, const TDesC& /*aMsg*/)

	{

	}

void CBtServiceView::AsyncCompleted()

	{

	}

class CCmdBtsvc : public CCommandBase, public CBtServiceView 

	{

public:

	static CCommandBase* NewLC();

	~CCmdBtsvc();

private:

	CCmdBtsvc();

	void DoScanDeviceL();

	void DoListServiceL();

	void DoAttributeL();

	void DoLocalL();

	void DoListUuidFilterL();

	void SelectBTDeviceL(TBTDeviceName& aName, TBTDevAddr& aBDAddr, TBTDeviceClass& aDevClass);

	TBool GetBTDevClassFromRegistryL(TBTDevAddr& aBDAddr, TBTDeviceClass& aDevClass);

#ifdef SUPPORT_ONOFF

	void SetEnabledL(TBool aEnable);

	void ShowStatusL();

	TBool GetPowerStateL();

#endif

private: // From CCommandBase.

	virtual const TDesC& Name() const;

	virtual void DoRunL();

	virtual void ArgumentsL(RCommandArgumentList& aArguments);

	virtual void OptionsL(RCommandOptionList& aOptions);

private:

	virtual void PrintTextMsg(TInt aVerboseLevel, const TDesC& aMsg);

	virtual void AsyncCompleted();

private:

	CBtServicesEng* iEngine; 

	CActiveSchedulerWait* iActiveWait;

	RArray<TBool> iVerbose;

	HBufC* iOptBTAddr;

	HBufC* iOptSvcHandle;	//service handle

	HBufC* iOptUuidFilter;	//uuid filter

	enum TBtSvcCmd

		{

		ECmdDevice,

		ECmdService,

		ECmdAttribute,

		ECmdLocal,

		ECmdUuid,

		ECmdStatus,

		ECmdEnable,

		ECmdDisable,

		};

	TBtSvcCmd iCommand;

	CBTEngSettings* iSettings;

	};

CCommandBase* CCmdBtsvc::NewLC()

	{

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

	CleanupStack::PushL(self);

	self->BaseConstructL();

	return self;

	}

CCmdBtsvc::CCmdBtsvc()

	{

	iActiveWait = new (ELeave) CActiveSchedulerWait;

	}

CCmdBtsvc::~CCmdBtsvc()

	{

#ifdef SUPPORT_ONOFF

	delete iSettings;

#endif

	delete iOptBTAddr;

	delete iOptSvcHandle;

	delete iOptUuidFilter;

	delete iActiveWait;

	delete iEngine;

	iVerbose.Close();

	}

void CCmdBtsvc::PrintTextMsg(TInt aVerboseLevel, const TDesC& aMsg)

	{

	TInt VerboseLevel = iVerbose.Count();

	if (aVerboseLevel <= VerboseLevel)

		Printf(aMsg);

	}

void CCmdBtsvc::AsyncCompleted()

	{

	if (iActiveWait->IsStarted())

		{

		iActiveWait->AsyncStop();

		}

	}

const TDesC& CCmdBtsvc::Name() const

	{

	_LIT(KName, "btservices");

	return KName;

	}

void CCmdBtsvc::ArgumentsL(RCommandArgumentList& aArguments)

	{

	_LIT(KArgCommand, "command");

	aArguments.AppendEnumL((TInt&)iCommand, KArgCommand);

	}

void CCmdBtsvc::OptionsL(RCommandOptionList& aOptions)

	{		

	aOptions.AppendStringL(iOptBTAddr, _L("address"));

	aOptions.AppendStringL(iOptSvcHandle, _L("record"));

	aOptions.AppendStringL(iOptUuidFilter, _L("uuid"));		

	aOptions.AppendBoolL(iVerbose, _L("verbose"));

	}

void CCmdBtsvc::DoRunL()

	{

	switch (iCommand)

		{

		case ECmdDevice:

			DoScanDeviceL();

			break;

		case ECmdService:

			DoListServiceL();

			break;

		case ECmdAttribute:

			DoAttributeL();

			break;

		case ECmdLocal:

			DoLocalL();

			break;

		case ECmdUuid:

			DoListUuidFilterL();

			break;

#ifdef SUPPORT_ONOFF

		case ECmdStatus:

			ShowStatusL();

			break;

		case ECmdEnable:

			SetEnabledL(ETrue);

			break;

		case ECmdDisable:

			SetEnabledL(EFalse);

			break;

#endif

		default:	

			LeaveIfErr(KErrArgument, _L("Invalid command"));

		}

	}

void CCmdBtsvc::DoAttributeL()

	{

	TInt err;

	//if want to query full attribute set of one particular service,

	//call CBtServicesEng::GetAttributesL()

	if (iOptSvcHandle && iOptSvcHandle->Length())

		{

		iEngine = CBtServicesEng::NewL();

		iEngine->SetView(this);

		iEngine->CancelSdpAgent();

		iEngine->DeleteSdpAgent();

		err = iEngine->BluetoothReady();

		LeaveIfErr(err, _L("Bluetooth not ready"));

		TBTDeviceName Name; 

		TBTDevAddr BDAddr;

		TBTDeviceClass DevClass;

		//iOptSvcHandle should begin with "0x" (hex)

		if ((iOptSvcHandle->Left(2))==_L("0x"))

			{

			TSdpServRecordHandle Handle;

			TLex lex(*iOptSvcHandle);

			lex.SkipAndMark(2);

			err = lex.Val(Handle, EHex);

			LeaveIfErr(err, _L("Service Handle:\"%S\" is not in valid format"), iOptSvcHandle);

			SelectBTDeviceL(Name, BDAddr, DevClass);

			Printf(_L("==============================================\r\n"));

			iEngine->GetDeviceAttributesL(BDAddr, Name, Handle);

			//wait for results

			iActiveWait->Start();

			}

		else

			LeaveIfErr(KErrArgument, _L("Service Handle:\"%S\" is not in valid format"), iOptSvcHandle);		

		}

	else

		LeaveIfErr(KErrArgument, _L("use -r to specify a service record handle"));

	}

//do a BT device scan with RHostResolver,

//and make a list of BT addresses, device name, and device class

//

void CCmdBtsvc::DoScanDeviceL()

	{

	TInt err;

	TInt ItemsFound = 0;

	TBTDevAddr BDAddr;

	TBTDeviceName Name;

	TBTDeviceClass DevClass;

	Printf(_L("Scanning for BT devices ...\r\n"));

	RSocketServ SktSrv;

	CleanupClosePushL(SktSrv);

	err = SktSrv.Connect();

	LeaveIfErr(err, _L("Could not connect to socket server"));

	RHostResolver Host;

	CleanupClosePushL(Host);

	RHostResolver HostForName;

	CleanupClosePushL(HostForName);

	TProtocolDesc ProtocolInfo;

	err = SktSrv.FindProtocol(_L("BTLinkManager"), ProtocolInfo);

	User::LeaveIfError(err);

	err = Host.Open(SktSrv, ProtocolInfo.iAddrFamily , ProtocolInfo.iProtocol);

	LeaveIfErr(err, _L("Could not open host resolver"));

	err = HostForName.Open(SktSrv, ProtocolInfo.iAddrFamily , ProtocolInfo.iProtocol);

	LeaveIfErr(err, _L("Could not open host resolver"));

	TInquirySockAddr Inq;	

	Inq.SetIAC(KGIAC);

	Inq.SetAction(KHostResInquiry/*|KHostResIgnoreCache*/);

	TNameEntry Result;

	err = Host.GetByAddress(Inq, Result);

	//this is for querying name

	TInquirySockAddr InqName;	

	InqName.SetAction(KHostResName);

	TNameEntry ResultName;

	Printf(_L("========================================================\r\n"));

	Printf(_L("BTAddr         | DeviceClass| Name\r\n"));

	Printf(_L("========================================================\r\n"));

	while(1)

		{

		if (err == KErrNone)

			{

			ItemsFound++;

			TInquirySockAddr& sa = TInquirySockAddr::Cast(Result().iAddr);

			const TBTDevAddr& bdaddr = sa.BTAddr();

			BDAddr = bdaddr;

			Name = Result().iName;

			TUint16 MajorServiceClass = sa.MajorServiceClass(); 

			DevClass = TBTDeviceClass(

					MajorServiceClass, sa.MajorClassOfDevice(), sa.MinorClassOfDevice() );

			TBuf<128> BTReadAddress;

			BDAddr.GetReadable(BTReadAddress);

			//query its name

			InqName.SetBTAddr(bdaddr);

			err = HostForName.GetByAddress(InqName, ResultName);			

			if (err==KErrNone)

				Name = ResultName().iName;

			else

				Name.Format(_L("Unable to get the name, err=%d"), err);

			Printf(_L("0x%S | 0x%08x | \"%S\" \r\n"), 

					&BTReadAddress, DevClass.DeviceClass(), &Name);

			err = Host.Next(Result);

			}

		else if (err == KErrEof)

			{

			break;

			}

		else

			LeaveIfErr(err, _L("Resolving address failed"));

		}

	CleanupStack::PopAndDestroy();

	CleanupStack::PopAndDestroy();

	CleanupStack::PopAndDestroy();

	Printf(_L("%d devices found\r\n"),ItemsFound);

	}

//NOT TESTED YET, do not use

//aBDAddr:[in]

//aDevClass:[out]	

TBool CCmdBtsvc::GetBTDevClassFromRegistryL(TBTDevAddr& aBDAddr, TBTDeviceClass& aDevClass)

	{

	TInt err;

	TBuf<128> buf;

	aBDAddr.GetReadable(buf);

	Printf(_L("Query DeviceClass for BTAddr:0x%S\r\n"), &buf);

	RBTRegServ Srv;

	CleanupClosePushL(Srv);

	err = Srv.Connect();

	User::LeaveIfError(err);

	RBTRegistry Reg;

	CleanupClosePushL(Reg);

	err = Reg.Open(Srv);

	User::LeaveIfError(err);

	TBTNamelessDevice Dev;

	Dev.SetAddress(aBDAddr);

	TRequestStatus status;

	Reg.GetDevice(Dev, status);

	User::WaitForRequest(status);

	err = status.Int();

	User::LeaveIfError(err);

	if (err == KErrNone )

		{

		aDevClass = Dev.DeviceClass();		

		}

	CleanupStack::PopAndDestroy();	

	CleanupStack::PopAndDestroy();	

	return ETrue;

	}

//select a BT device either from RNotifier, 

//or using BT address string if it is specified

//aName: [out]

//aBDAddr: [out]

//aDevClass: [out]

void CCmdBtsvc::SelectBTDeviceL(TBTDeviceName& aName, TBTDevAddr& aBDAddr, TBTDeviceClass& aDevClass)

	{

	TInt err;

	if (iOptBTAddr && iOptBTAddr->Length()>0)

		//use RHostResolver to get name and device class

		{

		Printf(_L("Querying name for \"%S\"...\r\n"), iOptBTAddr);

		RSocketServ SktSrv;

		CleanupClosePushL(SktSrv);

		err = SktSrv.Connect();

		LeaveIfErr(err, _L("Could not connect to socket server"));

		RHostResolver Host;

		CleanupClosePushL(Host);

		TProtocolDesc ProtocolInfo;

		err = SktSrv.FindProtocol(_L("BTLinkManager"), ProtocolInfo);

		User::LeaveIfError(err);

		err = Host.Open(SktSrv, ProtocolInfo.iAddrFamily , ProtocolInfo.iProtocol);

		LeaveIfErr(err, _L("Could not open host resolver"));

		TBTDevAddr Addr;