/*

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

*

*/

/**

 @file

 @test

 @internalComponent

*/

#include <s32mem.h>

#include <f32file.h>

#include <s32file.h>

#include "rtadatahandler.h"

#include "RTAsession.h"

#include "RTAserver.h"

#include "rightsobject.h"

#include "rtaArchive.h"

#include "drmfilecontent.h"

#include "drmfiles.h"

using namespace ReferenceTestAgent;

using namespace ContentAccess;

CRtaDataHandler* CRtaDataHandler::NewL(const CSession2& aSession)

	{

	return new (ELeave) CRtaDataHandler(aSession);

	}

CRtaDataHandler::CRtaDataHandler(const CSession2& aSession) : CRtaMessageHandler(aSession)

	{

	}

CRtaDataHandler::~CRtaDataHandler()

	{

	delete iArchive;

	iFile.Close();

	}

void CRtaDataHandler::ServiceL(const RMessage2& aMessage)

//

// Handle a client request.

	{

	switch (aMessage.Function())

		{	

	// RRtaData functions

	case EOpenFile:

	case ENoEnforceOpenFile:

		OpenFileL(aMessage);

		break;

	case EOpenFileHandle:

	case ENoEnforceOpenFileHandle:

		OpenFileHandleL(aMessage);

		break;

	case EEvaluateIntent:

	case ENoEnforceEvaluateIntent:

		EvaluateIntentL(aMessage);

		break;

	case EExecuteIntent:

	case ENoEnforceExecuteIntent:

		ExecuteIntentL(aMessage);

		break;

	case EReadData:

	case ENoEnforceReadData:

		ReadDataL(aMessage);

		break;

	case EReadOffsetData:

	case ENoEnforceReadOffsetData:

		ReadOffsetDataL(aMessage);

		break;

	case ESeek:

	case ENoEnforceSeek:

		SeekL(aMessage);

		break;

	case EDataSize:

	case ENoEnforceDataSize:

		DataSizeL(aMessage);

		break;

	case EGetAttribute:

		GetAttributeL(aMessage);

		break;

	case EGetAttributeSet:

		GetAttributeSetL(aMessage);

		break;

	case EGetStringAttribute:

		GetStringAttributeL(aMessage);

		break;

	case EGetStringAttributeSet:

		GetStringAttributeSetL(aMessage);

		break;

	case EDataSetProperty:

	case ENoEnforceDataSetProperty:

		SetPropertyL(aMessage);

		break;

	default:

		CRtaSession::PanicClient(aMessage,EPanicIllegalFunction);

		break;

		}

	}

void CRtaDataHandler::OpenFileL(const RMessage2& aMessage)

	{

	TUint mode;

	TPckg <TUint> fileModePckg(mode);

	HBufC* fileName = ReadDesC16LC(aMessage, 0);

	HBufC* uniqueId= ReadDesC16LC(aMessage, 1);

	aMessage.ReadL(2, fileModePckg);

	User::LeaveIfError(Server().CheckPermittedFileName(*fileName));

	User::LeaveIfError(iFile.Open(Server().Fs(), *fileName, mode));

	// create a DRM archive based upon the file handle 

	iArchive = CRefTestAgentArchive::NewL(iFile);

	iContentObject = &iArchive->DrmFilesL().FindL(*uniqueId);

	CleanupStack::PopAndDestroy(2, fileName); // fileName, UniqueId

	}

void CRtaDataHandler::OpenFileHandleL(const RMessage2& aMessage)

	{

	User::LeaveIfError(iFile.AdoptFromClient(aMessage, 0, 1));

	HBufC* uniqueId = ReadDesC16LC(aMessage, 2);	

	// create a DRM archive based upon the file handle 

	iArchive = CRefTestAgentArchive::NewL(iFile);

	iContentObject = &iArchive->DrmFilesL().FindL(*uniqueId);

	CleanupStack::PopAndDestroy(uniqueId); // file, UniqueId

	}

void CRtaDataHandler::EvaluateIntentL(const RMessage2& aMessage)

	{

	TIntent intent;

	TPckg <TIntent> intentPckg(intent);

	aMessage.ReadL(0, intentPckg);

	Server().EvaluateIntentL(iContentObject->Cid(), intent);	

	}

void CRtaDataHandler::ExecuteIntentL(const RMessage2& aMessage)

	{

	TIntent intent;

	TPckg <TIntent> intentPckg(intent);

	aMessage.ReadL(0, intentPckg);

	Server().ExecuteIntentL(iContentObject->Cid(), intent);

	}

void CRtaDataHandler::ReadDataL(const RMessage2& aMessage)

	{

	TInt length = 0;

	TPckg <TInt> lengthPckg(length);

	HBufC8* buffer = ReadDes8LC(aMessage, 0);

	aMessage.ReadL(1, lengthPckg);

	TPtr8 bufPtr = buffer->Des();	

	User::LeaveIfError(iContentObject->Read(bufPtr, length));

	WriteL(aMessage, 0, *buffer);

	CleanupStack::PopAndDestroy(buffer);

	}

void CRtaDataHandler::ReadOffsetDataL(const RMessage2& aMessage)

	{

	TInt length = 0;

#ifdef SYMBIAN_ENABLE_64_BIT_FILE_SERVER_API

	TInt64 pos = 0;

	TPckg <TInt64> posPckg(pos);

#else

	TInt pos = 0;

	TPckg <TInt> posPckg(pos);

#endif // SYMBIAN_ENABLE_64_BIT_FILE_SERVER_API

	TPckg <TInt> lengthPckg(length);

	aMessage.ReadL(0, posPckg);

	HBufC8* buffer = ReadDes8LC(aMessage, 1);

	aMessage.ReadL(2, lengthPckg);

	TPtr8 bufPtr = buffer->Des();	

	User::LeaveIfError(iContentObject->Read(pos, bufPtr, length));

	WriteL(aMessage, 1, *buffer);

	CleanupStack::PopAndDestroy(buffer);

	}

void CRtaDataHandler::SeekL(const RMessage2& aMessage)

	{

	TSeek mode;

	TPckg <TSeek> modePckg(mode);

	aMessage.ReadL(0, modePckg);

#ifdef SYMBIAN_ENABLE_64_BIT_FILE_SERVER_API

	TInt64 pos = 0;

	TPckg <TInt64> posPckg(pos);

#else

	TInt pos = 0;

	TPckg <TInt> posPckg(pos);

#endif // SYMBIAN_ENABLE_64_BIT_FILE_SERVER_API	

	aMessage.ReadL(1, posPckg);

	User::LeaveIfError(iContentObject->Seek(mode, pos));

	WriteL(aMessage, 1, posPckg);

	}

void CRtaDataHandler::DataSizeL(const RMessage2& aMessage)

	{

#ifdef SYMBIAN_ENABLE_64_BIT_FILE_SERVER_API

	TInt64 size = 0;

	TPckg <TInt64> sizePckg(size);

#else

	TInt size = 0;

	TPckg <TInt> sizePckg(size);

#endif // SYMBIAN_ENABLE_64_BIT_FILE_SERVER_API

	aMessage.ReadL(0, sizePckg);

	User::LeaveIfError(iContentObject->Size(size));

	WriteL(aMessage, 0, sizePckg);

	}

void CRtaDataHandler::GetAttributeL(const RMessage2& aMessage)

	{

	TInt attribute;

	TPckg <TInt> attributePckg(attribute);

	TInt value;

	TPckg <TInt> valuePckg(value);			

	aMessage.ReadL(0, attributePckg);

	iContentObject->GetAttribute(attribute, value);

	WriteL(aMessage, 1, valuePckg);

	}

void CRtaDataHandler::GetAttributeSetL(const RMessage2& aMessage)

	{

	RAttributeSet attributeSet;

	CleanupClosePushL(attributeSet);

	HBufC8* value = ReadDes8LC(aMessage, 0);

	TPtr8 valuePtr = value->Des();

	RDesReadStream readStream(valuePtr);

	attributeSet.InternalizeL(readStream);

	CleanupStack::PopAndDestroy(value);

	iContentObject->GetAttributeSet(attributeSet);

	// Write the object out to a buffer, send to client

	CBufFlat* buf = CBufFlat::NewL(50);

	CleanupStack::PushL(buf);

	// create write stream

	RBufWriteStream writeStream(*buf);

	// write the directory to the stream

	attributeSet.ExternalizeL(writeStream);

	TPtr8 bufPtr = buf->Ptr(0);

	WriteL(aMessage, 0, bufPtr);

	CleanupStack::PopAndDestroy(2, &attributeSet); // buf, attributeSet

	}

void CRtaDataHandler::GetStringAttributeL(const RMessage2& aMessage)

	{

	TInt attribute;

	TPckg <TInt> attributePckg(attribute);

	aMessage.ReadL(0, attributePckg);

	HBufC* value = ReadDes16LC(aMessage, 1);

	TPtr valuePtr = value->Des();

	User::LeaveIfError(iContentObject->GetStringAttribute(attribute, valuePtr));

	WriteL(aMessage, 1, valuePtr);

	CleanupStack::PopAndDestroy(value);

	}

void CRtaDataHandler::GetStringAttributeSetL(const RMessage2& aMessage)

	{

	RStringAttributeSet attributeSet;

	CleanupClosePushL(attributeSet);

	HBufC8* value = ReadDes8LC(aMessage, 0);

	TPtr8 valuePtr = value->Des();

	RDesReadStream readStream(valuePtr);

	attributeSet.InternalizeL(readStream);

	CleanupStack::PopAndDestroy(value);

	iContentObject->GetStringAttributeSet(attributeSet);

	// Write the object out to a buffer, send to client

	CBufFlat* buf = CBufFlat::NewL(50);

	CleanupStack::PushL(buf);

	// create write stream

	RBufWriteStream writeStream(*buf);

	// write the directory to the stream

	attributeSet.ExternalizeL(writeStream);

	TPtr8 bufPtr = buf->Ptr(0);

	WriteL(aMessage, 0, bufPtr);

	CleanupStack::PopAndDestroy(2, &attributeSet); // buf, attributeSet

	}

void CRtaDataHandler::SetPropertyL(const RMessage2& /*aMessage*/)

	{	

	User::Leave(KErrCANotSupported);

	}