/*

* Copyright (c) 2006-2007 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:  Monitors BTRegistry device changes and sends the 

*				 new status to listener

*

*/

#include "btregistryobserver.h"

#include "debug.h"

#include <bt_subscribe.h>

const TInt KDeviceArrayDefaultSize=10;

// ---------------------------------------------------------------------

// Constructor

// ---------------------------------------------------------------------

CBTRegistryObserver::CBTRegistryObserver(MBTRegistryObserver* aObserver, 

    const TBTRegistrySearch aPattern) 

    	: CActive(CActive::EPriorityHigh), 

      	  iObserver(aObserver),   iSearchPattern(aPattern)

    {    

    TRACE_FUNC_ENTRY

    CActiveScheduler::Add(this);

    // The priority will be EPriorityHigh only initially.

    // after the first successfull retrieval of the devicelist

    // the priority will be changed to EPriorityLow.

    // This will make the 1st devicelist drawn as quickly as possible,

    // but the subsequent refrehes will not decrease the responsiveness

    // of the Btui.

    iAnotherEventPending=EFalse;

    TRACE_FUNC_EXIT

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::NewL

// ---------------------------------------------------------------------

CBTRegistryObserver* CBTRegistryObserver::NewL(MBTRegistryObserver* aObserver,

	  const TBTRegistrySearch aPattern)

    {

    CBTRegistryObserver* self = new (ELeave) CBTRegistryObserver(aObserver, aPattern);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

// ---------------------------------------------------------------------

// Destructor

// ---------------------------------------------------------------------    

CBTRegistryObserver::~CBTRegistryObserver()

    {

    TRACE_FUNC_ENTRY

    Cancel();

    iProperty.Close();

    delete iDevMan;

    DeleteAllocatedDevices();

    delete iRegDeviceArray;

    iRegDeviceArray=NULL;

    TRACE_FUNC_EXIT

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::ConstructL()

// ---------------------------------------------------------------------

void CBTRegistryObserver::ConstructL()

    {

    TRACE_FUNC_ENTRY

	iRegDeviceArray = new (ELeave) CBTDeviceArray(KDeviceArrayDefaultSize);    

    iDevMan =  CBTEngDevMan::NewL(this);

    iDevMan->SetPriority(CActive::EPriorityHigh);

    iProperty.Attach(KPropertyUidBluetoothCategory, KPropertyKeyBluetoothGetRegistryTableChange);

    StartIfNotRunning();

    TRACE_FUNC_EXIT

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::Refresh

// This will simulate registry change event.

// ---------------------------------------------------------------------    

void CBTRegistryObserver::Refresh()

	{

	TRACE_FUNC_ENTRY

	__ASSERT_DEBUG(iDevMan, User::Invariant());

    if (iDevMan->IsActive())

    	{

    	// An attempt to start a new search, during a prior

    	// one. 

    	iAnotherEventPending=ETrue;

    	return;

    	}   

	Cancel();

    DeleteAllocatedDevices();

    iDevMan->GetDevices(iSearchPattern, iRegDeviceArray);

	StartIfNotRunning();    

    TRACE_FUNC_EXIT    

	}

// ---------------------------------------------------------------------

// CBTRegistryObserver::StartIfNotRunning

// this have to be called again each time there has been registry event

// ---------------------------------------------------------------------

void CBTRegistryObserver::StartIfNotRunning()

    {

    TRACE_FUNC_ENTRY

    if (!IsActive())

        {

        TRACE_INFO(_L("Start()"))

        iIsStopped = EFalse;

        iProperty.Subscribe(iStatus);

        SetActive();

        }

    TRACE_FUNC_EXIT        

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::RunL

// From CAtive

// This is called when registry has changed. This will not

// be called when BTRegistry date retrieval is complete, since

// HandleGetDevicesComplete is called when RBTregistry data retrieval

// is complete

// ----------------------------------------------------------------------

void CBTRegistryObserver::RunL()

    {

    TRACE_FUNC_ENTRY

    if(iDevMan && iDevMan->IsActive())

    	{

    	// An attempt to start a new search, during a prior

    	// one. We will not start a new search, but we

    	// will do it after the current search is complete

    	iAnotherEventPending=ETrue;

    	StartIfNotRunning();

		TRACE_FUNC_EXIT    	

    	return;

    	}

    if(!IsActive())

    	SetPriority(CActive::EPriorityLow);

    TInt registryTable;

    iProperty.Get(registryTable);

    iAnotherEventPending=EFalse;

    if(iDevMan && iStatus.Int() == KErrNone && registryTable == KRegistryChangeRemoteTable)

        {

        TRACE_INFO(_L("Remote table change"))

        DeleteAllocatedDevices();

        iDevMan->GetDevices(iSearchPattern, iRegDeviceArray);

        }

    StartIfNotRunning();

    TRACE_FUNC_EXIT

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::HandleGetDevicesComplete

// From MBTEngDevManObserver

//

// This function will not filter out refreshes with no changes,

// since the connect status may have been changed in those cases, and

// this class does not know about that

//

// It is worth to mention that CBTDeviceContainer will not refresh parts

// of the screen that are not changed.

// ---------------------------------------------------------------------

void  CBTRegistryObserver::HandleGetDevicesComplete(TInt aErr, CBTDeviceArray* aDeviceArray)

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO((_L("aErr = %d"), aErr))

    // the initial view refresh is done. We will decrese

    // the priority of this component to quarantee UI

    // responsiveness

    if(!iDevMan->IsActive())

    	iDevMan->SetPriority(CActive::EPriorityLow);

    TRAP_IGNORE(

		if( aErr != KErrNotFound)

			iObserver->RegistryChangedL(aDeviceArray );

		else

			{

			// handle the empty response case. The DevMan may issue

			// NULL in that case 

			iObserver->RegistryChangedL(iRegDeviceArray );	

			}

	);	

    DeleteAllocatedDevices();

	if(iAnotherEventPending)	

		{

		// Current results are not sent further, since

		// there has been changes, witch may have rendered the current

		// results allready obsolate. Therefore a refresh is made instead

		iAnotherEventPending=EFalse;

        iDevMan->GetDevices(iSearchPattern, iRegDeviceArray);

		}

    TRACE_FUNC_EXIT		

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::DeleteAllocatedDevices

// ---------------------------------------------------------------------

void CBTRegistryObserver::DeleteAllocatedDevices()

	{

	TRACE_FUNC_ENTRY

	if(iRegDeviceArray)

		{

        iRegDeviceArray->ResetAndDestroy();

        }

    TRACE_FUNC_EXIT		

	}

// ---------------------------------------------------------------------

// CBTRegistryObserver::Cancel

// From CActive

// ---------------------------------------------------------------------

void CBTRegistryObserver::Cancel()

    {

    TRACE_FUNC_ENTRY

    iIsStopped = ETrue;

    iAnotherEventPending=EFalse;    

    CActive::Cancel();

    if (iDevMan) iDevMan->Cancel();

    DeleteAllocatedDevices();

    TRACE_FUNC_EXIT    

    }

// ---------------------------------------------------------------------

// CBTRegistryObserver::DoCancel

// From CActive

// ---------------------------------------------------------------------

void CBTRegistryObserver::DoCancel()

	{

	TRACE_FUNC_ENTRY

    iProperty.Cancel();	

    TRACE_FUNC_EXIT

	}