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

#include "cafstep.h"
#include <test/testexecutelog.h>
#include <caf/content.h>
#include <caf/attribute.h>
#include "cafserver.h"
#include "resolver.h"
#include "manager.h"
#include "bitset.h"
#include "CafApaRecognizer.h"

#include <apasvst.h>
#include <apaflrec.h>
#include <fbs.h>
#include <charconv.h>
#include <eikenv.h>

using namespace ContentAccess;

/* 
 * Base class for all CAF test steps
 *
 */

CCAFStep::CCAFStep()
	{
	}

CCAFStep::~CCAFStep()
	{
	}
	
void CCAFStep:: InitialiseFileHandleParametersL()	
	{
	GetStringFromConfig(ConfigSection(),_L("uri"),iUri);
	GetStringFromConfig(ConfigSection(),_L("uniqueid"),iUniqueId);
	GetIntFromConfig(ConfigSection(),_L("result"),iExpectedResult);

	iFs.Connect();
	CleanupClosePushL(iFs);
	User::LeaveIfError(iFs.ShareProtected());
	User::LeaveIfError(iFile.Open(iFs, iUri, EFileShareReadersOnly| EFileRead | EFileStream));
	CleanupClosePushL(iFile);
	}
	
void CCAFStep::ReadBufferL(TDesC16& aFileName, TDes8& aBuffer)
	{
	RFs fs;
	RFile handle;
	TInt result;
	User::LeaveIfError(fs.Connect());
	CleanupClosePushL(fs);
	result = handle.Open(fs,aFileName,EFileRead | EFileStream | EFileShareAny);
	User::LeaveIfError(result);
	CleanupClosePushL(handle);
	handle.Read(aBuffer);
	CleanupStack::PopAndDestroy(2, &fs);
	}

HBufC8* CCAFStep::ConvertDes16toHBufC8LC(TDesC& source)
	{
	RFs fs;
	HBufC8 *buf = HBufC8::NewL(source.Length());
	CleanupStack::PushL(buf);
	TPtr8 ptr=buf->Des();

	CCnvCharacterSetConverter *converter = CCnvCharacterSetConverter::NewLC();
	User::LeaveIfError(fs.Connect());
	CleanupClosePushL(fs);
	converter->PrepareToConvertToOrFromL(KCharacterSetIdentifierAscii, fs);
	converter->ConvertFromUnicode(ptr, source);
	CleanupStack::PopAndDestroy(2, converter);
	return buf;
	}

HBufC16* CCAFStep::ConvertDes8toHBufC16LC(TDesC8& source)
	{
	RFs fs;
	TInt status=0;
	HBufC16 *buf = HBufC16::NewL(source.Length());
	CleanupStack::PushL(buf);
	TPtr16 ptr=buf->Des();
	CCnvCharacterSetConverter *converter = CCnvCharacterSetConverter::NewLC();
	User::LeaveIfError(fs.Connect());
	CleanupClosePushL(fs);
	converter->PrepareToConvertToOrFromL(KCharacterSetIdentifierAscii, fs);
	converter->ConvertToUnicode(ptr, source, status);
	CleanupStack::PopAndDestroy(2, converter);
	return buf;
	}

#ifdef SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT
         
HBufC8* CCAFStep::CreateWmdrmHeaderLC()     
    {     
    // create dummy header data.     
    const TInt KMaxBufferLen = 64;     
    _LIT8(KHeaderData, "W\0R\0M\0H\0E\0A\0D\0E\0R\0");     
         
    HBufC8* headerData = HBufC8::NewMaxLC(KMaxBufferLen);     
    TPtr8 headerPtr = headerData->Des();     
    headerPtr.Repeat(KHeaderData);     
    return headerData;     
    }     
#endif //SYMBIAN_ENABLE_SDP_WMDRM_SUPPORT     
  

void CCAFStep::LoadCafRecognizerL()
	{
	static const TUid KImplementationUID= {0x102031E9};

	TAny* ptr = REComSession::CreateImplementationL(KImplementationUID, iDtorIDKey);
	iRecognizer = static_cast <CApaDataRecognizerType*>(ptr);
    }

void CCAFStep::UnLoadCafRecognizer()
	{
	delete iRecognizer;
	iRecognizer=NULL;
	REComSession::DestroyedImplementation(iDtorIDKey);
	REComSession::FinalClose();
	}

TInt CCAFStep::Delete(const TDesC& aFile)
	{
	TInt err = KErrNone;
	RFs fs;
	err = fs.Connect();
	if(err == KErrNone)
		{
		err = fs.Delete(aFile);
		fs.Close();
		}
	return err;
	}



TVerdict CCAFStep::doTestStepPreambleL()
	{
	iActiveScheduler = new (ELeave) CActiveScheduler;
	CActiveScheduler::Install(iActiveScheduler);
	return TestStepResult();
	}

TVerdict CCAFStep::doTestStepPostambleL()
	{
	CActiveScheduler::Install(NULL);
	delete iActiveScheduler;
	return TestStepResult();
	}


// Dummy class required to create an apparc server (below)
class CT_Serv2DummyShell : public CBase, public MApaAppStarter
     {
 public:
     TThreadId StartAppL(const CApaCommandLine&) { return *(TThreadId*)this; }
     void ConstructL();
 public:
     RFs iFs;
     RFbsSession iFbs;
     };

void CT_Serv2DummyShell::ConstructL()
     {
     User::LeaveIfError(iFs.Connect());
     User::LeaveIfError(iFbs.Connect());
     }


void CCAFStep::StartApparcServerL()
	{
	INFO_PRINTF1(_L("Starting Apparc Server"));
    FbsStartup();
    TInt ret=RFbsSession::Connect();
         TEST(ret==KErrNone);
 
     // set up an fbs
     ret = FbsStartup();
         TEST(ret==KErrNone);
     //
     // set up an app starter
     CT_Serv2DummyShell* dummy=new(ELeave) CT_Serv2DummyShell();
     dummy->ConstructL();
 
 	 ret=StartupApaServerProcess();


     TEST(((ret==KErrNone)||(ret==KErrAlreadyExists)));
     //
 
 
     INFO_PRINTF1(_L("Apparc Startup Complete"));
	}