/*

* Copyright (c) 2002-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:  This class is used for MIDI.

*

*/

//  INCLUDE FILES

#include <mmf/server/mmffile.h>

#include <logger.h>

#include <e32base.h>

#include <AudioPreference.h>

#include "cmmamidiplayer.h"

#include "mmmadisplay.h"

const TInt KErrorMessageSize = 32;

_LIT(KErrDefaultError, "Symbian OS Error: %d");

const TInt KMidiDefaultBank = 0x3c80;

const TInt KMidiDrumBank = 0x3c7c;

const TInt KMidiDrumChannel = 9;

const TInt KMidiChannels = 16;

const TInt KMidiDefaultInstrument = 1;

CMMAMIDIPlayer* CMMAMIDIPlayer::NewLC(const TDesC& aContentType,

                                      TFileName aFileName)

{

    CMMAMIDIPlayer* self = new(ELeave) CMMAMIDIPlayer(aFileName);

    CleanupStack::PushL(self);

    self->ConstructL(aContentType);

    return self;

}

CMMAMIDIPlayer::~CMMAMIDIPlayer()

{

    CloseClientUtility();

    // new function added to CMMAPlayer delete the controls before the destruction of iMidi.

    DeleteControls();

    delete iMidi;

    delete iActiveSchedulerWait;

    iObservers.Close();

    LOG(EJavaMMAPI, EInfo, "MMA::CMMAMIDIPlayer::~CMMAMIDIPlayer");

}

void CMMAMIDIPlayer::ConstructL(const TDesC& aContentType)

{

    LOG(EJavaMMAPI, EInfo, "CMMAMIDIPlayer::ConstructL");

    iContentType = aContentType.AllocL();

    iActiveSchedulerWait = new(ELeave)CActiveSchedulerWait;

    iMidi = CMidiClientUtility::NewL(*this, KAudioPriorityRecording,

                                     KMMAMIDIPriorityPreference, ETrue);

    CMMAPlayer::ConstructL();

}

CMMAMIDIPlayer::CMMAMIDIPlayer(TFileName aFileName):

        iFileName(aFileName),

        iMediaTime(KTimeUnknown), iStartedEventTime(0)

{

}

EXPORT_C CMidiClientUtility* CMMAMIDIPlayer::MidiClient() const

{

    return iMidi;

}

void CMMAMIDIPlayer::RealizeL()

{

    LOG(EJavaMMAPI, EInfo, "CMMAMIDIPlayer::RealizeL");

    CMMAPlayer::RealizeL();

}

void CMMAMIDIPlayer::PrefetchL()

{

    LOG1(EJavaMMAPI, EInfo, "CMMAMIDIPlayer::PrefetchL stream count %d", iSourceStreams.Count());

    if (iFileName != KNullDesC)

    {

        iMidi->OpenFile(iFileName);

    }

    else if (iSourceStreams.Count() == 0)

    {

        // We have no data, but need to initialize the player

        // Preparing all channels

        for (TInt i = 0; i < KMidiChannels; i++)

        {

            iMidi->SetInstrumentL(i, KMidiDefaultBank,

                                  KMidiDefaultInstrument);

        }

        // Setting drums to channel 10

        iMidi->SetInstrumentL(KMidiDrumChannel, KMidiDrumBank,

                              KMidiDefaultInstrument);

        // Start it immediately in order to get MIDIControl work without

        // calling the start. This is how reference implementation works.

        iMidi->Play();

    }

    else

    {

        // Created with content, audio player will initialize controller

        // and data source.

        iSourceStreams[ 0 ]->ReadAllL();

    }

}

//

// This method is called when CMMASourceStreamReader finished reading

// initiated in PrefetchL

//

void CMMAMIDIPlayer::ReadCompletedL(TInt aStatus, const TDesC8& aData)

{

    if (aStatus < KErrNone)

    {

        PostActionCompleted(aStatus);

    }

    else

    {

        // we're not finished yet

        iMidi->OpenDes(aData);      //wait for MMidiClientUtilityObserver::MmcuoStateChanged

    }

}

void CMMAMIDIPlayer::DeallocateL()

{

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMidiPlayer: DeallocateL +");

    if (iState == EPrefetched)

    {

        CloseClientUtility();

        ResetSourceStreams();

        ChangeState(ERealized);

    }

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMidiPlayer: DeallocateL -");

}

void CMMAMIDIPlayer::StartL()

{

    iMediaTime = KTimeUnknown;

    // Player is already started if this player is constructed with

    // device://midi locator.

    TBool isDeviceMidi = (iSourceStreams.Count() == 0 &&

                          iFileName == KNullDesC);

    if (!isDeviceMidi)

    {

        iMidi->Play();

    }

    // inform java side

    PostLongEvent(CMMAPlayerEvent::EStarted, iStartedEventTime);

    ChangeState(EStarted);

    // To achieve similar functionality as reference implementation,

    // END_OF_MEDIA must be sent right after Start on device://midi.

    if (isDeviceMidi)

    {

        PostLongEvent(CMMAPlayerEvent::EEndOfMedia, iStartedEventTime);

        ChangeState(EPrefetched);

    }

    PostActionCompletedStart();

    //PostActionCompleted(KErrNone);   // java start return

}

void CMMAMIDIPlayer::StopL(TBool aPostEvent)

{

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMidiPlayer::StopL");

    if (iState == EStarted)

    {

        TInt64 time;

        GetMediaTime(&time);

        iStartedEventTime = time;

        // do the stop only if we are playing some content

        if ((iSourceStreams.Count() > 0) ||

                (iFileName != KNullDesC))

        {

            // should actually pause!!!

            iMidi->Stop(TTimeIntervalMicroSeconds(0));

        }

        if (aPostEvent)

        {

            PostLongEvent(CMMAPlayerEvent::EStopped, time);

        }

        // go back to prefetched state

        ChangeState(EPrefetched);

    }

}

void CMMAMIDIPlayer::GetDuration(TInt64* aDuration)

{

    // Special case for device://midi

    if ((iSourceStreams.Count() == 0) &&

            (iFileName == KNullDesC))

    {

        iDuration = KErrNone;

    }

    else if (iDuration == KTimeUnknown)

    {

        TRAPD(err, iDuration = iMidi->DurationMicroSecondsL().Int64());

        if (err != KErrNone)

        {

            // Duration was not available.

            iDuration = KTimeUnknown;

        }

    }

    *aDuration = iDuration;

}

void CMMAMIDIPlayer::SetMediaTimeL(TInt64* aTime)

{

    TTimeIntervalMicroSeconds position(*aTime);

    iMidi->SetPositionMicroSecondsL(position);

    // Reset cached media time, because actual set position may be

    // something else than aTime.

    iMediaTime = KTimeUnknown;

    // Inform about the position change to the StateListeners

    ChangeState(iState);

    // Get the actual media time

    GetMediaTime(aTime);

    iStartedEventTime = iMediaTime;

}

void CMMAMIDIPlayer::GetMediaTime(TInt64* aMediaTime)

{

    // Special case for device://midi

    if ((iSourceStreams.Count() == 0) &&

            (iFileName == KNullDesC))

    {

        iMediaTime = KErrNone;

    }

    else if (iMediaTime == KTimeUnknown || iState == EStarted)

    {

        TTimeIntervalMicroSeconds position(0);

        TRAPD(error, position = iMidi->PositionMicroSecondsL());

        if (error == KErrNone)

        {

            TInt64 newTime = position.Int64();

            // Sanity check for media time going backwards or beyond the

            // duration.

            // Some native controls may return zero media time for

            // a few moments just before playback will complete.

            if (newTime < iMediaTime ||

                    (iDuration > 0 && newTime > iDuration))

            {

                GetDuration(&iMediaTime);

            }

            else

            {

                // set return value

                iMediaTime = newTime;

            }

        }

        else

        {

            // media time cannot be get

            iMediaTime = KTimeUnknown;

        }

    }

    *aMediaTime = iMediaTime;

}

void CMMAMIDIPlayer::ReInitializeMidiEngineL(const TDesC8* aMidiSequence)

{

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMIDIPlayer: ReInitializeMidiEngineL: + ");

    CloseClientUtility();

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMidiPlayer: ReInitializeMidiEngineL: Opening descriptor");

    iMidi->OpenDes(*aMidiSequence);

    // Wait until asynchronous OpenDes call has completed

    if (!iActiveSchedulerWait->IsStarted())

    {

        iActiveSchedulerWait->Start();

    }

    ChangeState(EPrefetched);

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMIDIPlayer: ReInitializeMidiEngineL: - ");

}

void CMMAMIDIPlayer::addObserverL(MMidiClientUtilityObserver* aObserver)

{

    iObservers.AppendL(aObserver);

}

void CMMAMIDIPlayer::CloseL()

{

    CMMAPlayer::CloseL();

    CloseClientUtility();

}

const TDesC& CMMAMIDIPlayer::Type()

{

    return KMMAMIDIPlayer;

}

void CMMAMIDIPlayer::PlayCompleteL(TInt aError)

{

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMidiPlayer: PlayCompleteL +");

    ELOG1(EJavaMMAPI, "MMA: CMMAMidiPlayer: PlayCompleteL: Error=%d", aError);

    TInt64 duration;

    GetDuration(&duration);

    iMediaTime = duration;

    iStartedEventTime = 0;

    iMidi->Stop(TTimeIntervalMicroSeconds(0));

    // go back to prefetched state

    ChangeState(EPrefetched);   // ready to play again

    // Send 'Stopped' only when stop() is called.

    PostLongEvent(CMMAPlayerEvent::EEndOfMedia, duration);

    if (aError == KErrNone)

    {

        iRepeatCount++;

        if (iRepeatForever || iRepeatCount < iRepeatNumberOfTimes)

        {

            StartL();

        }

        else

        {

            iRepeatCount = 0;

        }

    }

    else

    {

        // error has occured, setting correct number of

        // repeats for next start

        SetLoopCount(iRepeatNumberOfTimes);

    }

    LOG(EJavaMMAPI, EInfo, "MMA: CMMAMidiPlayer: PlayCompleteL -");

}

void CMMAMIDIPlayer::MmcuoStateChanged(TMidiState aOldState,

                                       TMidiState aNewState,

                                       const TTimeIntervalMicroSeconds& aTime,

                                       TInt aError)

{

    TInt err = aError;

    ELOG3(EJavaMMAPI, "MMA: CMMAMIDIPlayer: MmcuoStateChanged: Old=%d, New=%d, Error=%d",

          aOldState,

          aNewState,

          err);

    // Closing the utility or reinitialising

#ifdef RD_JAVA_TMIDISTATECHANGE

    if (iActiveSchedulerWait->IsStarted() &&

            ((aNewState == EMidiStateClosedDisengaged) ||

             (aNewState == EMidiStateOpenDisengaged) ||

             (aNewState == EMidiStateClosedEngaged)))

#else

    if (iActiveSchedulerWait->IsStarted() &&

            ((aNewState == EClosedDisengaged) ||

             (aNewState == EOpenDisengaged) ||

             (aNewState == EClosedEngaged)))

#endif

    {

        iActiveSchedulerWait->AsyncStop();

    }

    // changing from realized to prefetched state

#ifdef RD_JAVA_TMIDISTATECHANGE

    else if ((iState == ERealized) &&

             (aOldState == EMidiStateClosedDisengaged) &&

             ((aNewState == EMidiStateOpenDisengaged) ||

              (aNewState == EMidiStateClosedEngaged) ||

              (aNewState == EMidiStateClosedDisengaged)))

#else

    else if ((iState == ERealized) &&

             (aOldState == EClosed) &&

             ((aNewState == EOpen) || (aNewState == EClosedEngaged) ||

              (aNewState == EClosed)))     // EClosed is EClosedDisengaged

#endif

    {

        if (aError == KErrNone)

        {

            // prefetch succeed

            ChangeState(EPrefetched);

        }

        // else state remains realized

        // inform java

        PostActionCompleted(aError);

        err = KErrNone; // don't report the error again

    }

#ifdef RD_JAVA_TMIDISTATECHANGE

    else if ((aOldState == EMidiStateOpenPlaying) &&

             (aNewState == EMidiStateOpenEngaged) &&

             (iState == EStarted))

#else

    else if ((aOldState == EPlaying) &&

             (aNewState == EOpenEngaged) &&

             (iState == EStarted))

#endif

    {

        // If iState is not EStarted PlayCompleteL may not be called because

        // player may be already stopped.

        // playing completed

        TRAPD(playErr, PlayCompleteL(aError));

        if (playErr != KErrNone)

        {

            err = playErr;

        }

    }

    if (err != KErrNone)

    {

        TBuf<KErrorMessageSize> errorMessage;

        errorMessage.Format(KErrDefaultError, err);

        PostStringEvent(CMMAPlayerEvent::EError, errorMessage);

        if (iActiveSchedulerWait->IsStarted())

        {

            iActiveSchedulerWait->AsyncStop();

        }

    }

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoStateChanged(aOldState, aNewState, aTime, aError);

    }

    LOG1(EJavaMMAPI, EInfo, "MMA: CMMAMIDIPlayer: MmcuoStateChanged: midi state %d",

         iMidi->State());

}

void CMMAMIDIPlayer::MmcuoTempoChanged(TInt aMicroBeatsPerMinute)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoTempoChanged(aMicroBeatsPerMinute);

    }

}

void CMMAMIDIPlayer::MmcuoVolumeChanged(TInt aChannel,TReal32 aVolumeInDecibels)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoVolumeChanged(aChannel, aVolumeInDecibels);

    }

}

void CMMAMIDIPlayer::MmcuoMuteChanged(TInt aChannel,TBool aMuted)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoMuteChanged(aChannel, aMuted);

    }

}

void CMMAMIDIPlayer::MmcuoSyncUpdate(const TTimeIntervalMicroSeconds& aMicroSeconds,TInt64 aMicroBeats)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoSyncUpdate(aMicroSeconds, aMicroBeats);

    }

}

void CMMAMIDIPlayer::MmcuoMetaDataEntryFound(const TInt aMetaDataEntryId,const TTimeIntervalMicroSeconds& aPosition)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoMetaDataEntryFound(aMetaDataEntryId, aPosition);

    }

}

void CMMAMIDIPlayer::MmcuoMipMessageReceived(const RArray<TMipMessageEntry>& aMessage)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoMipMessageReceived(aMessage);

    }

}

void CMMAMIDIPlayer::MmcuoPolyphonyChanged(TInt aNewPolyphony)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoPolyphonyChanged(aNewPolyphony);

    }

}

void CMMAMIDIPlayer::MmcuoInstrumentChanged(TInt aChannel,TInt aBankId,TInt aInstrumentId)

{

    // notify observers

    TInt count = iObservers.Count();

    for (TInt i = 0; i < count; i++)

    {

        iObservers[ i ]->MmcuoInstrumentChanged(aChannel, aBankId, aInstrumentId);

    }

}

void CMMAMIDIPlayer::CloseClientUtility()