/*

 * 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"));

 	}