// 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 <e32base.h>
#include <e32std.h>
#include <e32test.h>
#include <c32comm.h>
#include <f32file.h>
#include <bt_subscribe.h>

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
#include <bt_subscribe_partner.h>
#endif

#include <bt_sock.h>
#include "AFHSetter.h"
#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

_LIT(KInstructions, "ffffffffffffffffffff allows all frequencies.\nYou will either be instructed to type in a new number\nor to enter individual bad channels by choosing a sequence\nof numbers in [0, 78]");

inline void __BTDEBUGGER()
// needed to call __DEBUGGER inside an __ASSERT
	{
	__DEBUGGER()
	}

GLDEF_D RTest test(_L("AFH Setter App"));

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"));
	}


void TestL()
	{
	test.Printf(_L("%S\n"), &KInstructions);

	// This function is essential!
	LoadLDD_PDD();
	// For some reason, you have to do the following to
	// ensure that the file server behaves properly.


//	File session
	RFs fs;
	fs.Connect();
	fs.Close();
	
	CAFHSetter* AFHsetter = CAFHSetter::NewL(test);
	//Subscriber* AFHSubscriber = CAFHSubscriber::NewL(test);

	CActiveScheduler::Start();
	
	//delete AFHSubscriber;
	delete AFHsetter;
	}


CAFHSetter* CAFHSetter::NewL(RTest& aTest)
	{
	CAFHSetter* s = new(ELeave) CAFHSetter(aTest);
	CleanupStack::PushL(s);
	s->ConstructL();
	CleanupStack::Pop(s);
	return s;
	}

CAFHSetter::CAFHSetter(RTest& aTest)
: CActive(EPriorityStandard), iTest(aTest)
	{
	CActiveScheduler::Add(this);
	}

CAFHSetter::~CAFHSetter()
	{
	Cancel();
	iTimer.Close();
	iSS.Close();
	}

void CAFHSetter::ConstructL()
	{
	//start timer
	iTimer.CreateLocal();
	//start bluetooth
	iSS.Connect();
	TRequestStatus status;
    //iSS.StartProtocol(KBTAddrFamily,KSockSeqPacket,KBTLinkManager,status);
    iSS.StartProtocol(KBTAddrFamily,KSockSeqPacket,KL2CAP,status);
    User::WaitForRequest(status);
	
	//start publish and subscribe
	_LIT_SECURITY_POLICY_PASS(KPassPolicy);
	TInt err;
	err=iProperty.Define(KPropertyUidBluetoothCategory,
						 KPropertyKeyBluetoothSetAFHHostChannelClassification,
						 RProperty::EByteArray,
						 KPassPolicy,
						 KPassPolicy);
	err=iProperty.Define(KPropertyUidBluetoothCategory,
						 KPropertyKeyBluetoothSetAFHChannelAssessmentMode,
						 RProperty::EInt,
						 KPassPolicy,
						 KPassPolicy);
	__ASSERT_DEBUG(err==0, __BTDEBUGGER());
	
	if (err) test.Printf(_L("Error %d defining property, continuing anyway\n"),err);


	Start();
	}

void CAFHSetter::Start()
	{
	iTest.Console()->ClearScreen();
	SendBluetoothAFHHostChannelClassification(); //send classification as kick off
	GetClassificationBySettingBadChannels();
	iTimer.After(iStatus,1);
	SetActive();
	}

TInt CAFHSetter::SendBluetoothAFHHostChannelClassification()
	{
	//Set channels 3,4,5,6,7,8,9,10,12 and 15 as busy - not to be used by 
	//Bluetooth Adaptive Frequency Hopping.
	RProperty property;
	TBTAFHHostChannelClassification channelClassification;
	_LIT_SECURITY_POLICY_PASS(KPassPolicy);
	TInt ret = KErrNone;
	ret=property.Define(KPropertyUidBluetoothCategory,
				        KPropertyKeyBluetoothSetAFHHostChannelClassification,
				        RProperty::EByteArray,
						KPassPolicy,
						KPassPolicy);
	if(ret!=KErrNone)
			{
			return ret;
			}
	ret = channelClassification.SetChannelRangeBad(3, 10);
	if(ret!=KErrNone)
		{
		return ret;
		}
	ret = channelClassification.SetChannelBad(12);
	if(ret!=KErrNone)
		{
		return ret;
		}
	ret = channelClassification.SetChannelBad(15);
	if(ret!=KErrNone)
		{
		return ret;
		}
	ret = property.Set(KPropertyUidBluetoothCategory,  
					   KPropertyKeyBluetoothSetAFHHostChannelClassification, 
					   channelClassification);
	property.Delete(KPropertyUidBluetoothCategory,
			 KPropertyKeyBluetoothSetAFHHostChannelClassification);
	return ret;
	}

TInt CAFHSetter::GetNextChannelNum()
    {
	TKeyCode code;
	TBuf8<2> character;
	TUint8 byte;
	character.SetLength(0);

	FOREVER
		{
		code = iTest.Console()->Getch();
		iState &= ~KSetChannelsBad;
	
		// If <CR> finish editing string
		if (code == 0x0d)
			{
			return KSendHCC;
			}

		else if (code == 'r' || code == 'R')
			{
			iTest.Console()->Printf(_L("Taking ranges...\n"));
			iState |= KPairs;
			iState &= ~KLast;
			character.SetLength(0);
			}
		
		else if (code == 's' || code == 'S')
			{
			iTest.Console()->Printf(_L("Taking singles...\n"));
			iState &= ~KPairs;
			iState |= KLast;
			character.SetLength(0);
			}
		
		// if <BS> remove last character
		else if (code == 0x08)
			{
			character.SetLength(0);
			}

		else
			{
			if (character.Length() == 0)
				{
				character.Append(code);
				}
			else
				{
				character.Append(code);
				TLex8 lex(character);
				character.SetLength(0);
				TInt err = lex.Val(byte, EDecimal);
				if(!err)
					{
					iTest.Console()->Printf(_L("%02d"),byte);
					if(iState & KLast)
						{
						iTest.Console()->Printf(_L("\n"));
						iChannel2 = byte;
						if(iState & KPairs)
							{
							iState &= ~KLast;
							}
						iState |= KSetChannelsBad;
						}
					else
						{
						iTest.Console()->Printf(_L(", "));
						iChannel1 = byte;
						iState |= KLast;
						}
					return KErrNone;
					}
				else
					{
					__BTDEBUGGER();
					return err;
					}
				}
			}
		}
    }

void CAFHSetter::GetClassificationBySettingBadChannels()
    {
	test.Printf(_L("Please enter a sequence of bad channels [0, 78]\n"));
	test.Printf(_L("Please type 'r' to CHANGE to enter bad channels as RANGES...\n"));
	test.Printf(_L(".... type 's' to CHANGE to enter bad channels SINGLY (default)...\n"));
	test.Printf(_L("Press return to finish\n\n"));
	
	iHCC.Reset();

	for(TUint8 i=0; i<KHCIAFHHostChannelClassificationSize; ++i)
		{
		__ASSERT_DEBUG(iHCC[i] == 0xff, __BTDEBUGGER());
		}
	
	iState = 0;
	iState |= KLast;

	FOREVER
		{
		TInt ret = GetNextChannelNum();
		if(ret==KSendHCC)
			{
			return;
			}
		
		else if(ret!=KErrNone)
			{
			__BTDEBUGGER();
			}
			
		else if(ret==KErrNone && iState&KSetChannelsBad)
			{
			if(iState & KPairs)
				{
				ret = iHCC.SetChannelRangeBad(iChannel1, iChannel2);
				}
			else
				{
				ret = iHCC.SetChannelBad(iChannel2);
				}
				
			if(ret!=KErrNone)
				{
				__BTDEBUGGER();
				}
			}
		else
			{
			__ASSERT_DEBUG(!(iState&KSetChannelsBad), __BTDEBUGGER());
			}
		}
    }

void CAFHSetter::DoCancel()
	{
	iTest.Console()->ReadCancel();
	}

void CAFHSetter::RunL()
	{
	if(TInt err = iStatus.Int()!=KErrNone)
		{
		__BTDEBUGGER();
		}
	TInt ret = iProperty.Set(KPropertyUidBluetoothCategory, KPropertyKeyBluetoothSetAFHHostChannelClassification, iHCC);
	__ASSERT_DEBUG(ret==0, __BTDEBUGGER());
	//second request
	/**/
	ret = iProperty.Set(KPropertyUidBluetoothCategory, KPropertyKeyBluetoothSetAFHHostChannelClassification, iHCC);
	__ASSERT_DEBUG(ret==0, __BTDEBUGGER());
	/**/
	test.Printf(_L("\n\nContinue?\n"));
	TKeyCode code;
	code = iTest.Console()->Getch();
	switch(code)
		{
		case 'n':
		case 'N':
		case 27:
			CActiveScheduler::Stop();
			return;
		default:
			;//continue
		}

	Start();
	}



//....
TInt E32Main()
	{
	CTrapCleanup* cleanupStack=CTrapCleanup::New();
	CActiveScheduler::Install(new CActiveScheduler);

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

	if (err != KErrNone)
		{
		test.Printf(_L("Error %d"), err);
		test.Getch();
		}

	delete cleanupStack;
	return err;
	}