/*
* Copyright (c) 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:
*
*/
#include "tsrunningappsession.h"
#include "tstaskmonitorglobals.h"

#include "tsdataobservertask.h"
#include "tsdataprovidertask.h"
#include "tsdatatask.h"

_LIT(KErrObserverExists, "Observer already exists");
// -----------------------------------------------------------------------------
/**
 * Constructor for performing 1st stage construction
 */
CTsRunningAppSession::CTsRunningAppSession( 
                                    const MTsDataProvider& aDataProvider )
:
    iDataProvider(aDataProvider)
    {
    // No implementation required
    }

// -----------------------------------------------------------------------------
/**
 * Destructor.
 */
CTsRunningAppSession::~CTsRunningAppSession()
    {
    iDataStorages.Close();
    iObservers.ResetAndDestroy();
    }

// -----------------------------------------------------------------------------
/**
 * Two-phased constructor.
 * @param aObserverStorage - observers storage
 * @param aDataProvider - serialized data provider
 * @param aDataStorages - data storages
 */
CTsRunningAppSession* CTsRunningAppSession::NewL(
                                  const MTsDataProvider& aDataProvider,
                                  const TArray<MTsDataStorage*> &aDataStorages )
    {
    CTsRunningAppSession* self = 
        new (ELeave) CTsRunningAppSession( aDataProvider );
    CleanupStack::PushL( self );
    self->ConstructL( aDataStorages );
    CleanupStack::Pop( self );
    return self;
    }

// -----------------------------------------------------------------------------
/**
* EPOC default constructor for performing 2nd stage construction
*/
void CTsRunningAppSession::ConstructL(
                                 const TArray<MTsDataStorage*> &aDataStorages )
    {
    for( TInt iter(0); iter < aDataStorages.Count(); ++iter )
        {
        iDataStorages.AppendL( aDataStorages[iter] );
        }
    }

// -----------------------------------------------------------------------------
/**
 * Implements interface
 * @see void CSession2::ServiceL(const RMessage2&)
 */
void CTsRunningAppSession::ServiceL(const RMessage2& aMessage)
    {
    switch ( aMessage.Function() )
        {
        case SubscribeRunningAppChanges:
            CTsDataObserverTask::ExecuteLD( *this, aMessage );
            break;
        
        case CancelSubscribeRunningAppChanges:
            iObservers.ResetAndDestroy();
            aMessage.Complete(KErrNone);
            break;
        
        case GetRunningAppInfo:
        case FlushData:
            TsDataProviderTask::ExecuteL( iDataProvider, aMessage );
            break;
        
        case RegisterScreenshotMessage:
        case UnregisterScreenshotMessage:
        case VisibilityChange:
        case OpenTaskMessage:
        case CloseTaskMessage:
            TsDataTask::ExecuteL( iDataStorages.Array(), aMessage );
            break;
        
        default:
            aMessage.Complete(CServer2::EBadMessageNumber);
        }
    }

// -----------------------------------------------------------------------------
/**
 * Implements interface
 * @see void MTsDataObserver::DataChanged()
 */
void CTsRunningAppSession::DataChanged()
    {
    TInt iter(iObservers.Count()-1);
    iMissedDataUpdate = ( iter < 0 );
    for( ; iter >= 0; --iter )
        {
        iObservers[iter]->DataChanged();
        }
    }

// -----------------------------------------------------------------------------
/**
 * Implements interface
 * @see void MTsDataObserverStorage::PushL(CTsDataObserver*)
 */
void CTsRunningAppSession::PushL(CTsDataObserver* aObserver)
    {
    ( 0 <= iObservers.Find( aObserver ) ) ?
            User::Panic( KErrObserverExists, KErrAlreadyExists ) :
            iObservers.AppendL( aObserver );
    if( iMissedDataUpdate )
        {
        aObserver->DataChanged();
        iMissedDataUpdate = EFalse;
        }
    }

// -----------------------------------------------------------------------------
/**
 * Implements interface
 * @see void MTsDataObserverStorage::Pop(CTsDataObserver*)
 */
void CTsRunningAppSession::Pop(CTsDataObserver* aObserver)
    {
    const TInt offset( iObservers.Find( aObserver ) );
    if( 0 <= offset )
        {
        iObservers.Remove(offset);
        }
    }