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

/**
 @file
 @internalComponent
*/

#include <bluetooth/logger.h>
#include <es_prot.h>
#include <bt_subscribe.h>
#include "CBTAddrSubscriber.h"

#ifdef __FLOG_ACTIVE
_LIT8(KLogComponent, LOG_COMPONENT_PAN_BNEP);
#endif

CBTAddrSubscriber::CBTAddrSubscriber (TBTDevAddr& aAddr, CBnepLocalDevice& aLocal)
        : CActive(EPriorityStandard), iAddr(aAddr), iOwner(aLocal)
    {
    LOG_FUNC
    CActiveScheduler::Add(this);
    }

CBTAddrSubscriber::~CBTAddrSubscriber()
    {
    LOG_FUNC
    Cancel();
    }

/**
   Create an address subscriber and queue the first request.
   @param aAddr The address to update with published data.
   @param aLocal The local device node which will be informed when the device
   address changes.
*/
CBTAddrSubscriber* CBTAddrSubscriber::NewL (TBTDevAddr& aAddr, CBnepLocalDevice& aLocal)
    {
    LOG_STATIC_FUNC
    CBTAddrSubscriber* self = new(ELeave) CBTAddrSubscriber(aAddr, aLocal);
    CleanupStack::PushL(self);
    User::LeaveIfError(self->iDevAddrProperty.Attach(KPropertyUidBluetoothCategory, KPropertyKeyBluetoothGetLocalDeviceAddress));

    // Attempt to fetch the device address property and activate the AO subscription on 
    // the property so that the upper layers can be notified when it is initialised by 
    // the BT stack. If the property hasn't been initialised yet, SyncFetch will 
    // return KErrUnderflow. In this context it is alright to ignore that return value.
    self->SyncFetch(ETrue);
    LOG(_L8("CBTAddrSubscriber requesting notifications"));
    CleanupStack::Pop(self);
    return self;
    }

/**
   Having been notified of a BDADDR change, notify owner if we
   have an address at the moment.
*/
void CBTAddrSubscriber::RunL ()
    {
    LOG_FUNC
    // Don't plan to restart the active object since the device address
    // is unlikely to change after this runs once. However, the AO
    // will reactivate if the property could not be fetched
    // properly (i.e. err != KErrNone)
    TInt err = SyncFetch(); 
    if(KErrNone == err)
        {
        // Notify the upper layers of the address update.
        iOwner.BDADDRChanged();
        }
    else
        {
        iDevAddrProperty.Subscribe(iStatus);
        SetActive();
        }
    }

void CBTAddrSubscriber::DoCancel ()
    {
    LOG_FUNC
    iDevAddrProperty.Cancel();
    }

/**
   Fetches the device address property synchronously if it exists.
   Conditionally queue a request to be notified of future BDADDR changes.
   By default, a request is not queued automatically.
   @param aRestart specify whether to queue request and schedule the active object. Default is EFalse.
   @return KErrUnderflow The property has zero length (i.e. is uninitialised)
   @internalComponent
*/
TInt CBTAddrSubscriber::SyncFetch (TBool aRestart)
    {
    LOG_FUNC
    TInt retval = KErrNone;
    TBuf8<KBTDevAddrSize> addr;
    iDevAddrProperty.Get(addr);
    if (addr.Length())
        {
        iAddr = TBTDevAddr(addr);
        LOG_BT(_L8("Setting address to %S"), iAddr);
        }
    else
        {
        // The property hasn't been initialised yet.
        retval = KErrUnderflow;
        }

    if(aRestart)
        {
		if(retval == KErrNone)
			{
			// The BT stack was already up when BNEP started.  Call the
			// BDADDRChanged method to inform the NIF that the link layer 
			// is up.
			iOwner.BDADDRChanged();
			}
		else
			{
	        // Watch out for any future updates on the property.
	        iDevAddrProperty.Subscribe(iStatus);
	        SetActive();
			}
        }
    return retval;
    }