/*
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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:  
*
*/

/*
 * Stray signal test function
 */
#include <e32svr.h>
#include <StifParser.h>
#include <StifTestInterface.h>
#include <lbsrequestor.h>
#include <liwservicehandler.h>
#include <liwcommon.h>

#include "tcomplugin.h"
 
 #define TRACE 0 
 #define GETLOCATION 1
 
class ASyncCB : public MLiwNotifyCallback
{
	TInt iCount ; 
	TInt iCmd ;
	MLiwInterface *iLocationInterface ;
	CLiwGenericParamList *iInputList ;
	
	public :
	TInt iRetStatus ;

	TInt HandleNotifyL(
	    TInt aCmdId,
	    TInt aEventId,
	    CLiwGenericParamList& aEventParamList,
	    const CLiwGenericParamList& aInParamList) ;

	ASyncCB() : iRetStatus(KErrGeneral) , iCount(0) ,iCmd(0)//Default constructor 
		{
			;
		}
	ASyncCB(TInt aCmd , MLiwInterface *aInterface , CLiwGenericParamList *aInputList)	 ;
};


ASyncCB :: ASyncCB(TInt aCmd ,MLiwInterface *aInterface , CLiwGenericParamList *aInputList):iCount(0) 
{ 
  iCmd = aCmd ;
  iLocationInterface = aInterface ;
  iInputList = aInputList ;
  	
}


TInt ASyncCB ::  HandleNotifyL(
	    TInt aCmdId,
	    TInt aEventId,
	    CLiwGenericParamList& aEventParamList,
	    const CLiwGenericParamList& aInParamList)
{

//DeRefrence Allocated Map first 
	TInt index = 0 ;
	
	_LIT(KTraceFile , "C:\\Trace.txt") ;
	
	RFile TraceFile ;
	RFs  TraceSession ;
	
	TraceSession.Connect() ;
	
	if(TraceFile.Open(TraceSession ,KTraceFile , EFileWrite | EFileShareAny )  == KErrNotFound)
	{
		if(TraceFile.Create(TraceSession ,KTraceFile , EFileWrite | EFileShareAny ) != KErrNone)
		{
		 	return KErrGeneral ;
		}

	}
	
	TInt pos =  0 ;
	TraceFile.Seek(ESeekEnd , pos) ;

//	const TLiwGenericParam *Notifyparm = aEventParamList.FindFirst(index ,KLocationMap) ;
/*
	if(Notifyparm)
	{
		TLiwVariant mapVar = Notifyparm->Value() ;
		const CLiwMap *map = mapVar.AsMap() ;
		//map->DecRef() ;
	}
	
*/		iCount++ ;
	
	
		
	if(iCount > 2)
		{
		 CActiveScheduler *current = CActiveScheduler :: Current() ;
		 TraceFile.Write(_L8("Active Scheduler stopped\n")) ;
		 current->Stop() ;
		 return KErrNone ;
		}
		
	if(iCmd == TRACE)
		{
		TBuf8<20>CmdBuf(KCmdCancelRequest) ;
		TLiwVariant CancelType(KCmdTraceLocation) ;
		
		TLiwGenericParam CancelParm(KCancelType ,  TLiwVariant (KRequestTrace)) ;
		iInputList->AppendL(CancelParm) ;
		CLiwGenericParamList *outlist1 = CLiwGenericParamList :: NewL() ;	
		 
		TraceFile.Write(_L8("Trace Command Cancelled Submitted \n")) ;
		
	    iLocationInterface->ExecuteCmdL(CmdBuf , *iInputList , *outlist1 ) ;
	    TraceFile.Write(_L8("Trace Command Cancelled Executed \n")) ;
		iInputList->Reset() ;
		TraceFile.Write(_L8("Input list reset  \n")) ;
		delete outlist1 ;
		TraceFile.Write(_L8("outlist deleted \n")) ;
		return 0;
		}
		
	else if(iCmd == GETLOCATION)
		{
		
		TraceFile.Write(_L8("GetLoc Notification \n")) ;
		TraceFile.Flush() ;
		
		TBuf8<20>CmdBuf(KCmdGetLocation) ;
		CLiwGenericParamList *outlist2 = CLiwGenericParamList :: NewL() ;
		
		
		iInputList->Reset() ;
		
		TraceFile.Write(_L8("input for GetLoc   List reset \n")) ;
		TraceFile.Flush() ;
		TraceFile.Write(_L8("GetLocation Cmd submitted \n")) ;
		TraceFile.Flush() ;
		
		iLocationInterface->ExecuteCmdL(CmdBuf , *iInputList , *outlist2 , 0 , this );
		TraceFile.Write(_L8("GetLocation Command Executed \n")) ;
		outlist2->Reset() ;
		TraceFile.Write(_L8("Out List GetLocation reset \n")) ;
		delete outlist2 ;

		 
		}
		

	iRetStatus = KErrNone ;
	return iRetStatus ;	
}
  
  
TInt StrayTestL()
{

    __UHEAP_MARK ;
	_LIT(KTraceFile , "C:\\Trace.txt") ;
	
	RFile TraceFile ;
	RFs  TraceSession ;
	
	TraceSession.Connect() ;
	
	if(TraceFile.Open(TraceSession ,KTraceFile , EFileWrite | EFileShareAny )  == KErrNotFound)
		{
		if(TraceFile.Create(TraceSession ,KTraceFile , EFileWrite | EFileShareAny ) != KErrNone)
			{
	 		return KErrGeneral ;
			}

		}

	CActiveScheduler *Scheduler = new CActiveScheduler ;

	CActiveScheduler :: Install(Scheduler) ;

	 
    
	
    CLiwServiceHandler* ServiceHandler = CLiwServiceHandler::NewL();
  
    // Input and output parameter list
    CLiwGenericParamList* inputlist = &(ServiceHandler->InParamListL());
    CLiwGenericParamList* outputlist = &(ServiceHandler->OutParamListL());
    
    


	CLiwCriteriaItem* crit = CLiwCriteriaItem::NewL(1, KContents, KService);
	

	crit->SetServiceClass(TUid::Uid(KLiwClassBase));

	RCriteriaArray a;
	a.AppendL(crit);
	
	ServiceHandler->AttachL(a) ;
	ServiceHandler->ExecuteServiceCmdL(*crit, *inputlist, *outputlist);

	 
 	 

	TInt pos = 0;
	
	const TLiwGenericParam *errorprm = outputlist->FindFirst(pos , KErrorCode) ;
	
	if(!errorprm)
	{
		return KErrGeneral ;
	}
	
    pos = 0 ;
 	const TLiwGenericParam *genericparm = outputlist->FindFirst(pos, KLsInterfaceName );
	
	if(!genericparm)
	{
	
		return KErrGeneral ;
	}
	
   MLiwInterface* locinterface = (genericparm->Value()).AsInterface();
	
  

    TBuf8<20>CmdBuf(KCmdTraceLocation) ;
	
	CLiwGenericParamList *InputList = CLiwGenericParamList :: NewL() ;
	CLiwGenericParamList *OutParmList = CLiwGenericParamList :: NewL() ;
	
	
	ASyncCB Updates(TRACE , locinterface , InputList)  ;
	ASyncCB GetLoc(GETLOCATION , locinterface , InputList) ;
	
	locinterface->ExecuteCmdL(CmdBuf , *InputList , *OutParmList ,KLiwOptASyncronous ,  &Updates);
	
	CmdBuf = KCmdGetLocation ;
	locinterface->ExecuteCmdL(CmdBuf , *InputList , *OutParmList ,KLiwOptASyncronous ,  &GetLoc);

	CActiveScheduler :: Start() ;
	
	TInt skpos = 0 ;
	
	TraceFile.Seek(ESeekEnd , skpos) ;
	
	TraceFile.Write(_L8("Trace stray signal executed \n")) ;
	
	
	a.ResetAndDestroy() ;
	locinterface->Close() ;
	
	TraceFile.Write(_L8("Interface closed \n")) ;

	delete ServiceHandler ;
	
	TraceFile.Write(_L8("ServiceHandler deleted\n")) ;
	delete InputList ;
	delete OutParmList ;
	delete Scheduler ;
	
	TraceFile.Write(_L8("Scheduler  deleted\n")) ;
    __UHEAP_MARKEND ;
	return 0 ; // Controll never reaches here
}


TInt StrayTest(TAny */*Arg*/)
{
 // __UHEAP_MARK ;
	CTrapCleanup* cleanup = CTrapCleanup::New();
	TInt val = 0 ;
	//Install a new active scheduler to this thread 
	TRAPD(err , (val =StrayTestL())) ;
	delete cleanup ;
	
	if(err)
	    {
	     return err ;
	    }
	else 
	return val ;   	

}