/*

* Copyright (c) 2003-2010 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: 

*

*/

#include <test/testexecutelog.h>

#include <caf/content.h>

#include <caf/data.h>

#include <caf/attribute.h>

#include "cafserver.h"

#include "bitset.h"

#include "contentstep.h"

#include "EmbeddedObject.h"

#include "StreamablePtrArray.h"

#include "attributeset.h"

#include "stringattributeset.h"

#include <caf/agentfactory.h>

using namespace ContentAccess;

/* 

 * Content attribute step

 *

 */

CCAFContentAttributeStep::~CCAFContentAttributeStep()

	{

	}

CCAFContentAttributeStep::CCAFContentAttributeStep(CCAFServer& aParent) : iParent(aParent)

	{

	SetTestStepName(KCAFContentAttributeStep);

	}

TVerdict CCAFContentAttributeStep::doTestStepL()

	{

#ifdef SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT     

    TBool wmdrmFlag = EFalse;     

    GetBoolFromConfig(ConfigSection(),_L("wmdrmEnabled"), wmdrmFlag);     

    if(wmdrmFlag)     

        {     

        TVerdict verdict = doWmdrmTestStepL();     

        return verdict;     

        }     

#endif //SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT 

	TInt attribute;

	TInt value = KErrNone;

	TInt expectedValue;

	TInt unresolvedUri = EFalse;

	TPtrC uri;

	TPtrC uniqueId;

	SetTestStepResult(EPass);

	GetIntFromConfig(ConfigSection(),_L("attribute"),attribute);

	GetStringFromConfig(ConfigSection(),_L("uri"),uri);

	GetStringFromConfig(ConfigSection(),_L("uniqueid"),uniqueId);

	GetIntFromConfig(ConfigSection(),_L("value"),expectedValue);

	GetIntFromConfig(ConfigSection(),_L("unresolveduri"),unresolvedUri);

	__UHEAP_MARK;

	// Open using file name

	CContent *content = CContent::NewLC(uri);

	value = expectedValue+1;

	User::LeaveIfError(content->GetAttribute(attribute, value, uniqueId));

	if(expectedValue != value )

		{

		SetTestStepResult(EFail);

		INFO_PRINTF3(_L("CContent::GetAttribute() Expected value: %d, actual value: %d"), expectedValue, value);

		}

	CleanupStack::PopAndDestroy(content);		    		

	// Open using file handle

   	// cannot do if URI is unresolved - i.e. if it contains "Reference Test Agent" instead of actual private directory name

   	if (!unresolvedUri) 

		{

		RFile file;

		file.Open(iParent.Fs(), uri, EFileShareReadersOnly);		

		value = expectedValue+1;

		User::LeaveIfError(content->GetAttribute(attribute, value, uniqueId));

		if(expectedValue != value)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF3(_L("CContent::GetAttribute() Expected value: %d, actual value: %d"), expectedValue, value);

			}

		CleanupStack::PopAndDestroy(content);		    		

		}

	__UHEAP_MARKEND;

	return TestStepResult();

	}

/* 

 * Content attributeset step

 *

 */

CCAFContentAttributeSetStep::~CCAFContentAttributeSetStep()

	{

	}

CCAFContentAttributeSetStep::CCAFContentAttributeSetStep(CCAFServer& aParent) : iParent(aParent)

	{

	SetTestStepName(KCAFContentAttributeSetStep);

	}

TVerdict CCAFContentAttributeSetStep::doTestStepL()

	{

#ifdef SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT     

    TBool wmdrmFlag = EFalse;     

    GetBoolFromConfig(ConfigSection(),_L("wmdrmEnabled"), wmdrmFlag);     

    if(wmdrmFlag)     

        {     

        TVerdict verdict = doWmdrmTestStepL();     

        return verdict;     

        }     

#endif //SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT     

	TInt value1;

	TInt value2;

	TInt expectedValue1;

	TInt expectedValue2;

	TInt attribute1;

	TInt attribute2;

	TInt result = KErrNone;

	TInt unresolvedUri = EFalse;

	TPtrC uri;

	TPtrC uniqueId;

	SetTestStepResult(EPass);

	GetStringFromConfig(ConfigSection(),_L("uri"),uri);

	GetStringFromConfig(ConfigSection(),_L("uniqueid"),uniqueId);

	GetIntFromConfig(ConfigSection(),_L("attribute1"),attribute1);

	GetIntFromConfig(ConfigSection(),_L("attribute2"),attribute2);

	GetIntFromConfig(ConfigSection(),_L("value1"),expectedValue1);

	GetIntFromConfig(ConfigSection(),_L("value2"),expectedValue2);

	GetIntFromConfig(ConfigSection(),_L("unresolveduri"),unresolvedUri);

	__UHEAP_MARK;

	// open using filename

	CContent *content = CContent::NewLC(uri);

	RAttributeSet attributeSet;

	CleanupClosePushL(attributeSet);

	attributeSet.AddL(attribute1);

	attributeSet.AddL(attribute2);

	if(uniqueId == KDefaultContentObject())

		{

		result = content->GetAttributeSet(attributeSet);

		}

	else

		{

		result = content->GetAttributeSet(attributeSet, uniqueId);

		}

	if(result != KErrNone)

		{

		SetTestStepResult(EFail);

		INFO_PRINTF1(_L("CContent::GetAttribute() failed"));

		}

	User::LeaveIfError(attributeSet.GetValue(attribute1, value1));

	User::LeaveIfError(attributeSet.GetValue(attribute2, value2));

	if(expectedValue1 != value1 || expectedValue2 != value2 || attributeSet.Count() != 2)

		{

		SetTestStepResult(EFail);

		INFO_PRINTF1(_L("CContent::GetAttributeSet() values don't match expected values"));

		}

	CleanupStack::PopAndDestroy(&attributeSet);		

	CleanupStack::PopAndDestroy(content);		

   	// Open using file handle

   	// cannot do if URI is unresolved - i.e. if it contains "Reference Test Agent" instead of actual private directory name

   	if (!unresolvedUri) 

		{

		RFile file;

		file.Open(iParent.Fs(), uri, EFileShareReadersOnly);		

		CleanupClosePushL(attributeSet);

		attributeSet.AddL(attribute1);

		attributeSet.AddL(attribute2);

		result = content->GetAttributeSet(attributeSet, uniqueId);

		if(result != KErrNone)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF1(_L("CContent::GetAttribute() failed"));

			}

		User::LeaveIfError(attributeSet.GetValue(attribute1, value1));

		User::LeaveIfError(attributeSet.GetValue(attribute2, value2));

		if(expectedValue1 != value1 || expectedValue2 != value2 || attributeSet.Count() != 2)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF1(_L("CContent::GetAttributeSet() values don't match expected values"));

			}

		CleanupStack::PopAndDestroy(&attributeSet);		

		CleanupStack::PopAndDestroy(content);		

	   	}

	__UHEAP_MARKEND;

	return TestStepResult();

	}

/* 

 * Content string attribute step

 *

 */

CCAFContentStringAttributeStep::~CCAFContentStringAttributeStep()

	{

	}

CCAFContentStringAttributeStep::CCAFContentStringAttributeStep(CCAFServer& aParent) : iParent(aParent)

	{

	SetTestStepName(KCAFContentStringAttributeStep);

	}

TVerdict CCAFContentStringAttributeStep::doTestStepL()

	{

#ifdef SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT     

    TBool wmdrmFlag = EFalse;     

    GetBoolFromConfig(ConfigSection(),_L("wmdrmEnabled"), wmdrmFlag);     

    if(wmdrmFlag)     

        {     

        TVerdict verdict = doWmdrmTestStepL();     

        return verdict;     

        }     

#endif //SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT 

	TInt expectedResult;

	TInt attribute;

	TInt unresolvedUri = EFalse;

	TPtrC expectedValue;

	TBuf <200> value;

	TInt result = KErrNone;

	TPtrC uri;

	TPtrC uniqueId;

	SetTestStepResult(EPass);

	GetIntFromConfig(ConfigSection(),_L("attribute"),attribute);

	GetStringFromConfig(ConfigSection(),_L("uri"),uri);

	GetStringFromConfig(ConfigSection(),_L("uniqueid"),uniqueId);

	GetStringFromConfig(ConfigSection(),_L("value"),expectedValue);

	GetIntFromConfig(ConfigSection(),_L("result"),expectedResult);

	GetIntFromConfig(ConfigSection(),_L("unresolveduri"),unresolvedUri);

	__UHEAP_MARK;

	// Open using file name

	CContent *content = CContent::NewLC(uri);

	if(uniqueId == KDefaultContentObject())

		{

		result = content->GetStringAttribute(attribute, value);

		}

	else

		{

		result = content->GetStringAttribute(attribute, value, uniqueId);

		}

	if(result != expectedResult)

		{

		SetTestStepResult(EFail);

		INFO_PRINTF3(_L("CContent::GetStringAttribute() Expected result: %d, actual result: %d"), expectedResult, result);

		}

	if(value != expectedValue)

		{

		SetTestStepResult(EFail);

		INFO_PRINTF3(_L("CContent::GetStringAttribute() Expected value: %S, actual result: %S"), &expectedValue, &value);

		}

	CleanupStack::PopAndDestroy(content);		

   	// Open using file handle

   	// cannot do if URI is unresolved - i.e. if it contains "Reference Test Agent" instead of actual private directory name

   	if (!unresolvedUri) 

	   	{

		RFile file;

		file.Open(iParent.Fs(), uri, EFileShareReadersOnly);		

		result = content->GetStringAttribute(attribute, value, uniqueId);

		if(result != expectedResult)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF3(_L("CContent::GetStringAttribute() Expected result: %d, actual result: %d"), expectedResult, result);

			}

		else if(value != expectedValue)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF3(_L("CContent::GetStringAttribute() Expected value: %S, actual result: %S"), &expectedValue, &value);

			}

		CleanupStack::PopAndDestroy(content);		

		}		

	__UHEAP_MARKEND;

	return TestStepResult();

	}

/* 

 * Content StringAttributeSet step

 *

 */

CCAFContentStringAttributeSetStep::~CCAFContentStringAttributeSetStep()

	{

	}

CCAFContentStringAttributeSetStep::CCAFContentStringAttributeSetStep(CCAFServer& aParent) : iParent(aParent)

	{

	SetTestStepName(KCAFContentStringAttributeSetStep);

	}

TVerdict CCAFContentStringAttributeSetStep::doTestStepL()

	{

#ifdef SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT     

    TBool wmdrmFlag = EFalse;     

    GetBoolFromConfig(ConfigSection(),_L("wmdrmEnabled"), wmdrmFlag);     

    if(wmdrmFlag)     

        {     

        TVerdict verdict = doWmdrmTestStepL();     

        return verdict;     

        }     

#endif //SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT 

	TPtrC expectedValue1;

	TPtrC expectedValue2;

	TBuf <200> value1;

	TBuf <200> value2;

	TInt result1;

	TInt result2;

	TInt attribute1;

	TInt attribute2;

	TInt result = KErrNone;

	TInt unresolvedUri = EFalse;

	TPtrC uri;

	TPtrC uniqueId;

	SetTestStepResult(EPass);

	GetStringFromConfig(ConfigSection(),_L("uri"),uri);

	GetStringFromConfig(ConfigSection(),_L("uniqueid"),uniqueId);

	GetIntFromConfig(ConfigSection(),_L("attribute1"),attribute1);

	GetIntFromConfig(ConfigSection(),_L("attribute2"),attribute2);

	GetStringFromConfig(ConfigSection(),_L("value1"),expectedValue1);

	GetStringFromConfig(ConfigSection(),_L("value2"),expectedValue2);

	GetIntFromConfig(ConfigSection(),_L("result1"),result1);

	GetIntFromConfig(ConfigSection(),_L("result2"),result2);

	GetIntFromConfig(ConfigSection(),_L("unresolveduri"),unresolvedUri);

	__UHEAP_MARK;

	// Open using file name

	CContent *content = CContent::NewLC(uri);

	RStringAttributeSet attributeSet;

	CleanupClosePushL(attributeSet);

	attributeSet.AddL(attribute1);

	attributeSet.AddL(attribute2);

	if(uniqueId == KDefaultContentObject())

		{

		result = content->GetStringAttributeSet(attributeSet);	

		}

	else

		{

		result = content->GetStringAttributeSet(attributeSet, uniqueId);

		}

	if(result != KErrNone)

		{

		SetTestStepResult(EFail);

		INFO_PRINTF1(_L("CContent::GetAttribute() failed"));

		}

	if(result1 != attributeSet.GetValue(attribute1, value1))

		{

		INFO_PRINTF1(_L("RStringAttributeSet::GetValue failed"));

		}

	if(result2 != attributeSet.GetValue(attribute2, value2))

		{

		INFO_PRINTF1(_L("RStringAttributeSet::GetValue failed"));

		}

	if(value1 != expectedValue1 || value2 != expectedValue2 || attributeSet.Count() != 2)

		{

		SetTestStepResult(EFail);

		INFO_PRINTF1(_L("CContent::GetAttributeSet() values don't match expected values"));

		}

	CleanupStack::PopAndDestroy(&attributeSet);		

	CleanupStack::PopAndDestroy(content);		

   	// Open using file handle

   	// cannot do if URI is unresolved - i.e. if it contains "Reference Test Agent" instead of actual private directory name

   	if (!unresolvedUri) 

		{	

		RFile file;

		file.Open(iParent.Fs(), uri, EFileShareReadersOnly);		

		CleanupClosePushL(attributeSet);

		attributeSet.AddL(attribute1);

		attributeSet.AddL(attribute2);

		result = content->GetStringAttributeSet(attributeSet, uniqueId);	

		if(result != KErrNone)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF1(_L("CContent::GetAttribute() failed"));

			}

		if(result1 != attributeSet.GetValue(attribute1, value1))

			{

			INFO_PRINTF1(_L("RStringAttributeSet::GetValue failed"));

			}

		if(result2 != attributeSet.GetValue(attribute2, value2))

			{

			INFO_PRINTF1(_L("RStringAttributeSet::GetValue failed"));

			}

		if(value1 != expectedValue1 || value2 != expectedValue2 || attributeSet.Count() != 2)

			{

			SetTestStepResult(EFail);

			INFO_PRINTF1(_L("CContent::GetAttributeSet() values don't match expected values"));

			}

		CleanupStack::PopAndDestroy(&attributeSet);		

		CleanupStack::PopAndDestroy(content);		

		}

	__UHEAP_MARKEND;

	return TestStepResult();

	}

/* 

 * This step tests the notification functions

 *

 */

CCAFContentNotifyStep::~CCAFContentNotifyStep()

	{

	}

CCAFContentNotifyStep::CCAFContentNotifyStep(CCAFServer& aParent) : iParent(aParent)

	{

	SetTestStepName(KCAFContentNotifyStep);

	}

TVerdict CCAFContentNotifyStep::doTestStepL()

	{

	TPtrC uri;

	TInt result;

	TRequestStatus status = KRequestPending;

	TInt Status1;

	TInt Cancel1;

	TInt Cancel2;

	SetTestStepResult(EPass);

	// Find the file to copy and the expected return code from the INI file

	GetStringFromConfig(ConfigSection(),_L("uri"),uri);

	GetIntFromConfig(ConfigSection(),_L("Status1"),Status1);

	GetIntFromConfig(ConfigSection(),_L("Cancel1"),Cancel1);

	GetIntFromConfig(ConfigSection(),_L("Cancel2"),Cancel2);

	INFO_PRINTF2(_L("Performing notification tests on %S"), &uri);

	__UHEAP_MARK;

	CContent *content = CContent::NewLC(uri);

	// Wait for rights 

	content->NotifyStatusChange(ERightsAvailable, status);

	User::WaitForRequest(status);

	if(status.Int() != Status1)

		{

		INFO_PRINTF3(_L("Status expected: %d returned unexpected status %d"), Status1, status.Int());

		SetTestStepResult(EFail);

		}

	result = content->CancelNotifyStatusChange(status);

	if(result != Cancel1)

		{

		INFO_PRINTF3(_L("Cancel request expected return value: %d returned unexpected value %d"), Cancel1, result);

		SetTestStepResult(EFail);

		}

	// Wait for rights expired but cancel before they arrive

	content->NotifyStatusChange(ERightsExpired, status);

	result = content->CancelNotifyStatusChange(status);

	if(result != Cancel2)

		{