// Copyright (c) 2005-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:
// Name          : CSIPRoutingRequestStore.cpp
// Part of       : SIP Server Core
// Version       : SIP/4.0 
//



#include "CSIPRoutingRequestStore.h"
#include "CSIPRoutingRequest.h"
#include "MSIPRequestRouterObserver.h"
#include "CSipServerCore.h"
#include "sipresponse.h"


// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::NewL
// ----------------------------------------------------------------------------
//
CSIPRoutingRequestStore* CSIPRoutingRequestStore::NewL(
    CSipServerCore& aServerCore)
    {
    CSIPRoutingRequestStore* self = 
        CSIPRoutingRequestStore::NewLC(aServerCore);
    CleanupStack::Pop(self);
    return self;
    }

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::NewLC
// ----------------------------------------------------------------------------
//
CSIPRoutingRequestStore* CSIPRoutingRequestStore::NewLC(
    CSipServerCore& aServerCore)
    {
	CSIPRoutingRequestStore* self = 
		new(ELeave)CSIPRoutingRequestStore(aServerCore);
    CleanupStack::PushL(self);
    return self;
    }

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::CSIPRoutingRequestStore
// ----------------------------------------------------------------------------
//
CSIPRoutingRequestStore::CSIPRoutingRequestStore (CSipServerCore& aServerCore)
: iServerCore(aServerCore),
  iList(CSIPRoutingRequest::LinkOffset())
    {
    }

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::~CSIPRoutingRequestStore
// ----------------------------------------------------------------------------
//
CSIPRoutingRequestStore::~CSIPRoutingRequestStore ()
    {
	TSglQueIter<CSIPRoutingRequest> iter(iList);
	for (CSIPRoutingRequest* request = iter++; request; request = iter++)
		{
		iList.Remove(*request);
		delete request;
    	}    
    }

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::TransactionOwnerL
// From MSIPRequestRouter
// ----------------------------------------------------------------------------
//
TUint32 CSIPRoutingRequestStore::TransactionOwnerL(
    CSIPRequest& aRequest,
    TUint32 aIapId,
    MSIPRequestRouterObserver& aObs)
	{
	CSIPRoutingRequest* request = CSIPRoutingRequest::NewLC(aIapId,aObs);
	TUint32 requestId = iServerCore.RequestHandler().ChannelL(aRequest);
	CleanupStack::Pop(request);
	request->SetRequestId(requestId);
	iList.AddLast(*request);
	return requestId;
	}

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::Cancel
// From MSIPRequestRouter
// ----------------------------------------------------------------------------
//   
void CSIPRoutingRequestStore::Cancel(TUint32 aRequestId)
	{
	iServerCore.RequestHandler().Cancel(aRequestId);
	RemoveAndDelete(aRequestId);
	}
	
// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::ClientFoundL
// From MSIPRequestHandlerObserver	
// ----------------------------------------------------------------------------
// 	
void CSIPRoutingRequestStore::ClientFoundL(TUint32 aRequestId, TUid aUid)
	{
	CSIPRoutingRequest* request = Find(aRequestId);
	if (request)
		{
		TUint32 iapId = request->IapId();
		MTransactionOwner* owner = iServerCore.FindOwner(iapId,aUid);
		if (owner)
			{
			request->Observer().OwnerFoundL(aRequestId,owner);
			}
		else
			{
			request->Observer().ErrorOccurred(aRequestId,KErrNotFound);	
			}
		RemoveAndDelete(aRequestId);
		}	
	}

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::ClientNotFoundL
// From MSIPRequestHandlerObserver	
// ----------------------------------------------------------------------------
//
void CSIPRoutingRequestStore::ClientNotFoundL(TUint32 aRequestId,
                                              CSIPResponse* aSIPResponse)
	{
	CSIPRoutingRequest* request = Find(aRequestId);
	if (request)
		{
		request->Observer().OwnerNotFoundL(aRequestId,aSIPResponse);
		RemoveAndDelete(aRequestId);
		}
	else
		{
		delete aSIPResponse;
		}
	}

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::ClientFoundL
// From MSIPRequestHandlerObserver	
// ----------------------------------------------------------------------------
//
void CSIPRoutingRequestStore::ErrorOccurred(TUint32 aRequestId, TInt aError)
	{
	CSIPRoutingRequest* request = Find(aRequestId);
	if (request)
		{
		request->Observer().ErrorOccurred(aRequestId,aError);
		RemoveAndDelete(aRequestId);		
		}	
	}
	
// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::Find
// ----------------------------------------------------------------------------
//	
CSIPRoutingRequest* CSIPRoutingRequestStore::Find(TUint32 aRequestId)
	{
	TSglQueIter<CSIPRoutingRequest> iter(iList);
	for (CSIPRoutingRequest* request = iter++; request; request = iter++)
		{
        if (request->RequestId() == aRequestId)
            {
            return request;
            }
		}
	return NULL;
	}

// ----------------------------------------------------------------------------
// CSIPRoutingRequestStore::RemoveAndDelete
// ----------------------------------------------------------------------------
//	
void CSIPRoutingRequestStore::RemoveAndDelete(TUint32 aRequestId)
	{
	CSIPRoutingRequest* request = Find(aRequestId);
	if (request)
	    {
		iList.Remove(*request);
		delete request;		
		}		
	}