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

	}