/*
* Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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: 
* Utils functions used by scr session and subsession clients.
*
*/


/**
 @file
 @internalComponent
 @released
*/

#ifndef SCRCLIENT_INL
#define SCRCLIENT_INL

#include "scr.h"
#include <scs/cleanuputils.h>
#include <scs/streamingarray.h>
#include <s32mem.h>

namespace Usif
	{
	template <class C>
	inline HBufC8* GetObjectDataLC(const C& aConnection, TInt aFunction, TInt aDataSize)
		{
		HBufC8 *buf = HBufC8::NewLC(aDataSize);
		TPtr8 ptrBuf(buf->Des());
		TIpcArgs argBuf(&ptrBuf);
		User::LeaveIfError(aConnection.SendSyncMessage(aFunction, argBuf));
		return buf; 
		}
	
	template <class T, class C>
	inline T* GetObjectL(const C& aConnection, TInt aSizeFunction, TInt aDataFunction, TInt aArgNum, TIpcArgs& aArgs)
		{
		TInt size(0);
		TPckg<TInt> sizePak(size);
		aArgs.Set(aArgNum, &sizePak);
		User::LeaveIfError(aConnection.SendSyncMessage(aSizeFunction, aArgs));
		if(!size)
			{// There is no related object return NULL
			return NULL;
			}
		HBufC8 *buf = GetObjectDataLC(aConnection, aDataFunction, size);
			
		RDesReadStream stream(*buf);
		CleanupClosePushL(stream);
		T *retObject = TTraits<T>::ReadFromStreamL(stream);
		CleanupStack::PopAndDestroy(2, buf);
		return retObject;
		}
	
	template <class T, class C>
	inline TBool GetObjectL(const C& aConnection, T& aObject, TInt aSizeFunction, TInt aDataFunction, TInt aArgNum, TIpcArgs& aArgs)
		{
		TInt size(0);
		TPckg<TInt> sizePak(size);
		aArgs.Set(aArgNum, &sizePak);
		User::LeaveIfError(aConnection.SendSyncMessage(aSizeFunction, aArgs));
		if(!size)
			{// There is no related object, return EFalse
			return EFalse;
			}
		HBufC8 *buf = GetObjectDataLC(aConnection, aDataFunction, size);
				
		RDesReadStream stream(*buf);
		CleanupClosePushL(stream);
		aObject.InternalizeL(stream);
		CleanupStack::PopAndDestroy(2, buf);
		return ETrue;
		}
	
	template <class C, class T>
	inline void GetObjectArrayL(const C& aConnection, TInt aSizeFunction, TInt aDataFunction, TInt aArgNum, TIpcArgs& aArgs, RPointerArray<T>& aArray)
		{
		TInt size(0);
		TPckg<TInt> sizePak(size);
		aArgs.Set(aArgNum, &sizePak);
		User::LeaveIfError(aConnection.SendSyncMessage(aSizeFunction, aArgs));
		if(!size)
			{// There is no related data, return.
			return;
			}
		HBufC8 *buf = GetObjectDataLC(aConnection, aDataFunction, size);
			
		RDesReadStream stream(*buf);
		CleanupClosePushL(stream);
		InternalizePointersArrayL(aArray, stream);
		CleanupStack::PopAndDestroy(2, buf);
		}
	
	template <class C, class T>
	inline void GetObjectArrayL(const C& aConnection, TInt aSizeFunction, TInt aDataFunction, TInt aArgNum, TIpcArgs& aArgs, RArray<T>& aArray)
		{
		TInt size(0);
		TPckg<TInt> sizePak(size);
		aArgs.Set(aArgNum, &sizePak);
		User::LeaveIfError(aConnection.SendSyncMessage(aSizeFunction, aArgs));
		if(!size)
			{// There is no related data, return.
			return;
			}
		HBufC8 *buf = GetObjectDataLC(aConnection, aDataFunction, size);
				
		RDesReadStream stream(*buf);
		CleanupClosePushL(stream);
		InternalizeFixedLengthArrayL(aArray, stream);
		CleanupStack::PopAndDestroy(2, buf);
		}
	
	template <class C>
	inline void ExternalizeObjectL(const C* aObject, RBuf8& aBuf)
		{
		const C *localCopyOfObject(0);
		
		if(!aObject)
			{// if object is not supplied, then create an empty one.
			localCopyOfObject = C::NewLC();
			}
		else
			{
			localCopyOfObject = aObject;
			}
			
		// Get the required buffer size for the externalized C object
		TInt bufSize = GetObjectBufferSizeL(*localCopyOfObject);
			
		// Clean the buffer and re-create it with the required buffer size 
		aBuf.Close();
		aBuf.CreateL(bufSize);
			
		// Externalize the filter object into the buffer
		RDesWriteStream wstream(aBuf);
		wstream.PushL();
		wstream << *localCopyOfObject;
		wstream.CommitL();
		wstream.Pop();
		wstream.Release();
			
		if(!aObject)
			{// destroy the filter if created locally
			CleanupStack::PopAndDestroy((C*)localCopyOfObject);
			}
		}// Emd of ExternalizeFilterL
	}

#endif /* SCRCLIENT_INL */