/*

* 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 151 

	#undef EAP_FILE_NUMBER_DATE 

	#define EAP_FILE_NUMBER_DATE 1127594498 

#endif //#if defined(USE_EAP_MINIMUM_RELEASE_TRACES)

#include "eapol_am_wlan_authentication_symbian.h"

#include "abs_eapol_am_wlan_authentication.h"

#include "eap_header_string.h"

//#include "eap_type_all.h"

#include "eap_config.h"

#include "eap_file_config.h"

#include "eap_am_file_input_symbian.h"

#include "eap_type_selection.h"

#include "eapol_key_types.h"

#include "eap_timer_queue.h"

#include "eap_crypto_api.h"

#include "abs_eapol_wlan_database_reference_if.h"

#include "abs_eap_state_notification.h"

#include "eap_state_notification.h"

#include "eap_automatic_variable.h"

#include "eap_base_type.h"

#include "EapolDbDefaults.h"

#include "EapolDbParameterNames.h"

const TUint KMaxSqlQueryLength = 2048;

#ifdef USE_EAP_EXPANDED_TYPES

const TUint KExpandedEAPSize = 8;

#else

const TUint KMaxEapCueLength = 3;

#endif //#ifdef USE_EAP_EXPANDED_TYPES

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

// 

EAP_FUNC_EXPORT eapol_am_wlan_authentication_symbian_c::~eapol_am_wlan_authentication_symbian_c()

{

	EAP_TRACE_DEBUG(

		m_am_tools, 

		TRACE_FLAGS_DEFAULT, 

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

		this));

}

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

// 

EAP_FUNC_EXPORT eapol_am_wlan_authentication_symbian_c::eapol_am_wlan_authentication_symbian_c(

	abs_eap_am_tools_c * const tools,

	const bool is_client_when_true,

	const abs_eapol_wlan_database_reference_if_c * const wlan_database_reference)

: CActive(CActive::EPriorityStandard)

, m_am_partner(0)

#if defined(USE_EAP_SIMPLE_CONFIG)

, m_configuration_if(0)

#endif // #if defined(USE_EAP_SIMPLE_CONFIG)

, m_am_tools(tools)

, m_fileconfig(0)

, m_SSID(tools)

, m_wpa_preshared_key(tools)

, m_wpa_preshared_key_hash(tools)

, m_wlan_database_reference(wlan_database_reference)

#ifdef USE_EAP_EXPANDED_TYPES

, m_eap_type_array(tools)

#endif

, m_receive_network_id(tools)

, m_security_mode(Wpa)

, m_selected_eapol_key_authentication_type(eapol_key_authentication_type_none)

, m_WPA_override_enabled(false)

, m_is_client(is_client_when_true)

, m_is_valid(false)

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	m_is_valid = true;

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

}

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

EAP_FUNC_EXPORT bool eapol_am_wlan_authentication_symbian_c::get_is_valid()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return m_is_valid;

}

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

void eapol_am_wlan_authentication_symbian_c::TryInitDatabaseL()

{

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("eapol_am_wlan_authentication_symbian_c::TryOpenDatabaseL()\n")));	

	// 1. Open/create a database	

	RDbNamedDatabase db;

#ifdef SYMBIAN_SECURE_DBMS

	// Create the secure shared database (if necessary) with the specified secure policy.

	// Database will be created in the data caging path for DBMS (C:\private\100012a5).

	TInt err = db.Create(m_session, KDatabaseName, KSecureUIDFormat);

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("TryOpenDatabaseL() - Created Secure DB for eapol.dat. err=%d\n"), err ));	

	if(err == KErrNone)

	{	

		db.Close();

	} else if (err != KErrAlreadyExists) 

	{

		User::LeaveIfError(err);

	}

	User::LeaveIfError(db.Open(m_session, KDatabaseName, KSecureUIDFormat));	

#else

	// For non-secured database. The database will be created in the old location (c:\system\data).

	// Create the database (if necessary)		

	TInt err = db.Create(m_fs, KDatabaseName);

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("TryOpenDatabaseL() - Created Non-Secure DB for eapol.dat. err=%d\n"), err ));	

	if(err == KErrNone)

	{

		db.Close();

	} else if (err != KErrAlreadyExists) 

	{

		User::LeaveIfError(err);

	}

	User::LeaveIfError(db.Open(m_session, KDatabaseName));

#endif // #ifdef SYMBIAN_SECURE_DBMS		

	CleanupClosePushL(db);

	HBufC* buf = HBufC::NewLC(KMaxSqlQueryLength);

	TPtr sqlStatement = buf->Des();

	// 2. Create the table for pre-shared keys in database (ignore error if exists)

	//// NAME /////////////////////////////////////////////////// TYPE ////////////// Constant ///////

	//| ServiceType											  | UNSIGNED INTEGER | KServiceType    |//

	//| ServiceIndex										  | UNSIGNED INTEGER | KServiceIndex   |//

	//| SSID												  | VARBINARY(255)	 | KSSID		   |//	

	//| Password											  | VARBINARY(255)	 | KPassword	   |//	

	//| PSK												      | VARBINARY(255)   | KPSK			   |//	

	//////////////////////////////////////////////////////////////////////////////////////////////////	

	_LIT(KSQLCreateTable2, "CREATE TABLE %S (%S UNSIGNED INTEGER, \

											 %S UNSIGNED INTEGER, \

											 %S VARBINARY(255), \

											 %S VARBINARY(255), \

											 %S VARBINARY(255))");

	sqlStatement.Format(KSQLCreateTable2, &KEapolPSKTableName, 

		&KServiceType, &KServiceIndex, &KSSID, &KPassword, &KPSK);

	err = db.Execute(sqlStatement);

	if (err != KErrNone && err != KErrAlreadyExists)

	{

		User::Leave(err);

	}

	CleanupStack::PopAndDestroy(); // buf

	// If compacting is not done the database will start growing

	db.Compact();

	CleanupStack::PopAndDestroy(); // Close database

}

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

void eapol_am_wlan_authentication_symbian_c::InitDatabaseL()

{

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("eapol_am_wlan_authentication_symbian_c::OpenDatabaseL()\n")));

	// Create the database (if necessary)

	TRAPD(err, TryInitDatabaseL());

	if (err != KErrNone)

	{

		// Because of error remove the database file.

		err = m_fs.Delete(KDatabaseName);

		if(err != KErrNone)

		{

			User::Leave(KErrCorrupt);

		}		

		// Try open database again. This will leave if fails second time.

		TryInitDatabaseL();

	}

}

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

EAP_FUNC_EXPORT eap_status_e eapol_am_wlan_authentication_symbian_c::configure()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_TRACE_DEBUG(

		m_am_tools, 

		TRACE_FLAGS_DEFAULT, 

		(EAPL("eapol_am_wlan_authentication_symbian_c::configure(): %s, this = 0x%08x => 0x%08x\n"),

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

		 this,

		 dynamic_cast<abs_eap_base_timer_c *>(this)));

	TInt error(KErrNone);

	// Open the database session

	error = m_session.Connect();

	if (error != KErrNone)

	{

		eap_status_e status(m_am_tools->convert_am_error_to_eapol_error(error));

		EAP_TRACE_DEBUG(

			m_am_tools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("RDbs::Connect() failed %d.\n"),

			status));

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("Database session initialized...\n")));

	// Connect to FS

	error = m_fs.Connect();

	if (error != KErrNone)

	{

		eap_status_e status(m_am_tools->convert_am_error_to_eapol_error(error));

		EAP_TRACE_DEBUG(

			m_am_tools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("RFs::Connect() failed %d.\n"),

			status));

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("Fileserver session initialized...\n")));

	// Initialize database

	TRAPD(err, InitDatabaseL());

	if (err != KErrNone)

	{

		eap_status_e status(m_am_tools->convert_am_error_to_eapol_error(error));

		EAP_TRACE_DEBUG(

			m_am_tools,

			TRACE_FLAGS_DEFAULT,

			(EAPL("InitDatabaseL failed %d.\n"),

			status));

		EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

		return EAP_STATUS_RETURN(m_am_tools, status);

	}

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("Database initialized...\n")));

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

#if defined(USE_EAP_FILECONFIG)

	{

		eap_am_file_input_symbian_c * const fileio = new eap_am_file_input_symbian_c(m_am_tools);

		eap_automatic_variable_c<eap_am_file_input_symbian_c> automatic_fileio(m_am_tools, fileio);

		if (fileio != 0

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

		{

			EAP_TRACE_DEBUG(

				m_am_tools,

				TRACE_FLAGS_DEFAULT,

				(EAPL("Initialize file configuration.\n")));

			eap_variable_data_c file_name_c_data(m_am_tools);

			eap_status_e status(eap_status_process_general_error);

			{

				#if defined(EAPOL_SYMBIAN_VERSION_7_0_s)

					eap_const_string const FILECONFIG_FILENAME_C

						= "c:\\system\\data\\eap.conf";

				#else

					eap_const_string const FILECONFIG_FILENAME_C

						= "c:\\private\\101F8EC5\\eap.conf";

				#endif

				status = file_name_c_data.set_copy_of_buffer(

					FILECONFIG_FILENAME_C,

					m_am_tools->strlen(FILECONFIG_FILENAME_C));

				if (status != eap_status_ok)

				{

					EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

					return EAP_STATUS_RETURN(m_am_tools, status);

				}

				status = file_name_c_data.add_end_null();

				if (status != eap_status_ok)

				{

					EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

					return EAP_STATUS_RETURN(m_am_tools, status);

				}

			}

			eap_variable_data_c file_name_z_data(m_am_tools);

			{

				#if defined(EAPOL_SYMBIAN_VERSION_7_0_s)

					eap_const_string const FILECONFIG_FILENAME_Z

						= "z:\\system\\data\\eap.conf";

				#else

					eap_const_string const FILECONFIG_FILENAME_Z

						= "z:\\private\\101F8EC5\\eap.conf";

				#endif

				status = file_name_z_data.set_copy_of_buffer(

					FILECONFIG_FILENAME_Z,

					m_am_tools->strlen(FILECONFIG_FILENAME_Z));

				if (status != eap_status_ok)

				{

					EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

					return EAP_STATUS_RETURN(m_am_tools, status);

				}

				status = file_name_z_data.add_end_null();

				if (status != eap_status_ok)

				{

					EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

					return EAP_STATUS_RETURN(m_am_tools, status);

				}

			}

			if (status == eap_status_ok)

			{

				// First try open from C: disk.

				status = fileio->file_open(

					&file_name_c_data,

					eap_file_io_direction_read);

				if (status == eap_status_ok)

				{

					EAP_TRACE_DEBUG(

						m_am_tools,

						TRACE_FLAGS_DEFAULT,

						(EAPL("Opens configure file %s\n"),

						file_name_c_data.get_data(file_name_c_data.get_data_length())));

				}

				else if (status != eap_status_ok)

				{

					// Second try open from Z: disk.

					status = fileio->file_open(

						&file_name_z_data,

						eap_file_io_direction_read);

					if (status == eap_status_ok)

					{

						EAP_TRACE_DEBUG(

							m_am_tools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("Opens configure file %s\n"),

							 file_name_z_data.get_data(file_name_z_data.get_data_length())));

					}

				}

				if (status == eap_status_ok)

				{

					// Some of the files were opened.

					m_fileconfig = new eap_file_config_c(m_am_tools);

					if (m_fileconfig != 0

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

					{

						status = m_fileconfig->configure(fileio);

						if (status != eap_status_ok)

						{

							EAP_TRACE_DEBUG(

								m_am_tools,

								TRACE_FLAGS_DEFAULT,

								(EAPL("ERROR: Configure read from %s failed.\n"),

								file_name_c_data.get_data(file_name_c_data.get_data_length())));

						}

						else

						{

							EAP_TRACE_DEBUG(

								m_am_tools,

								TRACE_FLAGS_DEFAULT,

								(EAPL("Configure read from %s\n"),

								file_name_c_data.get_data(file_name_c_data.get_data_length())));

						}

					}

					else

					{

						// No file configuration.

						delete m_fileconfig;

						m_fileconfig = 0;

						EAP_TRACE_DEBUG(

							m_am_tools,

							TRACE_FLAGS_DEFAULT,

							(EAPL("ERROR: Cannot create configure object for file %s\n"),

							file_name_c_data.get_data(file_name_c_data.get_data_length())));

					}

				}

				else

				{

					EAP_TRACE_DEBUG(

						m_am_tools,

						TRACE_FLAGS_DEFAULT,

						(EAPL("ERROR: Cannot open configure file neither %s nor %s\n"),

						file_name_c_data.get_data(file_name_c_data.get_data_length()),

						file_name_z_data.get_data(file_name_z_data.get_data_length())));

				}

			}

		}

		else

		{

			EAP_TRACE_DEBUG(

				m_am_tools,

				TRACE_FLAGS_DEFAULT,

				(EAPL("Skips file configuration.\n")));

		}

	}

#endif //#if defined(USE_EAP_FILECONFIG)

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

#if defined(USE_EAP_FILE_TRACE)

	{

		eap_variable_data_c trace_output_file(m_am_tools);

		eap_status_e status = read_configure(

			cf_str_EAP_TRACE_output_file_name.get_field(),

			&trace_output_file);

		if (status == eap_status_ok

			&& trace_output_file.get_is_valid_data() == true)

		{

			status = m_am_tools->set_trace_file_name(&trace_output_file);

			if (status == eap_status_ok)

			{

				// OK, set the default trace mask.

				m_am_tools->set_trace_mask(

					eap_am_tools_c::eap_trace_mask_debug

					| eap_am_tools_c::eap_trace_mask_always

					| eap_am_tools_c::eap_trace_mask_error

					| eap_am_tools_c::eap_trace_mask_message_data);

			}

		}

	}

#endif //#if defined(USE_EAP_FILE_TRACE)

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

	{

		eap_variable_data_c EAP_TRACE_enable_timer_queue_traces(m_am_tools);

		eap_status_e status = read_configure(

			cf_str_EAP_TRACE_enable_timer_queue_traces.get_field(),

			&EAP_TRACE_enable_timer_queue_traces);

		if (status == eap_status_ok

			&& EAP_TRACE_enable_timer_queue_traces.get_is_valid_data() == true)

		{

			u32_t *enable_timer_queue_traces = reinterpret_cast<u32_t *>(

				EAP_TRACE_enable_timer_queue_traces.get_data(sizeof(u32_t)));

			if (enable_timer_queue_traces != 0

				&& *enable_timer_queue_traces != 0)

			{

				m_am_tools->set_trace_mask(

					m_am_tools->get_trace_mask()

					| eap_am_tools_c::eap_trace_mask_timer_queue

					);

			}

		}

	}