/*

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

* CTestStep derived implementation

*

*/

#include "tAuthSvrStep.h"

#include <s32file.h>

class CAuthActive2 : public CActive

    {

    public:

    CAuthActive2(RAuthMgrClient& aClient, CAuthExpression* aExpr,

				 TInt aFresh, TBool aClientSpecific, TBool aStop = ETrue) : 

         CActive(EPriorityNormal),

         iClient(aClient),

		 iResult(EFail),

         iRunCount(0),

         iAe(aExpr),

         iStop(aStop),

         iFresh(aFresh),

         iIdToStore(0), 

         iClientSpecific(aClientSpecific)

        {

        CActiveScheduler::Add(this);

        }

    void doAuth() 

        {

        SetActive();		

		TRequestStatus* status = &iStatus;		    

		User::RequestComplete(status, KErrNone);

		iRunCount = 0;

        }

    void doDeAuth()

        {

        iClient.DeauthenticateL();

        }

	void DoCancel() 

        {

        }

     void RunL() 

        {

        iErr = iStatus.Int();

		switch (iRunCount)

		  {

		  case 0:

            iStatus = KRequestPending;

			iId = 0;

			iClient.AuthenticateL(*iAe, iFresh, iClientSpecific, EFalse, iId, iStatus);

			SetActive();

			break;

		  case 1:

			if (0 != iId)

				{

				iIdToStore = iId->Id();

				delete iId;

				}

			iStatus = KRequestPending;

			TRequestStatus* status;

			status = &iStatus;				

			User::RequestComplete(status, iErr);				

			SetActive();

			break;

   		  case 2:

			iResult = iStatus == KErrNone ? EPass : EFail;

            iErr = iStatus.Int();

			if (iStop)

                {

                CActiveScheduler::Stop();

                }

			break;

     	  default:

			iResult = EFail;

			if (iStop)

				{

			    CActiveScheduler::Stop();

			    }

		    }

		  ++iRunCount;

          }

	RAuthMgrClient& iClient;

	TVerdict iResult;

	TInt iRunCount;

	CAuthExpression* iAe;

	CIdentity* iId;

    TBool iStop;

    TInt iErr;

    TInt iFresh;

    TIdentityId iIdToStore;

    TBool iClientSpecific;

    };

//====================================================================================================

class CRegActive : public CActive

    {

    public:

    CRegActive(RAuthMgrClient& aClient, HBufC* aIdentityString, CIdentity*& aResult) : 

         CActive(EPriorityNormal),

         iFirstTime(true),

         iClient(aClient), 

         iResult(aResult),

         iIdentityString(aIdentityString),

         iErr(KErrNone)

        {

        CActiveScheduler::Add(this);

        }

    ~CRegActive()

    	{

    	delete iIdentityString; 

    	}

    void doReg()

        {

        SetActive();		

		TRequestStatus* status = &iStatus;

		User::RequestComplete(status, KErrNone);

		iFirstTime = ETrue;

        }

        void DoCancel() 

        {

        }

     void RunL() 

        {

        iErr = iStatus.Int();

        if (iFirstTime)

            {

			SetActive();

            iStatus = KRequestPending;

            iClient.RegisterIdentityL(iResult, *iIdentityString, iStatus);

            iFirstTime = false;

            }

        else

            {

            iErr = iStatus.Int();

            CActiveScheduler::Stop();

			}

        }

    TBool iFirstTime;

    RAuthMgrClient& iClient;

    CIdentity*& iResult;

    HBufC* iIdentityString;

    TInt iErr;

    };

//====================================================================================================

CTRegIdentity::~CTRegIdentity()

/**

  Destructor

 */

	{}

CTRegIdentity::CTRegIdentity(CTAuthSvrServer& aParent): iParent(aParent)

/**

  Constructor

 */

	{

	// Call base class method to set up the human readable name for logging

	SetTestStepName(KTAuthSvrCheck);

	}

TVerdict CTRegIdentity::doTestStepPreambleL()

/**

  @return - TVerdict code

  Override of base class virtual

 */

	{

	//Call the parent class preamble, setting up the file server, etc

	CTStepActSch::doTestStepPreambleL();	

	return TestStepResult();

	}

TVerdict CTRegIdentity::doTestStepL()

/**

  @return - TVerdict code

  Override of base class pure virtual

 */

	{	

	SetTestStepResult(EPass);	

__UHEAP_MARK;		// Check for memory leaks

	SetPinPluginStateL();

	//-----------------------------------------------------------------------------------------------------	

	InitAuthServerFromFileL();	// Set things like 'iSupportsDefaultData' and 'DefaultPlugin'

	// this method creates the dat file from where the test implementation

	// of pin plugin notifier reads user input.

	// as the pin plugin fails without this data it has been included 

	// in the code as a default step for initializing the pin plugin

	// data.

	TPinValue aPinValue;

	CreatePinPluginInputFileL(EPinPluginTraining,aPinValue);

	CActiveScheduler::Install(iActSchd);

	//Connect to the AuthServer	

	AuthServer::RAuthMgrClient authMgrClient1;	

	TInt connectVal = authMgrClient1.Connect();

	if (KErrNotFound == connectVal)

		{

		//Retry after a delay

		TTimeIntervalMicroSeconds32 timeInterval = 2000;	//2 Milliseconds

		User::After(timeInterval);

		connectVal = authMgrClient1.Connect();

		}

	if (KErrNone != connectVal)

		{

		ERR_PRINTF2(_L("Unable to start a session or other connection error. Err = %d"), connectVal);

		RemovePinPluginFileL();

		User::LeaveIfError(connectVal);

		}	

	CleanupClosePushL(authMgrClient1);

	//Examine the authserver and see what's there

	ListPluginsL(authMgrClient1);

	TBool statusAll = EFalse;

	statusAll = CheckPluginStatusAllL(authMgrClient1);

	//Check the username of the second identity and then attempt to set it.

//	SetTestStepResult(checkAndSetUserNameL(authMgrClient1, 0));	

	// Get the identity string (if defined)

	TPtrC identityString;

	if (!GetStringFromConfig(ConfigSection(), _L("IdentityString"), identityString))

		{

		identityString.Set(_L("SOMENAME"));

		}

	//Register an identity using an active object

	CIdentity* identity1 = 0;

    CRegActive* active = new (ELeave) CRegActive(authMgrClient1, identityString.AllocL(), identity1); // Ownership transferred

    active->doReg();

	CActiveScheduler::Start();

	TInt err = active->iErr;

	delete active;

	SetTestStepError(err);

	if(KErrAuthServPluginQuit == err)

		{

		INFO_PRINTF1(_L("Training was Quit."));

		INFO_PRINTF1(_L("User entered the Quit code as trainingInput."));		

		}

	else if (KErrAuthServPluginCancelled == err)

		{

		INFO_PRINTF1(_L("Training was cancelled."));

		INFO_PRINTF1(_L("User entered trainingInput same as identifyingInput or an existing PIN."));

		INFO_PRINTF1(_L("Or the Cancel code."));		

		}

    else if ((identity1 == 0) && (KErrAuthServPluginQuit != err))

        {

        ERR_PRINTF1(_L("An unexpected error occurred during the registration process."));

        SetTestStepResult(EFail);

        }

    else

  		{

  		if (0 != identity1)

  			{

  			INFO_PRINTF3(_L("Id = %x , KeyLength = %d\n"), identity1->Id(), identity1->Key().KeyData().Size());

  			}	

		//Get a list of all the present identities

		RIdentityIdArray ids;

		authMgrClient1.IdentitiesL(ids);

		CleanupClosePushL(ids);

		TInt actualNumIds = ids.Count();

		//If specified in the ini file, check the number of identities now present

		TInt numIdsValue = 0;

		if (GetIntFromConfig(ConfigSection(),_L("NumIdentities"), numIdsValue) != EFalse) // the tag 'numIds' was present

			{

			if (actualNumIds != numIdsValue)

				{

				ERR_PRINTF3(_L("Error. ActualNumIds = %d, numIdsExpected = %d"), actualNumIds, numIdsValue);

				SetTestStepResult(EFail);

				}				

			}

		//List the present identities by their strings

		for (TInt i = 0; i < actualNumIds; i++)

			{

			HBufC* idName = 0;			

			idName = authMgrClient1.IdentityStringL(ids[i]);

			INFO_PRINTF3(_L("Id %d has the name %S"), i, idName);

			delete idName; 

			}		

		CleanupStack::PopAndDestroy(&ids);

		delete identity1;				

  		}//End check for when identity1 == 0, i.e 'RegisterIdentity() fails

	//Examine the authserver and see what's there

	ListPluginsL(authMgrClient1);

	statusAll = CheckPluginStatusAllL(authMgrClient1);

	if (!statusAll)

		{

		SetTestStepResult(EFail);

		}

	CleanupStack::PopAndDestroy(&authMgrClient1);	// authClient1	

	RemovePinPluginFileL();

	//Garbage collect the last previously destroyed implementation 

	// and close the REComSession if no longer in use

	REComSession::FinalClose(); 	

__UHEAP_MARKEND;

	return TestStepResult();	

	}

void CTRegIdentity::ListPluginsL(AuthServer::RAuthMgrClient& aAuthMgrClient )

	{

	RPluginDescriptions pluginList1;

	TCleanupItem cleanup(CleanupEComArray, &pluginList1);

	CleanupStack::PushL(cleanup);					

	aAuthMgrClient.PluginsL(pluginList1);	

	TInt numTotalPlugins = pluginList1.Count();

	TInt i;

	for(i = 0; i < numTotalPlugins; i++)

		{

		TInt presentPluginIdVal = pluginList1[i]->Id();

		TInt presentPluginStatus = pluginList1[i]->TrainingStatus();

		INFO_PRINTF3(_L("PluginId=%x,status =%i"), presentPluginIdVal,presentPluginStatus);

		}

	CleanupStack::PopAndDestroy(&pluginList1); //infoArray, results in a call to CleanupEComArray	

	}

void CTRegIdentity::SetPinPluginStateL()

	{

	TPtrC activeStateFromFile;

	_LIT(KPinPlugin,"pinplugin_inactive.txt");

	TFileName filename;

	filename.Copy(KPinPlugin); // convert from 8 -> 16 bit descriptor

	TDriveUnit sysDrive = RFs::GetSystemDrive();

	TDriveName sysDriveName (sysDrive.Name());

	filename.Insert(0,sysDriveName);

	filename.Insert(2,_L("\\"));		

	RFileWriteStream stream;

	RFs fs;

	CleanupClosePushL(fs);

	User::LeaveIfError(fs.Connect());

	fs.Delete(filename);

	if (GetStringFromConfig(ConfigSection(),_L("Pin200032E5Active"), activeStateFromFile)) 

		{

		if(activeStateFromFile == _L("false"))

			{		

			User::LeaveIfError(stream.Create(fs, filename, EFileWrite | EFileShareExclusive));

			stream.Close();

			}

		}

	CleanupStack::PopAndDestroy(); // fs

	}

void CTRegIdentity::RemovePinPluginFileL()

	{

	TPtrC activeStateFromFile;

	_LIT(KPinPlugin,"pinplugin_inactive.txt");

	TFileName filename;

	filename.Copy(KPinPlugin); // convert from 8 -> 16 bit descriptor

	TDriveUnit sysDrive = RFs::GetSystemDrive();

	TDriveName sysDriveName (sysDrive.Name());

	filename.Insert(0,sysDriveName);

	filename.Insert(2,_L("\\"));

	RFs fs;

	CleanupClosePushL(fs);

	User::LeaveIfError(fs.Connect());

	fs.Delete(filename);

	CleanupStack::PopAndDestroy(); // fs

	}

TVerdict CTRegIdentity::doTestStepPostambleL()

/**

  @return - TVerdict code

  Override of base class virtual

 */

	{

	//Call the parent postamble, releasing the file handle, etc

	CTStepActSch::doTestStepPostambleL();

	return TestStepResult();

	}