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

//

#include <e32property.h>

#include <f32file.h>

#include <e32debug.h>

#include <barsc2.h>

#include <remcondatabaseawarenowplayingtarget.h>

#include <remcondatabaseawaremediabrowsetarget.h>

#include <remcondatabaseawaremedialibrarybrowse.h>

#include <remcondatabaseawarenowplayingbrowse.h>

#include <remconmediaerror.h>

#include <reftsp/reftspactiveplayerobserver.h>

#include "browsingframe.h"

#include "tavsrc.h"

#include "tavsrcmtupdaterdatabaseaware.h"

#include "activecallbackconsole.h"

#ifdef __WINS__

GLDEF_D TSize gUpdaterConsole(75,30);

GLDEF_D TSize gBrowseConsole(75,30);

#else

GLDEF_D TSize gUpdaterConsole(KConsFullScreen,KConsFullScreen);

GLDEF_D TSize gBrowseConsole(KConsFullScreen,KConsFullScreen);

#endif

#define BROWSE_CONSOLE iMtBrowseConsole

const TRemConItemUid KUidMarker = 0xc0ffeeee00000000ull;

const TRemConItemUid KFolderMarker = 0x0000000100000000ull;

const TInt KNumberFolderItemsInFolder = 1;

const TInt KNumberMediaItemsInFolder = 1502;

const TInt KNumberItemsInFolder = KNumberMediaItemsInFolder + KNumberFolderItemsInFolder; 

const TInt KMaxFolderDepth = 10;

_LIT8(KFolderName, "Folder%08x");

CTavsrcMtUpdater* CTavsrcMtUpdater::NewL(CRemConInterfaceSelector& aIfSel, TUint aRemConInterfaces)

	{

	CTavsrcMtUpdater* mt = new(ELeave)CTavsrcMtUpdater();

	CleanupStack::PushL(mt);

	mt->ConstructL(aIfSel, aRemConInterfaces);

	CleanupStack::Pop();

	return mt;

	}

struct TMediaBrowseThreadParams

	{

	CRemConInterfaceSelector*	iIfSel;

	CTavsrcMtUpdater*			iUpdater;

	};

TInt CTavsrcMtUpdater::MediaBrowseThread(TAny* aPtr)

	{

	TMediaBrowseThreadParams* params = reinterpret_cast<TMediaBrowseThreadParams*>(aPtr);

	CTrapCleanup* cleanupStack = CTrapCleanup::New();

	CActiveScheduler* activescheduler = new CActiveScheduler;

	CActiveScheduler::Install(activescheduler);

	TInt err = KErrNoMemory;

	if(cleanupStack && activescheduler)

		{

		CTavsrcMtUpdater* self = params->iUpdater;

		TRAP(err, self->BrowseSetupL(*(params->iIfSel)))

		RThread().Rendezvous(err);

		if(err == KErrNone)

			{

			CActiveScheduler::Start();

			}

		self->BrowseCleanup();

		}

	delete activescheduler;

	delete cleanupStack;

	return err;

	}

void CTavsrcMtUpdater::BrowseSetupL(CRemConInterfaceSelector& aIfSel)

	{

	iMtBrowseConsole = CActiveCallBackConsole::NewL(BrowseKeyPressed, this, _L("MtBrowse"),gBrowseConsole);

	BrowseMenu();

	iMtBrowseStopper = CStopBrowseWatcher::NewL();

	iMediaBrowse = CRemConDatabaseAwareMediaBrowseTarget::NewL(aIfSel, 

			*this, *this, EFalse, iMediaBrowseInterface, 

			iNowPlayingBrowseInterface,

			iUidCounter);

	iMtBrowseStopper->Start();

	}

void CTavsrcMtUpdater::BrowseCleanup()

	{

	delete iMtBrowseStopper; iMtBrowseStopper = NULL;

	delete iMtBrowseConsole; iMtBrowseConsole = NULL;

	}

void CTavsrcMtUpdater::ConstructL(CRemConInterfaceSelector& aIfSel, TUint aRemConInterfaces)

	{ 

	if (aRemConInterfaces & EPlayerInformation)

		{

		iPlayerInformation = CPlayerInfoTarget::NewL(aIfSel,

											iPlayerCapabilitiesObserver,

											iPlayerApplicationSettingsObserver,

											iPlayerEventsObserver,

											*this);

		}

	if (aRemConInterfaces & ENowPlaying)

		{

		iNowPlaying = CRemConDatabaseAwareNowPlayingTarget::NewL(aIfSel, *this);

		}

	if (aRemConInterfaces & EMediaBrowse)

		{

		// Create media browse thread (and wait until it is running)...

		TMediaBrowseThreadParams params;

		params.iIfSel = &aIfSel;

		params.iUpdater = this;

		TRequestStatus status;

		User::LeaveIfError(iMediaBrowseThread.Create(KNullDesC, CTavsrcMtUpdater::MediaBrowseThread, KDefaultStackSize, NULL, &params));

		iMediaBrowseThread.Rendezvous(status);

		iMediaBrowseThread.Resume();

		User::WaitForRequest(status);

		User::LeaveIfError(status.Int());

		iMediaBrowseThreadOpen = ETrue;

		}

	iMtUpdaterConsole = CActiveConsole::NewL(*this,_L("MtUpdater"),gUpdaterConsole);

	// configure the PlayerInformation from resource file	

	ReadAVRCPSettingsFile(KAVRCPSettingsResourceFilename);

	// We don't need to call AddEvent() for PlaybackStatusChanged or TrackChanged

	// since these are mandatory events which must be supported. A KErrAlreadyExists

	// error is returned if these are called from here.

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationPlaybackStatusChanged);

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationTrackChanged);

	// configure the interface with the events supported by tavsrc

	// This cannot fail as we constructed the iNotificationEvents array to have a granularity sufficient to 

	// contain all events without having to grow

	User::LeaveIfError( iPlayerCapabilitiesObserver->AddEvent(ERegisterNotificationTrackReachedEnd));

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationTrackReachedEnd);

	User::LeaveIfError( iPlayerCapabilitiesObserver->AddEvent(ERegisterNotificationTrackReachedStart));

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationTrackReachedStart);

	User::LeaveIfError( iPlayerCapabilitiesObserver->AddEvent(ERegisterNotificationPlaybackPosChanged));

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationPlaybackPosChanged);

	User::LeaveIfError( iPlayerCapabilitiesObserver->AddEvent(ERegisterNotificationBatteryStatusChanged));

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationBatteryStatusChanged);

	User::LeaveIfError( iPlayerCapabilitiesObserver->AddEvent(ERegisterNotificationPlayerApplicationSettingChanged));

	(void)iNotificationEvents.InsertInOrder(ERegisterNotificationPlayerApplicationSettingChanged);

	// save a Company ID

	iPlayerCapabilitiesObserver->AddCompanyId(0x4321);

	iCompanyIds.InsertInOrderL(0x4321);

	// set the player events to some test values 

	iPlayerEventsObserver->TrackReachedEnd();

	// playing 12, which is 2:30 long with a low battery

	iPlayerEventsObserver->PlaybackStatusChanged(MPlayerEventsObserver::EStopped);

	iPlaybackStatus = MPlayerEventsObserver::EStopped;

	iPlayerEventsObserver->TrackChanged(12, 150*1000);

	iLength = 150*1000;

	iPlayerEventsObserver->SetBatteryStatus(MPlayerEventsObserver::ECritical);

	iBatteryStatus = MPlayerEventsObserver::ECritical;

	// current position is 1 minute 10 secs though track 12

	iPlayerEventsObserver->SetPlaybackPosition(70000);	

	iPosition = 70000;

	_LIT_SECURITY_POLICY_PASS(KPassPolicy);

	TInt err = RProperty::Define(TUid::Uid(KRefTspProperty), KRefTspActivePlayer, RProperty::EInt, KPassPolicy, KPassPolicy);

	if(err != KErrNone && err != KErrAlreadyExists)

		{

		User::Leave(err);

		}

	MtMenu();

	}

CTavsrcMtUpdater::CTavsrcMtUpdater()

	: iNotificationEvents(ERegisterNotificationReservedLast),

	  iUidCounter(1)

	{

	}

CTavsrcMtUpdater::~CTavsrcMtUpdater()

	{

	delete iMtUpdaterConsole;

	iNotificationEvents.Close();

	iCompanyIds.Close();

	if(iMediaBrowseThreadOpen)

		{

		TRequestStatus status;

		iMediaBrowseThread.Logon(status);

		iMtBrowseStopper->Complete();

		User::WaitForRequest(status);

		// the browse thread should not be running now.

		}

	iMediaBrowseThread.Close();

	}

void CTavsrcMtUpdater::ReadAVRCPSettingsFile(const TDesC& aResourceFileName)

/**

 - Creates the resource reader.

 - Reads the default policy evaluator and dialog creator UIDs.

 - Reads the number of policies in the resource file.

@param aRFs					The file server session used by the resource parser.

@param aResourceFileName	The name of the AVRCP settings file to read.

*/

	{

	RFs rfs;

	rfs.Connect();

	RFile r;

	User::LeaveIfError(r.Open(rfs, aResourceFileName, EFileRead | EFileShareReadersOnly));

	CleanupClosePushL(r);

	TInt size;

	User::LeaveIfError(r.Size(size));

	CleanupStack::PopAndDestroy(&r);

	CResourceFile* resourceFile = CResourceFile::NewLC(rfs, aResourceFileName, 0, size);

	PlayerApplicationSettingsResourceInit::DefineAttributesL(*iPlayerApplicationSettingsObserver, *resourceFile);

	CleanupStack::PopAndDestroy(resourceFile);

	}

void CTavsrcMtUpdater::KeyPressed(TChar aKey)

	{

	switch(aKey)

		{

	case 'e':

		{

		AddEvent(ERegisterNotificationPlaybackPosChanged);

		iNotificationEvents.InsertInOrder(ERegisterNotificationPlaybackPosChanged);

		iMtUpdaterConsole->Console().Printf(_L("Add event EPlaybackPosChanged\n"));

		break;

		}

	case 'c':

		{

		AddCompanyId(0x5678);

		(void)iCompanyIds.InsertInOrder(0x5678);

		iMtUpdaterConsole->Console().Printf(_L("Add CompanyId 0x5678\n"));

		break;

		}

	case '1':

		{

		PlackbackStatusChanged(NextPlaybackStatus());

		iMtUpdaterConsole->Console().Printf(_L("Playback status changed %d\n"),iPlaybackStatus);

		break;

		}

	case '2':

		{

		TrackChanged(++iIndex, KDefaultLength);

		iMtUpdaterConsole->Console().Printf(_L("Track changed\n"));

		break;

		}

	case '3':

		{

		TrackReachedEnd();

		iMtUpdaterConsole->Console().Printf(_L("Track reached end\n"));

		break;

		}

	case '4':

		{

		TrackReachedStart();

		iMtUpdaterConsole->Console().Printf(_L("Track reached end\n"));

		break;

		}

	case '5':

		{

		iPosition += KPositionIncrement;

		SetPlaybackPosition(iPosition);

		iMtUpdaterConsole->Console().Printf(_L("Position %d\n"),iPosition );

		break;

	case '6':

		{

		SetBatteryStatus(NextBatteryStatus());

		iMtUpdaterConsole->Console().Printf(_L("BatteryStatus %d\n"),iBatteryStatus );

		break;

		}

		}

	case '8':

		{

		// change an application setting, 

		// increment the value if attribute ID no 1 for example

		// CPlayerInfoTarget

		iPlayerApplicationSettingsObserver->SetAttributeL(1, 2);

		iMtUpdaterConsole->Console().Printf(_L("Increment the value if attribute ID no 1\n") );

		break;

		}

	case '9':

		{

		// Update NowPlayingList 

		iNowPlaying->NowPlayingContentChanged();

		iMtUpdaterConsole->Console().Printf(_L("Now Playing List updated\n") );

		break;

		}

	case '0':

		{

		User::SafeInc(*reinterpret_cast<TInt*>(&iUidCounter)); // Might get dodgy when reaching 0x80000000

		iMediaBrowseInterface->MrcdamlbMediaLibraryStateChange(iUidCounter);

		iMtUpdaterConsole->Console().Printf(_L("UIDs changed: %d \n"), iUidCounter);

		break;

		}

	case 'a':

		{

		SetAsActivePlayer();

		break;

		}

	default:

		iMtUpdaterConsole->Console().Printf(_L("No such command\n"));

		break;

		};

	MtMenu();

	}

void CTavsrcMtUpdater::MtMenu()

	{

	DisplayCurrentState();

	iMtUpdaterConsole->Console().Printf(_L("e.\tAddEvent\n"));

	iMtUpdaterConsole->Console().Printf(_L("c.\tAddCompanyId\n"));

	iMtUpdaterConsole->Console().Printf(_L("1.\tPlaybackStatusChanged\n"));

	iMtUpdaterConsole->Console().Printf(_L("2.\tTrackChanged\n"));

	iMtUpdaterConsole->Console().Printf(_L("3.\tTrackReachedEnd\n"));

	iMtUpdaterConsole->Console().Printf(_L("4.\tTrackReachedStart\n"));

	iMtUpdaterConsole->Console().Printf(_L("5.\tPlaybackPositionChanged\n"));

	iMtUpdaterConsole->Console().Printf(_L("6.\tSetBatteryStatus\n"));

	iMtUpdaterConsole->Console().Printf(_L("8.\tAttributeChanged\n"));

	iMtUpdaterConsole->Console().Printf(_L("9.\tNowPlayingContentChanged\n"));

	iMtUpdaterConsole->Console().Printf(_L("0.\tUIDsChanged\n"));

	iMtUpdaterConsole->Console().Printf(_L("\n"));

	iMtUpdaterConsole->RequestKey();

	}

TInt CTavsrcMtUpdater::BrowseKeyPressed(TAny* aPtr, TChar aKey)

	{

	TRAPD(err, static_cast<CTavsrcMtUpdater*>(aPtr)->BrowseKeyPressedL(aKey));

	return err;

	}

void CTavsrcMtUpdater::BrowseKeyPressedL(TChar aKey)

	{

	switch(aKey)

		{

	case '0':

		{

		User::SafeInc(*reinterpret_cast<TInt*>(&iUidCounter)); // Might get dodgy when reaching 0x80000000

		iMediaBrowseInterface->MrcdamlbMediaLibraryStateChange(iUidCounter);

		BROWSE_CONSOLE->Console().Printf(_L("UIDs changed: %d \n"), iUidCounter);

		break;

		}

	default:

		BROWSE_CONSOLE->Console().Printf(_L("No such command\n"));

		break;

		};

	BrowseMenu();

	}

void CTavsrcMtUpdater::BrowseMenu()

	{

	BROWSE_CONSOLE->Console().Printf(_L("0.\tUIDsChanged\n"));

	BROWSE_CONSOLE->Console().Printf(_L("\n"));

	BROWSE_CONSOLE->RequestKey();

	}

void CTavsrcMtUpdater::AddEvent(TRegisterNotificationEvent aEvent)

	{

	iPlayerCapabilitiesObserver->AddEvent(aEvent);

	}

void CTavsrcMtUpdater::AddCompanyId(TInt aCompanyId)

	{

	// save a Company ID

	iPlayerCapabilitiesObserver->AddCompanyId(aCompanyId);

	}

void CTavsrcMtUpdater::TrackReachedEnd()

	{

	iPlayerEventsObserver->TrackReachedEnd();

	}

void CTavsrcMtUpdater::TrackReachedStart()

	{

	iPlayerEventsObserver->TrackReachedStart();

	}

void CTavsrcMtUpdater::PlackbackStatusChanged(MPlayerEventsObserver::TPlaybackStatus aPlaybackStatus)

	{ 

	iPlayerEventsObserver->PlaybackStatusChanged(aPlaybackStatus);

	}

void CTavsrcMtUpdater::TrackChanged(TUint64 aIndex, TUint32 aLengthInMilliseconds)

	{ 

	iPlayerEventsObserver->TrackChanged(aIndex, aLengthInMilliseconds);

	}

void CTavsrcMtUpdater::SetBatteryStatus(MPlayerEventsObserver::TTargetBatteryStatus aStatus)

	{

	iPlayerEventsObserver->SetBatteryStatus(aStatus);

	}

void CTavsrcMtUpdater::SetPlaybackPosition(TUint32 aPosition)

	{	

	iPlayerEventsObserver->SetPlaybackPosition(aPosition);

	}

void CTavsrcMtUpdater::SetAsActivePlayer()

	{

	TInt err = RProperty::Set(TUid::Uid(KRefTspProperty), KRefTspActivePlayer, RProcess().Id());

	iMtUpdaterConsole->Console().Printf(_L("Set as active player %d\n"), err);

	}

MPlayerEventsObserver::TPlaybackStatus CTavsrcMtUpdater::NextPlaybackStatus()

	{

	if(iPlaybackStatus == MPlayerEventsObserver::EStopped)

		{

		iPlaybackStatus = MPlayerEventsObserver::EPlaying;

		}

	else if(iPlaybackStatus == MPlayerEventsObserver::EPlaying)

		{

		iPlaybackStatus = MPlayerEventsObserver::EPaused;

		}

	else if(iPlaybackStatus == MPlayerEventsObserver::EPaused)

		{

		iPlaybackStatus = MPlayerEventsObserver::EFwdSeek;

		}

	else if(iPlaybackStatus == MPlayerEventsObserver::EFwdSeek)

		{

		iPlaybackStatus = MPlayerEventsObserver::ERevSeek;

		}

	else if(iPlaybackStatus == MPlayerEventsObserver::ERevSeek)

		{

		iPlaybackStatus = MPlayerEventsObserver::EStopped;

		}

	return iPlaybackStatus;

	}

MPlayerEventsObserver::TTargetBatteryStatus CTavsrcMtUpdater::NextBatteryStatus()

	{

	if(iBatteryStatus == MPlayerEventsObserver::ENormal)

		{

		iBatteryStatus = MPlayerEventsObserver::EWarning;

		}

	else if(iBatteryStatus == MPlayerEventsObserver::EWarning)

		{

		iBatteryStatus = MPlayerEventsObserver::ECritical;

		}

	else if(iBatteryStatus == MPlayerEventsObserver::ECritical)

		{

		iBatteryStatus = MPlayerEventsObserver::EExternal;

		}

	else if(iBatteryStatus == MPlayerEventsObserver::EExternal)

		{

		iBatteryStatus = MPlayerEventsObserver::EFullCharge;

		}

	else if(iBatteryStatus == MPlayerEventsObserver::EFullCharge)

		{

		iBatteryStatus = MPlayerEventsObserver::ENormal;

		}

	return iBatteryStatus;

	}

// from MPlayerApplicationSettingsNotify

void CTavsrcMtUpdater::MpasnSetPlayerApplicationValueL(const RArray<TInt>& aAttributeID, const RArray<TInt>& aAttributeValue)

	{

	for (TInt i=0; i < aAttributeID.Count(); i++)

		{

		iMtUpdaterConsole->Console().Printf(_L("SetPlayerApplication attribute:%d value:%d \n"),aAttributeID[i], aAttributeValue[i]);	

		}

	}

void CTavsrcMtUpdater::MrcdanptoPlayItem(const TRemConItemUid& aItem, TRemConFolderScope aScope, TUint16 aUidCounter)

	{

	iMtUpdaterConsole->Console().Printf(_L("* PlayItem %08x %08x\t scope %d remote uidcounter %d\n"), aItem>>32, aItem & 0xffffffff, aScope, aUidCounter);

	if(iUidCounter != aUidCounter)

		{

		iMtUpdaterConsole->Console().Printf(_L("remote uidcounter does not match local(%d)\n"), iUidCounter);

		iNowPlaying->PlayItemResponse(KErrInvalidMediaLibraryStateCookie);

		}

	else

		{

		iNowPlaying->PlayItemResponse(KErrNone);

		}

	}

void CTavsrcMtUpdater::MrcdanptoAddToNowPlaying(const TRemConItemUid& aItem, TRemConFolderScope aScope, TUint16 aUidCounter)

	{

	iMtUpdaterConsole->Console().Printf(_L("* AddToNowPlaying %08x%08x\t scope %d uidcounter %d\n"), aItem>>32, aItem, aScope, aUidCounter);

	if(iUidCounter != aUidCounter)

		{

		iMtUpdaterConsole->Console().Printf(_L("remote uidcounter does not match local(%d)\n"), iUidCounter);