/*
* Copyright (c) 2007 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:  Defines the notification map data structure used by Location 
*				 Triggering Server Logic to store notification request messages
*
*/


//  INCLUDE FILES
#include <e32base.h>
#include "lbtnotificationmap.h"
#include "lbtglobal.h"
#include "lbtlogger.h"

// ======== LOCAL FUNCTIONS ========

TInt OrderNotifReqs(
    const CLbtNotificationMap::TLbtNotificationReq& aLhs, 
    const CLbtNotificationMap::TLbtNotificationReq& aRhs)
	{
	FUNC_ENTER("CLbtNotificationMap::OrderNotifReqs");
	const RMessage2& lhs = aLhs.iMsg;
	const RMessage2& rhs = aRhs.iMsg;

	if(lhs.SecureId() == rhs.SecureId())
		{
		return 0;
		}
	if(lhs.SecureId() < rhs.SecureId())
		{
		return -1;
		}
	else
		{
		return 1;
		}
	}


TInt SecureIdCompare(CSession2** aSession, RMessage2& aMessage)
	{
	FUNC_ENTER("CLbtNotificationMap::SecureIdCompare");
	if(aMessage.Session() == (*aSession))
		{
		return 0;
		}
	if(aMessage.Session() < (*aSession))
		{
		return -1;
		}
	else
		{
		return 1;
		}
	}

// ======== MEMBER FUNCTIONS ========

// ---------------------------------------------------------------------------
// CLbtNotificationMap::NewL
// Symbian Two - phase constructor
// ---------------------------------------------------------------------------
//
CLbtNotificationMap* CLbtNotificationMap::NewL()
	{
	FUNC_ENTER("CLbtNotificationMap::NewL");
	CLbtNotificationMap* self = new ( ELeave ) CLbtNotificationMap;
    CleanupStack::PushL( self );
    self->ConstructL();    
    CleanupStack::Pop();
    return self;
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::~CLbtNotificationMap
// Destructor
// ---------------------------------------------------------------------------
//
CLbtNotificationMap::~CLbtNotificationMap()
	{
	FUNC_ENTER("CLbtNotificationMap::~CLbtNotificationMap");
	Reset(KErrServerBusy);
	iMessageArray.Close();
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::InsertL
// ---------------------------------------------------------------------------
//
void CLbtNotificationMap::InsertL(
    const RMessage2& aMessage,
    CLbtServerLogicBase::TSubSessionType aType)	
	{
	FUNC_ENTER("CLbtNotificationMap::InsertL");
	TLbtNotificationReq req = { aMessage, aType };

	//Insert in sorted order into to the message array
	TLinearOrder<TLbtNotificationReq> OrderPredicate(OrderNotifReqs);
	iMessageArray.InsertInOrderAllowRepeats(req, OrderPredicate);
//	iMessageArray.Append(req);
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::Retreive
// ---------------------------------------------------------------------------
//
TInt CLbtNotificationMap::Retreive(RMessage2& aMessage, 
				    			   TUint32 aSubSessionHandle, 
				    			   TSecureId aSecureId,
				    			   TInt aServiceId,
				    			   CSession2* aSession)
	{
	FUNC_ENTER("CLbtNotificationMap::Retreive");
	for(TInt i=0; i<iMessageArray.Count(); ++i)
		{
		
		RMessage2& msg = iMessageArray[i].iMsg;
		if( msg.SecureId() == aSecureId &&
		    msg.Int3() == aSubSessionHandle && 
		    msg.Function() == aServiceId && 
		    msg.Session() == aSession )
			{
			aMessage = msg;
			iMessageArray.Remove(i);
			return KErrNone;
			}
		}

	return KErrNotFound;
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::Retreive
// ---------------------------------------------------------------------------
//
TInt CLbtNotificationMap::Retreive(RMessage2& aMessage, 
				    			   TSecureId aSecureId,
				    			   TInt aServiceId)
	{
	FUNC_ENTER("CLbtNotificationMap::Retreive");
	for(TInt i=0; i<iMessageArray.Count(); ++i)
		{
		RMessage2& msg = iMessageArray[i].iMsg;
		if( msg.SecureId() == aSecureId &&
			msg.Function() == aServiceId )
			{
			aMessage = msg;
			iMessageArray.Remove(i);
			return KErrNone;
			}
		}
	return KErrNotFound;
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::Retreive
// ---------------------------------------------------------------------------
//
TInt CLbtNotificationMap::Retreive(RMessage2& aMessage, 
                                   TInt aSubSessionHandle,
                                   TSecureId aSecureId)
    {
    FUNC_ENTER("CLbtNotificationMap::Retreive");
    for(TInt i=0; i<iMessageArray.Count(); ++i)
        {
        RMessage2& msg = iMessageArray[i].iMsg;
        if( msg.SecureId() == aSecureId && 
            msg.Int3() == aSubSessionHandle )
            {
            aMessage = msg;
            iMessageArray.Remove(i);
            return KErrNone;
            }
        }
    return KErrNotFound;
    }


// ---------------------------------------------------------------------------
// CLbtNotificationMap::Retreive
// ---------------------------------------------------------------------------
//
TInt CLbtNotificationMap::Retreive(RMessage2& aMessage, 
				    			   TInt aServiceId,
				    			   CLbtServerLogicBase::TSubSessionType aType)
	{
	FUNC_ENTER("CLbtNotificationMap::Retreive");
	for(TInt i=0; i<iMessageArray.Count(); ++i)
		{
		RMessage2& msg = iMessageArray[i].iMsg;
		if( msg.Function() == aServiceId &&
			iMessageArray[i].iType == aType )
			{
			aMessage = msg;
			iMessageArray.Remove(i);
			return KErrNone;
			}
		}
	return KErrNotFound;
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::CompleteMessagesOfSubsession
// ---------------------------------------------------------------------------
//
void CLbtNotificationMap::CompleteMessagesOfSubsession(const CSession2* aSession, const TInt aSubSessionHandle, TInt aErrorCode)
	{
	FUNC_ENTER("CLbtNotificationMap::CompleteMessagesOfSubsession");
	for(TInt i=0;i<iMessageArray.Count();++i)
		{
		RMessage2& message = iMessageArray[i].iMsg;
		if(message.Session() == aSession && 
		   message.Int3() == aSubSessionHandle)
			{
			LbtGlobal::RequestComplete(message, aErrorCode);
			iMessageArray.Remove(i);
			}
		}
	}
// ---------------------------------------------------------------------------
// CLbtNotificationMap::CompleteMessagesOfSubsession
// ---------------------------------------------------------------------------
//
void CLbtNotificationMap::RemoveAllClientMessages(TSecureId aSecureId)	
	{
	FUNC_ENTER("CLbtNotificationMap::RemoveAllClientMessages");
	for(TInt i=0;i<iMessageArray.Count();i++)
		{
		RMessage2& message = iMessageArray[i].iMsg;
		if(message.SecureId() == aSecureId)
			{
			LbtGlobal::RequestComplete(message,KErrDied);
			iMessageArray.Remove(i);
			}
		}
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::Reset
// ---------------------------------------------------------------------------
//
void CLbtNotificationMap::Reset(TInt aErrorCode)
	{
	FUNC_ENTER("CLbtNotificationMap::Reset");
	for(TInt i=0;i<iMessageArray.Count();++i)
		{
		const RMessage2& message = iMessageArray[i].iMsg;
		LbtGlobal::RequestComplete(message, aErrorCode);
		}
	iMessageArray.Reset();
	}

// ---------------------------------------------------------------------------
// CLbtNotificationMap::ConstructL
// ---------------------------------------------------------------------------
//
void CLbtNotificationMap::ConstructL()
	{
	FUNC_ENTER("CLbtNotificationMap::ConstructL");
	}

// end of file