--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/networkprotocolmodules/privacyprotocolmodule/PrivacyProtocolModule/src/privacyserver.cpp	Tue Feb 02 01:50:39 2010 +0200
@@ -0,0 +1,360 @@
+// 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 "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 "lbsdevloggermacros.h"
+#include <lbs/lbsloccommon.h>
+#include "privacyserver.h"
+#include "privacysession.h"
+#include "privacyshutdown.h"
+
+
+/**
+LBSPRIVACY_POLICY_ALLOW_COMMDD
+
+If this is defined, clients need only the CommDD capability to 
+use this server.
+
+If undefined, then clients must have all of the following capabilities:
+  Location
+  ProtServ
+  ReadDeviceData
+  WriteDeviceData
+*/
+#define LBSPRIVACY_POLICY_ALLOW_COMMDD
+
+
+/**
+Define the TPolicy for this server.
+*/
+const TUint KRangeCount = 3;
+const TInt KRanges[KRangeCount] = 
+	{
+	0,
+	1, // 1-11
+	12
+	};
+const TUint8 KElementsIndex[KRangeCount] = 
+	{
+	CPolicyServer::ENotSupported,
+	CPolicyServer::ECustomCheck, // 1-11
+	CPolicyServer::ENotSupported 
+	};
+const CPolicyServer::TPolicy KPolicy = 
+	{
+	CPolicyServer::EAlwaysPass,
+	KRangeCount,
+	KRanges,
+	KElementsIndex,
+	NULL
+	};
+
+_LIT(KPrivacyServerName,"LBSPrivacyServer");
+
+/**
+Static public constructor.
+
+@param aProtocol Interface to send privacy requests to.
+
+@return A new instance of this class.
+*/
+CPrivacyServer* CPrivacyServer::NewL(MPrivacyProtocol& aProtocol)
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::NewL() Begin\n");
+	CPrivacyServer* self = new(ELeave) CPrivacyServer(aProtocol);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop();
+
+	LBSLOG(ELogP1, "CPrivacyServer::NewL() End\n");
+	return self;
+	}
+
+
+/**
+Create a new session.
+
+@param aVersion Version information.
+@param aMessage Incoming message.
+
+@return A new CPrivacySession object.
+*/
+CSession2* CPrivacyServer::NewSessionL(const TVersion& aVersion, const RMessage2& /*aMessage*/) const
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::NewSessionL() Begin\n");
+
+	// Check that the shutdown timer hasn't already requested
+	// the LBS system to shutdown
+	if (iShutdown->State() == CPrivacyShutdown::EShutdownStateShutdownRequested)
+		{
+		User::Leave(KErrServerTerminated);
+		}
+
+	TLbsProxyApiType apiType = ELbsProxyApiTypeUnknown;
+	
+	// Check the client version is supported.
+	// We also use this to distinguish between local and network sessions.
+	if (aVersion.iMajor == KLbsLocalPrivacyAPIVersionMajor &&
+		aVersion.iMinor == KLbsLocalPrivacyAPIVersionMinor &&
+		aVersion.iBuild == KLbsLocalPrivacyAPIVersionBuild)
+		{
+		apiType = ELbsProxyApiTypeLocal;
+		}
+	else if (aVersion.iMajor == KLbsNetworkPrivacyAPIVersionMajor &&
+			  aVersion.iMinor == KLbsNetworkPrivacyAPIVersionMinor &&
+			  aVersion.iBuild == KLbsNetworkPrivacyAPIVersionBuild)
+		{
+		apiType = ELbsProxyApiTypeNetwork;
+		}
+	else
+		{
+		// Unknown client version
+		User::Leave(KErrNotSupported);
+		}
+ 
+	// Check we aren't about to exceed the maximum number of sessions for this request source
+	if (MaxSessionsReached(apiType))
+		{
+		User::Leave(KErrInUse);
+		}
+	
+	// Need to castaway the const.
+	CSession2* session = new (ELeave) CPrivacySession(iProtocol,apiType);
+
+	LBSLOG(ELogP1, "CPrivacyServer::NewSessionL() End\n");
+	return session;
+	}
+
+
+/**
+Set the shutdown delay.
+*/
+void CPrivacyServer::SetShutdownDelay(TInt32 aShutdownDelay)
+	{
+	iShutdownDelay = aShutdownDelay;
+	}
+
+/**
+Set the maximum number of network sessions allowed.
+*/
+void CPrivacyServer::SetMaxNetworkSessions(TInt aMaxNetworkSessions)
+	{
+	iMaxNetworkSessions = aMaxNetworkSessions;
+	}
+
+/**
+Destructor.
+*/
+CPrivacyServer::~CPrivacyServer()
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::~CPrivacyServer() Begin\n");
+	delete iShutdown;
+	LBSLOG(ELogP1, "CPrivacyServer::~CPrivacyServer() End\n");
+	}
+		
+
+/**
+Increment the session count.
+
+This is to allow the server to keep track of the number of active sessions.
+*/
+void CPrivacyServer::IncSessionCount(TLbsProxyApiType aApiType)
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::IncSessionCount() Begin\n");
+
+	if (aApiType == ELbsProxyApiTypeLocal)
+		{
+		++iLocalSessionCount;
+		}
+	else if (aApiType == ELbsProxyApiTypeNetwork)
+		{
+		++iNetworkSessionCount;
+		}
+
+	if (iShutdown && ((iLocalSessionCount + iNetworkSessionCount) == 1))
+		{
+		// Cancel shutdown sequence as we have an active session
+		LBSLOG(ELogP1, "CPrivacyServer::IncSessionCount() Cancelling shutdown timer\n");
+		iShutdown->Cancel();
+		}
+
+	LBSLOG(ELogP1, "CPrivacyServer::IncSessionCount() End\n");
+	}
+
+	
+/**
+Decrement the session count.
+
+This is to allow the server to keep track of the number of active sessions.
+*/
+void CPrivacyServer::DecSessionCount(TLbsProxyApiType aApiType)
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::DecSessionCount() Begin\n");
+	
+	if (aApiType == ELbsProxyApiTypeLocal)
+		{
+		--iLocalSessionCount;
+		}
+	else if (aApiType == ELbsProxyApiTypeNetwork)
+		{
+		--iNetworkSessionCount;
+		}
+
+	if (iShutdown && ((iLocalSessionCount + iNetworkSessionCount) <= 0))
+		{
+		// Last session has disconnected, start shutdown timer
+		LBSLOG(ELogP1, "CPrivacyServer::DecSessionCount() Session count zero - starting shutdown timer\n");
+		iShutdown->Start(iShutdownDelay);
+		}
+	
+	LBSLOG(ELogP1, "CPrivacyServer::DecSessionCount() End\n");
+	}
+
+/**
+Determine if the maximum number of sessions has been reached for this request source
+
+*/
+TBool CPrivacyServer::MaxSessionsReached(TLbsProxyApiType aApiType) const
+	{
+	if (aApiType == ELbsProxyApiTypeNetwork)
+		{
+		return (iMaxNetworkSessions >= 0 && (iNetworkSessionCount >= iMaxNetworkSessions));
+		}
+
+	// Unlimited number of local sessions allowed
+	return EFalse;
+	}
+
+/**
+Security policies used for custom security check below:
+*/
+static _LIT_SECURITY_POLICY_C1(KLocationPolicy, ECapabilityLocation);
+static _LIT_SECURITY_POLICY_C1(KReadDeviceDataPolicy, ECapabilityReadDeviceData);
+static _LIT_SECURITY_POLICY_C1(KCommDDPolicy, ECapabilityCommDD);
+static _LIT_SECURITY_POLICY_C1(KNetworkServicesPolicy, ECapabilityNetworkServices);
+
+
+/**
+Perform a custom security check.
+
+@param aMsg The message to check.
+@param aAction A reference to the action to take if the security check fails.
+@param aMissing A reference to the list of security attributes missing from the checked process.
+
+@return Enum specifying the result of the security check.
+*/
+CPolicyServer::TCustomResult CPrivacyServer::CustomSecurityCheckL(const RMessage2 &aMsg, TInt& /*aAction*/, TSecurityInfo& /*aMissing*/)
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() Begin\n");
+	switch(aMsg.Function())
+		{
+		case ELbsPrivacyServerConnect: 
+		case ELbsPrivacyServerDisconnect:
+			{
+			if (KLocationPolicy().CheckPolicy(aMsg) &&
+				KReadDeviceDataPolicy.CheckPolicy(aMsg))
+				{
+				LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (PASS)\n");
+				return EPass;
+				}
+
+			#ifdef LBSPRIVACY_POLICY_ALLOW_COMMDD
+				if (KCommDDPolicy.CheckPolicy(aMsg))
+					{
+					LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (PASS with CommDD)\n");
+					return EPass;
+					}
+			#endif
+			break;
+			}
+		case ELbsPrivacyServerNotifyLocation:
+		case ELbsPrivacyServerVerifyLocation:
+		case ELbsPrivacyServerNotifyVerificationTimeout:
+		case ELbsPrivacyServerCancelVerifyLocationRequest:
+			{
+			if (KLocationPolicy().CheckPolicy(aMsg) &&
+				KReadDeviceDataPolicy.CheckPolicy(aMsg) &&
+				KNetworkServicesPolicy.CheckPolicy(aMsg))
+				{
+				LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (PASS)\n");
+				return EPass;
+				}
+
+			#ifdef LBSPRIVACY_POLICY_ALLOW_COMMDD
+				if (KCommDDPolicy.CheckPolicy(aMsg))
+					{
+					LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (PASS with CommDD)\n");
+					return EPass;
+					}
+			#endif
+			break;
+			}
+		case ELbsPrivacyServerNewPrivacyRequestLocal:
+		case ELbsPrivacyServerRepeatPrivacyRequestLocal:
+		case ELbsPrivacyServerCompleteRequest:
+			{
+			if (KLocationPolicy().CheckPolicy(aMsg) &&
+				KReadDeviceDataPolicy.CheckPolicy(aMsg))
+				{
+				LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (PASS)\n");
+				return EPass;
+				}
+			break;
+			}
+		case ELbsPrivacyServerNewPrivacyRequestNetwork:
+		case ELbsPrivacyServerRepeatPrivacyRequestNetwork: 
+			{
+			if (KLocationPolicy().CheckPolicy(aMsg) &&
+				KReadDeviceDataPolicy.CheckPolicy(aMsg) &&
+				KNetworkServicesPolicy.CheckPolicy(aMsg))
+				{
+				LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (PASS)\n");
+				return EPass;
+				}
+			break;
+			}
+		default:
+			{
+			return EFail;
+			}
+		}
+
+	LBSLOG(ELogP1, "CPrivacyServer::CustomSecurityCheckL() End (FAIL)\n");
+	return EFail;
+	}
+
+
+/**
+Constructor.
+
+@param aProtocol Interface to send privacy requests to.
+*/
+CPrivacyServer::CPrivacyServer(MPrivacyProtocol& aProtocol) :
+	CPolicyServer(EPriorityStandard, KPolicy),
+	iProtocol(aProtocol)
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::CPrivacyServer()\n");
+	}
+
+
+/**
+Second phase constructor.
+*/
+void CPrivacyServer::ConstructL()
+	{
+	LBSLOG(ELogP1, "CPrivacyServer::ConstructL() Begin\n");
+	iShutdown = CPrivacyShutdown::NewL();
+	StartL(KPrivacyServerName);
+	LBSLOG(ELogP1, "CPrivacyServer::ConstructL() End\n");
+	}