/*

* 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 "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:   SUPL protocol manager implementation.i.e. OMA SUPL implementation 

*

*/

// Includes

#include <centralrepository.h>

#include <commdb.h>

#include <etelmm.h> 

#include <ecom/ecom.h> 

#include <in_sock.h> 

#include <bautils.h>

#include <flogger.h>

#include <CoreApplicationUIsSDKCRKeys.h>

#include "epos_comasuplasnmessagebase.h"

#include "epos_comasuplsessionid.h"

#include "lbs/epos_comasuplposhandlerbase.h"

#include "epos_suplconstants.h"

#include "epos_csuplsettings.h"

#include "epos_comasupletelnotifier.h"

#include "epos_csuplsettingsinternal.h"

#include "epos_suplterminalconstants.h"

#include "epos_comasuplprotocolmanager2.h"

#include "epos_csuplcommunicationmanager.h"

#include "epos_comasuplcompleteselfrequestor.h"

#include "epos_comasuplecomeventwatcher.h"

#include "epos_comasuplsettings.h"

#include "epos_omasuplconstants.h"

#include "epos_omasuplconfigurationkeys.h"

#include "epos_comasupltrace.h"

#include "epos_comasupltimeouttimer.h"

#include "epos_omasuplconstants.h"

#include "epos_comasuplcommonconfig.h"

// Constants

_LIT(KTraceFileName,"SUPL_OMA_PH::EPos_COMASUPLProtocolManager2.cpp");

const TInt KMaxIMSILen = 20;

const TInt KMaxDelay = 128;

const TInt KDefaultHorizontalAccuracy = 0;

const TInt KQueuedBufferTimeout = 11;

// -----------------------------------------------------------------------------

// ResetAndDestroy()

// Resets & destroys array if leave occurs

// -----------------------------------------------------------------------------

void ResetAndDestroy(TAny* aArray)

	{

	((RImplInfoPtrArray*)aArray)->ResetAndDestroy();

	}

// -----------------------------------------------------------------------------

// FindNearestN

// -----------------------------------------------------------------------------

TInt FindNearestN(TInt n)    

	{

	TInt count = 0;

	TInt originalNumber = n;

	while(n)

		{

		n = n >> 1;

		count++;

		}

	TInt previousNumber = count - 1;	

	TReal min,max;

	Math::Pow(min,2,previousNumber);

	Math::Pow(max,2,count);

	TInt avg = (min + max ) / 2;

	if (avg < originalNumber)

		return  max;

	else

		return min;

	}

// ============================ MEMBER FUNCTIONS ===============================    

// Create instance of concrete ECOM interface implementation

EXPORT_C COMASUPLProtocolManager2* COMASUPLProtocolManager2::NewL()

	{

	COMASUPLProtocolManager2* self = new(ELeave) COMASUPLProtocolManager2();

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	} 

// Destructor.

EXPORT_C COMASUPLProtocolManager2::~COMASUPLProtocolManager2()

	{

	/*if(iSettingsLauncher)		

		{

			iSettingsLauncher->CancelLaunch();

		}*/

	DeleteAllSessions();

	iSuplSessions.Reset();

	iSuplSessions.Close();

	    iTelServer.UnloadPhoneModule(iTsyName);

	iQueuedPacket.Close();

	delete iTimer;

	if(iSuplStorageSettings)

	{

		iSuplStorageSettings->RemoveObserver();

		iSuplStorageSettings->RemoveSessionObserver();

	}

	delete iSuplStorageSettings;

    //delete iSettingsLauncher;

    delete iNotifier;

	iMobilePhone.Close(); 

	iTelServer.Close();

	iIMSI.Close();

	iUIRequestArray.Close();	

	delete iOMASuplAsnHandlerBaseImpl;

	iTrace->Trace(_L("At the End of COMASUPLProtocolManager2::~COMASUPLProtocolManager2"), 

							KTraceFileName, __LINE__);

	delete iTrace;	

	}

// Constructor

COMASUPLProtocolManager2::COMASUPLProtocolManager2() : 

								iRunningSessionCount(0),

                                iSessnUIObserver(NULL),

                                iDeInitDone(EFalse),

                                iNotifyStarted(EFalse),

                                iTimeOutDialogPresent(EFalse)

	{

	// no implementation required

	}

// Second phase construction.

void COMASUPLProtocolManager2::ConstructL()

	{

	iTrace = COMASuplTrace::NewL();		    

	iTrace->Trace(_L("COMASUPLProtocolManager2::ConstructL"), KTraceFileName, __LINE__); 

	iSuplStorageSettings = CSuplSettingsInternal::NewL();

	iSuplStorageSettings->SetObserverL(*this);

	iSuplStorageSettings->SetSessionObserverL(*this);

   	//iSettingsLauncher = COMASuplSettingsLauncher::NewL( *this );

    TRAPD(err,iOMASuplAsnHandlerBaseImpl = COMASuplAsnHandlerBase::NewL(2);) 

    TBuf<64> buf(_L("ASN Plugin 2.0 loaded with error : "));                

    buf.AppendNum(err);

    iTrace->Trace(buf,KTraceFileName, __LINE__);        

    User::LeaveIfError(err);

    iIMSI.CreateL( KMaxIMSILen );

	iIsPreviouslyDecodingFailed = EFalse;

	iTimer = COMASuplTimeoutTimer::NewL(*this);	

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::CreateNewSessionL, 

// Creates new session 

// it transfers ownership to callee

// 

// -----------------------------------------------------------------------------

//    

EXPORT_C CSuplSessionBase* COMASUPLProtocolManager2::CreateNewSessionL(

									CSUPLProtocolManagerBase::TSuplReqType aRequestType, 

									TInt aIpcSessionId, 

									RSuplTerminalSubSession::TSuplServiceType aSuplService)

	{

	// Map the type before creating the session object

	COMASuplSession::TOMASuplReqType requestType = COMASuplSession::ESUPL_TERMINAL;

	switch(aRequestType)

		{

		case CSUPLProtocolManagerBase::ENetwork:

			requestType = COMASuplSession::ESUPL_NETWORK;

			break;

		case CSUPLProtocolManagerBase::ETerminal:

			requestType = COMASuplSession::ESUPL_TERMINAL;

		default:	

			break;

		}	

	return CreateNewSessionL(requestType, aIpcSessionId,aSuplService);

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::CreateNewSessionL

// An overloaded CreateNewSession to take care of Invalid session ID

// 

// -----------------------------------------------------------------------------

//    

CSuplSessionBase* COMASUPLProtocolManager2::CreateNewSessionL(

									COMASuplSession::TOMASuplReqType aRequestType, 

									TInt aIpcSessionId,

									RSuplTerminalSubSession::TSuplServiceType /*aSuplService*/)

	{  

	iTrace->Trace(_L("Creating New OMA SUPL Session"), KTraceFileName, __LINE__); 

	CSuplSessionBase* SuplSession = COMASuplSession::NewL(

									*iCommManager, 

									iMobilePhone, 

									iSuplSettings,

									iSuplStorageSettings, 

									aRequestType, 

									*this, 

									iPosHandler, 

									iIMSI,

                                    *this, 

                                    aIpcSessionId,

                                    iOMASuplAsnHandlerBaseImpl);

  SuplSession->SetSUPLVersion(2);                                    

	User::LeaveIfError(iSuplSessions.Append(SuplSession));

  	return SuplSession;

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::InitializeL 

// Does the connect to ETel. 

// Intilize POS if present 

// 

// -----------------------------------------------------------------------------

//    

EXPORT_C  void COMASUPLProtocolManager2::InitializeL(

			CSuplCommunicationManager* aCommManager,

			TRequestStatus& /*aInitilizationRequestStatus*/)

	{

	iTrace->Trace(_L("COMASUPLProtocolManager2::InitializeL"), KTraceFileName, __LINE__);

	iCommManager = aCommManager;			

	//Connect to ETel

	User::LeaveIfError(ConnectToETelL());

    //ReadSuplUsage();    

	if(iSuplEcomEventWatcher)

		{

	    iTrace->Trace(_L("NotifyOnPlugInUnInstallation starting"), KTraceFileName, __LINE__);	

		iSuplEcomEventWatcher->NotifyOnPlugInUnInstallation();	

		}

		if(!iNotifier)

			{

    		iNotifier = COMASuplETelNotifier::NewL(*this,iMobilePhone);

    	}

	iTrace->Trace(_L("ETEL Notifier created"), KTraceFileName, __LINE__);	

	iTrace->Trace(_L("COMASUPLProtocolManager2::InitializeL completed"), KTraceFileName, __LINE__);

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::InitializeL 

// Cancel Initilization of Protocol manager

// 

// -----------------------------------------------------------------------------

//

EXPORT_C  void COMASUPLProtocolManager2::CancelInitialize() 

	{		

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::RunSessionL

// Starts the SUPL Sesssion for Terminal Initiated Location Request

// 

// -----------------------------------------------------------------------------

//

EXPORT_C void COMASUPLProtocolManager2::RunSessionL(

							CSuplSessionBase *const  aSuplSession,

							TRequestStatus& aStatus,

							const TDesC& aHslpAddress, 

							TBool aFallBack,

							TBool aFirstReq,

							TInt aAllowedCapabilities,

							TInt aRequestID)

	{

	iTrace->Trace(_L("COMASUPLProtocolManager2::RunSessionL"), KTraceFileName, __LINE__);

#ifdef PRINT_MESSAGE

    TBuf<255> tempBuf;

    tempBuf.Append(_L("Server name in Protocol Handler is : "));

    tempBuf.Append(aHslpAddress);

    iTrace->Trace(tempBuf, KTraceFileName, __LINE__);

    if (aFallBack)

	    {

    	tempBuf.Copy(_L("Fallback is set as TRUE."));    

    	}

    else

    	{

    	tempBuf.Copy(_L("Fallback is set as False"));

    	}

    iTrace->Trace(tempBuf, KTraceFileName, __LINE__);

#endif	

	iTrace->Trace(_L("COMASUPLProtocolManager2::RunSessionL"), KTraceFileName, __LINE__); 

	if ( iSuplSessions.Find(aSuplSession) == KErrNotFound )

		{

		TRequestStatus *status = &aStatus; 

		User::RequestComplete(status,KErrNotFound ); 

		return;

		}

	CheckForSessionCount();

	iRunningSessionCount++;

	COMASuplSession* OMASession =  static_cast<COMASuplSession*>(aSuplSession);

	OMASession->SetConfigurationParameters(

							iUT1_StartTimer,

							iUT2_PosInitTimer, 

							iUT3_PosTimer,

							iPrivacyTimer,

							iSETMode,

                    		iSuplUsage, 

                    		iPersistFailTimer,

                    		iSuplInitTimeOut);

	OMASession->RunSuplSessionL(

							aStatus,

							aFirstReq, 

							aHslpAddress, 

							aFallBack, 

							aAllowedCapabilities,

							iRunningSessionCount,

							aRequestID);

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::RunSessionL

// Starts the SUPL Sesssion for Terminal Initiated Location Request,with QoP support

// 

// -----------------------------------------------------------------------------

//

EXPORT_C void COMASUPLProtocolManager2::RunSessionL(

                            CSuplSessionBase *const aSuplSession,

                            TRequestStatus& aStatus,

                            const TDesC& aHslpAddress, 

                            TBool aFallBack,

                            TBool aFirstReq,

  							TInt aAllowedCapabilities,

  							TSuplTerminalQop& aQop, 

  							TInt aRequestID)

	{

	iTrace->Trace(_L("COMASUPLProtocolManager2::RunSessionL"), KTraceFileName, __LINE__);

#ifdef PRINT_MESSAGE

    TBuf<255> tempBuf;

    tempBuf.Append(_L("Server name in Protocol Handler is : "));

    tempBuf.Append(aHslpAddress);

    iTrace->Trace(tempBuf, KTraceFileName, __LINE__);

    if (aFallBack)

    	{

    	tempBuf.Copy(_L("Fallback is set as TRUE."));

    	}

    else

    	{

    	tempBuf.Copy(_L("Fallback is set as False"));

    	}

    iTrace->Trace(tempBuf, KTraceFileName, __LINE__);

#endif

	iTrace->Trace(_L("COMASUPLProtocolManager2::RunSessionL"), KTraceFileName, __LINE__); 

	if ( iSuplSessions.Find(aSuplSession) == KErrNotFound )

		{

		TRequestStatus *status = &aStatus; 

		User::RequestComplete(status,KErrNotFound ); 

		return;

		}

	TReal32 horizonatalAccuracy;

	if(aQop.GetHorizontalAccuracy(horizonatalAccuracy) == KErrNotFound)

		{

		aQop.SetHorizontalAccuracy(KDefaultHorizontalAccuracy);

		}

	TReal32 verticalAccuracy;

	if(aQop.GetVerticalAccuracy(verticalAccuracy) == KErrNone)

		{

        if (verticalAccuracy > KOMAMaxVerticalAccuracy)            

		    aQop.SetVerticalAccuracy(KOMAMaxVerticalAccuracy);

		}

	TInt delay;

	if(aQop.GetDelay(delay) != KErrNotFound)

		{

		if(delay < 1 )

			{

			TRequestStatus *status = &aStatus; 

			User::RequestComplete(status,KErrArgument); 

			return;

			}

		if( delay >  128 )

			{

			aQop.SetDelay(KMaxDelay);

			}

		else

			{

			switch(delay)	

				{

				case 1:

				case 2:

				case 4:

				case 8:

				case 16:

				case 32:

				case 64:

				case 128:

					  break;	

				default:

					{

					aQop.SetDelay(FindNearestN(delay));

					}

				}

			}

		}

	CheckForSessionCount();

	iRunningSessionCount++;

	COMASuplSession* OMASession =  static_cast<COMASuplSession*>(aSuplSession);

	OMASession->SetConfigurationParameters(

								iUT1_StartTimer,

								iUT2_PosInitTimer, 

								iUT3_PosTimer,

								iPrivacyTimer,

								iSETMode,

                    			iSuplUsage, 

                    			iPersistFailTimer,

                    			iSuplInitTimeOut);

	OMASession->RunSuplSessionL(

								aStatus,

								aFirstReq, 

								aHslpAddress, 

								aFallBack, 

								aAllowedCapabilities,

								iRunningSessionCount,

								aQop,

								aRequestID);

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::CheckForSessionCount

// Check for MAximum session count..if it reaches to MAX,it resets to zero

// -----------------------------------------------------------------------------

//

void COMASUPLProtocolManager2::CheckForSessionCount()

	{

	if (iRunningSessionCount == KMaxSessionCount)

		iRunningSessionCount = 0;

	}

// -----------------------------------------------------------------------------

// COMASUPLProtocolManager2::ConnectToETelL

// Connects to Telephony server & RMobilePhone

// Returns System wide error,if any occurs

// -----------------------------------------------------------------------------

//

TInt COMASUPLProtocolManager2::ConnectToETelL()

	{

	iTrace->Trace(_L("Start of COMASUPLProtocolManager2::ConnectToETelL"), KTraceFileName, __LINE__);

	TInt err = iTelServer.Connect(); 

	if(err != KErrNone)

		{

		TBuf<8> errrorCode;

		errrorCode.AppendNum(err);

		TBuf<64> msg(_L("Failed to Connect ETel with Reason Code "));

		msg.Append(errrorCode);

		iTrace->Trace(msg,KTraceFileName, __LINE__);

		return err;

		}

	iTrace->Trace(_L("Opening CommsDatabase..."), KTraceFileName, __LINE__);		

	CCommsDatabase* const db = CCommsDatabase::NewL(EDatabaseTypeUnspecified); 

	CleanupStack::PushL(db); 

	TUint32 modemId = 0; 

	db->GetGlobalSettingL(TPtrC(MODEM_PHONE_SERVICES_SMS), modemId); 

	iTrace->Trace(_L("Retriving TSY Name..."), KTraceFileName, __LINE__);		

	CCommsDbTableView* const view = db->OpenViewMatchingUintLC(TPtrC(MODEM), TPtrC(COMMDB_ID), 

																modemId); 

	err = view->GotoFirstRecord(); 

	if(err != KErrNone)

		{

		CleanupStack::PopAndDestroy(2,db);			

		return err;	

		}

	view->ReadTextL(TPtrC(MODEM_TSY_NAME), iTsyName); 

	err = iTelServer.LoadPhoneModule(iTsyName);

	if(err != KErrNone)

		{