/*
* Copyright (c) 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:  This class launchs music player, then send play command
*                to the player at 2 seconds timeout.
*
*/


// INCLUDE FILES
#include <apacmdln.h>
#include <apgcli.h>
#include <e32property.h>
#include <remconcoreapitarget.h>
#include "btrccplayerstarter.h"
#include "btaudioremconpskeys.h"
#include "debug.h"

// MODULE DATA STRUCTURES

// mpx playeris name is mpx.exe in 5.0.
// it is musicplayer.exe in 3.2.
_LIT(KMpxPlayerExeName, "mpx.exe");

_LIT(KMpxPlayerSearchPatternBySID, "*102072c3*");
_LIT(KVideoPlayerSearchPatternBySID, "*200159B2*");

static const TInt KPlayCmdToPlayerDelay = 6000000; // value will be tuned later 

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

// -----------------------------------------------------------------------------
// CPlayerStarter::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CPlayerStarter* CPlayerStarter::NewL()
	{
	CPlayerStarter* self = new (ELeave) CPlayerStarter();
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CPlayerStarter::SetCoreTarget(CRemConCoreApiTarget& aTarget)
    {
    iCoreTarget = &aTarget;
    }

// -----------------------------------------------------------------------------
// CPlayerStarter::CPlayerStarter
// C++ constructor.
// -----------------------------------------------------------------------------
//
CPlayerStarter::CPlayerStarter()
  :CActive(EPriorityNormal)
    {
    CActiveScheduler::Add(this);
    }

// -----------------------------------------------------------------------------
// CPlayerStarter::ConstructL
// Symbian 2nd phase constructor.
// -----------------------------------------------------------------------------
//
void CPlayerStarter::ConstructL()
    {
    TRACE_FUNC
    iTimer.CreateLocal();
    }

// -----------------------------------------------------------------------------
// Destructor.
// -----------------------------------------------------------------------------
//
CPlayerStarter::~CPlayerStarter()
	{
	TRACE_FUNC
	// Starting player is not finished yet, send play command. Just wish the player 
	// can receive it.
	if (IsActive() && iState != ERespondPlayNok)
	    {
        RProperty::Set(KBTAudioRemCon, KBTAudioPlayerControl, 
                EBTAudioResumePlayer);	    
	    }
	Cancel();
	iTimer.Close();
	}

// -----------------------------------------------------------------------------
// CPlayerStarter::RunL
// -----------------------------------------------------------------------------
//
void CPlayerStarter::RunL()
    {
    TRACE_INFO((_L("CPlayerStarter::RunL() state %d, status %d"), iState, iStatus.Int()));
    if (iStatus != KErrNone)
        {
        iState = EIdle;
        return;
        }
    switch (iState)
        {
        case ERespondPlayOk:
            {
            // Response OK has been sent to the remote device, start timer waiting
            // for player's initialization.
            iTimer.After(iStatus, KPlayCmdToPlayerDelay);
            SetActive();
            iState = EPlayMusicTiming;
            TRACE_INFO(_L("schedule PLAY command ..."));
            break;
            }
        case EPlayMusicTiming:
            {
            // Player should have fully up and running. Send PLAY command to it
            // through our internal Play API.
            RProperty::Set(KBTAudioRemCon, KBTAudioPlayerControl, 
                    EBTAudioResumePlayer);
            TRACE_INFO(_L("PLAY command sent to btmonobearer"));
            iState = EIdle;
            break;
            }
        default:
            {
            iState = EIdle;
            break;
            }
        }
    }

// -----------------------------------------------------------------------------
// CPlayerStarter::RunError
// -----------------------------------------------------------------------------
//
TInt CPlayerStarter::RunError(TInt aError)
    {
    TRACE_FUNC
    (void) aError;
    return KErrNone;
    }

// -----------------------------------------------------------------------------
// CPlayerStarter::DoCancel
// -----------------------------------------------------------------------------
//
void CPlayerStarter::DoCancel()
    {
    TRACE_FUNC
    switch (iState)
        {
        case ERespondPlayOk:
        case ERespondPlayNok:
            {
            // This cancel won't cancel the response sending to the remote 
            // device. (RemCon FW's cancel mechanism is only completing client's request.
            // the real operation in its server side won't be stopped.)
            iCoreTarget->Cancel();
            break;
            }
        case EPlayMusicTiming:
            {
            iTimer.Cancel();
            break;
            }
        }
    }
// ---------------------------------------------------------------------------
// A 'play' command has been received.
// ---------------------------------------------------------------------------
//
void CPlayerStarter::MrccatoPlay(
    TRemConCoreApiPlaybackSpeed /* aSpeed */,
    TRemConCoreApiButtonAction aButtonAct )
    {
    TRACE_FUNC
    if ( ( aButtonAct == ERemConCoreApiButtonClick ) ||
        ( aButtonAct == ERemConCoreApiButtonPress ) )
        {
        StartPlayIfNeeded();
        }
    }

// ---------------------------------------------------------------------------
// A command has been received.
// ---------------------------------------------------------------------------
//
void CPlayerStarter::MrccatoCommand(
    TRemConCoreApiOperationId aOperationId,
    TRemConCoreApiButtonAction aButtonAct )
    {
    TRACE_INFO((_L("CPlayerStarter::MrccatoCommand opId %d, button %d"), 
        aOperationId, aButtonAct));
    switch (aOperationId)
        {
        case ERemConCoreApiPlay:
            {
            if ( ( aButtonAct == ERemConCoreApiButtonClick ) ||
                ( aButtonAct == ERemConCoreApiButtonPress ) )
                {
                StartPlayIfNeeded();
                }
            break;
            }
        case ERemConCoreApiStop:
        case ERemConCoreApiPause:
            {
            if ( ( aButtonAct == ERemConCoreApiButtonClick ) ||
                ( aButtonAct == ERemConCoreApiButtonPress ) )
                {
                // if starting player is ongoing, possibly PLAY command has been scheduled
                // need to abort it.
                Cancel();
                }
            break;
            }
        default:
            {
            break;
            }
        }
    }

// -----------------------------------------------------------------------------
// CPlayerStarter::StartPlayIfNeeded
// -----------------------------------------------------------------------------
//
void CPlayerStarter::StartPlayIfNeeded() 
    {
    TRACE_FUNC
    // unfinished business ongoing, eat the event.
    if (IsActive())
        {
        return;
        }
    if (!IsMusicPlayerRunning() && !IsVideoPlayerRunning())
         {
         TRAPD(err, LaunchMusicPlayerL());
         // Send the response of play command to remote device
         iCoreTarget->PlayResponse(iStatus, err);
         SetActive();
         iState = (err) ? ERespondPlayNok : ERespondPlayOk;
         }
    }

TBool CPlayerStarter::IsMusicPlayerRunning()
    {
    TRACE_FUNC
    // Music player is running if we can find a thread whose name contains 
    // S60 Music Player's SID.
    TFindThread findt(KMpxPlayerSearchPatternBySID);
    TFullName result;
    TBool running(EFalse);
    if (!findt.Next(result))
        {
        TRACE_INFO((_L("Thread '%S'is found"), &result));
        running = ETrue;
        }
    return running;
    }

TBool CPlayerStarter::IsVideoPlayerRunning()
    {
    TRACE_FUNC
    // Video player is running if we can find a thread whose name contains 
    // Video Player's SID.
    TFindThread findt(KVideoPlayerSearchPatternBySID);
    TFullName result;
    TBool running(EFalse);
    if (!findt.Next(result))
        {
        TRACE_INFO((_L("Thread '%S'is found"), &result));
        running = ETrue;
        }
    return running;
    }

void CPlayerStarter::LaunchMusicPlayerL()
    {
    RApaLsSession ls;
    User::LeaveIfError(ls.Connect());
    CleanupClosePushL(ls);
    CApaCommandLine* cmd = CApaCommandLine::NewL();
    CleanupStack::PushL(cmd);
    cmd->SetExecutableNameL( KMpxPlayerExeName );
    cmd->SetCommandL( EApaCommandOpen );
    User::LeaveIfError(ls.StartApp( *cmd ));
    CleanupStack::PopAndDestroy(2); // cmd, ls
    }


//  End of File