/*
* Copyright (c) 2002 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 is used for streaming audio.
*
*/


//  INCLUDE FILES
#include <AudioPreference.h>
#include <jdebug.h>

#include "cmmaaudiostreamplayer.h"
#include "cmmadatasourcestream.h"
#include "cmmaeventsource.h"
#include "cmmastreamhandler.h"

_LIT(KMMAStreamErrorMessage, "Internal error: %d");


CMMAAudioStreamPlayer* CMMAAudioStreamPlayer::NewLC(
    CMMAEMCResolver* aResolver)
{
    DEBUG("MMA::CMMAAudioStreamPlayer::NewLC +");
    CMMAAudioStreamPlayer* self = new(ELeave) CMMAAudioStreamPlayer(aResolver);
    CleanupStack::PushL(self);
    self->ConstructL();
    DEBUG("MMA::CMMAAudioStreamPlayer::NewLC -");
    return self;
}

CMMAAudioStreamPlayer::~CMMAAudioStreamPlayer()
{
    DEBUG("MMA::CMMAAudioStreamPlayer::~CMMAAudioStreamPlayer +");

    if (iMStreamControl->GetState() > MStreamControl::CLOSED)
    {
        iMStreamControl->Close();
    }

    delete iStreamHandler;

    DEBUG("MMA::CMMAAudioStreamPlayer::~CMMAAudioStreamPlayer -");
}


CMMAAudioStreamPlayer::CMMAAudioStreamPlayer(
    CMMAEMCResolver* aResolver):
        CMMAEMCAudioPlayer(aResolver)
{
    DEBUG("MMA::CMMAAudioStreamPlayer::CMMAAudioStreamPlayer");
}

void CMMAAudioStreamPlayer::ConstructL()
{
    DEBUG("MMA::CMMAAudioStreamPlayer::ConstructL +");
    iControllerPrimed = EFalse;
    CMMAEMCAudioPlayer::ConstructL();
    iMetaDataUtility = CMetaDataUtility::NewL();
    iStreamHandler = CMMAStreamHandler::NewL(*this,
                     *iMStreamControl,
                     *iMDataBufferSource,
                     *iFactory,
                     *iMetaDataUtility);
    iActiveSchedulerWait = new(ELeave)CActiveSchedulerWait();
    DEBUG("MMA::CMMAAudioStreamPlayer::ConstructL -");
}

CMMASourceStream* CMMAAudioStreamPlayer::AddSourceStreamL(JNIEnv* aJNIEnv,
        CMMAEventSource* aEventSource,
        jobject aReader)
{
    DEBUG("MMA::CMMAAudioStreamPlayer::AddSourceStreamL +");
    CMMADataSourceStream* sourceStream = CMMADataSourceStream::NewLC(aJNIEnv,
                                         aEventSource,
                                         aReader,
                                         this);
    User::LeaveIfError(iSourceStreams.Append(sourceStream));
    CleanupStack::Pop(sourceStream);
    iStreamHandler->SetSourceStream(sourceStream);
    DEBUG("MMA::CMMAAudioStreamPlayer::AddSourceStreamL -");
    return sourceStream;
}

CMetaDataUtility* CMMAAudioStreamPlayer::MetaDataUtilityOwnership()
{
    CMetaDataUtility* temp = iMetaDataUtility;
    iMetaDataUtility = NULL;
    return temp;
}

void CMMAAudioStreamPlayer::DeallocateL()
{
    DEBUG("MMA::CMMAAudioStreamPlayer::DeallocateL +");
    iStreamHandler->Stop();
    iControllerPrimed = EFalse;
    CMMAEMCPlayerBase::DeallocateL();
    DEBUG("MMA::CMMAAudioStreamPlayer::DeallocateL -");
}

void CMMAAudioStreamPlayer::PrefetchL()
{
    DEBUG("CMMAAudioStreamPlayer::PrefetchL +");
    __ASSERT_DEBUG(iSourceStreams.Count() > 0, User::Invariant());
    iStreamHandler->Prepare(*iMimeType);
    DEBUG("CMMAAudioStreamPlayer::PrefetchL -");
}

void CMMAAudioStreamPlayer::StartL(TBool aPostEvent)
{
    DEBUG("MMA::CMMAAudioStreamPlayer::StartL +");
    if (iStreamHandler->LastBufferWritten() &&
            (iMStreamControl ->GetState() == MStreamControl::PAUSED))
    {
        TInt64 time;
        GetMediaTime(&time);
        TInt err = iMStreamControl->Start();
        if (err == KErrNone && iState != EStarted)
        {
            // move to started state and post started event
            if (aPostEvent)
            {
                PostLongEvent(CMMAPlayerEvent::EStarted, time);
            }
            ChangeState(EStarted);
        }
        else
        { // post error event
            HandleError(err);
            PostActionCompleted(err);   // java start return
        }
    }
    else
    {
        iStreamHandler->Start();
    }

    DEBUG("MMA::CMMAAudioStreamPlayer::StartL -");
}

void CMMAAudioStreamPlayer::StopL(TBool aPostEvent)
{
    DEBUG_INT("CMMAAudioStreamPlayer::Stop state %d", iState);
    if (iState == EStarted)
    {
        User::LeaveIfError(Pause());
        // go back to prefetched state
        ChangeState(EPrefetched);
        if (aPostEvent)
        {
            TInt64 time;
            GetMediaTime(&time);
            PostLongEvent(CMMAPlayerEvent::EStopped, time);
        }
    }
    DEBUG("CMMAAudioStreamPlayer::Stop OK");
}

TInt CMMAAudioStreamPlayer::Pause()
{
    DEBUG("MMA::CMMAAudioStreamPlayer::Pause +");
    iStreamHandler->Pause();
    DEBUG_INT("MMA::CMMAAudioStreamPlayer:: iStreamControl State = %d",iMStreamControl->GetState());

    TInt err = KErrNone;
    if (iMStreamControl->GetState() != MStreamControl::PAUSED)
    {
        err = iMStreamControl->Pause();
        DEBUG_INT("MMA::CMMAAudioStreamPlayer:: iStreamControl Pause error = %d", err);
        if ((!iActiveSchedulerWait->IsStarted()) && (err == KErrNone))
        {
            iActiveSchedulerWait->Start();
        }
    }
    DEBUG("MMA::CMMAAudioStreamPlayer::Pause -");
    return err;
}

void CMMAAudioStreamPlayer::PlayCompleteL(TInt aError)
{
    DEBUG_INT("MMA::CMMAAudioStreamPlayer::PlayCompleteL error %d",
              aError);

    // Before controller is started it must be primed
    iControllerPrimed = EFalse;

    TInt64 time;
    GetDuration(&time);

    // Send 'Stopped' only when stop() is called.
    PostLongEvent(CMMAPlayerEvent::EEndOfMedia, time);

    ChangeState(EPrefetched);   // ready to play again

    if (aError == KErrNone)
    {
        iRepeatCount++;

        if (iRepeatForever || iRepeatCount < iRepeatNumberOfTimes)
        {
            StartL(ETrue);
        }
        else
        {
            iRepeatCount = 0;
        }
    }
    else
    {
        // error has occured, setting correct number of
        // repeats for next start
        SetLoopCount(iRepeatNumberOfTimes);
    }
}

void CMMAAudioStreamPlayer::GetDuration(TInt64* aDuration)
{
    CMMAPlayer::GetDuration(aDuration);
}

void CMMAAudioStreamPlayer::PrepareComplete(TInt aError)
{
    DEBUG_INT("MMA::CMMAAudioStreamPlayer::PrepareComplete error %d",
              aError);

    if (aError == KErrNone)
    {
        ChangeState(EPrefetched);
    }
    PostActionCompleted(aError);   // java prefetch return
}

void CMMAAudioStreamPlayer::StartComplete(TInt aError)
{
    DEBUG_INT("MMA::CMMAAudioStreamPlayer::StartComplete error %d",
              aError);

    // do not start if player is deallocated or closed
    // RateControl start can start controller in started state
    if ((iState != EStarted) &&
            (iState != EPrefetched))
    {
        PostActionCompleted(KErrNone);   // java start return
        return;
    }

    TInt err = aError;
    if (!iControllerPrimed)
    {
        // Prime must be called when player is started first time or restarted
        err = iMStreamControl->Prime();

        DEBUG_INT("MMA::CMMAAudioStreamPlayer::StartComplete prime error %d",
                  err);
    }
    else
    {
        err = KErrNone;
    }

    if (iControllerPrimed && (iState == EPrefetched))
    {

        TInt64 time;
        if (err == KErrNone)
        {
            // must be primed before media time can be get
            GetMediaTime(&time);
            err = iMStreamControl->Start();
            DEBUG_INT("MMA::CMMAAudioStreamPlayer::StartComplete play error %d",
                      err);

        }

        // RateControl can start controller in started state, then Java event is
        // not sent
        if (err == KErrNone && iState != EStarted)
        { // move to started state and post started event
            PostLongEvent(CMMAPlayerEvent::EStarted, time);
            ChangeState(EStarted);
        }
        else
        { // post error event
            HandleError(aError);
            PostActionCompleted(aError);   // java start return
        }
    }

}

void CMMAAudioStreamPlayer::HandleError(TInt aError)
{
    DEBUG_INT("MMA::CMMAAudioStreamPlayer::HandleError error %d",
              aError);

    TName errorMessage;
    errorMessage.Format(KMMAStreamErrorMessage, aError);
    PostStringEvent(CMMAPlayerEvent::EError, errorMessage);
}

void CMMAAudioStreamPlayer::Event(MControl* aControl, TUint aEventType, TAny* aEventObject)
{

    switch (aEventType)
    {

    case MStreamControlObserver::KStateChangedEvent:
    {
        MStateChangedEvent* evt = (MStateChangedEvent*)aEventObject;
        MStreamControl* control1 = (MStreamControl*)(aControl);
        switch (control1->GetState())
        {
        case MStreamControl::CLOSED:
        {
            iPrevStreamControlState = MStreamControl::CLOSED;
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :CLOSED");
        }
        break;

        case MStreamControl::INITIALIZED:
        {
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :INITIALIZED");
            switch (iPrevStreamControlState)
            {
            case MStreamControl::CLOSED:
            {
                iPrevStreamControlState = MStreamControl::INITIALIZED;
                if (iActiveSchedulerWait->IsStarted())
                {
                    iActiveSchedulerWait->AsyncStop();
                }
            }
            break;

            case MStreamControl::INITIALIZED:
            {
                iPrevStreamControlState = MStreamControl::INITIALIZED;
                DEBUG("inner Switch case: MStreamControl::INITIALIZED ");
                DEBUG_INT("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent:ErrorCode = %d ",evt->GetErrorCode());
                // error occured during prime operation
                // move player back to prefetched state
                if (iState == EStarted)
                {
                    ChangeState(EPrefetched);
                }
                PostActionCompleted(evt->GetErrorCode());   // java start return
            }
            break;

            case MStreamControl::PRIMED:
            {
                iPrevStreamControlState = MStreamControl::INITIALIZED;
                DEBUG("inner Switch case: MStreamControl::PRIMED ");

            }
            break;

            case MStreamControl::EXECUTING:
            {
                iPrevStreamControlState = MStreamControl::INITIALIZED;
                DEBUG("inner Switch case: MStreamControl::EXECUTING ");
                DEBUG_INT("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent:ErrorCode = %d ",evt->GetErrorCode());
                if (KErrEof == evt->GetErrorCode())
                {
                    TRAPD(error, PlayCompleteL(KErrNone));
                    if (KErrNone != error)
                    {
                        DEBUG_INT("MMA::CMMAAudioStreamPlayer::Event:PlayCompleteL Error = %d", error);
                    }
                }
            }
            break;

            case MStreamControl::BUFFERING:
            {
                iPrevStreamControlState = MStreamControl::INITIALIZED;
                DEBUG("inner Switch case: MStreamControl::BUFFERING ");
            }
            break;

            case MStreamControl::PAUSED:
            {
                iPrevStreamControlState = MStreamControl::INITIALIZED;
                DEBUG("inner Switch case: MStreamControl::PAUSED ");
            }
            break;
            }
        }
        break;

        case MStreamControl::PRIMED:
        {
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :PRIMED");
            iPrevStreamControlState = MStreamControl::PRIMED;
            iControllerPrimed = ETrue;
            TInt64 time;
            // must be primed before media time can be get
            GetMediaTime(&time);
            TInt err = iMStreamControl->Start();
            DEBUG_INT("MMA::CMMAAudioStreamPlayer::Event play error %d",
                      err);

            // RateControl can start controller in started state, then Java event is
            // not sent
            if (err == KErrNone && iState != EStarted)
            { // move to started state and post started event
                PostLongEvent(CMMAPlayerEvent::EStarted, time);
                ChangeState(EStarted);
            }
            else
            {
                PostLongEvent(CMMAPlayerEvent::EStarted, time);
            }
        }
        break;

        case MStreamControl::EXECUTING:
        {
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :EXECUTING");
            iPrevStreamControlState = MStreamControl::EXECUTING;
            PostActionCompleted(KErrNone);   // java start return
        }
        break;

        case MStreamControl::BUFFERING:
        {
            iPrevStreamControlState = MStreamControl::BUFFERING;
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :BUFFERING");
        }
        break;

        case MStreamControl::PAUSED:
        {
            iPrevStreamControlState = MStreamControl::PAUSED;
            if (iActiveSchedulerWait->IsStarted())
            {
                iActiveSchedulerWait->AsyncStop();
            }
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :PAUSED");
        }
        break;

        default:
            DEBUG("MMA::CMMAAudioStreamPlayer::Event:KStateChangedEvent :DEFAULT");
            break;
        }
    }
    break;

    case MControlObserver::KErrorEvent:
    {
        MErrorCode* evt = (MErrorCode*)aEventObject;
        if (KErrNone != evt->GetErrorCode())
        {
            DEBUG_INT("MMA::CMMAAudioStreamPlayer::Event:KErrorEvent, err = %d", evt->GetErrorCode());
        }
    }
    break;
    }
}
//  END OF FILE