// Copyright (c) 2004-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:
// Implementation file for the IP SubConnection Provider
// 
//

/**
 @file
*/

#include <e32std.h>
#include <e32test.h>
#include <ss_glob.h>
#include "deft_scpr.h"
#include "ipscprlog.h"
#ifdef SYMBIAN_NETWORKING_UMTSR5
#include "MAppIdInfo.h"
#include <networking/qos3gpp_subconparams.h>
#include <ip_subconparams.h>
#endif //SYMBIAN_NETWORKING_UMTSR5

#ifdef SYMBIAN_NETWORKING_UMTSR5
	const TUint32 KSIPSecureId  = 270490934;
	const TUint32 KDHCPSecureId = 270522821;
	const TUint32 KDNSSecureId  = 268437634;
#endif //SYMBIAN_NETWORKING_UMTSR5

CEmptySubConnectionProvider::~CEmptySubConnectionProvider()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("~CEmptySubConnectionProvider [this=%08x]"), this));
	if (iConnectionProvider)
		{
		iConnectionProvider->Leave(*this);
		}
	}

void CEmptySubConnectionProvider::DoControlClientJoiningL(MSubConnectionControlClient& aControlClient)
	{
	(void)aControlClient;
	__IPCPRLOG(IpCprLog::Printf(_L("CEmptySubConnectionProvider [this=%08x]:\tDoControlClientJoiningL() [iControlClients.Count=%d] [aControlClient=%08x]"), this, iControlClients.Count(), &aControlClient));
	}
	
void CEmptySubConnectionProvider::DoControlClientLeaving(MSubConnectionControlClient& aControlClient)
	{
	(void)aControlClient;
	__IPCPRLOG(IpCprLog::Printf(_L("CEmptySubConnectionProvider [this=%08x]:\tDoControlClientLeaving() [iControlClients.Count=%d] [aControlClient=%08x]"), this, iControlClients.Count(), &aControlClient));
	}

void CEmptySubConnectionProvider::EnumerateClientsL(TUint& aCount, TDes8& aDes, CConnectionProviderBase::TEnumClients aClientType)
	{
	STypeId tid = STypeId::CreateSTypeId(KConnectionClientExtUid,EConnectionClientDesc);
	TInt max = iControlClients.Count();
	for ( TInt n = 0; n < max; n++ )
		{
		MConnectionClientDesc* intf = reinterpret_cast<MConnectionClientDesc*>(iControlClients[n]->FetchInterfaceInstanceL(*this,tid));
		if ( intf )
			{
			TConnectionProcessInfo cinfo;
			cinfo.GetInfoL(aClientType,aCount, *intf, aDes);
			}
		}
	STypeId tid2 = STypeId::CreateSTypeId(KConnectionClientExtUid,EConnectionEnumerateClients);
	max = iDataClients.Count();
	for ( TInt n = 0; n < max; n++ )
		{
		MConnectionEnumerateClients* intf = reinterpret_cast<MConnectionEnumerateClients*>(iDataClients[n]->FetchInterfaceInstanceL(*this,tid2));
		if ( intf )
			{
			intf->EnumerateClientsL(aCount,aDes,aClientType);
			}
		}
	}

void CEmptySubConnectionProvider::ConnectionError(TInt /*aStage*/, TInt aError)
	{//it's comming from connection at the same level so forward it sideways
	//with an origin EConnection
	TInt max = iDataClients.Count();
	for ( TInt n = max - 1; n >= 0; n-- )
		{
		iDataClients[n]->SubConnectionError(*this, MSubConnectionDataClient::EConnection, aError);
		}
	}

MConnectionDataClient* CEmptySubConnectionProvider::DoSelfConnectionDataClient()
	{
	return this;
	}


// Methods to be overriden be derived subconnection provider
void CDefaultSubConnectionProvider::DoControlClientJoiningL(MSubConnectionControlClient& aControlClient)
	{
	(void)aControlClient;
   __IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider::DoControlClientJoiningL [this=%08x]"), this));
   if (NULL != NextLayer())
      {
      __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP exists - joined with provider")));
      }
   else
      {
      __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP doesn't exists - not joined")));
      }
	
	}
	
void CDefaultSubConnectionProvider::DoDataClientJoiningL(MSubConnectionDataClient& aDataClient)
	{
#ifdef SYMBIAN_NETWORKING_UMTSR5
	// This piece of code is being added as per the requirements of PREQ 635 of dedicated PDP signalling 
	// context. When Primary PDP Context is created Network will return back the code saying whether it 
	// accepts the request to be dedicated signalling context or not. If Network decided to allow for dedicated
	// signalling context then UmtsGprs SCPR add the information into the iParameterBundle of the UmtsGprsScpr 
	
	// However, if the User doesnt do RSubConnection::SetParamter(EAttachDefault), which actually the user shouldn't do
	// then we have to Get the parameter from the Next Layer, which again might or might not be UmtsGprs SubConnection Provider.
	// Nevertheless if we call SetParameter() on iNextLayer then SetParameters across all the Layers below will get called, and 
	// since I knew that if any of the layer below is UmtsGprsSCpr, it will update the IMCN Signalling flag in the 
	// parameter Bundle which I will pass with the SetParameter()
	
	// We Initialize this variable everytime so that it can it can point to proper next layer 
	// everytime. Just a safety measure because it will anyway be initialised by the code written 
	// below
	iSubConNextLayer = NULL;
	if (NULL == iNextLayer)
		{
		// Find the Next Layer , otherwise iSubConNextLayer will be NULL by default.
		CConnectionProviderBase* lowerConnectionProvider = iConnectionProvider->NextLayer();
   		if (lowerConnectionProvider)
       		{
			TUint nextLayerFactoryId = lowerConnectionProvider->CanDoSubConnection(RSubConnection::EAttachToDefault);
			if (nextLayerFactoryId != 0)
	   			{	
           		TSockManData* sockManData = SockManGlobals::Get();
           		CSubConnectionFactoryContainer* subConnectionFactories = sockManData->iSubConnectionFactories;
   	            XSubConnectionFactoryQuery query(lowerConnectionProvider, RSubConnection::EAttachToDefault);
       		    iSubConNextLayer = subConnectionFactories->FindOrCreateProviderL(nextLayerFactoryId, query);
	   			}	
			        	
       		}
   		}
	else
		{
		// We have a NextLayer, Point iSubConNextLayer to the same
		iSubConNextLayer = iNextLayer;
		}

	// Get The parameter Bundle for this SubConnectionProvider Instance. if Not available create one
	// and Get the parameters from the Next Lyer
	CSubConParameterBundle *tempBundle = NULL;
	if (iSubConNextLayer != NULL)
		{
		tempBundle = iParameterBundle != NULL? iParameterBundle :CSubConParameterBundle::NewL();
		TRAP_IGNORE(iSubConNextLayer->SetParametersL(*tempBundle));
		}
	
	// Get the family if Available
	CSubConParameterFamily *imcnFamily = tempBundle != NULL ? tempBundle->FindFamily(KSubConnContextDescrParamsFamily) : NULL;
	if (imcnFamily)
		{
		// Find the family, Look for the IMCN value, using CSubConImsExtParamSet defined in Qos3gpp
		CSubConImsExtParamSet *imcnSigParams = static_cast<CSubConImsExtParamSet*>
		(imcnFamily->FindExtensionSet(STypeId::CreateSTypeId(KSubConIPParamsUid,KSubConImsExtParamsType), 
		CSubConParameterFamily::EGranted));
		// If Family contains IMCN Signalling Parameters
		if (imcnSigParams&& imcnSigParams->GetImsSignallingIndicator())	
			{
    		// Check and Delete
			if (tempBundle != iParameterBundle)
				{
				tempBundle->Close();
				tempBundle=NULL;
				}
			// Fetch the interface from the connection provider
			STypeId typeID = STypeId::CreateSTypeId(KConnectionAppInfoInterfaceId,0); // IP Conenction provider factory Uid
			TAny* intf = iConnectionProvider->FetchInterfaceInstanceL(typeID);
			if (!intf)
				{
				// We are not able to get the AppSId so leaving
				User::Leave(KErrNotSupported);
				}
			MConnectionAppIdInfo  *appIdIP = static_cast<MConnectionAppIdInfo*>(intf);
			TUint32 appSecureId = appIdIP->GetAppSecureId();
			
			// if socket is being opened by any application other than SIP, DHCP, and DNS we need to
			// restrict the socket from being Created.
		
			
			if ( ( appSecureId==KSIPSecureId || iAppId == KSIPSecureId)  || 
			     (appSecureId==KDHCPSecureId || iAppId == KDHCPSecureId)  || 
			     (appSecureId==KDNSSecureId || iAppId == KDNSSecureId) )
				{
				aDataClient.JoinComplete(*this);
				}
		    else
	            {
	            User::Leave(KErrPermissionDenied);
	            }	     
			} // if (imcnSigParams&& imcnSigParams->GetImsSignallingIndicator())	
		else
		    {
		    if (iConnectionProvider->IsLayerUp())
		        {
		         aDataClient.JoinComplete(*this);
		        }

	     	}
		} // if (imcnFamily)
		// Check and Delete
		if (tempBundle != iParameterBundle && tempBundle!=NULL)
		   {
		    tempBundle->Close();
	       }
#else 
			
		if (iConnectionProvider->IsLayerUp())
		  {
		   aDataClient.JoinComplete(*this);
		  }
#endif 	// #ifdef SYMBIAN_NETWORKING_UMTSR5

	}

void CDefaultSubConnectionProvider::DoDataClientLeaving(MSubConnectionDataClient& aDataClient)
	{
	aDataClient.LeaveComplete(*this);
	}
	
void CDefaultSubConnectionProvider::DoSourceAddressUpdate(MSubConnectionDataClient& /*aDataClient*/, const TSockAddr& /*aSource*/)
	{
	}
	
void CDefaultSubConnectionProvider::DoDestinationAddressUpdate(MSubConnectionDataClient& /*aDataClient*/, const TSockAddr& /*aDestination*/)
	{
	}
	
void CDefaultSubConnectionProvider::DoDataClientRouted(MSubConnectionDataClient& /*aDataClient*/, const TSockAddr& /*aSource*/, const TSockAddr& /*aDestination*/, const TDesC8& /*aConnectionInfo*/)
	{
	}
	
#ifdef SYMBIAN_NETWORKING_3GPPDEFAULTQOS
void CDefaultSubConnectionProvider::DoParametersAboutToBeSetL(CSubConParameterBundle& aParameterBundle)
	{
   __IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider::DoParametersAboutToBeSetL [this=%08x]"), this));
   if (NULL != NextLayer())
      {
      __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP exists - forwarding the request")));
      iNextLayer->SetParametersL(aParameterBundle);
      }
   else
      {
      __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP doesn't exists - the request not supported")));
      User::Leave(KErrNotSupported);        
      }
   }

#else
void CDefaultSubConnectionProvider::DoParametersAboutToBeSetL(CSubConParameterBundle& /*)aParameterBundle*/)
	{//this could potentially fetch a current parameters from GuQoS and return them back as granted ones	
	User::Leave(KErrNotSupported);
	}
#endif
	
#ifdef SYMBIAN_NETWORKING_UMTSR5	
TInt CDefaultSubConnectionProvider::DoControl(TUint aOptionLevel, TUint /*aOptionName*/, TDes8& /*aOption*/)
#else
TInt CDefaultSubConnectionProvider::DoControl(TUint /*aOptionLevel*/, TUint /*aOptionName*/, TDes8& /*aOption*/)
#endif //#ifdef SYMBIAN_NETWORKING_UMTSR5
	{
#ifdef SYMBIAN_NETWORKING_UMTSR5
//This control is used to send application secure ID of Active Connection. This Id 
//will be used to for adding socket as data client to the subconnection.
	iAppId=aOptionLevel;
	return KErrNone;
#else
	return KErrNotSupported;
#endif //#ifdef SYMBIAN_NETWORKING_UMTSR5
	}
	
void CDefaultSubConnectionProvider::DoStartL()
	{
   __IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider::DoStartL [this=%08x]"), this));
	}
	
void CDefaultSubConnectionProvider::DoStop()
	{
   __IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider::DoStop [this=%08x]"), this));
#ifdef SYMBIAN_NETWORKING_3GPPDEFAULTQOS
   if (iNextLayer)
      {
      __IPCPRLOG(IpCprLog::Printf(_L("Leaving Lower subconnection provider")));
      iNextLayer->Leave(*this);
      iNextLayer = NULL;
      }
#endif
	}
	
CSubConnectionProviderBase* CDefaultSubConnectionProvider::DoNextLayer()
	{
#ifdef SYMBIAN_NETWORKING_3GPPDEFAULTQOS
   __IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider [this=%08x]:\tDoNextLayer()"), this));
   if (NULL == iNextLayer)
      {
      CConnectionProviderBase* lowerConnectionProvider = iConnectionProvider->NextLayer();
      if (!lowerConnectionProvider)
         {
         //This could denote the connection isn't started and perhaps should be from here,
         // but since the selection isn't separated from startup, we don't have enough
         // information to do it here.
         __IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider [this=%08x]:\tDoNextLayer() Connection Provider is missing its NextLayer"), this));
         return NULL;   // No Lower layer,so leaving rhostresolver without connection.
         }
		                                 
		TUint nextLayerFactoryId = lowerConnectionProvider->CanDoSubConnection(RSubConnection::EAttachToDefault);
      TRAP_IGNORE(
      
   		if (nextLayerFactoryId != 0)
   		   {
            //'This' not started yet. The lower layer unknown
            //This is as much as we can delay with resolving the subconnection stack
            TSockManData* sockManData = SockManGlobals::Get();
            CSubConnectionFactoryContainer* subConnectionFactories = sockManData->iSubConnectionFactories;
      
            XSubConnectionFactoryQuery query(lowerConnectionProvider, RSubConnection::EAttachToDefault);
               iNextLayer = subConnectionFactories->FindOrCreateProviderL(nextLayerFactoryId, query);
   		   }
   		
         if (iNextLayer)
            {
            __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP found.. Joining")));
            iNextLayer->JoinL(*this);
            }
         else
            {
            __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP not found.. Continuing")));
            }
         );
         
      }
      
   return iNextLayer;

#else
   __IPCPRLOG(IpCprLog::Printf(_L("Lower subconnection provider for IP not supported")));
	return NULL;
#endif
//SYMBIAN_NETWORKING_3GPPDEFAULTQOS
	}
	
CConnDataTransfer& CDefaultSubConnectionProvider::DoDataTransferL()
	{
	User::Leave(KErrNotSupported);
	//unreachable code
	return iNextLayer->DataTransferL();
 	}
	
//MConnectionDataClient
TAny* CDefaultSubConnectionProvider::FetchInterfaceInstanceL(CConnectionProviderBase& /*aProvider*/, const STypeId& aTid)
	{
	return (aTid == STypeId::CreateSTypeId(KConnectionClientExtUid,EConnectionEnumerateClients)) ? static_cast<MConnectionEnumerateClients*>(this) : NULL;
	}
	
void CDefaultSubConnectionProvider::ConnectionGoingDown(CConnectionProviderBase& /*aConnProvider*/)
	{
	__IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider [this=%08x]:\tConnectionGoingDown()"), this));
	iConnectionProvider = NULL;
	DeleteMeNow();
	}
	
void CDefaultSubConnectionProvider::Notify(MConnectionDataClient::TNotify aNotifyType, CConnectionProviderBase* /*aConnProvider*/, TInt aError, const CConNotificationEvent* /*aConNotificationEvent*/)
	{
	int count = iControlClients.Count();	
	for (int i = count - 1; i >= 0; --i)
		{		
		iControlClients[i]->SubConnectionEvent(*this, aNotifyType, aError, NULL);
		}
	if (aNotifyType == ENotifyLayerUp)
		{//complete outstanding data client joins
		TInt max = iDataClients.Count();
		for ( TInt n = max - 1; n >= 0; n-- )
			{
			if (aError == KErrNone)
				{
				iDataClients[n]->JoinComplete(*this);
				}
			else
				{
				iDataClients[n]->JoinFailed(*this,aError);
				}
			}
		}
	}
	
void CDefaultSubConnectionProvider::AttachToNext(CSubConnectionProviderBase* /*aSubConnProvider*/)
	{
	}

CDefaultSubConnectionProvider::~CDefaultSubConnectionProvider ()
   {
	__IPCPRLOG(IpCprLog::Printf(_L("~CDefaultSubConnectionProvider [this=%08x]"), this));
#ifdef SYMBIAN_NETWORKING_3GPPDEFAULTQOS
   if (iNextLayer) 
      {
      iNextLayer->Leave (*this);
      }
#endif	
   }
	
	
#ifdef SYMBIAN_NETWORKING_3GPPDEFAULTQOS
void CDefaultSubConnectionProvider::DoControlClientLeaving(MSubConnectionControlClient& aControlClient)
   {
   (void)aControlClient;
	__IPCPRLOG(IpCprLog::Printf(_L("CDefaultSubConnectionProvider [this=%08x]:\tDoControlClientLeaving() [iControlClients.Count=%d] [aControlClient=%08x]"), this, iControlClients.Count(), &aControlClient));

    // Note: control client count == 1 because the the client has not been removed yet
    if (iNextLayer && iControlClients.Count() == 1 && iDataClients.Count() == 0) 
      {
      iNextLayer->Leave (*this);
      iNextLayer = NULL;
      }
   }

void CDefaultSubConnectionProvider::SubConnectionEvent(CSubConnectionProviderBase& /*aSubConnProvider*/, MConnectionDataClient::TNotify /*aNotifyType*/, TInt /*aError*/, const CSubConNotificationEvent* aEvent)
    {
    NotifyClientEvent(*aEvent);
    }	
    
    
void CDefaultSubConnectionProvider::SubConnectionGoingDown(CSubConnectionProviderBase& /*aSubConnProvider*/)
    {
	TInt max = iControlClients.Count();
	for ( TInt n = max - 1; n >= 0; n-- )
		{
		iControlClients[n]->SubConnectionGoingDown(*this);
		}
    }
    
    
void CDefaultSubConnectionProvider::LayerUp(CSubConnectionProviderBase& /*aSubConnProvider*/, TInt /*aError*/)
   {
   }
   
void CDefaultSubConnectionProvider::IncomingConnection(CSubConnectionProviderBase* /*aSubConnProvider*/, CSubConParameterBundle* /*aParameterBundle*/, TInt /*aError*/)
   {
   }
    
#endif
// SYMBIAN_NETWORKING_3GPPDEFAULTQOS