/*
* Copyright (c) 2004 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:  Implementation
*
*/

#include <btmanclient.h>
#include <bt_sock.h>

#ifdef __SERIES60_
	#include <btnotif.h>
#endif

#include "CTcBtManager.h"
#include "TTcBtFactory.h"

#include "debuglog.h"

/// See https://www.bluetooth.org/foundry/assignnumb/document/service_discovery
const TInt KTcSerialClassID( 0x1101 );
const TInt KTcRootBrowseGroup( 0x1002 );

/// Name and description of our BT service in SDP.
_LIT( KTcServiceName, "TestClient" );
_LIT( KTcServiceDescription, "Serial IUTCP connection" );

CTcBtManager* CTcBtManager::NewL( const TTcBtFactory& aFactory )
	{
	CTcBtManager* self = new( ELeave ) CTcBtManager( aFactory );

	CleanupStack::PushL( self );
	self->ConstructL();
	CleanupStack::Pop( self );

	return self;
	}

CTcBtManager::~CTcBtManager()
	{
	LOG( _L("CTcBtManager::~CTcBtManager()") );
	Close();
	iSockServ.Close();
	}

CTcBtManager::CTcBtManager( const TTcBtFactory& /*aFactory*/ )
	{
	}

void CTcBtManager::ConstructL()
	{
	LOG( _L("CTcBtManager::ConstructL()") );
	User::LeaveIfError( iSockServ.Connect() );
	iConn.SetObserver( this );
	iConn.SetConnection( &iSockServ, NULL );
	}

void CTcBtManager::ConnectL( TInetAddr* /*aRemoteAddr*/ )
	{
	LOG( _L("CTcBtManager::ConnectL()") );
	// Make sure that BT is enabled
	TurnOnBtL();

	// Start waiting for connections
	iConn.ConnectL();

#ifndef __BLUETOOTH_API_V2__
	// Define security requirements (lowest possible)
	SetSecurityL( iConn.LocalPort(), EFalse, EFalse, EFalse );
#endif

	// Start advertising the local BT channel for our service
	StartAdvertiserL( iConn.LocalPort() );
	LOG( _L("CTcBtManager::ConnectL() end") );
	}

void CTcBtManager::Close()
	{
	LOG( _L("CTcBtManager::Close()") );
	// Stop advertising our service
	StopAdvertiser();

	// Shut down the service port
	iConn.Close();
	}

void CTcBtManager::Send( const TDesC8& aDes )
	{
	iConn.Send( aDes );
	}

void CTcBtManager::Receive( TDes8& aDes )
	{
	iConn.Receive( aDes );
	}

void CTcBtManager::ReceiveOneOrMore( TDes8& aDes )
	{
	iConn.ReceiveOneOrMore( aDes );
	}

void CTcBtManager::SetObserver( MTcBearerObserver* aObserver )
	{
	iObserver = aObserver;
	}

void CTcBtManager::GetLocalAddressL( TDes& /*aDes*/ )
	{
	User::Leave( KErrNotSupported );
	}

void CTcBtManager::BearerCompletion( MTcBearerObserver::TOperation aOp,
									 TInt aStatus )
	{
	LOG( _L("CTcBtManager::BearerCompletion( %d, %d ) start"), aOp, aStatus );
	if( ( aOp == MTcBearerObserver::EConnect ) && !aStatus )
		{
		// A client has connected, mark the service as fully booked
		// It's safe to ignore any leaves
		TRAP_IGNORE( MakeAvailableL( EFalse ) )
		}

	if( iObserver )
		{
		iObserver->BearerCompletion( aOp, aStatus );
		}
	LOG( _L("CTcBtManager::BearerCompletion() end") );
	}

void CTcBtManager::StartAdvertiserL( TInt aChannel )
    {
	LOG( _L("CTcBtManager::StartAdvertiserL( %d ) start"), aChannel );
	StopAdvertiser();

	User::LeaveIfError( iSdpServ.Connect() );
	User::LeaveIfError( iSdpDb.Open( iSdpServ ) );

	// Create service record
	iSdpDb.CreateServiceRecordL( KTcSerialClassID, iSdpRecord );

 	LOG( _L("CTcBtManager::StartAdvertiserL() created service record") );

	// Add a Protocol to the record
	CSdpAttrValueDES* protocolDesList = CSdpAttrValueDES::NewDESL( NULL );
	CleanupStack::PushL( protocolDesList );

    TBuf8< 1 > channel;
    channel.Append( (TChar)aChannel );

	protocolDesList
	->StartListL()	 //  List of protocols required for this method
		->BuildDESL()
		->StartListL()
			->BuildUUIDL( KL2CAP )
		->EndListL()

		->BuildDESL()
		->StartListL()
			->BuildUUIDL( KRFCOMM )
			->BuildUintL( channel )
		->EndListL()
	->EndListL();

	iSdpDb.UpdateAttributeL( iSdpRecord,
							 KSdpAttrIdProtocolDescriptorList,
							 *protocolDesList );

	CleanupStack::PopAndDestroy( protocolDesList );

	LOG( _L("CTcBtManager::StartAdvertiserL() adding uid") );

	// Add a Unique ID to the record
	iSdpDb.UpdateAttributeL( iSdpRecord,
							 KSdpAttrIdServiceID,
							 0x10001234 );	// REPLACE!!

	LOG( _L("CTcBtManager::StartAdvertiserL() adding name") );

	// Add a name to the record
	iSdpDb.UpdateAttributeL( iSdpRecord,
							 KSdpAttrIdBasePrimaryLanguage
							 + KSdpAttrIdOffsetServiceName,
							 KTcServiceName );

	LOG( _L("CTcBtManager::StartAdvertiserL() adding description") );

	// Add a description to the record
	iSdpDb.UpdateAttributeL( iSdpRecord,
							 KSdpAttrIdBasePrimaryLanguage
							 + KSdpAttrIdOffsetServiceDescription,
							 KTcServiceDescription );

	// "Attach" our service to the root browse group.
	// This is required by some BT devices for successful remote SDP query
	TUUID rootTUUID( KTcRootBrowseGroup );
	CSdpAttrValueUUID* rootBrowseGroupAttr = CSdpAttrValueUUID::NewUUIDL( rootTUUID );
	CleanupStack::PushL( rootBrowseGroupAttr );
	iSdpDb.UpdateAttributeL( iSdpRecord, KSdpAttrIdBrowseGroupList, *rootBrowseGroupAttr );
	CleanupStack::PopAndDestroy( rootBrowseGroupAttr );

	MakeAvailableL( ETrue );
	LOG( _L("CTcBtManager::StartAdvertiserL() end") );
	}

void CTcBtManager::StopAdvertiser()
	{
	LOG( _L("CTcBtManager::StopAdvertiser()") );
	if( iSdpDb.SubSessionHandle() && iSdpRecord )
		{
		TRAP_IGNORE( iSdpDb.DeleteRecordL( iSdpRecord ) )
		iSdpRecord = 0;
		}
	}

void CTcBtManager::MakeAvailableL( TBool aIsAvailable )
    {
	// Fully unused (0xFF) or Fully used (0x00)
    TUint state = aIsAvailable ? 0xFF : 0x00;
	LOG( _L("CTcBtManager::MakeAvailableL( %d ) start, state = %d"), aIsAvailable, state );

     //  Update the availibility attribute field
    iSdpDb.UpdateAttributeL( iSdpRecord, KSdpAttrIdServiceAvailability, state );

    //  Mark the record as changed - by increasing its state number (version)
    iSdpDb.UpdateAttributeL( iSdpRecord, KSdpAttrIdServiceRecordState,
							 ++iSdpRecordState );
   	LOG( _L("CTcBtManager::MakeAvailableL() end") );
	}

// Note that security settings should be implemented for 8.x in BtConnection level
// That is not done yet!!!!! TODO when 8.x hw must be used
#ifndef __BLUETOOTH_API_V2__
void CTcBtManager::SetSecurityL( TInt aChannel,
								 TBool aAuthentication,
								 TBool aEncryption,
								 TBool aAuthorisation )
	{
   	LOG( _L("CTcBtManager::SetSecurityL() start") );
	RBTMan secManager;
	User::LeaveIfError( secManager.Connect() );
	CleanupClosePushL( secManager );

	RBTSecuritySettings secSession;
	User::LeaveIfError( secSession.Open( secManager ) );
	CleanupClosePushL( secSession );

	// Define security requirements for our application and RFCOMM.
	TBTServiceSecurity settings( TUid::Uid( 0x10001234 ), KSolBtRFCOMM, aChannel );
	settings.SetAuthentication( aAuthentication );
	settings.SetEncryption( aEncryption );
	settings.SetAuthorisation( aAuthorisation );

	// Register security settings, wait for async operation to complete
	TRequestStatus status;
	secSession.RegisterService( settings, status );
	User::WaitForRequest( status );

	// Report any errors
	User::LeaveIfError( status.Int() );

	CleanupStack::PopAndDestroy( 2 );	//	secSession, secManager
   	LOG( _L("CTcBtManager::SetSecurityL() end") );
	}
#endif

void CTcBtManager::TurnOnBtL()
	{
#ifdef __SERIES60_
   	LOG( _L("CTcBtManager::TurnOnBtL() start") );

	// Connect to notitifier service
	RNotifier notifier;
	User::LeaveIfError( notifier.Connect() );
	CleanupClosePushL( notifier );

	// Request notification about power, don't care about the results 
	// This results in a UI popup being displayed to the user shortly
	TRequestStatus status;
	TPckgBuf< TBool > pckg;
	TPckgBuf< TBool > resultPckg;
	notifier.StartNotifierAndGetResponse( status,
										  KPowerModeSettingNotifierUid,
										  pckg,
										  resultPckg );
	User::WaitForRequest( status );
	// Disable error checking. this would make auto-reconnect impossible
	// The power notifier reports an error if the time between the last
	// connection attempt and this connection is too small (even if it
	// doesn't hurt..)
	//User::LeaveIfError( status.Int() );

	notifier.CancelNotifier( KPowerModeSettingNotifierUid );

	CleanupStack::PopAndDestroy(); // notifier
   	LOG( _L("CTcBtManager::TurnOnBtL() end") );
#endif
	}