--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/smf/smfcredentialmgr/smfcredmgrserver/src/smfcredmgrserversession.cpp	Wed Jun 23 19:51:49 2010 +0530
@@ -0,0 +1,349 @@
+/**
+ * Copyright (c) 2010 Sasken Communication Technologies Ltd.
+ * All rights reserved.
+ * This component and the accompanying materials are made available
+ * under the terms of the "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:
+ * Pritam Roy Biswas, Sasken Communication Technologies Ltd - Initial contribution
+ *
+ * Description:
+ * Header file for Credential Manager Server Session.
+ */
+
+#include <S32MEM.H>
+#include <e32math.h>
+#include <time.h>
+#include <stdlib.h>
+#include <random.h>
+#include <smfcredmgrcommon.h>
+#include <smfcredmgrclientdatastruct.h>
+#include <smfutils.h>
+
+
+#include "smfcredmgrserversession.h"
+#include "smfcredmgrserver.h"
+#include "smfcredmgrdbuser.h"
+
+CSmfCredMgrServerSession* CSmfCredMgrServerSession::NewLC(
+		CSmfCredMgrServer& aServer)
+	{
+	CSmfCredMgrServerSession* self = new (ELeave) CSmfCredMgrServerSession(
+			aServer);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	return self;
+	}
+
+CSmfCredMgrServerSession* CSmfCredMgrServerSession::NewL(
+		CSmfCredMgrServer& aServer)
+	{
+	CSmfCredMgrServerSession* self = CSmfCredMgrServerSession::NewLC(aServer);
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+CSmfCredMgrServerSession::CSmfCredMgrServerSession(CSmfCredMgrServer& aServer) :
+	iServer(aServer)
+	{
+	RDebug::Printf("in constructor CSmfCredMgrServerSession");
+	}
+
+void CSmfCredMgrServerSession::ConstructL()
+	{
+	iDbUser = CSmfCredMgrDbUser::NewL(this);
+	iKeyStore = CSmfKeyStoreManager::NewL();
+	}
+
+CSmfCredMgrServerSession::~CSmfCredMgrServerSession()
+	{
+	RDebug::Printf("in destructor CSmfCredMgrServerSession");
+	delete iDbUser;
+	delete iKeyStore;
+	}
+
+void CSmfCredMgrServerSession::ServiceL(const RMessage2& aMessage)
+	{
+	TInt err = KErrNone;
+	switch (aMessage.Function())
+		{
+
+		case ESendAuthDataSet:
+			{
+			//create buffer to read the received data
+			RBuf8 dataBuf;
+			CleanupClosePushL(dataBuf);
+			dataBuf.CreateL(aMessage.GetDesLength(0));
+			aMessage.ReadL(0, dataBuf);
+			CSmfFetchAuthTokenSet* fetchAuthTokenSetParams =
+					new (ELeave) CSmfFetchAuthTokenSet;
+
+			CleanupStack::PushL(fetchAuthTokenSetParams);
+
+			fetchAuthTokenSetParams->InternalizeL(dataBuf);
+
+			getTokenArray(fetchAuthTokenSetParams);
+
+			//create buffer to serialize the data to be sent
+			CBufFlat* buf = CBufFlat::NewL(512);
+			CleanupStack::PushL(buf);
+			RBufWriteStream stream(*buf);
+			CleanupClosePushL(stream);
+
+			fetchAuthTokenSetParams->ExternalizeL(stream);
+
+			stream.CommitL();
+
+			TPtr8 bufPtr = buf->Ptr(0);
+
+			TInt err = aMessage.Write(1, bufPtr);
+
+			CleanupStack::PopAndDestroy(&stream);
+			CleanupStack::PopAndDestroy(buf);
+			CleanupStack::PopAndDestroy(fetchAuthTokenSetParams);
+			CleanupStack::PopAndDestroy(&dataBuf);
+			aMessage.Complete(err);
+			}
+			break;
+
+		case EUpdatePluginIDList:
+			{
+			//create buffer to read the received data
+			RBuf8 dataBuf;
+			CleanupClosePushL(dataBuf);
+			dataBuf.CreateL(aMessage.GetDesLength(0));
+			aMessage.ReadL(0, dataBuf);
+
+			CSmfPluginIDUpdate* changePluginListParams =
+					new (ELeave) CSmfPluginIDUpdate;
+			CleanupStack::PushL(changePluginListParams);
+
+			changePluginListParams->InternalizeL(dataBuf);
+
+			iDbUser->updatePlugin(changePluginListParams->iNewPluginID->Des(),
+					changePluginListParams->pluginIDEnabled,
+					changePluginListParams->iOldPluginID->Des());
+
+			CleanupStack::PopAndDestroy(changePluginListParams);
+			CleanupStack::PopAndDestroy(&dataBuf);
+			aMessage.Complete(err);
+			}
+			break;
+
+		case ESendURLList:
+			{
+			//create buffer to read the received data
+			RBuf8 dataBuf;
+			CleanupClosePushL(dataBuf);
+			dataBuf.CreateL(aMessage.GetDesLength(0));
+			aMessage.ReadL(0, dataBuf);
+
+			CSmfURLListParams* fetchURLListParams =
+					new (ELeave) CSmfURLListParams;
+			CleanupStack::PushL(fetchURLListParams);
+
+			fetchURLListParams->InternalizeL(dataBuf);
+
+			fetchURLs(fetchURLListParams);
+
+			//to serialize data we need a buffer
+			CBufFlat* buf = CBufFlat::NewL(512);
+			CleanupStack::PushL(buf);
+			RBufWriteStream stream(*buf);
+			CleanupClosePushL(stream);
+
+			fetchURLListParams->ExternalizeL(stream);
+
+			stream.CommitL();
+
+			TPtr8 bufPtr = buf->Ptr(0);
+
+			TInt err = aMessage.Write(1, bufPtr);
+
+			CleanupStack::PopAndDestroy(&stream);
+			CleanupStack::PopAndDestroy(buf);
+			CleanupStack::PopAndDestroy(fetchURLListParams);
+			CleanupStack::PopAndDestroy(&dataBuf);
+			aMessage.Complete(err);
+			}
+			break;
+
+		case ESendPluginIDList:
+			{
+			//create buffer to read
+			RBuf8 dataBuf;
+			CleanupClosePushL(dataBuf);
+			dataBuf.CreateL(aMessage.GetDesLength(0));
+			aMessage.ReadL(0, dataBuf);
+
+			CSmfPluginIDListParams* fetchPluginListParams =
+					new (ELeave) CSmfPluginIDListParams;
+			CleanupStack::PushL(fetchPluginListParams);
+			fetchPluginListParams->InternalizeL(dataBuf);
+
+			fetchPluginIDs(fetchPluginListParams);
+
+			//to serialize data we need a buffer
+			CBufFlat* buf = CBufFlat::NewL(512);
+			CleanupStack::PushL(buf);
+			RBufWriteStream stream(*buf);
+			CleanupClosePushL(stream);
+			fetchPluginListParams->ExternalizeL(stream);
+
+			stream.CommitL();
+
+			TPtr8 bufPtr = buf->Ptr(0);
+
+			TInt err = aMessage.Write(1, bufPtr);
+
+			CleanupStack::PopAndDestroy(&stream);
+			CleanupStack::PopAndDestroy(buf);
+			CleanupStack::PopAndDestroy(fetchPluginListParams);
+			CleanupStack::PopAndDestroy(&dataBuf);
+			aMessage.Complete(err);
+			}
+			break;
+
+		case ECheckPluginAuthentication:
+			{
+			//create buffer to read
+			RBuf8 dataBuf;
+			CleanupClosePushL(dataBuf);
+
+			dataBuf.CreateL(aMessage.GetDesLength(0));
+			aMessage.ReadL(0, dataBuf);
+
+			RDesReadStream stream(dataBuf);
+			CleanupClosePushL(stream);
+
+			TBool isAuthenticated = EFalse;
+
+			HBufC* buf = SmfUtils::InternalizeDesL(stream);
+			CleanupStack::PushL(buf);
+			TBuf<KMaxBufSize> pluginIDBuf(buf->Des());
+
+			TInt value = 0;
+			iDbUser->readFlagInPluginIdTable(pluginIDBuf, value);
+			if (value > 0)
+				isAuthenticated = ETrue;
+			else
+				isAuthenticated = EFalse;
+
+			HBufC8* isAuthenticatedBuf = HBufC8::NewLC(32);
+
+			TPtr8 isAuthenticatedBufPtr(isAuthenticatedBuf->Des());
+			isAuthenticatedBufPtr.AppendNum(isAuthenticated);
+
+			TInt err = aMessage.Write(1, isAuthenticatedBufPtr);
+
+			CleanupStack::PopAndDestroy(isAuthenticatedBuf);
+			CleanupStack::PopAndDestroy(buf);
+			CleanupStack::PopAndDestroy(&stream);
+			CleanupStack::PopAndDestroy(&dataBuf);
+			aMessage.Complete(err);
+			}
+			break;
+
+		case EStoreAuthData:
+			{
+			//create buffer to read
+			RBuf8 dataBuf;
+			CleanupClosePushL(dataBuf);
+			dataBuf.CreateL(aMessage.GetDesLength(0));
+			aMessage.ReadL(0, dataBuf);
+
+			CSmfStoreAuthParams* authenticationProcessData =
+					new (ELeave) CSmfStoreAuthParams;
+			CleanupStack::PushL(authenticationProcessData);
+
+			authenticationProcessData->InternalizeL(dataBuf);
+
+
+			TBuf8<56> regToken;
+			regToken.SetLength(regToken.MaxLength());
+			TRandom::RandomL(regToken);
+			authenticationProcessData->iRegistrationToken = HBufC::NewL(KMaxRegistrationTokenLength);
+			TPtr tokenPtr(authenticationProcessData->iRegistrationToken->Des());
+			tokenPtr.Copy(regToken);
+			storeInDb(authenticationProcessData);
+
+			aMessage.WriteL(1, regToken);
+			
+			CleanupStack::PopAndDestroy(authenticationProcessData->iRegistrationToken);
+			CleanupStack::PopAndDestroy(authenticationProcessData);
+			CleanupStack::PopAndDestroy(&dataBuf);
+			aMessage.Complete(err);
+			}
+			break;
+		case ESmfHMACSHA1SignMessage:
+		case ESmfRSASignMessage:
+		case ESmfStoreRSAKey:
+		case ESmfDeleteKeys:
+			{
+			iKeyStore->HandleMessageL(aMessage);
+			}
+			break;
+		default:
+			//todo -panic client
+			break;
+		}
+	}
+
+void CSmfCredMgrServerSession::storeInDb(
+		CSmfStoreAuthParams* aAuthenticationProcessData)
+	{
+	TBuf<KMaxBufSize> authAppIDbuf(
+			aAuthenticationProcessData->iAuthAppID->Des());
+
+	iDbUser->RegTokenValidityTableInsert(
+			aAuthenticationProcessData->iRegistrationToken->Des(),
+			authAppIDbuf, aAuthenticationProcessData->iValidity);
+
+	for (int i = 0; i < aAuthenticationProcessData->iAuthTokenArray.Count(); i++)
+		{
+		iDbUser->AuthParamsTableInsert(
+				authAppIDbuf,
+				aAuthenticationProcessData->iAuthTokenArray[i].iKey->Des(),
+				aAuthenticationProcessData->iAuthTokenArray[i].iSecret->Des());
+		}
+
+	//iterate pluginlist and insert in DB
+	for (int i = 0; i < aAuthenticationProcessData->iPluginIDList.Count(); i++)
+		{
+		HBufC* buf = aAuthenticationProcessData->iPluginIDList[i];
+		iDbUser->PluginIDTableInsert(buf->Des(), authAppIDbuf,
+				aAuthenticationProcessData->pluginIDEnabled);
+		}
+
+	//iterate URLlist and insert in DB
+	for (int i = 0; i < aAuthenticationProcessData->iURLList.Count(); i++)
+		{
+		HBufC* buf = aAuthenticationProcessData->iURLList[i];
+		iDbUser->URLTableInsert(authAppIDbuf, buf->Des());
+		}
+	}
+
+void CSmfCredMgrServerSession::fetchPluginIDs(CSmfPluginIDListParams* aParams)
+	{
+	TBuf<KMaxBufSize> tokenBuf(aParams->iRegistrationToken->Des());
+	iDbUser->fetchPluginList(tokenBuf, aParams->iPluginList);
+	}
+
+void CSmfCredMgrServerSession::fetchURLs(CSmfURLListParams* aArg)
+	{
+	TBuf<KMaxBufSize> authAppIDBuf;
+	iDbUser->readAuthAppIdInPluginIdTable(aArg->iPluginID->Des(), authAppIDBuf);
+	iDbUser->readURL(authAppIDBuf, aArg->iURLList);
+	}
+
+
+void CSmfCredMgrServerSession::getTokenArray(CSmfFetchAuthTokenSet* aParams)
+	{
+	TBuf<KMaxBufSize> authAppIDBuf;
+	iDbUser->readAuthAppIdInRegTokenTable(aParams->iRegistrationToken->Des(),
+			authAppIDBuf);
+	iDbUser->readAuthTokens(authAppIDBuf, aParams->iAuthTokenArray);
+	}
+