// 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:
// cupnpservicediscoveryimpl.cpp
// 
//

#include <connpref.h>
#include "cupnpservicediscoveryimpl.h"
#include <upnp/upnpconstants.h>

CUPnPServiceDiscoveryImpl::CUPnPServiceDiscoveryImpl ()
	{
	}
CUPnPServiceDiscoveryImpl* CUPnPServiceDiscoveryImpl::NewL()
	{
	CUPnPServiceDiscoveryImpl* self = new (ELeave) CUPnPServiceDiscoveryImpl;
	return self;
	}
CUPnPServiceDiscoveryImpl::~CUPnPServiceDiscoveryImpl ()
	{

	delete	iEventNotifier;
	delete 	iUPnPSearch;
	delete 	iUPnPDescribe;
	delete 	iUPnPSubscribe;
	delete 	iUPnPRegister;

	iHostResolver.Close();
	iSubConnection.Close();
	iConnection.Close();	
	iSocketServer.Close();
	}

// Explicitly start the connection
TInt CUPnPServiceDiscoveryImpl::Construct( TUint aTierId )
	{	
	TInt err;
	//Connect the Socket Server
	if((err = iSocketServer.Connect()) != KErrNone)
		return err;

	//const TUint KUPnPTierId = 0x2000D054;
	// Open the connection passing the socket server and the tier Id
	if((err = iConnection.Open( iSocketServer, aTierId )) != KErrNone)
		return err;

	//Start the connection using the given preferences
	TConnSnapPref prefs ( KDiscoveryConnPref );
	if((err = iConnection.Start( prefs )) != KErrNone)
		return err;

	//Create a new sub-connection on the started connection
	err = iSubConnection.Open(iSocketServer, RSubConnection::ECreateNew, iConnection);
	if ( err != KErrNone )
		return err;

	err = iHostResolver.Open( iSocketServer, KAfInet , KProtocolInetTcp);// , iConnection);
	if (err != KErrNone )
		return err;
	
	iEventNotifier = new CUPnPEventNotifier ( *this , iSubConnection );
	if( !iEventNotifier )
		return KErrNoMemory ;
	
	iEventNotifier->Notify();
	return KErrNone;
	}

// Sends the M-SEARCH request
void CUPnPServiceDiscoveryImpl::Discover ( const RPnPParameterBundle& aServiceInfo )
	{
	TRAPD( err, DiscoverL( aServiceInfo ));
	if(err != KErrNone )
		aServiceInfo.PnPObserver()->OnPnPError(err);
	}

void CUPnPServiceDiscoveryImpl::DiscoverL ( const RPnPParameterBundle& aServiceInfo )
	{
	if( !iUPnPSearch )
		iUPnPSearch = CUPnPSearch::NewL( iSubConnection );
	
	__ASSERT_DEBUG( iUPnPSearch->DiscoverInProgress()== EFalse,User::Panic(KUPnPDiscoveryInProgress,KUPnPErrDiscoveryInProgress) );
	iUPnPSearch->SubmitRequestL( aServiceInfo );
	}


void CUPnPServiceDiscoveryImpl::Describe(  const RPnPParameterBundle& aServiceInfo )
	{
	TRAPD( err, DescribeL( aServiceInfo ));
	if(err != KErrNone )
		aServiceInfo.PnPObserver()->OnPnPError(err);
	}
// Sends the Describe request
void CUPnPServiceDiscoveryImpl::DescribeL ( const RPnPParameterBundle& aServiceInfo )
	{
	if( !iUPnPDescribe )
		iUPnPDescribe = new (ELeave) CUPnPDescribe(iSubConnection ,iHostResolver);
	iUPnPDescribe->SubmitRequestL(aServiceInfo);
	}
//Sends the Subscribe request
void CUPnPServiceDiscoveryImpl::Subscribe ( const RPnPParameterBundle& aServiceInfo )
	{
	TRAPD( err, SubscribeL( aServiceInfo ));
	if(err != KErrNone )
		aServiceInfo.PnPObserver()->OnPnPError(err);
	}

void CUPnPServiceDiscoveryImpl::SubscribeL ( const RPnPParameterBundle& aServiceInfo )
	{
	if( !iUPnPSubscribe )
		iUPnPSubscribe = CUPnPSubscribe::NewL( iSubConnection,  iHostResolver );
	
	iUPnPSubscribe->SubmitRequestL( aServiceInfo );
	}

void CUPnPServiceDiscoveryImpl::RegisterNotify(  const RPnPParameterBundle& aServiceInfo )//done
	{
	TRAPD( err, RegisterNotifyL( aServiceInfo ));
	if(err != KErrNone )
		aServiceInfo.PnPObserver()->OnPnPError(err);
	}
// Used to register for advertisements of specific service type or ssdp:all
void CUPnPServiceDiscoveryImpl::RegisterNotifyL ( const RPnPParameterBundle& aServiceInfo )//done
	{
	if( !iUPnPRegister )
		iUPnPRegister = new (ELeave) CUPnPRegisterNotify(iSubConnection );
	iUPnPRegister->SubmitRequestL(aServiceInfo);
	}

/* Used to cancel previous requests of control point */
void CUPnPServiceDiscoveryImpl::Cancel ( const RPnPParameterBundle& aServiceInfo )//done
	{
	//Ignore the error.
	TRAP_IGNORE(ProcessCancelL(aServiceInfo));
	}

/* Used to call the NotifyResults method (which sends the responses back to the
  callback of the respective classes. In case , responses are coming for requests
  then they're ignored as they'll mostly be acknowlegements.
 @param afamilyId The family according to which NotifyResults of respective class
 				  is called
 */
void CUPnPServiceDiscoveryImpl::OnNotificationL (TUint32 afamilyId)
	{	
	RPnPParameterBundleBase pnpBundle;
	CleanupClosePushL(pnpBundle);
	// Get the subcon parameters
	User::LeaveIfError(iSubConnection.GetParameters(pnpBundle));

	// Send a clear request
	RPnPParameterBundleBase pBundle;
	User::LeaveIfError(pBundle.Open());
	CleanupClosePushL(pBundle);	
	RParameterFamily family = pBundle.CreateFamilyL(EUPnPClearParamSet);
	User::LeaveIfError ( iSubConnection.SetParameters(pBundle) );	
	CleanupStack::PopAndDestroy(&pBundle);
	CleanupStack::Pop(&pnpBundle);
	
	switch(afamilyId)
		{
		case EUPnPDiscoverResponseParamSet:
			iUPnPSearch->NotifyResultsL(pnpBundle);
		break;

		case EUPnPDescribeResponseParamSet:
			iUPnPDescribe->NotifyResultsL(pnpBundle);
		break;

		case EUPnPPresenceAnnouncementParamSet:
		case EUPnPAbsenceAnnouncementParamSet:
			iUPnPRegister->NotifyResultsL(afamilyId, pnpBundle);
		break;
		
		case EUPnPSubscribeResponseParamSet:
		case EUPnPNotifyEventParamSet:
			iUPnPSubscribe->NotifyResultsL(afamilyId, pnpBundle);
		break;
		
		default:
		__ASSERT_DEBUG(0, User::Panic(KUPnPInvalidFamily,KUPnPErrInvalidFamily));	
		break;
		}	
	}

TInt CUPnPServiceDiscoveryImpl::InitiateControl ( RControlChannel& /*aControlChannel*/, const TDesC8& aUri )
	{
	TInetAddr addr;
	TRAPD ( err, CUPnPUtils::ResolveHostAddressL ( iHostResolver, aUri, addr ) );
	
	if ( err == KErrNone )
		{
		TConnectionDetails connDetails ( &addr, aUri );
		//err = aControlChannel.Open ( iSocketServer, iSubConnection, KAfInet, EFalse, KProtocolInetTcp, connDetails );
		}
		
	return err;
	}

void CUPnPServiceDiscoveryImpl::ProcessCancelL( const RPnPParameterBundle& aServiceInfo)
	{
	RParameterFamily family=const_cast<RPnPParameterBundle&>(aServiceInfo).GetFamilyAtIndex(0);
	
	switch(family.Id())
		{
		case EUPnPCancelDiscoverParamSet:
		if( iUPnPSearch )
			iUPnPSearch->CancelSearchL( aServiceInfo );
		break;

		case EUPnPCancelDescribeParamSet:
		if ( iUPnPDescribe )
			iUPnPDescribe->CancelDescribeL( aServiceInfo );
		break;

		case EUPnPCancelRegisterNotifyParamSet:
		if( iUPnPRegister )
			iUPnPRegister->CancelNotifyAnnouncementL( aServiceInfo );
		break;

		case EUPnPCancelSubscribeParamSet:
		if ( iUPnPSubscribe )
			iUPnPSubscribe->CancelSubscribeL( aServiceInfo );
		break;

		default:
		__ASSERT_DEBUG(0, User::Panic(KUPnPInvalidFamily,KUPnPErrInvalidFamily));	
		break;
		}
	}