/*
* Copyright (c) 2008-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:  Java RemCon Observer Active Object
*
*/


#include "javaremconobserver.h"
#include <jdebug.h>

const TInt KMaxQueueSize(32);

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

// ---------------------------------------------------------------------------
// CJavaRemConObserver::NewL()
// ---------------------------------------------------------------------------
//
EXPORT_C CJavaRemConObserver* CJavaRemConObserver::NewL(
    MRemConCoreApiTargetObserver& aObserver)
{
    CJavaRemConObserver* self = new(ELeave) CJavaRemConObserver(aObserver);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::CJavaRemConObserver()
// ---------------------------------------------------------------------------
//
CJavaRemConObserver::CJavaRemConObserver(
    MRemConCoreApiTargetObserver& aObserver) :
        CActive(CActive::EPriorityStandard),
        iObserver(aObserver)
{
    CActiveScheduler::Add(this);
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::ConstructL()
// ---------------------------------------------------------------------------
//
void CJavaRemConObserver::ConstructL()
{
    iQueue.CreateLocal(KMaxQueueSize);
    IssueRequest();
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::IssueRequest()
// ---------------------------------------------------------------------------
//
void CJavaRemConObserver::IssueRequest()
{
    iQueue.NotifyDataAvailable(iStatus);
    SetActive();
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::~CJavaRemConObserver()
// ---------------------------------------------------------------------------
//
CJavaRemConObserver ::~CJavaRemConObserver()
{
    Cancel();
    iQueue.Close();
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::DoCancel()
// ---------------------------------------------------------------------------
//
void CJavaRemConObserver::DoCancel()
{
    iQueue.CancelDataAvailable();
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::AddPlayMessage()
// ---------------------------------------------------------------------------
//
void CJavaRemConObserver::AddPlayMessage(TRemConCoreApiPlaybackSpeed aSpeed,
        TRemConCoreApiButtonAction aButtonAct)
{
    DEBUG_INT2("CJavaRemConObserver::SetPlayParameters - aSpeed = %d, aButtonAct = %d", aSpeed, aButtonAct);
    TJavaRemConMessage message;
    message.iMethod = EMethodMrccatoPlay;
    message.iSpeed = aSpeed;
    message.iButtonAct = aButtonAct;
    iQueue.Send(message);
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::AddCommandMessage()
// ---------------------------------------------------------------------------
//
void CJavaRemConObserver::AddCommandMessage(
    TRemConCoreApiOperationId aOperationId,
    TRemConCoreApiButtonAction aButtonAct)
{
    DEBUG_INT2("CJavaRemConObserver::SetCommandParameters - aOperationId = %d, aButtonAct = %d", aOperationId, aButtonAct);
    TJavaRemConMessage message;
    message.iMethod = EMethodMrccatoCommand;
    message.iOperationId = aOperationId;
    message.iButtonAct = aButtonAct;
    iQueue.Send(message);
}

// ---------------------------------------------------------------------------
// CJavaRemConObserver::RunL()
// ---------------------------------------------------------------------------
//
void CJavaRemConObserver::RunL()
{
    DEBUG("+CJavaRemConObserver::RunL() ");
    TJavaRemConMessage message;
    iQueue.Receive(message);
    switch (message.iMethod)
    {
    case EMethodNone:
        DEBUG("CJavaRemConObserver::RunL - EMethodNone");
        break;
    case EMethodMrccatoCommand:
        DEBUG_INT2("CJavaRemConObserver::RunL - EMethodMrccatoCommand: aOperationId = %d, aButtonAct = %d", message.iOperationId, message.iButtonAct);
        iObserver.MrccatoCommand(message.iOperationId,
                                 message.iButtonAct);
        break;
    case EMethodMrccatoPlay:
        DEBUG_INT2("CJavaRemConObserver::RunL - EMethodMrccatoPlay: iSpeed = %d, aButtonAct = %d", message.iSpeed, message.iButtonAct);
        iObserver.MrccatoPlay(message.iSpeed,
                              message.iButtonAct);
        break;
    default:
        break;
    }
    IssueRequest();
    DEBUG("-CJavaRemConObserver::RunL() ");
}