/*

* Copyright (c) 2001-2006 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.

*

*/

/*

*/

// This is enumeration of EAPOL source code.

#if defined(USE_EAP_MINIMUM_RELEASE_TRACES)

	#undef EAP_FILE_NUMBER_ENUM

	#define EAP_FILE_NUMBER_ENUM 48 

	#undef EAP_FILE_NUMBER_DATE 

	#define EAP_FILE_NUMBER_DATE 1127594498 

#endif //#if defined(USE_EAP_MINIMUM_RELEASE_TRACES)

#include "eap_am_memory.h"

#include "eap_tools.h"

#include "eap_core_server_message_if.h"

#include "eap_crypto_api.h"

#include "eap_state_notification.h"

#include "eap_automatic_variable.h"

#include "eap_network_id_selector.h"

#include "eap_config.h"

#include "eap_buffer.h"

#include "eapol_session_key.h"

#include "eap_master_session_key.h"

#include "eap_am_stack.h"

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

// 

EAP_FUNC_EXPORT eap_core_server_message_if_c::~eap_core_server_message_if_c()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_TRACE_DEBUG(

		m_am_tools, 

		EAP_TRACE_FLAGS_MESSAGE_DATA, 

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

		this));

	EAP_ASSERT(m_shutdown_was_called == true);

	delete m_eap_core;

	delete m_am_stack;

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

}

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

#if defined(_WIN32) && !defined(__GNUC__)

	#pragma warning( disable : 4355 ) // 'this' : used in base member initializer list

#endif

// 

EAP_FUNC_EXPORT eap_core_server_message_if_c::eap_core_server_message_if_c(

	abs_eap_am_tools_c * const tools,

	const bool is_client_when_true,

	const u32_t MTU)

	: m_partner(0)

	, m_eap_core(eap_session_core_base_c::new_eap_session_core_c(tools, this, is_client_when_true, MTU))

	, m_am_stack(new_eap_am_stack_c(tools, is_client_when_true))

	, m_am_tools(tools)

	, m_eap_header_offset(0u)

	, m_MTU(MTU)

	, m_trailer_length(0u)

	, m_error_code(eap_status_ok)

	, m_error_function(eap_tlv_message_type_function_none)

	, m_is_client(is_client_when_true)

	, m_is_valid(false)

	, m_shutdown_was_called(false)

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_TRACE_DEBUG(

		m_am_tools, 

		EAP_TRACE_FLAGS_MESSAGE_DATA, 

		(EAPL("eap_core_server_message_if_c::eap_core_server_message_if_c(): %s, this = 0x%08x => 0x%08x, compiled %s %s.\n"),

		(m_is_client == true) ? "client": "server",

		this,

		dynamic_cast<abs_eap_base_timer_c *>(this),

		__DATE__,

		__TIME__));

	if (m_eap_core != 0

		&& m_eap_core->get_is_valid() == true

		&& m_am_stack != 0

		&& m_am_stack->get_is_valid() == true)

	{

		set_is_valid();

	}

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

}

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

//

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::configure(

	const eap_variable_data_c * const client_configuration)

{

	EAP_ASSERT(m_am_tools->get_global_mutex()->get_is_reserved() == true);

	EAP_TRACE_DEBUG(

		m_am_tools,

		EAP_TRACE_FLAGS_MESSAGE_DATA,

		(EAPL("%s: eap_core_server_message_if_c::configure()\n"),

		(m_is_client == true) ? "client": "server"));

	EAP_TRACE_RETURN_STRING_FLAGS(m_am_tools, EAP_TRACE_FLAGS_MESSAGE_DATA, "returns: eap_core_server_message_if_c::configure()");

	eap_status_e status(eap_status_process_general_error);

	m_eap_header_offset = 0ul;

	m_trailer_length = 0ul;

	if (m_am_stack != 0)

	{

		status = m_am_stack->set_partner(

			this

#if defined(USE_EAP_SIMPLE_CONFIG)

			, this

#endif // #if defined(USE_EAP_SIMPLE_CONFIG)

			);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

		status = m_am_stack->configure(client_configuration);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

	}

	if (m_eap_core != 0)

	{

		status = m_eap_core->configure();

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

	}

	return EAP_STATUS_RETURN(m_am_tools, status);

}

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

//

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::shutdown()

{

	EAP_TRACE_DEBUG(

		m_am_tools,

		EAP_TRACE_FLAGS_MESSAGE_DATA,

		(EAPL("%s: eap_core_server_message_if_c::shutdown(), m_shutdown_was_called=%d\n"),

		(m_is_client == true) ? "client": "server",

		m_shutdown_was_called));

	EAP_TRACE_RETURN_STRING_FLAGS(m_am_tools, EAP_TRACE_FLAGS_MESSAGE_DATA, "returns: eap_core_server_message_if_c::shutdown()");

	EAP_ASSERT(m_am_tools->get_global_mutex()->get_is_reserved() == true);

	if (m_shutdown_was_called == true)

	{

		// Shutdown function was called already.

		return EAP_STATUS_RETURN(m_am_tools, eap_status_ok);

	}

	m_shutdown_was_called = true;

	if (m_eap_core != 0)

	{

		(void) m_eap_core->shutdown();

	}

	if (m_am_stack != 0)

	{

		(void) m_am_stack->shutdown();

	}

	return EAP_STATUS_RETURN(m_am_tools, eap_status_ok);

}

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

//

EAP_FUNC_EXPORT void eap_core_server_message_if_c::set_partner(abs_eap_am_message_if_c * const partner)

{

	m_partner = partner;

}

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

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::send_error_message(

	const eap_status_e error_code,

	const eap_tlv_message_type_function_e function)

{

	eap_status_e status(eap_status_ok);

	{

		// Creates message data composed of Attribute-Value Pairs.

		eap_process_tlv_message_data_c message(m_am_tools);

		if (message.get_is_valid() == false)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, eap_status_allocation_error);

		}

		status = message.add_parameter_data(

			eap_tlv_message_type_error,

			static_cast<u32_t>(error_code));

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

		status = message.add_parameter_data(function);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

		status = send_message(&message);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

	}

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return EAP_STATUS_RETURN(m_am_tools, eap_status_ok);

}

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

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::send_message(eap_process_tlv_message_data_c * const message)

{

	// Sends message data composed of Attribute-Value Pairs.

	EAP_TRACE_DATA_DEBUG(

		m_am_tools,

		EAP_TRACE_FLAGS_MESSAGE_DATA,

		(EAPL("eap_core_client_message_if_c::send_message()"),

		message->get_message_data(),

		message->get_message_data_length()));

	EAP_TRACE_RETURN_STRING_FLAGS(m_am_tools, EAP_TRACE_FLAGS_MESSAGE_DATA, "returns: eap_core_client_message_if_c::send_message()");

	{

		eap_status_e send_status = m_partner->send_data(

			message->get_message_data(),

			message->get_message_data_length());

		if (send_status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			return EAP_STATUS_RETURN(m_am_tools, send_status);

		}

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, send_status);

	}

}

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

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::process_message_type_error(

	EAP_TEMPLATE_CONST eap_array_c<eap_tlv_header_c> * const parameters)

{

	eap_status_e status(eap_status_ok);

	eap_process_tlv_message_data_c message_data(m_am_tools);

	if (message_data.get_is_valid() == false)

	{

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, eap_status_allocation_error);

	}

	// Error payload is the first in this case.

	status = message_data.read_parameter_data(parameters, eap_message_payload_index_function, eap_tlv_message_type_error, &m_error_code);

	if (status != eap_status_ok)

	{

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	// Fuction payload is the second in this case.

	status = message_data.read_parameter_data(parameters, eap_message_payload_index_first_parameter, &m_error_function);

	if (status != eap_status_ok)

	{

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return EAP_STATUS_RETURN(m_am_tools, status);

}

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

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::process_message(eap_process_tlv_message_data_c * const message)

{

	// Parses message data composed of Attribute-Value Pairs.

	EAP_TRACE_DATA_DEBUG(

		m_am_tools,

		EAP_TRACE_FLAGS_MESSAGE_DATA,

		(EAPL("eap_core_server_message_if_c::process_message()"),

		message->get_message_data(),

		message->get_message_data_length()));

	EAP_TRACE_RETURN_STRING_FLAGS(m_am_tools, EAP_TRACE_FLAGS_MESSAGE_DATA, "returns: eap_core_server_message_if_c::process_message()");

	eap_array_c<eap_tlv_header_c> parameters(m_am_tools);

	eap_status_e status = message->parse_message_data(&parameters);

	if (status != eap_status_ok)

	{

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		(void) send_error_message(

			status,

			eap_tlv_message_type_function_none);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	if (parameters.get_object_count() == 0)

	{

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		status = eap_status_illegal_parameter;

		(void) send_error_message(

			status,

			eap_tlv_message_type_function_none);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	const eap_tlv_header_c * const function_header = parameters.get_object(eap_message_payload_index_function);

	if (function_header == 0

		|| (function_header->get_type() != eap_tlv_message_type_error

			&& function_header->get_type() != eap_tlv_message_type_function))

	{

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		status = eap_status_illegal_parameter;

		(void) send_error_message(

			status,

			eap_tlv_message_type_function_none);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	if (function_header->get_type() == eap_tlv_message_type_error)

	{

		status = process_message_type_error(&parameters);

	}

	else // function_header->get_type() == eap_tlv_message_type_function

	{

		eap_tlv_message_type_function_e function(eap_tlv_message_type_function_none);

		status = message->get_parameter_data(function_header, &function);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			(void) send_error_message(

				status,

				eap_tlv_message_type_function_none);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

		switch(function)

		{

		case eap_tlv_message_type_function_create_eap_session:

			status = create_eap_session(&parameters);

			break;

		case eap_tlv_message_type_function_remove_eap_session:

			status = remove_eap_session(&parameters);

			break;

		case eap_tlv_message_type_function_send_eap_identity_request:

			status = send_eap_identity_request(&parameters);

			break;

		case eap_tlv_message_type_function_packet_process:

			status = packet_process(&parameters);

			break;

		case eap_tlv_message_type_function_eap_acknowledge:

			status = eap_acknowledge(&parameters);

			break;

		case eap_tlv_message_type_function_set_eap_database_reference_values:

			status = set_eap_database_reference_values(&parameters);

			break;

		case eap_tlv_message_type_function_eap_mtu:

			status = eap_mtu(&parameters);

			break;

		case eap_tlv_message_type_function_get_802_11_authentication_mode:

			status = get_802_11_authentication_mode(&parameters);

			break;

		default:

			EAP_TRACE_ERROR(

				m_am_tools,

				TRACE_FLAGS_DEFAULT,

				(EAPL("ERROR: process_data(): unknown function %d.\n"),

				 function));

			status = eap_status_illegal_parameter;

			EAP_ASSERT_ANYWAY_TOOLS(m_am_tools);

		};

		if (status != eap_status_ok

			&& status != eap_status_success

			&& status != eap_status_pending_request

			&& status != eap_status_completed_request

			&& status != eap_status_drop_packet_quietly)

		{

			(void) send_error_message(

				status,

				function);

		}

	}

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return EAP_STATUS_RETURN(m_am_tools, status);

}

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

/// Function receives the data message from lower layer.

/// Data is formatted to Attribute-Value Pairs.

/// Look at eap_tlv_header_c and eap_tlv_message_data_c.

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::process_data(const void * const data, const u32_t length)

{

	eap_status_e status(eap_status_process_general_error);

	{

		eap_process_tlv_message_data_c message(m_am_tools);

		if (message.get_is_valid() == false)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			status = eap_status_allocation_error;

			(void) send_error_message(

				status,

				eap_tlv_message_type_function_none);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

		status = message.set_message_data(length, data);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			(void) send_error_message(

				status,

				eap_tlv_message_type_function_none);

			return EAP_STATUS_RETURN(m_am_tools, status);

		}

		status = process_message(&message);

	}

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return EAP_STATUS_RETURN(m_am_tools, status);

}

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

//

EAP_FUNC_EXPORT eap_status_e eap_core_server_message_if_c::packet_send(

	const eap_am_network_id_c * const send_network_id,

	eap_buf_chain_wr_c * const sent_packet,

	const u32_t header_offset,

	const u32_t data_length,

	const u32_t buffer_length)

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_ASSERT(m_am_tools->get_global_mutex()->get_is_reserved() == true);

	EAP_ASSERT(header_offset < sent_packet->get_data_length());

	EAP_ASSERT(data_length <= sent_packet->get_data_length());

	EAP_ASSERT(sent_packet->get_data_length() <= buffer_length);

	eap_status_e status(eap_status_process_general_error);

	if (sent_packet->get_do_length_checks() == true)

	{

		if (header_offset != 0ul)

		{

			EAP_TRACE_ERROR(

				m_am_tools,

				TRACE_FLAGS_DEFAULT,