/*

* ============================================================================

*  Name        : ./accesssec/eapol/eapol_framework/wapi_symbian/wapi_core/symbian/certificate_store_db_symbian.cpp

*  Part of     : WAPI / WAPI       *** Info from the SWAD

*  Description : WAPI authentication

*  Version     : %version: 61 % << Don't touch! Updated by Synergy at check-out.

*

*  Copyright © 2001-2009 Nokia.  All rights reserved.

*  This material, including documentation and any related computer

*  programs, is protected by copyright controlled by Nokia.  All

*  rights are reserved.  Copying, including reproducing, storing,

*  adapting or translating, any or all of this material requires the

*  prior written consent of Nokia.  This material also contains

*  confidential information which may not be disclosed to others

*  without the prior written consent of Nokia.

* ============================================================================

* Template version: 4.1.1

*/

// INCLUDE FILES

#include <mmtsy_names.h>

#include <utf.h>                           // for CnvUtfConverter

#include <s32strm.h> 	                   // For RReadStream

#include <d32dbms.h>                       // for RDbColReadStream

#include "certificate_store_db_symbian.h"

#include "eap_am_trace_symbian.h"

#include "eap_variable_data.h"

#include "abs_eap_am_tools.h"

#include "eap_am_tools_symbian.h"

#include "eap_am_types.h"

#include "wapi_asn1_der_parser.h"

#include "wapi_am_core_symbian.h"

// ================= public:  Constructors and destructor =======================

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

// CCertificateStoreDatabase::NewL()

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

//

CCertificateStoreDatabase* CCertificateStoreDatabase::NewL(

    abs_eap_am_tools_c* aAmTools )

    {    

	CCertificateStoreDatabase* self = new(ELeave)

	    CCertificateStoreDatabase( aAmTools );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    } // CCertificateStoreDatabase::NewL()

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

// CCertificateStoreDatabase::~CCertificateStoreDatabase()

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

//

CCertificateStoreDatabase::~CCertificateStoreDatabase()

    {

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::~CCertificateStoreDatabase() IN\n" ) ) );

    Close();

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::~CCertificateStoreDatabase() OUT\n" ) ) );

    } // CCertificateStoreDatabase::~CCertificateStoreDatabase()

// ================= public: New, open/close/destroy functionality =======================

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

// CCertificateStoreDatabase::OpenCertificateStoreL()

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

//

void CCertificateStoreDatabase::OpenCertificateStoreL()

	{

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::OpenCertificateStoreL() IN\n" ) ) );

    if ( iCsDbCreated == EFalse || iCsSessionOpened == EFalse )

		{

		// Certificate store DB and tables are not created.

		CreateCertificateStoreL();

		}

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::OpenCertificateStoreL() OUT\n" ) ) );

	} // CCertificateStoreDatabase::OpenCertificateStoreL()

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

// CCertificateStoreDatabase::Close()

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

//

void CCertificateStoreDatabase::Close()

	{

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::Close() IN\n" ) ) );

	if ( iCsDbCreated )

		{

		iCsDb.Close();

		iCsDbCreated = EFalse;

		}

	if ( iCsSessionOpened )

	    {

		iCsDbSession.Close();

		iCsSessionOpened = EFalse;

	    }	

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::Close() OUT\n" ) ) );

	} // CCertificateStoreDatabase::Close()

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

// CCertificateStoreDatabase::SetCorePartner()

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

//

void CCertificateStoreDatabase::SetCorePartner(wapi_am_core_symbian_c *partner)

    {

    iPartner = partner; 

    }

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

// CCertificateStoreDatabase::DestroyCertificateStore()

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

//

TInt CCertificateStoreDatabase::DestroyCertificateStore()

	{

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::DestroyCertificateStore() IN, \

        iCsSessionOpened=%d, iCsDbCreated=%d\n" ),

        iCsSessionOpened, iCsDbCreated ) );

    // There could be a case where certificate store DB is destroyed and UI

    // calls this function. We return KErrNone in that case.        

    if ( iCsDbCreated == EFalse )

        {

        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "WARNING: CCertificateStoreDatabase::DestroyCertificateStore() \

            Certificate store DB doesn't exist. Returning KErrNone.\n" ) ) );

        return KErrNone;

        }

    if ( iCsSessionOpened == EFalse )

		{

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "ERROR: CCertificateStoreDatabase::DestroyCertificateStore() \

			Certificate store not opened!\n" ) ) );

		return KErrSessionClosed;

		}	

    if (iPartner != NULL)

        {

        iPartner->reset();

        }

	TInt error = iCsDb.Destroy();

	if ( error != KErrNone )

		{

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "ERROR: CCertificateStoreDatabase::DestroyCertificateStore() \

			iCsDb.Destroy() failed, error=%d.\n" ), error ) );

		}

		else

		{

		iCsDbCreated = EFalse;

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "CCertificateStoreDatabase::DestroyCertificateStore() \

			CS DB destroyed successfully.\n" ) ) );	

		}

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::DestroyCertificateStore() OUT,\

        error=%d.\n" ), error ) );

    return error;

	} // CCertificateStoreDatabase::DestroyCertificateStore()

// ================= public:  New =======================

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

// CCertificateStoreDatabase::InitializeCertificateStoreL()

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

//

void CCertificateStoreDatabase::InitializeCertificateStoreL()

	{

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::InitializeCertificateStoreL() IN\n" ) ) );

    WriteCertificateStoreStateL( ECertificateStoreInitialized );

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::InitializeCertificateStoreL() OUT\n" ) ) );

	} // CCertificateStoreDatabase::InitializeCertificateStoreL()

// ================= public: New, get/set/remove data in database =======================

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

// CCertificateStoreDatabase::GetCsDataByReferenceL()

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

//

void CCertificateStoreDatabase::GetCsDataByReferenceL(

    ec_cs_data_type_e aDataType,

    const TDesC8& aDataReference,

   	HBufC8** aOutColumnValue )

	{

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataByReferenceL1() IN\n" ) ) );

        // Convert the received reference id into integer.. 

    TUint intRef;

    if (aDataType != ec_cs_data_type_selected_ca_id && aDataType != ec_cs_data_type_selected_client_id)

        {

        // Convert the received reference id into integer.. 

        intRef = eap_read_u32_t_network_order(

            aDataReference.Ptr(),

            aDataReference.Size());

        }

    else

        {

        intRef = static_cast<TUint>(*aDataReference.Ptr());

        }

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL

            ( "CCertificateStoreDatabase::GetCsDataByReference1L() \

            New entry: reference set to DB(TEXT)=%d\n" ), intRef ) );

    GetCsDataByReferenceL ( aDataType, intRef, aOutColumnValue );

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataByReferenceL1() OUT\n" ) ) );

	} // CCertificateStoreDatabase::GetCsDataByReferenceL()

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

// CCertificateStoreDatabase::GetCsDataByReferenceL()

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

//

void CCertificateStoreDatabase::GetCsDataByReferenceL(

    ec_cs_data_type_e aDataType,

    const TUint aDataReference,

   	HBufC8** aOutColumnValue )

    {

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataByReferenceL() IN\n" ) ) );

    // There could be a case where CS DB is destroyed and UI

    // calls this function. We just return in that case.

    if ( !iCsDbCreated )

        {

        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

                "ERROR: CCertificateStoreDatabase::GetCsDataByReferenceL() \

                CS DB doesn't exist. Don't do anything.\n" ) ) );

        return;

        }

    if ( !iCsSessionOpened )

        {

        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

                "ERROR: CCertificateStoreDatabase::GetCsDataByReferenceL() - CS not opened.\n" ) ) );

        User::Leave( KErrSessionClosed );

        }			

    // DB names

    TBuf<KDbMaxName> tableName;               // const from d32dbms.h

    TBuf<KDbMaxColName> referenceColumnName;  // const from d32dbms.h

    TBuf<KDbMaxColName> dataColumnName;       // const from d32dbms.h

    GetDbNamesFromDataTypeL( aDataType, tableName, referenceColumnName,

		                        dataColumnName );

    // create SQL query statement

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

    TPtr sqlStatement = buf->Des();

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

    sqlStatement.Format( KSqlQuery, &dataColumnName, &tableName, &referenceColumnName, aDataReference );

    EAP_TRACE_DATA_DEBUG_SYMBIAN( (

            "wapi_am_core_symbian_c::GetCsDataByReferenceL() sqlStatement",

            sqlStatement.Ptr(), sqlStatement.Size() ) );	

    RDbView view;

    User::LeaveIfError( view.Prepare( iCsDb, TDbQuery( sqlStatement ),

            TDbWindow::EUnlimited, RDbView::EReadOnly ) );

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataByReferenceL() View prepared OK.\n" ) ) );

	CleanupClosePushL( view );

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

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataByReferenceL() View evaluated OK.\n" ) ) );    

	if ( view.FirstL() )

	    {

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "CCertificateStoreDatabase::GetCsDataByReferenceL() view.FirstL() OK.\n" ) ) );    

		view.GetL();		

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "CCertificateStoreDatabase::GetCsDataByReferenceL() view.GetL() OK.\n" ) ) );    

		switch ( view.ColType( KDefaultColumnNumberOne ) )

		    {

		    case EDbColText:				

			    {

                // Buffer for unicode parameter

                HBufC* unicodebuf = HBufC::NewLC(view.ColLength( KDefaultColumnNumberOne ));

                TPtr unicodeString = unicodebuf->Des();

                unicodeString = view.ColDes(KDefaultColumnNumberOne);

                // Convert to 8-bit

                if (unicodeString.Size() > 0)

                    {

                    *aOutColumnValue = HBufC8::NewLC(

                        view.ColLength( KDefaultColumnNumberOne ) ); // Buffer for the data.

                    TPtr8 outColumnValuePtr8 = ( *aOutColumnValue )->Des();

                    outColumnValuePtr8.Copy(unicodeString);

                    if (outColumnValuePtr8.Size() == 0)

	                    {

	                        User::Leave(KErrNoMemory);

	                    }

                    CleanupStack::Pop( *aOutColumnValue );

                    } 

                else 

                    {

                        // Empty field. Do nothing...data remains invalid

                    }

                CleanupStack::PopAndDestroy(unicodebuf);

			    break;

			    }

		    case EDbColUint32:

	            {

	                TUint value;

	                value = view.ColUint32(KDefaultColumnNumberOne);

                    *aOutColumnValue = HBufC8::NewLC(

                        view.ColLength( KDefaultColumnNumberOne ) ); // Buffer for the data.

                    TPtr8 outColumnValuePtr8 = ( *aOutColumnValue )->Des();

                    outColumnValuePtr8.Copy((const unsigned char *)&value, sizeof(TUint));

                    if (outColumnValuePtr8.Size() == 0)

                    {

                        User::Leave(KErrNoMemory);

                    }

                    CleanupStack::Pop( *aOutColumnValue );

	            }

	            break;

		    case EDbColBinary:

			    {

		        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

	                "ERROR: CCertificateStoreDatabase::GetCsDataByReferenceL() \

	                Unsupported DB field EDbColBinary.\n" ) ) );

				User::Leave( KErrNotSupported );

                break;

			    }

		    case EDbColLongBinary:				

			    {

		        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

					"CCertificateStoreDatabase::GetCsDataByReferenceL() \

					Long binary column.\n" ) ) );			

				GetLongBinaryDataL( view, aOutColumnValue );

				break;

			    }			

		    default:

		    	{

		        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

		            "ERROR: CCertificateStoreDatabase::GetCsDataByReferenceL() \

		            Unsupported DB field:%d\n" ), 

		            view.ColType( KDefaultColumnNumberOne ) ) );

			    User::Leave( KErrNotSupported );

			    break;

		    	}

		    } // switch ( view.ColType( KDefaultColumnNumberOne ) )

	    } // if ( view.FirstL() )

	// clean

	CleanupStack::PopAndDestroy( &view ); // Close view.	

    CleanupStack::PopAndDestroy( buf );

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataByReferenceL() OUT\n" ) ) );

	} // CCertificateStoreDatabase::GetCsDataByReferenceL()

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

// CCertificateStoreDatabase::GetCsDataL()

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

//

void CCertificateStoreDatabase::GetCsDataL(

	ec_cs_data_type_e aDataType,

    HBufC8** aOutColumnValue,

	RArray<SWapiCertEntry>& aArray,

	TBool aGetAll)

	{

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataL() IN\n" ) ) );

    aArray.Reset();

    // There could be a case where CS DB is destroyed and UI

    // calls this function. We just return in that case.

    if ( !iCsDbCreated )

        {

        EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "ERROR: CCertificateStoreDatabase::GetCsDataL() \

            CS DB doesn't exist. Don't do anything.\n" ) ) );

        return;

        }

    if ( !iCsSessionOpened )

		{

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

            "ERROR: CCertificateStoreDatabase::GetCsDataL() CS not opened.\n" ) ) );

		User::Leave( KErrSessionClosed );

		}			

    // DB names

	TBuf<KDbMaxName> tableName;               // const from d32dbms.h

	TBuf<KDbMaxColName> dataColumnName;       // const from d32dbms.h

	GetDbNamesFromDataTypeL( aDataType, tableName, dataColumnName );

  	// create SQL query statement

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

	TPtr sqlStatement = buf->Des();

	_LIT( KSqlQuery, "SELECT %S FROM %S" );

    _LIT( KSqlQueryAll, "SELECT * FROM %S" );

	if (aGetAll)

	    sqlStatement.Format( KSqlQueryAll, &tableName );

	else

	    sqlStatement.Format( KSqlQuery, &dataColumnName, &tableName );

	EAP_TRACE_DATA_DEBUG_SYMBIAN( (

		"wapi_am_core_symbian_c::GetCsDataL() sqlStatement",

		sqlStatement.Ptr(), 

		sqlStatement.Size() ) );	

 	RDbView view;

	User::LeaveIfError( view.Prepare( iCsDb, TDbQuery( sqlStatement ),

		TDbWindow::EUnlimited, RDbView::EReadOnly ) );

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataL() View prepared OK.\n" ) ) );

	CleanupClosePushL( view );

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

    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

        "CCertificateStoreDatabase::GetCsDataL() View evaluated OK.\n" ) ) );    

 	if ( view.FirstL() && aGetAll == EFalse)

	    {

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

			"CCertificateStoreDatabase::GetCsDataL() view.FirstL() OK.\n" ) ) );

		view.GetL();		

	    EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

			"CCertificateStoreDatabase::GetCsDataL() view.GetL() OK.\n" ) ) );

		switch ( view.ColType( KDefaultColumnNumberOne ) )

		    {

		    case EDbColText:				

			    {

                EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

                    "CCertificateStoreDatabase::GetCsDataL() \

                    EDbColText.\n" ) ) );            

			    // Buffer for unicode parameter

                HBufC* unicodebuf = HBufC::NewLC(view.ColLength( KDefaultColumnNumberOne ));

			    TPtr unicodeString = unicodebuf->Des();

                unicodeString = view.ColDes(KDefaultColumnNumberOne);

                // Convert to 8-bit

                if (unicodeString.Size() > 0)

                    {

                    *aOutColumnValue = HBufC8::NewLC(

                        view.ColLength( KDefaultColumnNumberOne ) ); // Buffer for the data.

                    TPtr8 outColumnValuePtr8 = ( *aOutColumnValue )->Des();

                    outColumnValuePtr8.Copy(unicodeString);

                     if (outColumnValuePtr8.Size() == 0)

                    {

                        User::Leave(KErrNoMemory);

                    }

                     CleanupStack::Pop( *aOutColumnValue );

                } 

                else 

                    {

                        // Empty field. Do nothing...data remains invalid

                     }

                CleanupStack::PopAndDestroy(unicodebuf);

                break;

			    }

	         case EDbColUint32:

	                {

	                EAP_TRACE_DEBUG( iAmTools, TRACE_FLAGS_DEFAULT, ( EAPL(

	                    "CCertificateStoreDatabase::GetCsDataL() \

	                    EDbColUint32.\n" ) ) );            

	                    TUint value;

	                    value = view.ColUint32(KDefaultColumnNumberOne);

	                    *aOutColumnValue = HBufC8::NewLC(

	                        view.ColLength( KDefaultColumnNumberOne ) ); // Buffer for the data.

	                    TPtr8 outColumnValuePtr8 = ( *aOutColumnValue )->Des();

	                    outColumnValuePtr8.Copy((const unsigned char *)&value, sizeof(TUint));

	                    if (outColumnValuePtr8.Size() == 0)

	                    {

	                        User::Leave(KErrNoMemory);

	                    }

	                    CleanupStack::Pop( *aOutColumnValue );

	                    if (outColumnValuePtr8.Size() == 0)

	                    {

	                        User::Leave(KErrNoMemory);

	                    }

	                }

	                break;

		    case EDbColBinary: