/*

* Copyright (c) 2002-2005 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 

*

*/

#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_comasuplprotocolmanager1.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"

#include "epos_suplgeocellinfo.h"

#include "epos_comasupllocationid.h"

_LIT(KTraceFileName,"SUPL_OMA_PH::EPos_COMASUPLProtocolManager1.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 COMASUPLProtocolManager1* COMASUPLProtocolManager1::NewL()

	{

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

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	} 

// Destructor.

EXPORT_C COMASUPLProtocolManager1::~COMASUPLProtocolManager1()

	{

	if(iSuplSettings)

		{

		iSuplSettings->SetUIActive( EFalse );

		}

	DeleteAllSessions();

	iSuplSessions.Reset();

	iSuplSessions.Close();

	//Only attempt to unload the phone if the TSY has actually been initialised

	if(iTsyName.Length() > 0)

		{

		iTelServer.UnloadPhoneModule(iTsyName);

		}

	iQueuedPacket.Close();

	delete iTimer;

	if(iSuplStorageSettings)

		iSuplStorageSettings->RemoveObserver();

	delete iSuplStorageSettings;

	delete iSuplEcomEventWatcher;

    delete iNotifier;

	iMobilePhone.Close(); 

	iTelServer.Close();

	iIMSI.Close();

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

									KTraceFileName, __LINE__);		

	iUIRequestArray.Close();	

	delete iOMASuplAsnHandlerBaseImpl;

	delete iTrace;	

	}

// Constructor

COMASUPLProtocolManager1::COMASUPLProtocolManager1() : iRunningSessionCount(0),

													 iSessnUIObserver(NULL),

                                                     iDeInitDone(EFalse),

                                                     iNotifyStarted(EFalse),

                                                     iTimeOutDialogPresent(EFalse)

	{

	// no implementation required

	}

// Second phase construction.

void COMASUPLProtocolManager1::ConstructL()

	{

	iTrace = COMASuplTrace::NewL();		    

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

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

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

    buf.AppendNum(err);

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

    User::LeaveIfError(err);

	iSuplStorageSettings = CSuplSettingsInternal::NewL();

	iSuplStorageSettings->SetObserverL(*this);

   	iIMSI.CreateL( KMaxIMSILen );

	iIsPreviouslyDecodingFailed = EFalse;

	iTimer = COMASuplTimeoutTimer::NewL(*this);	

	}

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

// COMASUPLProtocolManager1::CreateNewSessionL, 

// Creates new session 

// it transfers ownership to callee

// 

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

//    

EXPORT_C CSuplSessionBase* COMASUPLProtocolManager1::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;

			break;

		default:

			requestType = COMASuplSession::ESUPL_TERMINAL;	

			break;

		}	

	return CreateNewSessionL(requestType, aIpcSessionId,aSuplService);

	}

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

// COMASUPLProtocolManager1::CreateNewSessionL

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

// 

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

//    

CSuplSessionBase* COMASUPLProtocolManager1::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(1);                                                            

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

  	return SuplSession;

	}

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

// COMASUPLProtocolManager1::InitializeL 

// Does the connect to ETel. 

// Intilize POS if present 

// 

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

//    

EXPORT_C  void COMASUPLProtocolManager1::InitializeL(

			CSuplCommunicationManager* aCommManager,

			TRequestStatus& /*aInitilizationRequestStatus*/	)

	{

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

	iCommManager = aCommManager;			

	//Connect to ETel

	User::LeaveIfError(ConnectToETelL());

	if(iSuplEcomEventWatcher)

		{

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

		iSuplEcomEventWatcher->NotifyOnPlugInUnInstallation();	

		}

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

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

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

	}

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

// COMASUPLProtocolManager1::InitializeL 

// Cancel Initilization of Protocol manager

// 

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

//

EXPORT_C  void COMASUPLProtocolManager1::CancelInitialize() 

	{		

	}

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

// COMASUPLProtocolManager1::RunSessionL

// Starts the SUPL Sesssion for Terminal Initiated Location Request

// 

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

//

EXPORT_C void COMASUPLProtocolManager1::RunSessionL(CSuplSessionBase *const  aSuplSession,

												   TRequestStatus& aStatus,

												   const TDesC& aHslpAddress, 

												   TBool aFallBack,

												   TBool aFirstReq,

												   TInt aAllowedCapabilities,

												   TInt aRequestID)

	{

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

    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__);

	iTrace->Trace(_L("COMASUPLProtocolManager1::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);

	}

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

// COMASUPLProtocolManager1::RunSessionL

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

// 

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

//

EXPORT_C void COMASUPLProtocolManager1::RunSessionL(

                            CSuplSessionBase *const aSuplSession,

                            TRequestStatus& aStatus,

                            const TDesC& aHslpAddress, 

                            TBool aFallBack,

                            TBool aFirstReq,

  							TInt aAllowedCapabilities,

  							TSuplTerminalQop& aQop, 

  							TInt aRequestID)

	{

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

    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__);

	iTrace->Trace(_L("COMASUPLProtocolManager1::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);

	}

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

// COMASUPLProtocolManager1::CheckForSessionCount

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

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

//

void COMASUPLProtocolManager1::CheckForSessionCount()

	{

	if (iRunningSessionCount == KMaxSessionCount)

		iRunningSessionCount = 0;

	}

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

// COMASUPLProtocolManager1::ConnectToETelL

// Connects to Telephony server & RMobilePhone

// Returns System wide error,if any occurs

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

//

TInt COMASUPLProtocolManager1::ConnectToETelL()

	{

	iTrace->Trace(_L("Start of COMASUPLProtocolManager1::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)

		{

		CleanupStack::PopAndDestroy(2,db);		

		return err;

		}

	// For the phone information

	RTelServer::TPhoneInfo info;

	iTelServer.GetPhoneInfo(0, info); 

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

	err = iMobilePhone.Open(iTelServer, info.iName);

	CleanupStack::PopAndDestroy(2,db);					

	if(err != KErrNone)

		{

		return err;	

		}

	iTrace->Trace(_L("End of COMASUPLProtocolManager1::ConnectToETelL"), KTraceFileName, __LINE__);		

	return err;

	}

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

// COMASUPLProtocolManager1::DestroySession

// Deletes specified session & removes from array.

// Returns System wide error,if any occurs

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

//

EXPORT_C TInt COMASUPLProtocolManager1::DestroySession(CSuplSessionBase* aSuplSession)	

	{

	// Log

	iTrace->Trace(_L("COMASUPLProtocolManager1::DestroySession"), KTraceFileName, __LINE__);

	// Check if the Session is valid

	TInt index = iSuplSessions.Find(aSuplSession);

	if(KErrNotFound == index)

		{

		iTrace->Trace(_L("Cannot found Supl session."), KTraceFileName, __LINE__);

		return KErrArgument;

		}

	// Remove from Array

	iTrace->Trace(_L("COMASUPLProtocolManager1::DestroySession Remove Session"), KTraceFileName, __LINE__);

	iSuplSessions.Remove(index);

	//Last Session invoking Destroy