/*

* 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:  CCFEcomObserver class implementation.

*

*/

#include "cfecomobserver.h"

#include "cftrace.h"

#include "cfstateobserver.h"

// LOCAL DEFINITIONS

#ifdef _DEBUG

_LIT( KPanicCat, "CFEcomObs" );

// Panic codes

enum TPanicReason

    {

    EAlreadyActive,

    EInvalidObserver

    };

// LOCAL FUNCTIONS

LOCAL_C void Panic( TInt aReason )

    {

    User::Panic( KPanicCat, aReason );

    }

#endif

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

// CCFEComObserver::CCFEComObserver

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

//

CCFEComObserver::CCFEComObserver(): CActive( EPriorityStandard )

	{

    FUNC_LOG;

    CActiveScheduler::Add( this );

	}

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

// CCFEComObserver::NewLC

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

//

CCFEComObserver* CCFEComObserver::NewLC()

	{

    FUNC_LOG;

	CCFEComObserver* self = new ( ELeave ) CCFEComObserver();

	CleanupStack::PushL( self );

	self->ConstructL();

	return self;

	}

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

// CCFEComObserver::NewL

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

//

CCFEComObserver* CCFEComObserver::NewL()

	{

    FUNC_LOG;

	CCFEComObserver* self = CCFEComObserver::NewLC();

	CleanupStack::Pop(); // self;

	return self;

	}

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

// CCFEComObserver::ConstructL

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

//

void CCFEComObserver::ConstructL()

	{

    FUNC_LOG;

	iEComSession = &REComSession::OpenL();

	StartObserving();

	}

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

// CCFEComObserver::~CCFEComObserver

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

//

CCFEComObserver::~CCFEComObserver()

	{

    FUNC_LOG;

    // Cancel any request, if outstanding

	Cancel();

    // Clean up memebers

    iObservers.Close();

    if( iEComSession )

        {

        iEComSession->Close();

        }

	}

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

// CCFEComObserver::DoCancel

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

//

void CCFEComObserver::DoCancel()

	{

    FUNC_LOG;

	iEComSession->CancelNotifyOnChange( iStatus );

	}

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

// CCFEComObserver::StartObserving

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

//

void CCFEComObserver::StartObserving()

	{

    FUNC_LOG;

    __ASSERT_DEBUG( !IsActive(), Panic( EAlreadyActive) );

    SetActive();

	iEComSession->NotifyOnChange( iStatus ); 

	}

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

// CCFEComObserver::AddObserverL

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

//

void CCFEComObserver::AddObserverL( MCFStateObserver* aObserver )

    {

    FUNC_LOG;

    __ASSERT_DEBUG( aObserver, Panic( EInvalidObserver ) );

    iObservers.AppendL( aObserver );

    }

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

// CCFEComObserver::RunL

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

//

void CCFEComObserver::RunL()

	{

    FUNC_LOG;

    // Store completion status

    TInt status = iStatus.Int();

    // Continue request

    StartObserving();

    // Notify observers

    if( status == KErrNone )

        {

        NotifyObservers();

        }    

	}

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

// CCFEComObserver::RunError

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

//

TInt CCFEComObserver::RunError( TInt aError )

	{

	return aError;

	}

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

// CCFEComObserver::NotifyObservers

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

//

void CCFEComObserver::NotifyObservers()

    {

    FUNC_LOG;

    INFO( "CCFEComObserver::NotifyObservers - New plug-ins detected, updating" );

    TInt count = iObservers.Count();

    for( TInt i = 0; i < count; i++ )

        {

        TInt err = KErrNone;

        TRAP( err, iObservers[i]->UpdatePlugInsL( ) );

        ERROR( err, "Failed to update plug-ins" );

        }

    }

// End of file