/*
* 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:  ?Description
*
*/


#include "irmetadata.h"
#include "irpubsubkeys.h"

#include "iractiveidleeng.h"
#include "iractiveidleengnotifyhandler.h"
#include "iractiveidleengpubsub.h"
#include "irdebug.h"


// ---------------------------------------------------------------------------
// CIRActiveIdleEng::CIRActiveIdleEng
// Default Constructor.
// ---------------------------------------------------------------------------
//
CIRActiveIdleEng::CIRActiveIdleEng( MIRActiveIdleEngNotifyHandler& aObserver )
    : iObserver( aObserver )
    {
    }

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::ConstructL
// Second-phase constructor
// ---------------------------------------------------------------------------
//
void CIRActiveIdleEng::ConstructL()
    {
    IRLOG_DEBUG( "CIRActiveIdleEng::ConstructL" );	
    //Subscriber for application running state 
    User::LeaveIfError(iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSDataApplicationRunning , 
    	RProperty::EInt) ) );
    //Subsciber for meta data
    User::LeaveIfError( iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSMetaData, 
    	RProperty::ELargeText)));
    //Subsciber for the volume level 
    User::LeaveIfError( iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSVolume , 
    	RProperty::EInt) ) );
    //Subsciber for the key KIRPSPlayStop at stop state
    User::LeaveIfError( iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSPlayStop ,
    	RProperty::EInt) ) );
    //Subsciber for the channel name
     User::LeaveIfError( iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSDataChannel, 
    	RProperty::ELargeText) ) );
    //Subscriber for favourite channel preset index 
    User::LeaveIfError( iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSPresetIndex ,
    	RProperty::EInt) ) );
    
    //Subscriber for favourite channel preset index 
    User::LeaveIfError( iPropertyObserverArray.Append( CIRActiveIdleEngPubSub::
    	NewL( *this, KUidActiveInternetRadioApp, KIRPSBufferingState ,
    	RProperty::EInt) ) );
    IRLOG_DEBUG( "CIRActiveIdleEng::ConstructL - Exiting." );	
    }

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::SecondConstructL()
// Finalizes the construction of the object
// ---------------------------------------------------------------------------
//
EXPORT_C void CIRActiveIdleEng::SecondConstructL()
	{
	
	IRLOG_DEBUG( "CIRActiveIdleEng::SecondConstructL" );
	for ( TInt i = 0; i < iPropertyObserverArray.Count(); i++ )
		{
		iPropertyObserverArray[i]->SecondConstructL();	
		}
	IRLOG_DEBUG( "CIRActiveIdleEng::SecondConstructL - Exiting." );
	}

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::NewL
// Static constructor.
// ---------------------------------------------------------------------------
//
EXPORT_C CIRActiveIdleEng* CIRActiveIdleEng::NewL( 
	MIRActiveIdleEngNotifyHandler& aObserver )
    {
    IRLOG_DEBUG( "CIRActiveIdleEng::NewL" );
    CIRActiveIdleEng* self = new ( ELeave ) CIRActiveIdleEng( aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
	IRLOG_DEBUG( "CIRActiveIdleEng::NewL - Exiting." );
    return self;
    }

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::~CIRActiveIdleEng()
// standard C++ destructor
// ---------------------------------------------------------------------------
//
EXPORT_C CIRActiveIdleEng::~CIRActiveIdleEng()
    {
    IRLOG_DEBUG( "CIRActiveIdleEng::~CIRActiveIdleEng" );
    iPropertyObserverArray.ResetAndDestroy();
    iPropertyObserverArray.Close();
    IRLOG_DEBUG( "CIRActiveIdleEng::~CIRActiveIdleEng - Exiting." );
    }

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::HandlePropertyChangeL
// Invoked when any listened P&S key is changed.
// ---------------------------------------------------------------------------
void CIRActiveIdleEng::HandlePropertyChangeL( const TUid& aCategory,
											TUint aKey,const TDesC8& aText ) 
	{
	IRLOG_DEBUG( "CIRActiveIdleEng::HandlePropertyChangeL" );
	if ( aCategory == KUidActiveInternetRadioApp )
		{
		if( aKey == KIRPSDataChannel )
			{
			iObserver.HandleChannelChangeL();
			}
		else if( aKey == KIRPSMetaData )
			{
			CIRMetaData* metaData = CIRMetaData::NewL( aText );
			CleanupStack::PushL( metaData );
			iObserver.HandleMetaDataReceivedL( *metaData );
			CleanupStack::PopAndDestroy( metaData );
			}
		else
			{
			// To avoid PC lint error
			}
		}
	IRLOG_DEBUG( "CIRActiveIdleEng::HandlePropertyChangeL - Exiting." );
	}

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::HandlePropertyChangeL
// Invoked when any listened P&S key is changed.
// ---------------------------------------------------------------------------
//
void CIRActiveIdleEng::HandlePropertyChangeL( 
	const TUid& aCategory, TUint aKey, TInt aValue )
	{
	IRLOG_DEBUG( "CIRActiveIdleEng::HandlePropertyChangeL" );
	if ( aCategory == KUidActiveInternetRadioApp )
		{
		if( aKey == KIRPSDataApplicationRunning)
			{
			iObserver.HandleApplicationRunningStateChangeL( 
				static_cast<TIRPSApplicationRunningState>( aValue ) );				
			}
		else if( aKey == KIRPSVolume)
			{
			iObserver.HandleVolumeChangeL( aValue );
			}
		else if( aKey == KIRPSPlayStop)
			{
			iObserver.HandlePlayStopL( static_cast<TIRStopPlayState>( aValue ) );
			}	   
		else if( aKey == KIRPSBufferingState)
			{
			IRRDEBUG2("CIRActiveIdleEng::HandlePropertyChangeL KIRPSBufferingState=%d ",aValue);
			iObserver.HandleBufferingStateL(static_cast<TIRBufferingState>(aValue));
			}	   
		else
			{
			// To avoid PC lint error
			}
		}
	IRLOG_DEBUG( "CIRActiveIdleEng::HandlePropertyChangeL - Exiting." );
	}

// ---------------------------------------------------------------------------
// CIRActiveIdleEng::HandlePropertyChangeErrorL
// Invoked when an error has occured while fetching the new value of any listened P&S key.
// ---------------------------------------------------------------------------
//
void CIRActiveIdleEng::HandlePropertyChangeErrorL( const TUid& /*aCategory*/,
	TUint /*aKey*/, TInt aError )
    {
    IRLOG_DEBUG( "CIRActiveIdleEng::HandlePropertyChangeErrorL" );
    if (aError < 0)
    	{
    	HandlePropertyChangeL(KUidActiveInternetRadioApp, 
    		KIRPSDataApplicationRunning, EIRPSApplicationClosing);
    	}
    IRLOG_DEBUG( "CIRActiveIdleEng::HandlePropertyChangeErrorL" );
    }