// Copyright (c) 2005-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 "MmfDevSoundCIMuxUtility.h"
#include <mmf/plugin/mmfdevsoundcustominterface.hrh>
#include <mmf/server/mmfdevsoundcustominterface.h>
#include <ecom/ecom.h>
#include <mm/mmpluginutils.h>

const TInt KMuxTempBufferSize = 20;


CMMFDevSoundCIMuxUtility* CMMFDevSoundCIMuxUtility::NewL(MMMFDevSoundCustomInterfaceChannel* aCustomChannel)
	{
	CMMFDevSoundCIMuxUtility* self = new (ELeave) CMMFDevSoundCIMuxUtility(aCustomChannel);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CMMFDevSoundCIMuxUtility::ConstructL()
	{
	// nothing needed in this implementation
	}

CMMFDevSoundCIMuxUtility::~CMMFDevSoundCIMuxUtility()
	{
	iAsyncCustomCommandCleanup.ResetAndDestroy();
	iAsyncCustomCommandCleanup.Close();	
	}

// create a custom interface Mux implementation
MMMFDevSoundCustomInterfaceMuxPlugin* CMMFDevSoundCIMuxUtility::CreateCustomInterfaceMuxL(TUid aInterfaceId)
	{
	// The Uid of the plugin will be used as string for matching the best suitable plug in.
	TInt uidAsInteger = aInterfaceId.iUid;
	TBuf8<KMuxTempBufferSize> tempBuffer;
	tempBuffer.Num(uidAsInteger, EHex);
	TUid interfaceUid = {KUidDevSoundCustomInterfaceMux};
	
	TUid destructorKey;
	MMMFDevSoundCustomInterfaceMuxPlugin* self = 
		static_cast<MMMFDevSoundCustomInterfaceMuxPlugin*>
		(MmPluginUtils::CreateImplementationL(interfaceUid, destructorKey, tempBuffer, KRomOnlyResolverUid));

	// pass the destructor key so class can destroy itself
	self->PassDestructorKey(destructorKey);
	CleanupReleasePushL(*self);

	// attempt to construct the plugin
	self->CompleteConstructL(this);
	CleanupStack::Pop(); // self
		
	return self;
	}

	
// from MMMFDevSoundCustomInterfaceMux interface
TInt CMMFDevSoundCIMuxUtility::OpenSlave(TUid aInterface, const TDesC8& aPackageBuf)
	{
	// 1. send openslave custom command to remote side
	// 2. devsoundsession intercepts this custom command
	//    and creates / opens interface
	TA3FCustomInterfaceCommand command;
	command.iType = EMMFDevSoundCustomCommandCIOpenSlave;
	command.iCommand = 0; // No custom command passed on an OpenSlave
	command.iHandle = aInterface.iUid;
	TPckgBuf<TA3FCustomInterfaceCommand> commandBuffer(command);
	return iCustomChannel->SyncCustomCommand(KUidInterfaceMMFDevSound, commandBuffer, aPackageBuf, NULL);
	}
	
void CMMFDevSoundCIMuxUtility::CloseSlave(TInt aHandle)
	{
	// 1. send closeslave custom command to remote side
	// 2. demuxplugin removes its handle for this interface
	TA3FCustomInterfaceCommand command;
	command.iType = EMMFDevSoundCustomCommandCICloseSlave;
	command.iCommand = 0; // No custom command passed on a CloseSlave
	command.iHandle = aHandle;
	TPckgBuf<TA3FCustomInterfaceCommand> commandBuffer(command);
	iCustomChannel->SyncCustomCommand(KUidInterfaceMMFDevSound, commandBuffer, KNullDesC8, NULL);
	}


TInt CMMFDevSoundCIMuxUtility::SendSlaveSyncCommand(TInt aHandle, TInt aCommand, const TDesC8& aPackageBuf)
	{
	TA3FCustomInterfaceCommand command;
	command.iType = EMMFDevSoundCustomCommandCISendSlaveSyncCommand;
	command.iCommand = aCommand;
	command.iHandle = aHandle;
	TPckgBuf<TA3FCustomInterfaceCommand> commandBuffer(command);
	
	return iCustomChannel->SyncCustomCommand(KUidInterfaceMMFDevSound, commandBuffer, aPackageBuf, NULL);
	}

TInt CMMFDevSoundCIMuxUtility::SendSlaveSyncCommandResult(TInt aHandle, TInt aCommand, const TDesC8& aPackageBuf, TDes8& aResultBuf)
	{
	TA3FCustomInterfaceCommand command;
	command.iType = EMMFDevSoundCustomCommandCISendSlaveSyncCommandResult;
	command.iCommand = aCommand;
	command.iHandle = aHandle;
	TPckgBuf<TA3FCustomInterfaceCommand> commandBuffer(command);

	return iCustomChannel->SyncCustomCommand(KUidInterfaceMMFDevSound, commandBuffer, aPackageBuf, &aResultBuf);
	}

void CMMFDevSoundCIMuxUtility::SendSlaveAsyncCommand(TMMFDevSoundCustomInterfaceCommandPackage& aComPackage, TRequestStatus& aStatus, const TDesC8& aPackageBuf)
	{
	CAsyncCommandCleanup *ciMuxAsyncCommandCleanup=NULL;
	TRAPD(err,ciMuxAsyncCommandCleanup = CAsyncCommandCleanup::NewL(this,iCustomChannel));
	TRequestStatus* status= &aStatus;
	if(err == KErrNone)
		{
		err=iAsyncCustomCommandCleanup.Append(ciMuxAsyncCommandCleanup);
		if(err == KErrNone)
			{
			ciMuxAsyncCommandCleanup->AsyncCustomCommand(EMMFDevSoundCustomCommandCISendSlaveAsyncCommand,aComPackage,aStatus,aPackageBuf,NULL);		
			}
		else
			{
			User::RequestComplete(status,err);
			delete ciMuxAsyncCommandCleanup;
			return;			
			}	
		}
	else
		{
		User::RequestComplete(status,err);
		return;	
		}
	
	}
	
void CMMFDevSoundCIMuxUtility::SendSlaveAsyncCommandResult(TMMFDevSoundCustomInterfaceCommandPackage& aComPackage, TRequestStatus& aStatus, const TDesC8& aPackageBuf, TDes8& aResultBuf)
	{
	CAsyncCommandCleanup* ciMuxAsyncCommandCleanup=NULL;
	TRAPD(err,ciMuxAsyncCommandCleanup = CAsyncCommandCleanup::NewL(this,iCustomChannel));
	TRequestStatus* status= &aStatus;
	if(err == KErrNone)
		{
		err=iAsyncCustomCommandCleanup.Append(ciMuxAsyncCommandCleanup);
		if(err == KErrNone)
			{
			ciMuxAsyncCommandCleanup->AsyncCustomCommand(EMMFDevSoundCustomCommandCISendSlaveAsyncCommandResult,aComPackage,aStatus,aPackageBuf,&aResultBuf);
			}
		else
			{
			User::RequestComplete(status,err);
			delete ciMuxAsyncCommandCleanup;
			return;			
			}	
		}
	else
		{
		User::RequestComplete(status,err);
		return;
		}
	}

CMMFDevSoundCIMuxUtility::CMMFDevSoundCIMuxUtility(MMMFDevSoundCustomInterfaceChannel* aCustomChannel)
: iCustomChannel(aCustomChannel)
	{
	}
	
void CMMFDevSoundCIMuxUtility::RemoveAsyncCommand(CAsyncCommandCleanup* aAsyncCustomCommandCleanup)
	{
	TInt index = iAsyncCustomCommandCleanup.Find(aAsyncCustomCommandCleanup);
	__ASSERT_DEBUG( index != KErrNotFound,User::Invariant());
	if(index > KErrNotFound)
		{
		iAsyncCustomCommandCleanup.Remove(index);
		iAsyncCustomCommandCleanup.Compress();
		}
	return;
	}
	
CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup* CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::NewL(CMMFDevSoundCIMuxUtility* aMuxUtility,MMMFDevSoundCustomInterfaceChannel* aCustomChannel)
	{
	CAsyncCommandCleanup *self= new (ELeave) CAsyncCommandCleanup(aMuxUtility,aCustomChannel);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}
	
void CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::ConstructL()
	{
	iCommandBuffer = new (ELeave) TPckgBuf<TA3FCustomInterfaceCommand>;
	}
	
CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::CAsyncCommandCleanup(CMMFDevSoundCIMuxUtility* aMuxUtility,MMMFDevSoundCustomInterfaceChannel* aCustomChannel)
:CActive(CActive::EPriorityStandard),iMuxUtility(aMuxUtility),iCustomChannel(aCustomChannel)
	{
	CActiveScheduler::Add(this);
	}
	
CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::~CAsyncCommandCleanup()
	{
	delete iCommandBuffer;
	Cancel();
	}
	
void CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::AsyncCustomCommand(CMMFDevSoundCIMuxUtility::TMMFDevSoundCustomCommand aType,TMMFDevSoundCustomInterfaceCommandPackage& aComPackage, TRequestStatus& aStatus, const TDesC8& aPackageBuf, TDes8* aResultBuf)
	{
	iClientRequestStatus = &aStatus;
	
	(*iCommandBuffer)().iType = aType;
	(*iCommandBuffer)().iCommand = aComPackage().iCommand;
	(*iCommandBuffer)().iHandle = aComPackage().iHandle;
	*iClientRequestStatus = KRequestPending;
	iCustomChannel->AsyncCustomCommand(KUidInterfaceMMFDevSound,iStatus, *iCommandBuffer, aPackageBuf, aResultBuf);
	SetActive();
	}
	
void CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::RunL()
	{
	if(iClientRequestStatus)
		{
		User::RequestComplete(iClientRequestStatus,iStatus.Int());		
		}
	iClientRequestStatus = NULL;
	iMuxUtility->RemoveAsyncCommand(this);
	delete this;
	}
	
void CMMFDevSoundCIMuxUtility::CAsyncCommandCleanup::DoCancel()
	{

	}