// 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:
//

#ifndef TAVSRC_H
#define TAVSRC_H

//only use define CHANNEL_BINDING_DEBUG_CHECK when checking channel binding
//#define CHANNEL_BINDING_DEBUG_CHECK

#define __PRINT iActiveConsole->Console().Printf
#define __LOG iLogConsole->Console().Printf /*RDebug::Print*/

#include "tavsrcConsole.h"
#include "tavsrcStreamerUser.h"
#include "tavsrcOperations.h"

#include <f32file.h>
#include <btsdp.h>
#include <rtp.h>
#include <gavdp.h>
#include <remconcoreapitargetobserver.h>
#include <remcongroupnavigationtarget.h>
#include <remcongroupnavigationtargetobserver.h>

#include <remconmediainformationtarget.h>
#include <remconmediainformationtargetobserver.h>

#include <remconbatterytarget.h>
#include <remconbatterytargetobserver.h>

#include <playerinformationtarget.h>
#include <playerinformationtargetobserver.h>

#include <remconabsvoltargetobserver.h>
#include <remcontrackinfotargetobserver.h>

enum TRemConInterfaces
	{
	ECoreApiTarget = 1 << 0,
	ECoreApiController = 1 << 1,
	EGroupNavigation = 1 << 2,
	EMediaInformation = 1 << 3,
	EBatteryStatus = 1 << 4,
	EAbsoluteVolumeTarget = 1 << 5,
	EAbsoluteVolumeController = 1 << 6,
	EPlayerInformation = 1 << 7,
	ENowPlaying = 1 << 8,
	EMediaBrowse = 1 << 9,
	EDatabaseAware = 1 << 10,
	ESeparateThreadForBrowse = 1 << 11,
	EVendorTrackInfoTarget = 1 << 12,
	EVendorAbsoluteVolumeTarget = 1 << 13,
	};


typedef TFixedArray<RSocket, 3> RSocketArray;

class CActivePacketDropIoctl;
class CActiveSockReader;
class CActiveSockWriter;
class CRemMetadataTransferTarget;
class CAVTestApp;
class CActiveStreamer;
class CTavsrcController;
class CRemConInterfaceSelector;	
class CRemConCoreApiTarget;
class CRemConTrackInfoTarget;
class CRemConAbsVolTarget;
class CTavsrcMtUpdater;
class CTavsrcAbsoluteVolume;
class CAVTestApp : public CBase, public MActiveConsoleNotify,
						public MGavdpUser, public MBluetoothPhysicalLinksNotifier,
						public MRemConCoreApiTargetObserver,
						public MActiveStreamerUser,
						public MRemConMediaInformationTargetObserver,
						public MRemConGroupNavigationTargetObserver,
						public MRemConBatteryTargetObserver,
						public MRemConTrackInfoTargetObserver,
						public MRemConAbsVolTargetObserver
	{
private:
	enum TTavsrcServiceCategory
		{
		ETavsrcServiceCategoryNull				=0x00,
		ETavsrcServiceCategoryMediaTransport 	=0x01,
		ETavsrcServiceCategoryReporting			=0x02,
		ETavsrcServiceCategoryRecovery			=0x04,
		ETavsrcServiceCategoryContentProtection	=0x08,
		ETavsrcServiceCategoryHeaderCompression	=0x10,
		ETavsrcServiceCategoryMultiplexing		=0x20,
		ETavsrcServiceCategoryMediaCodec		=0x40,
		};
public:
	static CAVTestApp* NewL();
	void EchoStorm();

	void StartL();
	void Stop();
	~CAVTestApp();
	void TestMenu();

	void KeyPressed(TChar aKey);

	TInt StartSrc();
	void StopSrc();
	void DisconnectSrc();

	// echo test
	virtual void HandleCreateConnectionCompleteL(TInt aErr);
	virtual void HandleDisconnectCompleteL(TInt aErr);
	virtual void HandleDisconnectAllCompleteL(TInt aErr);

private:
	void PreventLowPowerModes();
	void AllowLowPowerModes();
	void CreateBearers();
	void CloseBearers();
	void ConfigureSEPL();
	void Abort();
	void DiscoverSEPs();
	void StartStreams();
	void SuspendStreams();
	void GetCapabilities();
	void SendSecurityControl();
	TSBCCodecCapabilities InteractiveSBCMediaCodecConfig(TSBCCodecCapabilities& caps);
	
	void PrintCommandOption(TChar aOperation, TPtrC aDesc);
	
	void CreateStreamerL(RSocketArray aSockets);
	void CreateRemConInterfacesL();

	void Connect();
	TInt Listen();
	TInt RegisterSEP();
	
	CAVTestApp();
	void ConstructL();

	//return ETrue if current SEP is sink, EFalse otherwise
	TBool CurrentSEIDIsSink();

	void DisplayHelp();
	void ParseCommandLineL();
	
private:
	// GAVDP callbacks
	virtual void GAVDP_SEPDiscovered(const TAvdtpSEPInfo& aSEP);
	virtual void GAVDP_SEPDiscoveryComplete();
	virtual void GAVDP_SEPCapability(TAvdtpServiceCapability* aCapability);	
	virtual void GAVDP_SEPCapabilityComplete();
	virtual void GAVDP_AbortStreamConfirm();
	virtual void GAVDP_StartStreamsConfirm();
	virtual void GAVDP_SuspendStreamsConfirm();
	virtual void GAVDP_SecurityControlConfirm(const TDesC8& aResponseData);
	virtual void GAVDP_ConfigurationConfirm();	// configuration complete and SEP selected *AND* reconfigure confirm
	virtual void GAVDP_Error(TInt aError, const TDesC8& aErrorData);
	virtual void GAVDP_ConnectConfirm(const TBTDevAddr& aAddr);

	virtual void GAVDP_ConfigurationStartIndication(TSEID aLocalSEID, TSEID aRemoteSEID);	
	virtual TInt GAVDP_ConfigurationIndication(TAvdtpServiceCapability* aCapability);
	virtual TInt GAVDP_ConfigurationEndIndication();

	virtual TInt GAVDP_StartIndication(TSEID aSEID);
	virtual TInt GAVDP_SuspendIndication(TSEID aSEID);
	virtual TInt GAVDP_SecurityControlIndication(TSEID aSEID, TDes8& aSecurityData);
	virtual void GAVDP_AbortIndication(TSEID aSEID);
	virtual void GAVDP_ReleaseIndication(TSEID aSEID);
	virtual void GAVDP_BearerReady(RSocket aNewSocket, const TAvdtpSockAddr& aAddr);
	
	void PrettyPrint(TAvdtpServiceCapability& aCapability);
	
private:
	// RemConCoreApiTarget callbacks
	virtual void MrccatoCommand(TRemConCoreApiOperationId aOperationId, TRemConCoreApiButtonAction aButtonAct);
	virtual void MrccatoPlay(TRemConCoreApiPlaybackSpeed aSpeed, TRemConCoreApiButtonAction aButtonAct);

private:
	// from MActiveStreamerUser
	virtual void MediaCodecConfigurationRequired(TSBCCodecCapabilities& aConfig);

	virtual TInt MrcmtcGetElementAttributes(TUint64 aElement, TUint32 aAttribute, HBufC8*& aOutValueOwnershipTransferred);

	// from MRemConGroupNavigationTargetObserver	
	virtual void MrcgntoNextGroup(TRemConCoreApiButtonAction aButtonAct);
	virtual void MrcgntoPreviousGroup(TRemConCoreApiButtonAction aButtonAct);
	virtual void MrcbstoBatteryStatus(TControllerBatteryStatus& aBatteryStatus);

	// from MRemConMediaInformationTargetObserver	
	virtual void MrcmitoGetCurrentlyPlayingMetadata( TMediaAttributeIter& aAttributeIter );

	virtual void MrcncRegisterPlaybackStatusChangedNotification();
	virtual void MrcncRegisterTrackChangedNotification();
	virtual void MrcncRegisterTrackReachedEndNotification();
	virtual void MrcncRegisterTrackReachedStartNotification();
	virtual void MrcncRegisterPositionChangedNotification(TUint32 aInterval);
	virtual void MrcncRegisterBatteryStatusChangedNotification();
	virtual void MrcncRegisterSystemStatusChangedNotification();
	virtual void MrcncRegisterPlayerApplicationStatusChangedNotification();
	
	virtual void MrcavtoGetAbsoluteVolume();
	virtual void MrcavtoSetAbsoluteVolume(TUint /*aAbsVol*/, TUint /*aMaxVol*/);
	
	virtual void MrctitoGetTrackName();
	virtual void MrctitoGetArtist();
	virtual void MrctitoGetTrackDuration();

private:
	CActiveConsole* iActiveConsole;
	CActiveConsole* iLogConsole;
	CTavsrcMtUpdater*			iMtUpdater;
		
	RSocketServ iSockServ;
	
#ifdef CHANNEL_BINDING_DEBUG_CHECK
	CActiveSockReader* iRepReader;
	CActiveSockWriter* iRepWriter;
	CActiveSockReader* iRecvReader;
	CActiveSockWriter* iRecvWriter;
#endif
	
	CActivePacketDropIoctl* iPacketDropIoctl;

	RGavdp iGavdp;	
	
	TSEID iCurrentSEID; // Current Remote SEID
	TSEID iCurrentLocalSEID; // Current Local SEID

	RPointerArray<TAvdtpServiceCapability> iSEPCapabilities; // only held for one SEP at a time in this test code

	RArray<TSEID> iShortlistedSEIDs;	// for finding good remote SEP
	TBool iChosenSEP;
	
	RArray<TAvdtpSEPInfo> iLocallyRegisteredSEPs;
	TBool iRegisteringLocalSEP;
	
	CActiveStreamer* iStreamer;
	RSocketArray iPendingSockets;
	
	CRemConInterfaceSelector* iRemConInterfaceSelector;
	CRemConCoreApiTarget* iRemConTarget;
	CRemConGroupNavigationApiTarget* iGroupNavigation;
	CRemConMediaInformationTarget* iMediaInformation;
	CRemConBatteryApiTarget* iBatteryStatus;
	CRemConTrackInfoTarget* iTrackInfo;
	CRemConAbsVolTarget* iAbsoluteVolume;
	CTavsrcAbsoluteVolume* iTavsrcAbsoluteVolume;

	RSdp iSdp;
	RSdpDatabase iSdpDB;
	TSdpServRecordHandle iSrcHandle;
	TSdpServRecordHandle iSnkHandle;
	
	TBool iAutoStream;
	
	enum TGavdpState
		{
		ENoClientOpen,
		EIdle,
		ESigConnected,
		EOpen,
		ESuspended,
		ERemoteReconfiguring,
		};

	enum TStreamState
		{
		EClosed,
		EStreaming,
		EPaused,
		EStopped,
		};
		
	TGavdpState iGavdpState;
	TStreamState iStreamState;
	
	TSBCCodecCapabilities iReconfigInfo;
	TBool iLocalReconfigure;
	
	TUint iDisplayMode;
	TBool iPreloadFile;
	
	CTavsrcController* iController;
	TBTDevAddr iDevAddr;

	CTavsrcOperations* iOperations;
	
	RBuf iFilename;
	RBTPhysicalLinkAdapter iPhy;
		
	TUint iRemConInterfaces;
	};

#endif // TAVSRC_H