/*

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

	#undef EAP_FILE_NUMBER_DATE 

	#define EAP_FILE_NUMBER_DATE 1127594498 

#endif //#if defined(USE_EAP_MINIMUM_RELEASE_TRACES)

// INCLUDE FILES

#include <coemain.h>

#include <bautils.h>

#include <barsc.h>

#include "eap_am_memory.h"

#include "eap_tools.h"

#include "eap_am_type_securid_symbian.h"

#include "EapSecurIDDbParameterNames.h"

#include "EapSecurIDDbUtils.h"

#include "EapPluginDbDefaults.h"

#include "eap_auth_notifier.h"

#include "EapGtcDbParameterNames.h"

#include "EapGtcDbUtils.h"

#include "EapSecurIDNotifierUids.h"

#include "eap_configuration_field.h"

#include "eap_state_notification.h"

#include "EapTraceSymbian.h"

const TUint KMaxSqlQueryLength = 256;

const TUint KMaxDBFieldNameLength = 255;

const char EAP_GTC_USERNAME_HANDLE_KEY[] = "eap_type_securid_c GTC username";

const TInt 	KDefaultColumnInView_One = 1; // For DB view.

const TInt 	KMicroSecsInASecond = 1000000; // 1000000 micro seconds is 1 second.

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

EAP_FUNC_EXPORT eap_am_type_securid_symbian_c::~eap_am_type_securid_symbian_c()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);	

	EAP_TRACE_DEBUG(

		m_am_tools, 

		TRACE_FLAGS_DEFAULT, 

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

		this));

	EAP_ASSERT(m_shutdown_was_called == true);	

	m_database.Close();

	m_session.Close();

	delete m_dialog_data_ptr;

	delete m_dialog_data_pckg_ptr;

	delete m_message_buf;

	delete iEapAuthNotifier;

	iEapAuthNotifier = 0;

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

}

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

EAP_FUNC_EXPORT eap_status_e eap_am_type_securid_symbian_c::shutdown()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_TRACE_DEBUG(

		m_am_tools, 

		TRACE_FLAGS_DEFAULT, 

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

		this));

	m_shutdown_was_called = true;

	m_partner->cancel_timer(this, EHandlingTimerCall);

	EAP_TRACE_DEBUG(

		m_am_tools, 

		TRACE_FLAGS_DEFAULT, 

		(EAPL("eap_am_type_securid_symbian_c::shutdown(): this = 0x%08x returns\n"),

		this));

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return eap_status_ok;

}

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

eap_am_type_securid_symbian_c::eap_am_type_securid_symbian_c(

	abs_eap_am_tools_c * const tools,

	abs_eap_base_type_c * const partner,

	const TIndexType aIndexType,

	const TInt aIndex,

	const eap_type_value_e aTunnelingType,

	const eap_type_value_e aEapType,

	const bool aIsClient,

	const eap_am_network_id_c * const receive_network_id)

		: CActive(CActive::EPriorityStandard)

		, eap_am_type_securid_c(tools /*, partner */)

		, m_state(EHandlingIdentityQuery)

		, m_am_tools(tools)

		, m_partner(partner)

		, m_receive_network_id(tools)

		, m_index_type(aIndexType)

		, m_index(aIndex)

		, m_tunneling_type(aTunnelingType)

		, m_is_client(aIsClient)

		, m_is_valid(false)

		, m_shutdown_was_called(false)

		, m_eap_type(aEapType)

		, m_is_notifier_connected(false)

		, m_max_session_time(0)

		, iEapAuthNotifier(0)	

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	if (receive_network_id != 0

		&& receive_network_id->get_is_valid_data() == true)

	{

		eap_status_e status = m_receive_network_id.set_copy_of_network_id(

			receive_network_id);

		if (status != eap_status_ok)

		{

			EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

			(void)EAP_STATUS_RETURN(m_am_tools, eap_status_allocation_error);

			return;

		}

	}

	set_is_valid();

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

}

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

eap_am_type_securid_symbian_c* eap_am_type_securid_symbian_c::NewL(

	abs_eap_am_tools_c * const aTools,

	abs_eap_base_type_c * const aPartner,

	const TIndexType aIndexType,

	const TInt aIndex,

	const eap_type_value_e aTunnelingType,

	const eap_type_value_e aEapType,

	const bool aIsClient,

	const eap_am_network_id_c * const receive_network_id)

{

		aTools, 

		aPartner, 

		aIndexType, 

		aIndex, 

		aTunnelingType, 

		aEapType,

		aIsClient,

		receive_network_id);

		User::Leave(KErrGeneral);

	}

	return self;

}

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

void eap_am_type_securid_symbian_c::ConstructL()

{

	TInt error = m_session.Connect();

	EAP_TRACE_DEBUG_SYMBIAN((_L("eap_am_type_securid_symbian_c::ConstructL(): - m_session.Connect(), error=%d\n"), error));

	User::LeaveIfError(error);

	// Open/create database

	if (m_eap_type == eap_type_generic_token_card)

	{

		EapGtcDbUtils::OpenDatabaseL(m_database, m_session, m_index_type, m_index, m_tunneling_type);

	}

	else

	{

		EapSecurIDDbUtils::OpenDatabaseL(m_database, m_session, m_index_type, m_index, m_tunneling_type);

	}

	m_dialog_data_ptr = new(ELeave) CEapAuthNotifier::TEapDialogInfo;

	m_dialog_data_pckg_ptr = new(ELeave) TPckg<CEapAuthNotifier::TEapDialogInfo> (*m_dialog_data_ptr);

	CActiveScheduler::Add(this);

}

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

EAP_FUNC_EXPORT void eap_am_type_securid_symbian_c::set_is_valid()

{

	m_is_valid = true;

}

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

EAP_FUNC_EXPORT bool eap_am_type_securid_symbian_c::get_is_valid()

{

	return m_is_valid;

}

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

void eap_am_type_securid_symbian_c::send_error_notification(const eap_status_e error)

{

	eap_general_state_variable_e general_state_variable(eap_general_state_authentication_error);

	if (error == eap_status_user_cancel_authentication)

		{

		general_state_variable = eap_general_state_authentication_cancelled;

		}

	// Here we swap the addresses.

	eap_am_network_id_c send_network_id(m_am_tools,

		m_receive_network_id.get_destination_id(),

		m_receive_network_id.get_source_id(),

		m_receive_network_id.get_type());

	// Notifies the lower level of an authentication error.

	eap_state_notification_c notification(

		m_am_tools,

		&send_network_id,

		m_is_client,

		eap_state_notification_eap,

		eap_protocol_layer_general,

		m_eap_type,

		eap_state_none,

		general_state_variable,

		0,

		false);

	notification.set_authentication_error(error);

	m_partner->state_notification(&notification);

}

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

void eap_am_type_securid_symbian_c::RunL()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);		

	EAP_TRACE_DEBUG(

		m_am_tools,

		TRACE_FLAGS_DEFAULT,

		(EAPL("eap_am_type_securid_symbian_c::RunL - start")

		 EAPL("m_state, iStatus.Int()=%d\n"),

		 m_state, iStatus.Int()));

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);	

}

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

void eap_am_type_securid_symbian_c::DoCancel()

{

	iEapAuthNotifier->Cancel();

}

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

EAP_FUNC_EXPORT eap_status_e eap_am_type_securid_symbian_c::type_configure_read(

	const eap_configuration_field_c * const field,

	eap_variable_data_c * const data)

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_ASSERT(data != 0);

	// Trap must be set here because the OS independent portion of EAP SecurID

	// that calls this function does not know anything about Symbian.	

	eap_status_e status(eap_status_ok);

	TRAPD(err, type_configure_readL(

		field->get_field(),

		field->get_field_length(),

		data));

	if (err != KErrNone) 

	{

		// Read is routed to partner object, for reading from configuration file.

		status = m_partner->read_configure(

			field,

			data);

	}

	m_am_tools->trace_configuration(

		status,

		field,

		data);

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

	return EAP_STATUS_RETURN(m_am_tools, status);

}

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

void eap_am_type_securid_symbian_c::type_configure_readL(

	eap_config_string field,

	const u32_t field_length,

	eap_variable_data_c * const data)

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	EAP_TRACE_DEBUG(

		m_am_tools, 

		TRACE_FLAGS_DEFAULT,

		(EAPL("eap_am_type_securid_symbian_c::type_configure_readL(): m_index_type=%d, m_index=%d, m_tunneling_type=0xfe%06x%08x\n"),

		m_index_type,

		m_index,

		m_tunneling_type.get_vendor_id(),

		m_tunneling_type.get_vendor_type()));

	EAP_UNREFERENCED_PARAMETER(field_length);

	// Create a buffer for the ascii strings - initialised with the argument

	HBufC16* unicodeBuf = HBufC16::NewLC(KMaxDBFieldNameLength);

	TPtr16 unicodeString = unicodeBuf->Des();

	TPtrC8 fieldPtr(reinterpret_cast<const TUint8 *> (field), field_length);

	unicodeString.Copy(fieldPtr);

	// Now do the database query

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

	TPtr sqlStatement = buf->Des();

	_LIT(KSQLQueryRow, "SELECT %S FROM %S WHERE %S=%d AND %S=%d AND %S=%d AND %S=%d");

	if (m_eap_type == eap_type_securid)

	{

		sqlStatement.Format(

			KSQLQueryRow,

			&unicodeString,

			&KSecurIDTableName, 

			&KServiceType,

			m_index_type,

			&KServiceIndex,

			m_index,

			&KTunnelingTypeVendorId,

			m_tunneling_type.get_vendor_id(),

			&KTunnelingType, 

			m_tunneling_type.get_vendor_type());

	}

	else

	{

		sqlStatement.Format(

			KSQLQueryRow,

			&unicodeString,

			&KGtcTableName, 

			&KServiceType,

			m_index_type,

			&KServiceIndex,

			m_index,

			&KTunnelingTypeVendorId,

			m_tunneling_type.get_vendor_id(),

			&KTunnelingType, 

			m_tunneling_type.get_vendor_type());

	}

	RDbView view;

	User::LeaveIfError(view.Prepare(m_database, TDbQuery(sqlStatement), TDbWindow::EUnlimited));

	CleanupClosePushL(view);

	User::LeaveIfError(view.EvaluateAll());	

	if (view.FirstL())

	{

		eap_status_e status = eap_status_ok;

		view.GetL();		

		switch (view.ColType(KDefaultColumnInView_One))

		{

		case EDbColText:

			{

				if (view.ColLength(KDefaultColumnInView_One) > 0)

				{

					TPtrC16 value = view.ColDes16(KDefaultColumnInView_One);

					eap_variable_data_c string_unicode(m_am_tools);

					status = string_unicode.set_copy_of_buffer(value.Ptr(), value.Size());

					if (status != eap_status_ok)

					{

						User::Leave(

							m_am_tools->convert_eapol_error_to_am_error(

								EAP_STATUS_RETURN(m_am_tools, status)));

					}

					status = m_am_tools->convert_unicode_to_utf8(

						*data,

						string_unicode);

					if (status != eap_status_ok)

					{

						User::Leave(

							m_am_tools->convert_eapol_error_to_am_error(

								EAP_STATUS_RETURN(m_am_tools, status)));

					}

				} 

				else 

				{

					data->reset();

					status = data->set_copy_of_buffer("", 0);

					if (status != eap_status_ok)

					{

						User::Leave(

							m_am_tools->convert_eapol_error_to_am_error(

								EAP_STATUS_RETURN(m_am_tools, status)));

					}

				}

			}

			break;

		case EDbColUint32:

			{

				TUint value = view.ColUint32(KDefaultColumnInView_One);

				status = data->set_copy_of_buffer(reinterpret_cast<unsigned char *> (&value), sizeof(value));

				if (status != eap_status_ok)

				{

					User::Leave(

						m_am_tools->convert_eapol_error_to_am_error(

							EAP_STATUS_RETURN(m_am_tools, status)));

				}

			}

			break;

		default:

			EAP_TRACE_DEBUG(m_am_tools, TRACE_FLAGS_DEFAULT, (EAPL("type_configure_readL: Unexpected column type.\n")));

			User::Leave(KErrGeneral);

			break;

		}

	} 

	else 

	{

		// Could not find parameter

		EAP_TRACE_DEBUG(m_am_tools, TRACE_FLAGS_DEFAULT, (EAPL("type_configure_readL: Could not find configuration parameter.\n")));

		User::Leave(KErrArgument);

	}		

	CleanupStack::PopAndDestroy(3); // Close view, 2 x buf

	EAP_TRACE_END(m_am_tools, TRACE_FLAGS_DEFAULT);

}

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

EAP_FUNC_EXPORT eap_status_e eap_am_type_securid_symbian_c::type_configure_write(

	const eap_configuration_field_c * const field,

	eap_variable_data_c * const data)

{

	// NOTE: At the moment this is not called anywhere.

	// NOTE: This is really just for simulation.

	// Write is routed to partner object.

	eap_status_e status = m_partner->write_configure(

			field,

			data);

	return EAP_STATUS_RETURN(m_am_tools, status);

}

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

EAP_FUNC_EXPORT eap_status_e eap_am_type_securid_symbian_c::configure()

{

	EAP_TRACE_BEGIN(m_am_tools, TRACE_FLAGS_DEFAULT);

	{

		// Read Maximum Session Validity Time from the config file

		eap_variable_data_c sessionTimeFromFile(m_am_tools);

		eap_status_e status = type_configure_read(

			cf_str_EAP_GTC_max_session_validity_time.get_field(),

			&sessionTimeFromFile);

		if (status == eap_status_ok