/*

* Copyright (c) 2007-2008 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:  Listener for new ECom plugins

*

*/

#include "sensrvdefines.h"

#include "sensrvecomchangelistener.h"

#include "ssycontrol.h"

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

// Two-phased constructor.

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

//

CSensrvEcomChangeListener* CSensrvEcomChangeListener::NewL(MSensrvEcomChangeObserver& aObserver)

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::NewL(0x%x)" ), &aObserver ) );

    CSensrvEcomChangeListener* self = new (ELeave) CSensrvEcomChangeListener(aObserver);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::NewL - return 0x%x" ), self ) );

    return self;

    }

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

// C++ constructor

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

//

CSensrvEcomChangeListener::CSensrvEcomChangeListener(MSensrvEcomChangeObserver& aObserver)

    : CActive(EPriorityHigh),

      iObserver(aObserver)

    {

    // Nothing to do

    }

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

// 2nd phase of construction.

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

//

void CSensrvEcomChangeListener::ConstructL()

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::ConstructL()" ) ) );

    CActiveScheduler::Add(this);

    // Start listening to ecom

    iEcom = &(REComSession::OpenL());

    // Create retry timer

    iTimer = CSensrvEcomChangeListenerTimer::NewL( this );

    // Execute initial check for plugins immediately.

    // Plugins must be solved before clients start using the server after connect.

    CheckEcomChanges();

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::ConstructL - return" ) ) );

    }

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

// Destructor

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

//

CSensrvEcomChangeListener::~CSensrvEcomChangeListener()

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::~CSensrvEcomChangeListener()" ) ) );

    Cancel();

    if (iEcom)

        {

        iEcom->Close();

        }

    if ( iTimer )

        {

        iTimer->Cancel();

        delete iTimer;

        iTimer = NULL;

        }

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::~CSensrvEcomChangeListener - return" ) ) );

    }

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

// TimerCallBack

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

//

void CSensrvEcomChangeListener::TimerCallBack()

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::TimerCallBack()" ) ) );

    CheckEcomChanges();

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::TimerCallBack - return" ) ) );

    }

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

// CheckEcomChanges

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

//

void CSensrvEcomChangeListener::CheckEcomChanges()

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::CheckEcomChanges()" ) ) );

    TBool changeOk( ETrue );

    TInt err( KErrNone );

    if ( !IsActive() ) //Not active

        {

        iEcom->NotifyOnChange(iStatus);

        iTimer->Cancel();

        SetActive();

        }

    // Scan for SSY plugins

    RImplInfoPtrArray* implInfoArray = NULL;

    implInfoArray = new RImplInfoPtrArray();

    CleanupStack::PushL( implInfoArray );

    if ( implInfoArray )

        {

        TRAP(err, REComSession::ListImplementationsL( TUid::Uid(KSsyControlInterfaceUid),

                                                       *implInfoArray));

        }

    else

        {

        ERROR_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunL() - ERROR: Allocating implInfoArray failed" ) ) );

        err = KErrNoMemory;

        }

    // If listing implementations fails, ecom may be busy constructing the index.

    // Retry after one second in that case.

    if ( err == KErrNone )

        {

        // Everything ok, notify owner about new plugins

        COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunL() - Notifying observer" ) ) );

        changeOk = iObserver.EcomChanged(implInfoArray);

        // Do not destroy implementation infos, EcomChanged cleans array up if change is ok,

        // and otherwise they will get cleaned up below

        }

    CleanupStack::Pop( implInfoArray );

    if ( err != KErrNone || !changeOk )

        {

        ERROR_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunL() - ERROR: Scanning for plugins failed or server could not handle new plugins just now, starting retry timer" ) ) );

        if ( implInfoArray )

            {

            implInfoArray->ResetAndDestroy();

            delete implInfoArray;

            }

        // Start rescan timer

        iTimer->StartTimer();

        }

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::CheckEcomChanges - return" ) ) );

    }

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

// Handle notification from the other thread.

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

//

void CSensrvEcomChangeListener::RunL()

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunL()" ) ) );

    CheckEcomChanges();

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunL - return" ) ) );

    }

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

// Handle error in RunL

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

//

#ifdef ERROR_TRACE_DEBUG

TInt CSensrvEcomChangeListener::RunError(TInt aError)

#else

TInt CSensrvEcomChangeListener::RunError(TInt /*aError*/)

#endif

    {

    ERROR_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunError(%d)" ), aError) );

    // Panic this thread if there is unhandled error in RunL.

    // This should not be possible.

    User::Panic(KSensrvPanicCategory, ESensrvPanicEcomChangeRunError);

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::RunError - return %d" ), KErrNone ) );

    return KErrNone;

    }

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

// Handle cancel order on this active object.

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

//

void CSensrvEcomChangeListener::DoCancel()

    {

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::DoCancel()" ) ) );

    iEcom->CancelNotifyOnChange(iStatus);

    iTimer->Cancel();

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvEcomChangeListener::DoCancel - return" ) ) );

    }