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

/**
 @file
 @publishedPartner
 @prototype
*/

#include <mdf/mdfprocessingunit.h>
#include <mmf/common/mmfutilities.h>
#include "puloader.h"
#include <mdf/codecapiresolverdata.h>
#include <mdf/codecapiuids.hrh>
#include <mdf/codecapiresolver.hrh>
#include <mm/mmcleanup.h>
#include <ecom/ecom.h>

static const TInt KMaxDataTypeLength = 126;

CPuLoader* CPuLoader::NewL()
	{
	CPuLoader* self = new (ELeave) CPuLoader;
	return self;
	}


CMdfProcessingUnit* CPuLoader::LoadProcessingUnitL(const MMdfProcessingUnitObserver& aProcessingUnitObserver, 
		TUid aImplementationUid)
	{
	CMdfProcessingUnit* pu = NULL;
	pu = CMdfProcessingUnit::NewL(aImplementationUid);
	CleanupStack::PushL(pu);
	User::LeaveIfError(pu->Create(aProcessingUnitObserver));
	CleanupStack::Pop(pu);
	return pu;
	}
	
CMdfProcessingUnit* CPuLoader::LoadProcessingUnitL( const MMdfProcessingUnitObserver& aProcessingUnitObserver, 
		const TDesC8& aSrcDataType, const TDesC8& aDestDataType, const TUid& aImplementationType) 
	{
	CCodecApiResolverData* customMatchData = CCodecApiResolverData::NewLC();
	customMatchData->SetMatchType(EMatchInputAndOutputDataFormat);
	customMatchData->SetImplementationType(aImplementationType);
	// string value of the input source data	
	customMatchData->SetInputDataL(aSrcDataType);
	customMatchData->SetOutputDataL(aDestDataType);
	
 	HBufC8* package  = customMatchData->NewPackLC();

	TEComResolverParams resolverParams; // Parameters on which to match
	resolverParams.SetDataType(package->Des());
	
	RImplInfoPtrArray ecomArray;
	CleanupResetAndDestroyPushL(ecomArray);

	REComSession::ListImplementationsL(TUid::Uid(KUidMdfProcessingUnit), resolverParams, TUid::Uid(KUidCodecApiResolverImplementation), ecomArray);
	
	// check if there are any 
	TInt noOfProcessingUnits = ecomArray.Count();

	if(noOfProcessingUnits == 0)
		{
		User::Leave(KErrNotFound);
		}

	CMdfProcessingUnit *processingUnit = NULL;
	TInt index = 0;
	TInt error = KErrNone;
	do
		{
		// Iterate through the array until a plugin can be created without errors
		const CImplementationInformation& puInfo = *(ecomArray[index++]);
		
		TRAP(error, processingUnit = CMdfProcessingUnit::NewL(puInfo.ImplementationUid()));
		}
	while(index < noOfProcessingUnits && error != KErrNone);

	if(error)
		{
		ASSERT(!processingUnit && index <= noOfProcessingUnits);
		User::Leave(error);
		}

	CleanupStack::PopAndDestroy(3, customMatchData); // customMatchData, package, ecomArray	

		
	TInt err = processingUnit->Create(aProcessingUnitObserver);
	if (err != KErrNone)
		{
		// delete processing unit before leaving
		delete processingUnit;
		User::Leave(err);
		}
	return processingUnit;
	}
	
CMdfProcessingUnit* CPuLoader::LoadProcessingUnitL( const MMdfProcessingUnitObserver& aProcessingUnitObserver, 
		TFourCC aSrcDataType, TFourCC aDestDataType)
	{
	HBufC8* packageSrcDataType = HBufC8::NewLC(KMaxDataTypeLength);
	TPtr8 sourceDataType = packageSrcDataType->Des();
	aSrcDataType.FourCC(&sourceDataType);
			
	HBufC8* packageDestDataType = HBufC8::NewLC(KMaxDataTypeLength);
	TPtr8 destinationDataType = packageDestDataType->Des();
	aDestDataType.FourCC(&destinationDataType);
	
	CMdfProcessingUnit* processingUnit = LoadProcessingUnitL(aProcessingUnitObserver, sourceDataType, destinationDataType, TUid::Uid(KUidAudioCodec));
	CleanupStack::PopAndDestroy(2, packageSrcDataType);
	return processingUnit;
	}


TInt CPuLoader::TunnelSetup(MMdfOutputPort& aOutputPort, MMdfInputPort& aInputPort)
	{
	TTunnelFlags tunnelFlags = EBufferReadOnly;
	TSupplierType supplierType = EBufferSupplyUnspecified;
	TUint error = KErrNone;
	 
	if ((error = aOutputPort.MopTunnelRequest(aInputPort, tunnelFlags, supplierType)) != KErrNone)
		{
	 	return error;
	 	}
	return aInputPort.MipTunnelRequest(aOutputPort,tunnelFlags,supplierType);
	}
	

void CPuLoader::UnloadProcessingUnit(CMdfProcessingUnit*& aPu)
	{
	delete aPu;
	aPu = NULL;
	}
	
CPuLoader::CPuLoader()
	{
	}

CPuLoader::~CPuLoader()
	{
	}