/*

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

 * Implements CUpsSession.	 See class and function definitions for

 * more information.

 *

 */

 /**

  @file

 */

 #include "upsserver.h"

 #include "policycache.h"

 #include <ups/upsdbw.h>

 #include <scs/ipcstream.h>

 #include <scs/nullstream.h>

 #include "pluginmanager.h"

 #include "viewevaluator.h"

 #include "updateevaluator.h"

 #include "policychangeevaluator.h"

 namespace UserPromptService

 {

 CUpsSession* CUpsSession::NewL(CUpsServer &aServer)

 /**

 	Factory function allocates new instance of CUpsSession.

 	@return					New, initialized instance of CUpsSession

 							which is owned by the caller.

  */

 	{

 	CUpsSession* self = new(ELeave) CUpsSession(aServer);

 	CleanupStack::PushL(self);

 	self->ConstructL();			// CScsSession implementation

 	CleanupStack::Pop(self);

 	return self;

 	}

 CUpsSession::CUpsSession(CUpsServer &aServer)

 /**

 	This private constructor prevents direct instantiation.

  */

  :	CScsSession(aServer), iDbViewHandle(aServer.iDbHandle, this)

 	{

 	// empty.

 	//RDebug::Printf("0x%x CUpsSession(server %x) (&iDbViewHandle %x)\n", this, &aServer, &iDbViewHandle);

 	}

 CUpsSession::~CUpsSession()

 /**

 	The base class destructor destroys any remaining subsessions

 	or outstanding requests.

  */

 	{

 	//RDebug::Printf("0x%x ~CUpsSession (&iDbViewHandle %x)\n", this, &iDbViewHandle);

 	CleanupView();

 	iServiceConfig.Close();

 	iDbViewHandle.Close();

 	}

 TBool CUpsSession::DoServiceL(TInt aFunction, const RMessage2& aMessage)

 /**

 	Implement CScsSession by handling the supplied message.

 	Note the subsession creation command is automatically sent to

 	DoCreateSubsessionL, and not this function.

 	@param	aFunction		Function identifier without SCS code.

 	@param	aMessage		Standard server-side handle to message.	 Not used.

  */

 	{

 	TSessionFunction f = static_cast<TSessionFunction>(aFunction);

 	//RDebug::Printf("0x%x CUpsSession::DoServiceL function %d\n", this, f);

 	switch (f)

 		{

 		case EGetClientConfigLength:

 			{

 			iServiceConfig.Close();

 			UpsServer()->iPolicyCache->ServiceConfigL(aMessage.SecureId(), iServiceConfig);

 			TPckgBuf<TInt> lengthBuf;

 			lengthBuf() = iServiceConfig.Count();

 			aMessage.WriteL(0, lengthBuf);

 			return ETrue; // Complete request with KErrNone

 			}

 		case EGetClientConfigData:

 			{

 			TInt count = iServiceConfig.Count();

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

 				{

 				const TServiceConfig &sc = iServiceConfig[i];

 				TPtrC8 ptr((TUint8 *) &sc, sizeof(TServiceConfig));

 				aMessage.WriteL(0, ptr, i*sizeof(TServiceConfig));

 				}

 			iServiceConfig.Close();

 			return ETrue; // Complete request with KErrNone

 			}

 		case EDeleteDatabase:

 			TRAPD(err, UpsServer()->iDbHandle->DeleteDatabaseL(UpsServer()->iFs));

 			UpsServer()->iDbHandle.Close();

 			User::LeaveIfError(err);

 			return ETrue; // Complete request with KErrNone

 		case ECreateView:

 			{

 			if(iManagementView != 0)

 				{

 				User::Leave(KErrServerBusy);

 				}

 			CViewEvaluator *viewEvaluator = CViewEvaluator::NewLC(this, aMessage);

 			viewEvaluator->TransferToScsFrameworkL();

 			CleanupStack::Pop(viewEvaluator); // view now owned by SCS framework

 			/**

 			   	The CViewEvaluator is now responsible for completing the request,

 	   			so we must NOT leave.

 	   		*/

 			viewEvaluator->StartEvaluatingView();

 			return EFalse; // Do not complete client request - view evaulator will...

 			}

 		case ENextMatch:

 			{

 			if((iManagementView == 0) || (iRecord == 0))

 				{

 				User::Leave(KErrAbort);

 				}

 			// Copy the record to arg 0

 			RIpcWriteStream ipcstream;

 			ipcstream.Open(aMessage, 0);

 			CleanupClosePushL(ipcstream);

 			ipcstream << *iRecord;

 			CleanupStack::PopAndDestroy(&ipcstream);

 			// Update arg 1 with the length of the next record.

 			PrefetchRecordAndWriteLengthToClientL(aMessage);

 			return ETrue; // Complete client request with KErrNone

 			}

 		case ECloseView:

 			{

 			CleanupView();

 			return ETrue; // Complete client request with KErrNone

 			}

 		case ERemoveDecisions:

 			{

 			// Read filter from the client arg 0

 			RIpcReadStream ipcstream;

 			ipcstream.Open(aMessage, 0);

 			CleanupClosePushL(ipcstream);

 			CDecisionFilter *filter = CDecisionFilter::NewLC();

 			ipcstream >> *filter;

 			UpsServer()->iDbHandle->RemoveDecisionsL(*filter);

 			CleanupStack::PopAndDestroy(filter);

 			CleanupStack::PopAndDestroy(&ipcstream);

 			return ETrue; // Complete client request with KErrNone

 			}

 		case EUpdateDecision:

 			{

 			CUpdateEvaluator *updateEvaluator = CUpdateEvaluator::NewLC(this, aMessage);

 			updateEvaluator->TransferToScsFrameworkL();

 			CleanupStack::Pop(updateEvaluator); // view now owned by SCS framework

 			/**

 			   	The CViewEvaluator is now responsible for completing the request,

 	   			so we must NOT leave.

 	   		*/

 			updateEvaluator->StartUpdate();

 			return EFalse; // Do not complete client request - view evaulator will...

 			}

 		case EDeleteDecisionsForExe:

 			{

 			TUid exeSid;

 			exeSid.iUid = aMessage.Int0();

 			CDecisionFilter *filter = CDecisionFilter::NewLC();

 			filter->SetClientSid(exeSid, EEqual);

 			UpsServer()->iDbHandle->RemoveDecisionsL(*filter);

 			CleanupStack::PopAndDestroy(filter);

 			return ETrue; // Complete client request with KErrNone

 			}

 		case ENotifyPluginsMayHaveChanged:

 			// Tell plugin manager to unload, and hence reload, plugins ASAP.

 			UpsServer()->iPluginManager->Unload();

 			return ETrue; // Complete client request with KErrNone

 		case ENotifyPolicyFilesChanged:

 			{

 			CPolicyChangeEvaluator *changeEvaluator = CPolicyChangeEvaluator::NewLC(UpsServer()->iPolicyCache, this, aMessage);

 			changeEvaluator->TransferToScsFrameworkL();

 			CleanupStack::Pop(changeEvaluator); // Nnow owned by SCS framework

 			/**

 			   	The CPolicyChangeEvaluator is now responsible for completing the request,

 	   			so we must NOT leave.

 	   		*/

 			changeEvaluator->StartUpdate();

 			// Release our reference to the policy cache

 			UpsServer()->iPolicyCache.Release();

 			return EFalse; // Do not complete client request - policy change  evaluator will...

 			}

 		BULLSEYE_OFF

 		default:

 			break;

 		BULLSEYE_RESTORE

 		}

 	BULLSEYE_OFF

 	User::Leave(KErrNotSupported);

 	/*lint -unreachable */

 	return ETrue;

 	BULLSEYE_RESTORE

 	}

 CScsSubsession* CUpsSession::DoCreateSubsessionL(TInt aFunction, const RMessage2& aMessage)

 /**

 	Override CScsSession by allocating a new subsession object.

 	@param	aFunction		Function identifier without SCS code.

 	@param	aMessage		Standard server-side handle to message.	 Not used.

 	@return					New, initialized instance of CUpsSubsession, which is

 							owned by the caller.

  */

 	{

 	TSessionFunction f = static_cast<TSessionFunction>(aFunction);

 	switch (f)

 		{

 	case ESessSubsessFromThreadId:

 		// create a subsession object curried on the supplied thread ID.

 		return CUpsSubsession::NewL(*this, aMessage);

 	default:

 		User::Leave(KErrNotSupported);

 		/*lint -unreachable */

 		return 0;			// avoid compiler warning

 		}

 	}

 void CUpsSession::PrefetchRecordAndWriteLengthToClientL(const RMessagePtr2& aMessage)

 /**

 	Retrieve the next record from the iManagementView and return its length to the 

 	client in arg 1.

 */

 	{

 	if(iManagementView == 0)

 		{

 		User::Leave(KErrEof);

 		}

 	TPckgBuf<TUint32> nextRecordLenghthBuf;

 	delete iRecord;

 	iRecord = 0;

 	TRAPD(err, iRecord = iManagementView->NextDecisionL());

 	if((err != KErrNone) || (iRecord == 0))

 		{

 		nextRecordLenghthBuf() = 0;

 		}

 	else

 		{

 		RNullWriteStream nullstream;

 		nullstream << *iRecord;

 		nextRecordLenghthBuf() = nullstream.BytesWritten();

 		}

 	aMessage.WriteL(1, nextRecordLenghthBuf);

 	}

 void CUpsSession::CleanupView()

 /**

 	Cleanup view objects

 */

 	{

 	delete iManagementView;

 	iManagementView = 0;

 	delete iRecord;

 	iRecord = 0;

 	}

 void CUpsSession::DbHandleAboutToBeDeleted()

 /**

 	Master DB handle is about to be deleted, so we must delete our view now.

 	This will also cause the next RUpsManageMent::NextMatchL call to leave.

 */

 	{

 	if(iManagementView)

 		{

 		iManagementView->Cancel();

 		CleanupView();

 		}

 	}

 } // End of namespace UserPromptService

 // End of file