// Copyright (c) 2008-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:
// @file
// @internalComponent
// 
//


//Local Includes
#include "upnpflowbase.h"
#include "upnppint.h"

using namespace Messages;


CUPnPFlowBase::CUPnPFlowBase(CSubConnectionFlowFactoryBase& aFactory, ESock::CProtocolIntfBase* aProtocolIntf, TFlowType aFlowType, const TNodeId& aSubConnId)
		: CSubConnectionFlowBase(aFactory, aSubConnId, aProtocolIntf), iFlowType ( aFlowType )
	{
	}

CUPnPFlowBase::~CUPnPFlowBase()
	{
	iClients.Close ( );
	}

/*
//From CSubConnectionFlowBase MNode
TInt CUPnPFlowBase::ReceivedL(TCFSignatureBase& )
	{
	//This is just a base flow and should not receive any messages.
	ASSERT(0);
	return KErrNone;
	}
*/

void CUPnPFlowBase::AddControlClientL ( const TNodeId& aId )
	{
	if ( KErrNotFound == FindControlClient ( aId ) )
		{
		RNodeInterface client;
    	client.Open ( aId );
    	iClients.AppendL ( client );
		}
	}

TInt CUPnPFlowBase::RemoveControlClient ( TInt aIndex )
	{
	__ASSERT_DEBUG ( aIndex >= 0 && aIndex < iClients.Count () , User::Invariant ( ) );
	
	iClients.Remove ( aIndex );
	return iClients.Count ( );
	}

TInt CUPnPFlowBase::FindControlClient ( const TNodeId& aId )
	{
	for ( TInt i = 0; i < iClients.Count ( ); i++ )
		{
		if ( aId == iClients[i].RecipientId ( ) )
			{
			return i;
			}
		}
	return KErrNotFound;
	}

TInt CUPnPFlowBase::CountControlClients ( )
	{
	return iClients.Count ( );
	}

void CUPnPFlowBase::SetClientLeaving ( const TNodeId& aId )
	{
	TInt idx = FindControlClient ( aId );
	__ASSERT_DEBUG ( idx != KErrNotFound, User::Invariant ( ) );

	iClients[idx].SetFlags ( TClientType::ELeaving );
	}

TBool CUPnPFlowBase::IsClientLeaving ( const TNodeId& aId )
	{
	TInt idx = FindControlClient ( aId );
	__ASSERT_DEBUG ( idx != KErrNotFound, User::Invariant ( ) );

	if ( iClients[idx].Flags () == TClientType::ELeaving )
		{
		return ETrue;
		}
	return EFalse;
	}

TBool CUPnPFlowBase::CheckIfAllClientsLeaving ( )
	{
	TUint count = CountControlClients ( );
	for ( TInt i = 0; i < count; i++ )
		{
		if ( iClients[i].Flags () != TClientType::ELeaving )
			{
			return EFalse;
			}
		}
	return ETrue;
	}

void CUPnPFlowBase::PostDataClientStopped ( TNodeCtxId aSenderId )
	{
	//ESock::TCFDataClient::TDataClientStopped dataClientStopped ( NodeId (), aChannelId.iActivityId, 0 );
	//dataClientStopped.PostTo ( aChannelId.iNodeId );
	RClientInterface::OpenPostMessageClose(Id(), aSenderId, ESock::TCFDataClient::TStopped(0).CRef() );
	}