/*

* Copyright (c) 2002-2006 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:  Observer class for platformwide events

*

*/

#include <centralrepository.h>

#include "wlmplatformsubscriber.h"

#include "am_debug.h"

// ============================ MEMBER FUNCTIONS ===============================

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

// CWlmPlatformSubscriber::CWlmPlatformSubscriber

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CWlmPlatformSubscriber::CWlmPlatformSubscriber(

    TWlmSubscribeType aType,

    MWlmPlatformResponder& aCallback,

    const TUid& aCategory,

    const TUint aKey ) :

    CActive( CActive::EPriorityStandard ),

    iType( aType ),

    iCallback( aCallback ),

    iCategory( aCategory ),

    iKey( aKey ),

    iCenRep( NULL )

    {

    DEBUG( "CWlmPlatformSubscriber::CWlmPlatformSubscriber()" );

    }

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

// CWlmPlatformSubscriber::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CWlmPlatformSubscriber::ConstructL()

    {

    DEBUG( "CWlmPlatformSubscriber::ConstructL()" );

    CActiveScheduler::Add( this );

    // In case PubSub, attach to a certain key

    if ( iType == EWlmSubscribeTypePubSub )

        {

        iProperty.Attach( iCategory, iKey );    

        }

    // In case CenRep, open connection to a certain repository

    else if ( iType == EWlmSubscribeTypeCenRep )

        {

        iCenRep = CRepository::NewL( iCategory );

        }

    }

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

// CWlmPlatformSubscriber::NewL

// Two-phased constructor.

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

//

CWlmPlatformSubscriber* CWlmPlatformSubscriber::NewL(

    TWlmSubscribeType aType,

    MWlmPlatformResponder& aCallback,

    const TUid& aCategory,

    const TUint aKey )

    {

    DEBUG( "CWlmPlatformSubscriber::NewL()" );

    CWlmPlatformSubscriber* self = new( ELeave ) CWlmPlatformSubscriber(

        aType,

        aCallback,

        aCategory,

        aKey );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

// Destructor

CWlmPlatformSubscriber::~CWlmPlatformSubscriber()

    {

    DEBUG( "CWlmPlatformSubscriber::~CWlmPlatformSubscriber()" );

    Cancel();

    if ( iType == EWlmSubscribeTypePubSub )

        {        

        iProperty.Close();   

        }

    else if ( iType == EWlmSubscribeTypeCenRep )

        {

        delete iCenRep;

        }    

    }

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

// CWlmPlatformSubscriber::IssueRequest

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

//

void CWlmPlatformSubscriber::IssueRequest()

    {

    DEBUG( "CWlmPlatformSubscriber::IssueRequest()" );

    if( !IsActive() )

        {

        if ( iType == EWlmSubscribeTypePubSub )

            {

            DEBUG( "CWlmPlatformSubscriber::IssueRequest() - requestType == PubSub" );

            iProperty.Subscribe( iStatus );

            }

        else if ( iType == EWlmSubscribeTypeCenRep )     

            {

            DEBUG( "CWlmPlatformSubscriber::IssueRequest() - requestType == CenRep" );

            iCenRep->NotifyRequest( iKey, iStatus );

            }

        SetActive();

        }

    else

        {

        DEBUG("CWlmPlatformSubscriber::IssueRequest() - already active, ignoring");

        }

    }

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

// CWlmPlatformSubscriber::DoCancel

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

//

void CWlmPlatformSubscriber::DoCancel()

    {

    DEBUG( "CWlmPlatformSubscriber::DoCancel()" );

    if ( iType == EWlmSubscribeTypePubSub )

        {

        iProperty.Cancel();

        }

    else if ( iType == EWlmSubscribeTypeCenRep )    

        {

        iCenRep->NotifyCancel( iKey );

        }    

    }

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

// CWlmPlatformSubscriber::RunError

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

//

TInt CWlmPlatformSubscriber::RunError(

    TInt aError )

    {

    DEBUG( "CWlmPlatformSubscriber::RunError()" );

    if ( aError != KErrNone )

        {

        DEBUG1( "CWlmPlatformSubscriber::RunError() - aError = %d", aError );    

        }

    return KErrNone;

    }

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

// CWlmPlatformSubscriber::RunL

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

//

void CWlmPlatformSubscriber::RunL()

    {

    DEBUG( "CWlmPlatformSubscriber::RunL()" );

    DEBUG1( "CWlmPlatformSubscriber::RunL() - iStatus = %d", iStatus.Int() );

    iCallback.HandlePropertyChangedL( iCategory, iKey );

    IssueRequest();

    }

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

// CWlmPlatformSubscriber::Get

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

//    

TInt CWlmPlatformSubscriber::Get( TInt& aValue )

    {

    DEBUG( "CWlmPlatformSubscriber::Get()" );

    if ( iType == EWlmSubscribeTypePubSub )

        {

        return iProperty.Get( aValue );

        }

    else if ( iType == EWlmSubscribeTypeCenRep )

        {

        return iCenRep->Get( iKey, aValue );

        }

    return KErrNotFound;

    }