/*

* 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:  Source file of CIRActiveIdleStateDetector

*

*/

#include "irdebug.h"

#include <apgtask.h>

#include <eikenv.h>

#include "iractiveidlestatedetector.h"

#include "iractiveidleengnotifyhandler.h"

#include "ircommon.h"

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

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

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

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

//

CIRActiveIdleStateDetector::CIRActiveIdleStateDetector(MIRActiveIdleEngNotifyHandler& 

	aStateObserver):CActive(CActive::EPriorityStandard),iStateObserver(aStateObserver)

    {

    CActiveScheduler::Add( this );

    }

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

// Destructor

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

//

CIRActiveIdleStateDetector::~CIRActiveIdleStateDetector()

    {

	Cancel();

    }

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

// Starts listening

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

//

void CIRActiveIdleStateDetector::StartListeningL()

    {

    IRLOG_DEBUG("CIRActiveIdleStateDetector::StartListeningL.");

	if ( !IsActive() )

	    {

    	TApaTaskList taskList( CCoeEnv::Static()->WsSession() );

    	TApaTask task = taskList.FindApp( KUidInternetRadioApp );

    	if ( task.Exists() )

    		{

    		TThreadId threadId = task.ThreadId();

    		RThread thread;

    		User::LeaveIfError( thread.Open( threadId ) );

    		CleanupClosePushL( thread );

    		User::LeaveIfError( thread.Process( iProcess ) );

    		CleanupStack::PopAndDestroy();

            IRLOG_INFO("CIRActiveIdleStateDetector::StartListeningL - Logon.");

        	iProcess.Logon( iStatus );

        	SetActive();	

    		}

		else

		    {

            IRLOG_INFO("CIRActiveIdleStateDetector::StartListeningL  - sending EIRPSApplicationClosing.");

	        iStateObserver.HandleApplicationRunningStateChangeL( EIRPSApplicationClosing );

		    }

	    }

    IRLOG_DEBUG("CVRActiveIdleStateDetector::StartListeningL - Exiting.");	    

    }

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

// Implements cancellation of an outstanding request

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

//

void CIRActiveIdleStateDetector::DoCancel()

    {

    IRLOG_DEBUG("CIRActiveIdleStateDetector::DoCancel");

	iProcess.LogonCancel( iStatus );

	iProcess.Close();

    }

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

// Handles request completion event

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

//

void CIRActiveIdleStateDetector::RunL()

    {

    IRLOG_INFO2("CIRActiveIdleStateDetector::RunL (%d) sending EIRPSApplicationClosing", iStatus.Int());

	iProcess.Close();

	// Internet Radio has been closed

	iStateObserver.HandleApplicationRunningStateChangeL( EIRPSApplicationClosing );

    }