// Copyright (c) 2010 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:

//

/**

 @file

 @internalComponent

*/

#include <mtp/mmtpconnection.h>

#include <mtp/mmtpdataproviderframework.h>

#include <mtp/mtpdataproviderapitypes.h>

#include "cmtpplaybackcontroldp.h"

#include "cmtprequestprocessor.h"

#include "mtpplaybackcontroldpprocessor.h"

#include "cmtpplaybackmap.h"

#include "cmtpplaybackproperty.h"

#include "mmtpplaybackinterface.h"

#include "cmtpplaybackevent.h"

#include "mtpplaybackcontrolpanic.h"

static const TInt KMTPPlaybackControlDpSessionGranularity(3);

/**

MTP playback control data provider plug-in factory method.

@return A pointer to an MTP playback control data provider plug-in. Ownership IS

transfered.

@leave One of the system wide error codes, if a processing failure occurs.

*/

TAny* CMTPPlaybackControlDataProvider::NewL(TAny* aParams)

    {

    CMTPPlaybackControlDataProvider* self = new (ELeave) CMTPPlaybackControlDataProvider(aParams);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

/**

Destructor

*/

CMTPPlaybackControlDataProvider::~CMTPPlaybackControlDataProvider()

    {

    TInt count = iActiveProcessors.Count();

    while(count--)

        {

        iActiveProcessors[count]->Release();

        }

    iActiveProcessors.Close();

    delete iPlaybackMap;

    delete iPlaybackProperty;

    if(iPlaybackControl)

        {

        iPlaybackControl->Close();

        }

    }

void CMTPPlaybackControlDataProvider::Cancel()

    {

    }

void CMTPPlaybackControlDataProvider::ProcessEventL(const TMTPTypeEvent& /*aEvent*/, MMTPConnection& /*aConnection*/)

    {

    }

void CMTPPlaybackControlDataProvider::ProcessNotificationL(TMTPNotification aNotification, const TAny* aParams)

    {

    switch (aNotification)

        {

    case EMTPSessionClosed:

        SessionClosedL(*reinterpret_cast<const TMTPNotificationParamsSessionChange*>(aParams));

        break;

    case EMTPSessionOpened:

        SessionOpenedL(*reinterpret_cast<const TMTPNotificationParamsSessionChange*>(aParams));

        break;

    default:

        // Ignore all other notifications.

        break;

        }

    }

void CMTPPlaybackControlDataProvider::ProcessRequestPhaseL(TMTPTransactionPhase aPhase, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)

    {

    TInt index = LocateRequestProcessorL(aRequest, aConnection);

    __ASSERT_DEBUG(index != KErrNotFound, Panic(EMTPPBArgumentErr));

    MMTPRequestProcessor* processor = iActiveProcessors[index];

    iActiveProcessor = index;

    iActiveProcessorRemoved = EFalse;

    TBool result = processor->HandleRequestL(aRequest, aPhase);

    if (iActiveProcessorRemoved)

	    {

	    processor->Release(); // destroy the processor

	    }

    else if (result)

	    {

	    processor->Release();    	

	    iActiveProcessors.Remove(index);

	    }

    iActiveProcessor = -1;

    }

void CMTPPlaybackControlDataProvider::Supported(TMTPSupportCategory aCategory, RArray<TUint>& aArray) const

    {

    switch (aCategory)

        {

    case EDeviceProperties:

        {

        TInt count = sizeof(KMTPPlaybackControlDpSupportedProperties) / sizeof(KMTPPlaybackControlDpSupportedProperties[0]);

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

            {

            aArray.Append(KMTPPlaybackControlDpSupportedProperties[i]);

            }

        }

        break;

    case EOperations:

        {

        TInt count = sizeof(KMTPPlaybackControlDpSupportedOperations) / sizeof(KMTPPlaybackControlDpSupportedOperations[0]);

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

            {

            aArray.Append(KMTPPlaybackControlDpSupportedOperations[i]);

            }

        }

        break;

    case EEvents:

        {

        TInt count = sizeof(KMTPPlaybackControlDpSupportedEvents) / sizeof(KMTPPlaybackControlDpSupportedEvents[0]);

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

            {

            aArray.Append(KMTPPlaybackControlDpSupportedEvents[i]);

            }

        }

        break;

    default:

        // Unrecognised category, leave aArray unmodified.

        break;

        }

    }

/**

Constructor.

*/

CMTPPlaybackControlDataProvider::CMTPPlaybackControlDataProvider(TAny* aParams) :

    CMTPDataProviderPlugin(aParams),

    iActiveProcessors(KMTPPlaybackControlDpSessionGranularity),

    iActiveProcessor(-1),

    iRequestToResetPbCtrl(EFalse)

    {

    }

/**

Second phase constructor.

*/

void CMTPPlaybackControlDataProvider::ConstructL()

    {

    iPlaybackProperty = CMTPPlaybackProperty::NewL();

    iPlaybackMap = CMTPPlaybackMap::NewL(Framework(),*iPlaybackProperty);

    }

void CMTPPlaybackControlDataProvider::SendEventL(TMTPDevicePropertyCode aPropCode)

	{

	iEvent.Reset();

	iEvent.SetUint16(TMTPTypeEvent::EEventCode, EMTPEventCodeDevicePropChanged );

	iEvent.SetUint32(TMTPTypeEvent::EEventSessionID, KMTPSessionAll);

	iEvent.SetUint32(TMTPTypeEvent::EEventTransactionID, KMTPTransactionIdNone);

	iEvent.SetUint32(TMTPTypeEvent::EEventParameter1, aPropCode);

	Framework().SendEventL(iEvent);

	}

/**

Find or create a request processor that can process the request

@param aRequest    The request to be processed

@param aConnection The connection from which the request comes

@return the index of the found/created request processor

*/

TInt CMTPPlaybackControlDataProvider::LocateRequestProcessorL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)

    {

    TInt index = KErrNotFound;

    TInt count = iActiveProcessors.Count();

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

        {

        if(iActiveProcessors[i]->Match(aRequest, aConnection))

            {

            index = i;

            break;

            }

        }

    if(index == KErrNotFound)

        {

        MMTPRequestProcessor* processor = MTPPlaybackControlDpProcessor::CreateL(Framework(), aRequest, aConnection, *this);

        __ASSERT_DEBUG(processor, Panic(EMTPPBArgumentErr));

        CleanupReleasePushL(*processor);

        iActiveProcessors.AppendL(processor);

        CleanupStack::Pop();

        index = count;

        }

    return index;

    }

/**

Cleans up outstanding request processors when a session is closed.

@param aSession notification parameter block

*/

void CMTPPlaybackControlDataProvider::SessionClosedL(const TMTPNotificationParamsSessionChange& aSession)

    {

    TInt count = iActiveProcessors.Count();

    while (count--)

        {

        MMTPRequestProcessor* processor = iActiveProcessors[count];

        TUint32 sessionId(processor->SessionId());

        if ((sessionId == aSession.iMTPId) && (processor->Connection().ConnectionId() == aSession.iConnection.ConnectionId()))

            {

            iActiveProcessors.Remove(count);

            if (count == iActiveProcessor)

                {

                iActiveProcessorRemoved = ETrue;

                }

            else

                {

                processor->Release();

                }

            }

        }

    if(iPlaybackControl)

        {

        iPlaybackControl->Close();

        iPlaybackControl = NULL;

        }

    }

/**

Prepares for a newly-opened session.

@param aSession notification parameter block

*/

void CMTPPlaybackControlDataProvider::SessionOpenedL(const TMTPNotificationParamsSessionChange& aSession)

    {

    }

void CMTPPlaybackControlDataProvider::StartObjectEnumerationL(TUint32 aStorageId, TBool /*aPersistentFullEnumeration*/)

    {

    //This DP doesn't manage data.

    Framework().ObjectEnumerationCompleteL(aStorageId);

    }

void CMTPPlaybackControlDataProvider::StartStorageEnumerationL()

    {

    //This DP doesn't manage data.

    Framework().StorageEnumerationCompleteL();

    }

void CMTPPlaybackControlDataProvider::HandlePlaybackEventL(CMTPPlaybackEvent* aEvent, TInt aErr)

    {

    if(aErr != KPlaybackErrNone)

        {

        if(aErr == KPlaybackErrDeviceUnavailable )

            {

            iRequestToResetPbCtrl = ETrue;

            //Report error to initiator, .

            SendEventL(EMTPDevicePropCodePlaybackObject);

            SendEventL(EMTPDevicePropCodePlaybackRate);

            SendEventL(EMTPDevicePropCodePlaybackContainerIndex);

            SendEventL(EMTPDevicePropCodePlaybackPosition);

            }

        return;

        }

    __ASSERT_DEBUG((aEvent != NULL), Panic(EMTPPBDataNullErr));

    switch(aEvent->PlaybackEvent())

        {

        case EPlaybackEventVolumeUpdate:

            {

            SendEventL(EMTPDevicePropCodeVolume);

            }

            break;

        case EPlaybackEventStateUpdate:

            {

            SendEventL(EMTPDevicePropCodePlaybackRate);

            }

            break;           

        case EPlaybackEventObjectUpdate:

            {

            SendEventL(EMTPDevicePropCodePlaybackObject);

            }

            break;

        case EPlaybackEventObjectIndexUpdate:

            {

            SendEventL(EMTPDevicePropCodePlaybackContainerIndex);

            }

            break;

        default:

            break;

        }

    }

CMTPPlaybackMap& CMTPPlaybackControlDataProvider::GetPlaybackMap() const 

    {

    __ASSERT_DEBUG((iPlaybackMap != NULL), Panic(EMTPPBDataNullErr));

    return *iPlaybackMap;

    }

CMTPPlaybackProperty& CMTPPlaybackControlDataProvider::GetPlaybackProperty() const 

    {

    __ASSERT_DEBUG((iPlaybackProperty != NULL), Panic(EMTPPBDataNullErr));

    return *iPlaybackProperty;

    }

MMTPPlaybackControl& CMTPPlaybackControlDataProvider::GetPlaybackControlL() 

    {

    if(iPlaybackControl == NULL)

        {

        iPlaybackControl = MMTPPlaybackControl::NewL(*this);

        }

    else if(iRequestToResetPbCtrl)

        {

        iRequestToResetPbCtrl = EFalse;

        iPlaybackControl->Close();

        iPlaybackControl = NULL;

        iPlaybackControl = MMTPPlaybackControl::NewL(*this);

        }

    return *iPlaybackControl;

    }

void CMTPPlaybackControlDataProvider::RequestToResetPbCtrl()

    {

    iRequestToResetPbCtrl = ETrue;

    }