// Copyright (c) 2004-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 AVRCPINCOMINGCOMMANDHANDLER_H

#define AVRCPINCOMINGCOMMANDHANDLER_H

/**

@file

@internalComponent

@released

*/

#include <avctpservices.h>

#include <e32base.h>

#include <remcon/clientid.h>

#include "controlcommand.h"

#include "avrcpplayerinfomanager.h"

#include "commandhandlerinterface.h"

class CPassthroughHelper;

class CRcpRouter;

class CRemConBearerAvrcp;

class CAVCFrame;

class TBTDevAddr;

NONSHARABLE_CLASS(CRcpIncomingCommandHandler) : public CBase, public MPlayerChangeObserver, public MIncomingCommandHandler

	{

public:

	static CRcpIncomingCommandHandler* NewL(CRemConBearerAvrcp& aBearer, 

		MRemConBearerObserver& aObserver,

		CRcpRouter& aRouter,

		CDeltaTimer& aTimer,

		CAvrcpPlayerInfoManager& aPlayerInfoManager, TBTDevAddr& aDevice);

	void ConstructL();

	~CRcpIncomingCommandHandler();

	void Disconnect();

	inline CAvrcpPlayerInfoManager& AvrcpPlayerInfoManager() const;

private: // from MIncomingCommandHandler

	void MaxPacketSize(TInt aMtu);

	void ReceiveCommandL(const TDesC8& aMessageInformation, SymbianAvctp::TTransactionLabel aTransLabel, const TBTDevAddr& aAddr);

	void MessageSent(CAvrcpCommand& aCommand, TInt aSendResult);

	TInt SendRemConResponse(TUid aInterfaceUid, TUint aId, RBuf8& aData);

	void SendReject(TUid aInterfaceUid, TUint aId);

private:

	CRcpIncomingCommandHandler(CRemConBearerAvrcp& aBearer, 

		MRemConBearerObserver& aObserver,

		CRcpRouter& aRouter,

		CDeltaTimer& aTimer,

		CAvrcpPlayerInfoManager& aPlayerInfoManager,

		TBTDevAddr& aDevice);

	// From MPlayerChangeObserver

	void MpcoAvailablePlayersChanged();

	void MpcoAddressedPlayerChangedLocally(TRemConClientId aClientId);

	void MpcoUidCounterChanged(TRemConClientId aClientId);

	void Respond(CControlCommand& aCommand, TInt aErr);

	void HandledCommand(CControlCommand& aCommand);

	void HandleInternalCommand(CControlCommand& aCommand);

	void HandleRemConCommand(CControlCommand& aCommand);

	TInt HandleSetAddressedPlayer(TUint aId, RBuf8& aCommandData);

	void DoHandleSetAddressedPlayerL(RBuf8& aCommandData);

	void AddressedPlayerChangedL(TRemConClientId aClientId);

	TInt HandleRegisterAvailablePlayersNotification(CControlCommand& aCommand);

	void DoHandleRegisterAvailablePlayersNotificationL(RBuf8& aResponseData, CControlCommand& aCommand);

	TInt HandleRegisterAddressedPlayerNotification(CControlCommand& aCommand);

	void DoHandleRegisterAddressedPlayerNotificationL(RBuf8& aResponseData, CControlCommand& aCommand);

	TInt HandleUidChangedNotification( CControlCommand& aCommand);

	void DoHandleUidChangedNotificationL(RBuf8& aResponseData, TUint16 aUidCounter);

	void SendInternalResponse(TUint aId, RBuf8& aData);

	void SendResponse(TDblQue<CControlCommand>& aCommandQueue, TUint aId, RBuf8& aData);

	// Timer functions

	TBool DuplicateNotify(TDblQue<CControlCommand>& aCommandQueue, const CControlCommand& aCommand) const;

	CControlCommand* FindNotify(TDblQue<CControlCommand>& aCommandQueue, TUid aInterfaceUid, TUint aOperationId);

private:

	TDblQue<CControlCommand>	iCommandQueue;

	TDblQue<CControlCommand>	iInternalCommandQueue;

	CAVRCPFragmenter*		iFragmenter;

	CRemConBearerAvrcp&		iBearer;

	MRemConBearerObserver&	iObserver;

	CRcpRouter&				iRouter;

	CDeltaTimer& 			iTimer;

	TRemConClientId			iClientId; // We store the client id even if we aren't

									   // in addressed mode as we may switch into

									   // it and need to know the current local

									   // addressed player

	TBool					iAddressedMode;

	CAvrcpPlayerInfoManager&	iPlayerInfoManager;

	TBTDevAddr&					iDevice;

	CPassthroughHelper*			iPassthroughHelper;

	};

CAvrcpPlayerInfoManager& CRcpIncomingCommandHandler::AvrcpPlayerInfoManager() const

	{

	return iPlayerInfoManager;

	}

#endif // AVRCPINCOMINGCOMMANDHANDLER_H