--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/Client/upnpplugin/src/cupnpregisternotify.cpp	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,164 @@
+// 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:
+//
+
+#include "cupnpregisternotify.h"
+#include "pnputils.h"
+#include <upnp/upnpconstants.h>
+
+_LIT8(KSsdpAll,"ssdp:all");
+
+CUPnPRegisterNotify::CUPnPRegisterNotify( RSubConnection& aSubConnection )
+	: iSubConnection( aSubConnection )
+	{
+	}
+
+CUPnPRegisterNotify::~CUPnPRegisterNotify()
+	{
+	delete iElementArray;
+	}
+/* Submits a request to the network to register for announcements of a specific type.
+ @param aBundle Parameter bundle containing list of uris to be registered
+ */
+void CUPnPRegisterNotify::SubmitRequestL( const RPnPParameterBundle& aBundle )
+	{
+	RParameterFamily family = const_cast<RPnPParameterBundle&>(aBundle).FindFamily ( EUPnPRegisterAnnouncementParamSet );
+	// Iterate through all the param sets in the passed bundle
+
+	CUPnPRegisterAnnouncementParamSet* paramSet  = NULL;
+
+	TUint count = family.CountParameterSets ( RParameterFamily::ERequested ) ;
+	// Perform the first iteration in which validation of all the uris
+	// contained in the bundle will be done
+	
+	for ( TInt paramIndex = count - 1; paramIndex >= 0; paramIndex-- )
+		{
+		paramSet = static_cast<CUPnPRegisterAnnouncementParamSet*> ( family.GetParameterSetAtIndex ( paramIndex, RParameterFamily::ERequested ) );
+		const TDesC8& uri  = paramSet->Uri();
+		if( !iElementArray )
+			{
+			iElementArray = new (ELeave) CUPnPElementArray ;
+			if (uri.CompareF(KSsdpAll) != NULL)
+				User::LeaveIfError(CUPnPUtils::GenericUriValidity( uri, CUPnPUtils::EAny ));
+			iElementArray->InsertElementL( aBundle.PnPObserver() , uri );
+			}
+		else
+			{
+			if ( iElementArray->MatchElement( uri ) || iElementArray->MatchElement( KSsdpAll ))
+	 			{	 			
+	 			reinterpret_cast<RUPnPParameterFamily*>(&family)->DeleteParamSetL ( paramIndex );
+	 			continue;
+	 			}
+			if (uri.CompareF( KSsdpAll) == NULL)
+				{
+				iElementArray->SsdpAllModificationL( aBundle.PnPObserver() );
+				for(TInt i=family.CountParameterSets(RParameterFamily::ERequested)-1; i>=0 ; i--)
+					{
+					if( i != paramIndex )						
+						reinterpret_cast<RUPnPParameterFamily*>(&family)->DeleteParamSetL ( i );
+					}
+				break;
+				}	
+			
+			User::LeaveIfError( CUPnPUtils::GenericUriValidity( uri, CUPnPUtils::EAny ) );	
+			iElementArray->InsertElementL( aBundle.PnPObserver() , uri );
+			}
+		}
+	User::LeaveIfError(iSubConnection.SetParameters(aBundle));	
+	}
+
+/* Used to cancel registration request
+ @param aServiceInfo Bundle containing list of uris whose registraion for
+         			 advertisements have to be cancelled
+  */
+void CUPnPRegisterNotify::CancelNotifyAnnouncementL( const RPnPParameterBundle& aServiceInfo )
+	{
+	RParameterFamily family = const_cast<RPnPParameterBundle&>(aServiceInfo).FindFamily ( EUPnPCancelRegisterNotifyParamSet );
+	// Iterate through all the param sets in the passed bundle
+	CUPnPCancelRegisterNotifyParamSet* paramSet = NULL;
+	TUint count = family.CountParameterSets ( RParameterFamily::ERequested ) ;
+	
+	for ( TInt paramIndex = count - 1; paramIndex >= 0; paramIndex-- )
+	{
+	  	paramSet = static_cast<CUPnPCancelRegisterNotifyParamSet*> ( family.GetParameterSetAtIndex ( paramIndex, RParameterFamily::ERequested) );
+	  
+		if ( !(iElementArray->MatchElement(paramSet->Uri())))
+			{			
+			reinterpret_cast<RUPnPParameterFamily*>(&family)->DeleteParamSetL ( paramIndex );
+			continue;
+			}
+		else
+			iElementArray->RemoveElement( paramSet->Uri() );
+		// Removes the uri entry from the array if exists
+	}
+
+	User::LeaveIfError(iSubConnection.SetParameters( aServiceInfo ));	
+	}
+
+/* Sends the notification to the client according to the advertisement received.
+ Advertisements can be for both presence (ssdp:alive) or absence (ssdp:bye-bye)
+
+ @param aFamily Indicates whether the advertisement is presence or absence
+ */
+void CUPnPRegisterNotify::NotifyResultsL(TUint32 aFamily, RPnPParameterBundleBase& aBundle)
+	{
+	MPnPObserver* observer = NULL;
+	
+	CUPnPPresenceAnnouncementParamSet* presenceParamSet  = NULL;
+	CUPnPAbsenceAnnouncementParamSet* absenceParamSet  = NULL;
+	RParameterFamily family ;
+	switch(aFamily)
+		{
+		case EUPnPPresenceAnnouncementParamSet:
+			{
+			family = aBundle.FindFamily(EUPnPPresenceAnnouncementParamSet);						
+			__ASSERT_DEBUG(!family.IsNull (), User::Panic(KUPnPInvalidFamily,KUPnPErrInvalidFamily));
+			__ASSERT_DEBUG( family.CountParameterSets(RParameterFamily::ERequested) > 0, User::Panic(KUPnPNoParamSet,KUPnPErrNoParamSet));		
+			TUint count = family.CountParameterSets ( RParameterFamily::ERequested ) ;			
+			presenceParamSet = static_cast<CUPnPPresenceAnnouncementParamSet*> ( family.GetParameterSetAtIndex ( count - 1, RParameterFamily::ERequested ) );
+			
+			observer = iElementArray->MatchElement( presenceParamSet->Uri () );
+			if ( !observer )
+				{
+				observer = iElementArray->MatchElement( KSsdpAll );
+				User::LeaveIfNull(observer);
+				}
+			break;
+			}
+
+		case EUPnPAbsenceAnnouncementParamSet:
+			{
+			// Remove the uri from the element array as the service
+			// point is no more in the network
+			family = aBundle.FindFamily(EUPnPAbsenceAnnouncementParamSet);			
+			__ASSERT_DEBUG(!family.IsNull (), User::Panic(KUPnPInvalidFamily,KUPnPErrInvalidFamily));
+			__ASSERT_DEBUG( family.CountParameterSets(RParameterFamily::ERequested) > 0, User::Panic(KUPnPNoParamSet,KUPnPErrNoParamSet));
+			TUint count = family.CountParameterSets ( RParameterFamily::ERequested ) ;			
+			absenceParamSet = static_cast<CUPnPAbsenceAnnouncementParamSet*> ( family.GetParameterSetAtIndex ( count - 1, RParameterFamily::ERequested ) );		 
+
+			observer = iElementArray->MatchElement( absenceParamSet->Uri () );
+			if ( !observer )
+				{
+				observer = iElementArray->MatchElement( KSsdpAll );
+				User::LeaveIfNull(observer);
+				}
+			break;
+			}
+
+		default:
+		__ASSERT_DEBUG(0, User::Panic(KUPnPInvalidFamily,KUPnPErrInvalidFamily));	
+		}
+
+	observer->OnPnPEventL( aBundle ) ;
+	}