/*

* Copyright (c) 2001-2010 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:  EAP and WLAN authentication protocols.

*

*/

/*

*/

#include "EapServerProcessHandler.h"

#include "EapTraceSymbian.h"

#if defined(USE_FAST_EAP_TYPE)

#include "PacStoreIf.h"

#endif //#if defined(USE_FAST_EAP_TYPE)

#include "EapServerStrings.h"

#include "eap_automatic_variable.h"

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

CEapServerProcessHandler::CEapServerProcessHandler()

: CActive (0)

, iClient(0)

, iTools(0)

, iEapCore(0)

, iEapPlugin(0)

, iEapSettings(0)

#if defined (USE_WAPI_CORE)

, iWapiCore(0)

, iWapiSettings(0)

#endif

#if defined(USE_FAST_EAP_TYPE)

, iPacStore(0)

#endif //#if defined(USE_FAST_EAP_TYPE)

, iEapMessageQueue(0)

{

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::CEapServerProcessHandler(): this=0x%08x\n"),

		this));

	EAP_TRACE_RETURN_STRING(iTools, "returns: CEapServerProcessHandler::CEapServerProcessHandler()");

}

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

CEapServerProcessHandler::~CEapServerProcessHandler()

{

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::~CEapServerProcessHandler(): this=0x%08x\n"),

		this));

	EAP_TRACE_RETURN_STRING(iTools, "returns: CEapServerProcessHandler::~CEapServerProcessHandler()");

	if(IsActive())

	{

		Cancel();

	}

	delete iEapCore;

	iEapCore = 0;

	delete iEapPlugin;

	iEapPlugin = 0;

	delete iEapSettings;

	iEapSettings = 0;

#if defined (USE_WAPI_CORE)

    delete iWapiCore;

    iWapiCore = 0;

    delete iWapiSettings;

    iWapiSettings = 0;

#endif

#if defined(USE_FAST_EAP_TYPE)

    delete iPacStore;

    iPacStore = 0;

#endif //#if defined(USE_FAST_EAP_TYPE)

    delete iEapMessageQueue;

	iEapMessageQueue = 0;

}

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

CEapServerProcessHandler* CEapServerProcessHandler::NewL()

{

	return new (ELeave) CEapServerProcessHandler();

}

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

void CEapServerProcessHandler::ConstructL(AbsEapProcessSendInterface* const client, abs_eap_am_tools_c * const tools)

{

	EAP_TRACE_DEBUG(

		tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::ConstructL(): this=0x%08x\n"),

		this));

	EAP_TRACE_RETURN_STRING(tools, "returns: CEapServerProcessHandler::ConstructL()");

	iClient = client;

	iTools = tools;

	iEapMessageQueue = new(ELeave) EapMessageQueue(iTools);

}

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

eap_status_e CEapServerProcessHandler::SendData(const void * const data, const u32_t length, TEapRequests message)

{

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::SendData(): this=0x%08x\n"),

		this));

	EAP_TRACE_RETURN_STRING(iTools, "returns: CEapServerProcessHandler::SendData()");

	eap_status_e status(eap_status_ok);

	SaveMessage(message, data, length);

	return status;

}

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

void CEapServerProcessHandler::SaveMessage(TEapRequests message, const void * const data, const TUint length)

{

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::SaveMessage(): this=0x%08x, message=%d=%s\n"),

		this,

		message,

		EapServerStrings::GetEapRequestsString(message)));

	EAP_TRACE_RETURN_STRING(iTools, "returns: CEapServerProcessHandler::SaveMessage()");

	EAP_TRACE_DATA_DEBUG(

		iTools,

		(EAPL("CEapServerProcessHandler::SaveMessage()"),

		data,

		length));

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::SaveMessage(): calls iEapMessageQueue->AddMessage()\n")));

	TInt error = iEapMessageQueue->AddMessage(message, data, length);

	if (error != KErrNone)

	{

		EAP_TRACE_DEBUG(

			iTools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("ERROR: CEapServerProcessHandler::SaveMessage(): failed = %d\n"),

			error));

		return;

	}

	Activate();

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::SaveMessage(): returns this=0x%08x, message=%d=%s\n"),

		this,

		message,

		EapServerStrings::GetEapRequestsString(message)));

}

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

void CEapServerProcessHandler::Activate()

{

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::Activate(): this=0x%08x\n"),

		this));

	EAP_TRACE_RETURN_STRING(iTools, "returns: CEapServerProcessHandler::Activate()");

	if(!IsActive())

	{

		EAP_TRACE_DEBUG(

			iTools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("CEapServerProcessHandler::Activate(): calls User::RequestComplete()\n")));

		TRequestStatus* status = &iStatus;

		User::RequestComplete(status, KErrNone);

		EAP_TRACE_DEBUG(

			iTools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("CEapServerProcessHandler::Activate(): calls SetActive()\n")));

		SetActive();

	}

	else

	{

		EAP_TRACE_DEBUG(

			iTools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("CEapServerProcessHandler::Activate(): Already active.\n")));

	}

}

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

void CEapServerProcessHandler::RunL()

{

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("=start=====================================================================\n")));

	EAP_TRACE_RETURN_STRING(iTools, "returns: CEapServerProcessHandler::RunL()");

	EAP_TRACE_DEBUG(

		iTools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("CEapServerProcessHandler::RunL(): this=0x%08x\n"),

		this));

	EapMessageBuffer * const message = iEapMessageQueue->GetFirstMessage();

	if (message != 0)

	{

		EAP_TRACE_DEBUG(

			iTools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("CEapServerProcessHandler::RunL(): message->GetRequestType()=%d=%s, data=0x%08x, size=%d\n"),

			message->GetRequestType(),

			EapServerStrings::GetEapRequestsString(message->GetRequestType()),

			message->GetData()->Ptr(),

			message->GetData()->Size()));

		eap_status_e status(eap_status_ok);

		switch (message->GetRequestType())

		{

		case EEapCoreIfNew:

			{

				EAP_TRACE_DEBUG(

					iTools,

					TRACE_FLAGS_DEFAULT,

					(EAPL("CEapServerProcessHandler::RunL() EEapCoreIfNew\n")));

				CEapCoreIf * tmpEapCore = CEapCoreIf::new_CEapCoreIf(

					iTools,

					ETrue,

					0,

					this);

				if (tmpEapCore != 0)

				{

					CleanupStack::PushL(tmpEapCore);

					if (tmpEapCore->get_is_valid() == false)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): CEapCoreIf::new_CEapCoreIf() failed, this=0x%08x\n"),

							this));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, eap_status_allocation_error)));

					}

					const void * const aData = reinterpret_cast<const void *>(message->GetData()->Ptr());

					const TInt aLength = message->GetData()->Size();

					const eap_variable_data_c client_configuration(

						iTools,

						aData,

						aLength,

						false,

						false);

					if (client_configuration.get_is_valid() == false)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): eap_variable_data_c client_configuration() failed, this=0x%08x\n"),

							this));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, eap_status_allocation_error)));

					}

					status = tmpEapCore->configure(&client_configuration);

					if (status != eap_status_ok)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): tmpEapCore->configure() failed, this=0x%08x, status=%d=%s\n"),

							this,

							status,

							eap_status_string_c::get_status_string(status)));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, status)));

					}

					iEapCore = tmpEapCore;

					CleanupStack::Pop(tmpEapCore);

				}

				else

				{

					EAP_TRACE_DEBUG(

						iTools,

						TRACE_FLAGS_DEFAULT,

						(EAPL("ERROR: CEapServerProcessHandler::RunL(): EEapCoreIfNew, iEapCore is NULL\n")));

				}

			}

			break;

		case EEapPluginNew:

			{

				EAP_TRACE_DEBUG(

					iTools,

					TRACE_FLAGS_DEFAULT,

					(EAPL("CEapServerProcessHandler::RunL() EEapPluginNew\n")));

				CEapPluginIf * tmpEapPlugin = CEapPluginIf::new_CEapPluginIf(iTools);

				if (tmpEapPlugin != 0)

				{

					CleanupStack::PushL(tmpEapPlugin);

					if (tmpEapPlugin->get_is_valid() == false)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): CEapPluginIf::new_CEapPluginIf() failed, this=0x%08x\n"),

							this));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, eap_status_allocation_error)));

					}

					tmpEapPlugin->set_partner(this);

					const void * const aData = reinterpret_cast<const void *>(message->GetData()->Ptr());

					const TInt aLength = message->GetData()->Size();

					const eap_variable_data_c client_configuration(

						iTools,

						aData,

						aLength,

						false,

						false);

					if (client_configuration.get_is_valid() == false)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): eap_variable_data_c client_configuration() failed, this=0x%08x\n"),

							this));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, eap_status_allocation_error)));

					}

					status = tmpEapPlugin->configure(&client_configuration);

					if (status != eap_status_ok)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): tmpEapPlugin->configure() failed, this=0x%08x, status=%d=%s\n"),

							this,

							status,

							eap_status_string_c::get_status_string(status)));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, status)));

					}

					iEapPlugin = tmpEapPlugin;

					CleanupStack::Pop(tmpEapPlugin);

				}

				else

				{

					EAP_TRACE_DEBUG(

						iTools,

						TRACE_FLAGS_DEFAULT,

						(EAPL("ERROR: CEapServerProcessHandler::RunL(): EEapPluginNew, iEapPlugin is NULL\n")));

				}

			}

			break;

		case EEapSettingsNew:

			{

				EAP_TRACE_DEBUG(

					iTools,

					TRACE_FLAGS_DEFAULT,

					(EAPL("CEapServerProcessHandler::RunL() EEapSettingsNew\n")));

				CEapSettingsIf * tmpEapSettings = CEapSettingsIf::new_CEapSettingsIf(iTools);

				if (tmpEapSettings != 0)

				{

					CleanupStack::PushL(tmpEapSettings);

					if (tmpEapSettings->get_is_valid() == false)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): CEapSettingsIf::new_CEapSettingsIf() failed, this=0x%08x\n"),

							this));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, eap_status_allocation_error)));

					}

					tmpEapSettings->set_partner(this);

					const void * const aData = reinterpret_cast<const void *>(message->GetData()->Ptr());

					const TInt aLength = message->GetData()->Size();

					const eap_variable_data_c client_configuration(

						iTools,

						aData,

						aLength,

						false,

						false);

					if (client_configuration.get_is_valid() == false)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): eap_variable_data_c client_configuration() failed, this=0x%08x\n"),

							this));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, eap_status_allocation_error)));

					}

					status = tmpEapSettings->configure(&client_configuration);

					if (status != eap_status_ok)

					{

						EAP_TRACE_DEBUG(

							iTools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: CEapServerProcessHandler::RunL(): tmpEapSettings->configure() failed, this=0x%08x, status=%d=%s\n"),

							this,

							status,

							eap_status_string_c::get_status_string(status)));

						User::Leave(iTools->convert_eapol_error_to_am_error(EAP_STATUS_RETURN(iTools, status)));

					}

					iEapSettings = tmpEapSettings;

					CleanupStack::Pop(tmpEapSettings);

				}

				else

				{

					EAP_TRACE_DEBUG(

						iTools,

						TRACE_FLAGS_DEFAULT,

						(EAPL("ERROR: CEapServerProcessHandler::RunL(): EEapSettingsNew, iEapSettings is NULL\n")));

				}

			}

			break;

#if defined (USE_WAPI_CORE)

	     case EWapiCoreIfNew:

	            EAP_TRACE_DEBUG(

	                iTools,

	                TRACE_FLAGS_DEFAULT,

	                (EAPL("CEapServerProcessHandler::RunL() EWapiCoreIfNew\n")));

                iWapiCore = CWapiCoreIf::NewL(iTools, this);

				EAP_TRACE_DEBUG(

					iTools,

					TRACE_FLAGS_DEFAULT,

					(EAPL("CEapServerProcessHandler::RunL() EWapiCoreIfNew - iWapiCore = 0x%08x.\n"),

					iWapiCore));

	            break;

	        case EWapiSettingsNew:

	            EAP_TRACE_DEBUG(

	                iTools,

	                TRACE_FLAGS_DEFAULT,

	                (EAPL("CEapServerProcessHandler::RunL() EWapiSettingsNew\n")));

	            iWapiSettings = CWapiSettingsIf::NewL(iTools, this);

				EAP_TRACE_DEBUG(

					iTools,

					TRACE_FLAGS_DEFAULT,

					(EAPL("CEapServerProcessHandler::RunL() EWapiSettingsNew - iWapiSettings = 0x%08x.\n"),

					iWapiSettings));

	            break;

#endif

        case EEapPacStoreNew: