/*
* Copyright (c) 2008 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 <ss_glob.h>
#include <comms-infras/ss_thread.h>
#include "testmudpserver.h"
#include "pudpclienttests.h"
#include "upnp_cf_msgs.h"


const TUint32 KMulticastAddrIp = INET_ADDR ( 239, 255, 255, 250 );
const TUint KMulticastAddrPort = 1900;

CTestMUdpServer* CTestMUdpServer::NewL ( MTestServerObserver& aObserver )
	{
	CTestMUdpServer* self = new ( ELeave ) CTestMUdpServer ( aObserver );
	CleanupStack::PushL ( self );
	self->ConstructL ();
	CleanupStack::Pop ();
	return self;		
	}

CTestMUdpServer::CTestMUdpServer ( MTestServerObserver& aObserver ) 
	: iObserver ( aObserver ), iSocketHandler ( *this )
	{	
	}
	
void CTestMUdpServer::ConstructL ()
	{
	User::LeaveIfError ( OpenSocket () );	
	TUpnpMessage::RegisterL ( SockManGlobals::Get ()->SelfWorker ());
	}

CTestMUdpServer::~CTestMUdpServer ()
	{
	Shutdown ();
	iSocketHandler.CancelAll ();
	iSocket.Close ();
	delete iSocketOpener;
	TUpnpMessage::DeRegister ();
	}
	
TInt CTestMUdpServer::OpenSocket ()
	{
	TInt err = KErrNone;
	if ( NULL == iSocketOpener )
		{
		TRAP ( err, iSocketOpener = CSocketOpener::NewL ( *this ) );
		}

	if ( err == KErrNone )
		iSocketOpener->MakeSocket ( KAfInet, KSockDatagram, KProtocolInetUdp );

	return err;
	}
	
void CTestMUdpServer::Startup ()
	{//start listening to the mutlicast addresss
	//TInt ret = KErrNone;	
	TInetAddr addr;
  	addr.SetAddress ( KMulticastAddrIp );
  	addr.SetPort ( KMulticastAddrPort );

	if ( addr.Family() != KAfInet6 )
		{
		addr.ConvertToV4Mapped();				
		}
	TPckgBuf<TIp6Mreq> mReqBuf;
	mReqBuf().iAddr = addr.Ip6Address();
	mReqBuf().iInterface = 0;
		
	iSocket.SetOpt( KSoIp6JoinGroup, KSolInetIp, mReqBuf ); // Join the multicast group
	
	iSocketHandler.RecvFrom (); // Start the receive
	}
	
void CTestMUdpServer::Shutdown ()
	{
	TInetAddr addr;
  	addr.SetAddress ( KMulticastAddrIp );
  	addr.SetPort ( KMulticastAddrPort );

	if ( addr.Family() != KAfInet6 )
		{
		addr.ConvertToV4Mapped();				
		}
	TPckgBuf<TIp6Mreq> mReqBuf;
	mReqBuf().iAddr = addr.Ip6Address();
	mReqBuf().iInterface = 0;
		
	iSocket.SetOpt( KSoIp6LeaveGroup, KSolInetIp, mReqBuf ); // leave the multicast group		
	}
	
void CTestMUdpServer::OpenComplete ( RInternalSocket& aSocket )
	{
	iSocket = aSocket;
	iSocketHandler.Attach ( aSocket );
	TInetAddr addr ( KMulticastAddrPort );

	addr.SetAddress ( KInetAddrAny );
	TInt err = aSocket.Bind ( addr );

	if ( err == KErrNone )
		Startup ();
	TRAP_IGNORE(iObserver.OnTestServerEventL ( err ));
	}	
	
void CTestMUdpServer::RecvFromComplete ( RMBufChain& aData, const TSockAddr& aAddr )
	{//data/request completely recd
	iSendToAddr = aAddr;
	TBool recvAgain = EFalse;
	TRAP_IGNORE ( DoSendL ( aData, recvAgain ) );	
	aData.Free ();
	
	if ( recvAgain )
		{
		iSocketHandler.RecvFrom (); // Start the receive from the  multicast address
		}
	}
	
void CTestMUdpServer::DoSendL ( RMBufChain& aData, TBool& aRecvAgain )
	{//send the packet to the multicast address
	RBuf8 dataRcvd;
	dataRcvd.CreateMaxL ( aData.Length () );	//aData is the m-search request received..its a dummy request
	aData.CopyOut ( dataRcvd );
	
	if ( dataRcvd.FindF ( KTestCase1 ) != KErrNotFound )	//receives the requests
		{//if request is "TestCase1" then execute test case1 and send a response with missing content length
		//this response is captured by the client CTestUpnpClient# object & validated
		iSendChain.CreateL ( KInvalidCL );		//send responses
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );			//send to the client
	    }
	else if ( dataRcvd.FindF ( KTestCase2 ) != KErrNotFound )
		{
		iSendChain.CreateL ( KMissingST );					//send invalid response
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
    else if ( dataRcvd.FindF ( KTestCase3 ) != KErrNotFound )
		{
		iSendChain.CreateL ( KMissingRespLocn );					//send invalid response
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
    else if ( dataRcvd.FindF ( KTestCase4 ) != KErrNotFound )
		{
		iSendChain.CreateL ( KMissingContentLength );					//send invalid response
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
    else if ( dataRcvd.FindF ( KTestCase5 ) != KErrNotFound )
		{
		iSendChain.CreateL ( KMissingRespUSN );					//send invalid response
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
     else if ( dataRcvd.FindF ( KTestCase6 ) != KErrNotFound )
		{
		iSendChain.CreateL ( KInvalidCacheControl );					//send invalid response
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }        
      else if ( dataRcvd.FindF ( KTestCase7 ) != KErrNotFound )
		{
		iSendChain.CreateL ( KMissingExtn );					//send invalid response
		iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
      else if ( dataRcvd.FindF ( KTestCase8 ) != KErrNotFound )
      	{
      	iSendChain.CreateL ( KInvalidRes8 );					//send invalid response
      	iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
      else if ( dataRcvd.FindF ( KTestCase9 ) != KErrNotFound )
      	{
      	iSendChain.CreateL ( KInvalidRes9 );					//send invalid response
      	iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
      else if ( dataRcvd.FindF ( KTestCase10 ) != KErrNotFound )
      	{
      	iSendChain.CreateL ( KInvalidRes10 );					//send invalid response
      	iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
      else if ( dataRcvd.FindF ( KTestCase11 ) != KErrNotFound )
      	{
      	iSendChain.CreateL ( KInvalidRes11 );					//send invalid response
      	iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
      else if ( dataRcvd.FindF ( KTestCase12 ) != KErrNotFound )
      	{
      	iSendChain.CreateL ( KInvalidRes12 );					//send invalid response
      	iSocketHandler.SendTo ( iSendChain, iSendToAddr );        
        }
    else
    	{
    	aRecvAgain = ETrue;
    	}
	
	dataRcvd.Close ();	
	}
	
void CTestMUdpServer::SendToComplete ( TInt /*aLength*/ )
	{	
	iSendChain.Init ();
	iSocketHandler.RecvFrom (); // Start the receive
	}