/*

* Copyright (c) 2005 Nokia Corporation and/or its subsidiary(-ies). 

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "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:  AgentLog db-interface

*

*/

// INCLUDE FILES

#include <sysutil.h>

#include <bautils.h>

#include <utf.h>

#include <nsmlconstants.h>

#include <nsmldebug.h>

#include "nsmldbcaps.h"

#include "nsmldsdefines.h"

#include "nsmlagentlog.h"

#include "smldevinfdtd.h"

// CONSTANTS

// Size of empty AgentLog database in bytes.

const TInt KNSmlAgentLogEmptyDatabaseSize = 580;

// Estimated maximum size of AgentLog table row without the unrestricted

// ServerDeviceInfo and ServerFilterInfo fields.

const TInt KNSmlAgentLogMaxFixedLogRowSize = 860;

// Maximum size of Authentication table row without unrestricted Nonce field.

const TInt KNSmlAgentLogMaxFixedAuthRowSize = 320;

// Additional treshold used with OOD checks.

const TInt KNSmlAgentLogTreshold = 50;

_LIT8( KTabSeparator, " ");

//=============================================

//

//		CNSmlDSAgentLog

//

//=============================================

//=============================================

//		CNSmlDSAgentLog::NewL()

//		Creates a new instance of CNSmlDSAgentLog object.

//=============================================

EXPORT_C CNSmlDSAgentLog* CNSmlDSAgentLog::NewL()

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::NewL"));

	CNSmlDSAgentLog* self = CNSmlDSAgentLog::NewLC();	

	CleanupStack::Pop();

	return self;

	}	

//=============================================

//		CNSmlDSAgentLog::NewLC()

//		Creates a new instance of CNSmlDSAgentLog object. 

//		Pushes and leaves new instance into CleanupStack.

//=============================================

EXPORT_C CNSmlDSAgentLog* CNSmlDSAgentLog::NewLC()

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::NewLC"));

	CNSmlDSAgentLog* self = new ( ELeave ) CNSmlDSAgentLog;

	CleanupStack::PushL( self );

	self->ConstructL();	

	return self;

	}

//=============================================

//		CNSmlDSAgentLog::ConstructL()

//		Second phase constructor.

//=============================================

void CNSmlDSAgentLog::ConstructL()

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::ConstructL(): begin"));

	iLocalDB = HBufC::NewL( KNSmlMaxStringColumnLength );

	iServerId = HBufC::NewL( KNSmlMaxServerIdLength );

	iRemoteDB = HBufC::NewL( KNSmlMaxStringColumnLength );

	User::LeaveIfError( iFsSession.Connect() );	

	User::LeaveIfError( iRdbSession.Connect() );

    iFsSession.SetSessionToPrivate( KNSmlAgentLogDbDrive );

    TParse name;

    TBool createdDatabase = EFalse;

#ifdef SYMBIAN_SECURE_DBMS

	name.Set( KNSmlAgentLogDbName(), NULL, NULL );

#else

    name.Set( KNSmlAgentLogDbName(), KNSmlDatabasesNonSecurePath, NULL );

#endif

	// PP: data compatibility fix: If incompatible database is 

    // found, it will be deleted & recreated.

    TInt retry0(5);

    while ( retry0>0 )

        {

        retry0 = retry0 - 1;

	    TInt err = iDatabase.Open( iRdbSession /*iFsSession*/,

	                               name.FullName(),

	                               KNSmlDBMSSecureSOSServerID );

	    if (err == KErrNone)

	    	{

	    	User::LeaveIfError( iTableAgentLog.Open( iDatabase, KNSmlTableAgentLog ) );

	    	iColSet = iTableAgentLog.ColSetL();

	    	//RD_SUSPEND_RESUME	

	    	if (iColSet->ColNo( KNSmlAgentLogSuspendedState ) == KDbNullColNo

	    			|| iColSet->ColNo( KNSmlAgentLogPreviousSyncType ) == KDbNullColNo 

	    			|| iColSet->ColNo( KNSmlAgentLogPreviousClientSyncType ) == KDbNullColNo)

       			{

	    		iTableAgentLog.Close();

	    		iDatabase.Close();

	    		TInt error = iRdbSession.DeleteDatabase( name.FullName(), KNSmlSOSServerPolicyUID );

       			if (error == KErrNone)

	       			{

	       			err = KErrNotFound;	

	       			}

       			}

	    	}

	    if ( err == KErrNotFound )

		    {

		    CreateDatabaseL( name.FullName() );

		    User::LeaveIfError( iDatabase.Open( iRdbSession,

		                                        name.FullName(),

		                                        KNSmlDBMSSecureSOSServerID ) );

		    createdDatabase = ETrue;

		    }

	    else

		    {

		    User::LeaveIfError( err );

		    }

		if (createdDatabase) 

			{

			User::LeaveIfError( iTableAgentLog.Open( iDatabase, KNSmlTableAgentLog ) );

		    iColSet = iTableAgentLog.ColSetL();

			}

	    User::LeaveIfError( iTableAuthentication.Open( iDatabase, KNSmlTableAuthentication ) );

	    iColSetTableAuth = iTableAuthentication.ColSetL();

        TInt err2 = iTableDatastore.Open( iDatabase, KNSmlTableDatastore() );

        // Table datastore missing => must delete db

        if ( err2==KErrNotFound )

            {

	        delete iColSetTableDS;

	        iColSetTableDS = NULL;

	        delete iColSetTableAuth;

	        iColSetTableAuth = NULL;

            iTableAgentLog.Close();

            iTableAuthentication.Close();

            User::LeaveIfError(iDatabase.Destroy());

            }

        else

            {

            retry0=0;

	        User::LeaveIfError( err2 );

            }

        }

	iColSetTableDS = iTableDatastore.ColSetL();

	DBG_FILE(_S8("CNSmlDSAgentLog::ConstructL(): end"));

	}

//=============================================

//		CNSmlDSAgentLog::~CNSmlDSAgentLog()

//		Destructor.

//=============================================

CNSmlDSAgentLog::~CNSmlDSAgentLog()

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::~CNSmlDSAgentLog begins"));

	delete iLocalDB;

	delete iServerId;

	delete iRemoteDB;

	iView.Close();

	delete iColSet;

	iTableAgentLog.Close();

// <MAPINFO_RESEND_MOD_BEGIN>

	delete iColSetTableDS;

	iTableDatastore.Close();

// <MAPINFO_RESEND_MOD_END>

	delete iColSetTableAuth;

	iTableAuthentication.Close();

	iDatabase.Close();

	iFsSession.Close();

	iRdbSession.Close();

	DBG_FILE(_S8("CNSmlDSAgentLog::~CNSmlDSAgentLog ends"));

	}

//=============================================

//		CNSmlDSAgentLog::CreateDatabaseL()

//		Creates Agent Log database.

//=============================================

void CNSmlDSAgentLog::CreateDatabaseL(const TDesC& aFullName)

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::CreateDatabaseL begins"));

    // Check OOD before crating new AgentLog database

    if ( SysUtil::FFSSpaceBelowCriticalLevelL( &iFsSession,

            KNSmlAgentLogEmptyDatabaseSize + KNSmlAgentLogTreshold ) )

	    {

        User::Leave( KErrDiskFull );

		}

	_LIT( KCreateAgentLogTable, "CREATE TABLE AgentLog ( Id INTEGER NOT NULL, \

ImplementationUID INTEGER NOT NULL,  LocalDatabase CHAR(%d) NOT NULL, \

ServerId CHAR(%d), RemoteDatabase CHAR(%d) NOT NULL, \

LastSyncronised TIMESTAMP, SyncAnchor TIMESTAMP, SlowSyncRequest INTEGER, \

ServerDeviceInfo LONG VARCHAR, ServerSupportsNOC BIT, ServerSyncTypes INTEGER, \

ServerFilterInfo LONG VARCHAR, ServerSupportsHierarchicalSync BIT ,\

SyncSuspendedState INTEGER,PreviousSyncType INTEGER,\

PreviousClientSyncType INTEGER)" );

//RD_SUSPEND_RESUME- 3 new columns added

	_LIT( KCreateAuthenticationTable, "CREATE TABLE Authentication ( ServerId \

CHAR(%d), Nonce LONG VARCHAR, Type INTEGER, SessionId INTEGER )" );

// <MAPINFO_RESEND_MOD_BEGIN>

	_LIT( KCreateDatastoreTable, "CREATE TABLE %S ( %S COUNTER NOT NULL, \

	%S INTEGER NOT NULL, %S INTEGER NOT NULL, %S LONG VARBINARY )" );

// <MAPINFO_RESEND_MOD_END>

	_LIT( KCreateVersionTable, "CREATE TABLE Version ( \

VerMajor UNSIGNED TINYINT, VerMinor UNSIGNED TINYINT )" );

	HBufC* createAgentLogTable = HBufC::NewLC( KCreateAgentLogTable().Length() + 20 );

	TPtr agentLogTablePtr = createAgentLogTable->Des();

	HBufC* createAuthenticationTable = HBufC::NewLC( KCreateAuthenticationTable().Length() + 10);

	TPtr authenticationTablePtr = createAuthenticationTable->Des();

// <MAPINFO_RESEND_MOD_BEGIN>

	HBufC* createDatastoreTable = HBufC::NewLC( KCreateDatastoreTable().Length() * 3);

	TPtr datastoreTablePtr = createDatastoreTable->Des();

// <MAPINFO_RESEND_MOD_END>

	agentLogTablePtr.Format( KCreateAgentLogTable, KNSmlMaxDataLength,

	    KNSmlMaxServerIdLength, KNSmlMaxRemoteNameLength );

	authenticationTablePtr.Format( KCreateAuthenticationTable, KNSmlMaxServerIdLength );

// <MAPINFO_RESEND_MOD_BEGIN>

	datastoreTablePtr.Format(KCreateDatastoreTable(), &KNSmlTableDatastore(), &KNSmlDatastoreRowID(), &KNSmlDatastoreAgentlogID(), &KNSmlDatastoreStreamID(), &KNSmlDatastoreStreamData());

// <MAPINFO_RESEND_MOD_END>

	User::LeaveIfError( iDatabase.Create( iRdbSession,

	                                      aFullName,

	                                      KNSmlDBMSSecureSOSServerID ) );

	iDatabase.Begin();

	iDatabase.Execute( *createAgentLogTable );

	iDatabase.Execute( *createAuthenticationTable );

// <MAPINFO_RESEND_MOD_BEGIN>

	iDatabase.Execute( *createDatastoreTable );

// <MAPINFO_RESEND_MOD_END>

	iDatabase.Execute( KCreateVersionTable() );

	RDbTable table;

	User::LeaveIfError( table.Open( iDatabase, KNSmlTableVersion() ) );

	CleanupClosePushL( table );

	CDbColSet* colSet = table.ColSetL();

	CleanupStack::PushL( colSet );

	table.InsertL();

	table.SetColL( colSet->ColNo( KNSmlVersionColumnMajor ), KNSmlAgentLogCurrentVersionMajor );

	table.SetColL( colSet->ColNo( KNSmlVersionColumnMinor ), KNSmlAgentLogCurrentVersionMinor );

	table.PutL();

	CommitAndCompact();

	iDatabase.Close();

	DBG_FILE(_S8("CNSmlDSAgentLog::CreateDatabaseL ends"));

// <MAPINFO_RESEND_MOD_BEGIN>

	CleanupStack::PopAndDestroy( 5 ); // createAgentLogTable, createAuthenticationTable, colset, table

	//CleanupStack::PopAndDestroy( 4 ); // createAgentLogTable, createAuthenticationTable, colset, table

// <MAPINFO_RESEND_MOD_END>

	}	

//=============================================

//		CNSmlDSAgentLog::SetAgentLogKeyL()

//		Sets AgentLog key with given string values.

//=============================================

EXPORT_C void CNSmlDSAgentLog::SetAgentLogKeyL( const TInt aImplUid, const TDesC& aLocalDB, const TDesC& aServerId, const TDesC& aRemoteDB )

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::SetAgentLogKeyL begins"));

	HBufC* sql = HBufC::NewLC( KSQLGetAgentLogRow().Length() + 5 + aLocalDB.Length() + aServerId.Length() );

	TPtr sqlPtr = sql->Des();

	sqlPtr.Format( KSQLGetAgentLogRow, aImplUid, &aLocalDB, &aServerId );

	PrepareViewL( *sql, iView.EReadOnly );

	if ( iView.FirstL() )

		{

			for(TInt i = 0; i < iView.CountL() ; i++ )

			{

		iView.GetL();

				if( aRemoteDB.CompareF( iView.ColDes16( iColSet->ColNo( KNSmlAgentLogRemoteDatabase  ) ) ) == 0 )

				{

		iID = iView.ColInt( iColSet->ColNo( KNSmlAgentLogId ) );

					i = iView.CountL() ; // terminates the loop

				}

				else

				{

					iView.NextL();	

				}

			}

		}

	else

		{

		iID = KNSmlNewObject;

		}

	CleanupStack::PopAndDestroy( 1 ); // sql

	iImplUid = aImplUid;

	*iLocalDB = aLocalDB;

	*iServerId = aServerId;

	*iRemoteDB = aRemoteDB;

	DBG_FILE(_S8("CNSmlDSAgentLog::SetAgentLogKeyL ends"));

	}

//=============================================

//		CNSmlDSAgentLog::SetIntValueL()

//		Sets given integer value.

//=============================================

EXPORT_C void CNSmlDSAgentLog::SetIntValueL( TNSmlAgentLogData aType, const TInt aNewValue )

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::SetIntValueL begins"));

	// BPSS-7NZESW : return if remote database value is empty

	if ( iLocalDB == NULL || iServerId == NULL ||iRemoteDB == NULL || iRemoteDB->Length() < 1  )

		{

		return;

		}

	TBuf<32> columnName;

	TInt setValue( aNewValue );

	switch ( aType )

		{

		case ( EAgentLogSlowSyncRequest ) :

			columnName = KNSmlAgentLogSlowSyncRequest;

			break;

		case ( EAgentLogServerSupportsNOC ) :

			columnName = KNSmlAgentLogServerSupportsNOC;

			// Make sure that value is 1 or 0

			if ( setValue )

				{

				setValue = 1;

				}

			else

				{

				setValue = 0;

				}

			break;

		case ( EAgentLogServerSupportsHierarchicalSync ) :

			columnName = KNSmlAgentLogServerSupportsHierarchicalSync ;

			// Make sure that value is 1 or 0

			if ( setValue )

				{

				setValue = 1;

				}

			else

				{

				setValue = 0;

				}

			break;

		case ( EAgentLogServerSyncTypes ) :

			columnName = KNSmlAgentLogServerSyncTypes;

			break;

		//RD_SUSPEND_RESUME

		case (EAgentLogSyncSuspendedState) :

			columnName = KNSmlAgentLogSuspendedState;

			break;

		case (EAgentLogPreviousSyncType) :

		     columnName=KNSmlAgentLogPreviousSyncType;

		     break;

		case (EAgentLogPreviousClientSyncType):

		     columnName=KNSmlAgentLogPreviousClientSyncType;

		     break;

		default:

			User::Panic( KNSmlIndexOutOfBoundStr, KNSmlPanicIndexOutOfBound );

		}

	HBufC* sql = AgentLogRowSqlLC();

	PrepareViewL( *sql, iView.EUpdatable );

	iDatabase.Begin();

	if ( iView.FirstL() )

		{

		//existing row

		iView.GetL();

		iView.UpdateL();

		iView.SetColL( iColSet->ColNo( columnName ), setValue );

		iView.PutL();

		}

	else

		{

		//new row

		InitNewRowL();

		iTableAgentLog.SetColL( iColSet->ColNo( columnName ), setValue );

		iTableAgentLog.PutL();		

		}	

	CommitAndCompact();

	CleanupStack::PopAndDestroy( 1 ); // sql

	DBG_FILE(_S8("CNSmlDSAgentLog::SetIntValueL ends"));

	}

//=============================================

//		CNSmlDSAgentLog::IntValueL()

//		Gets given integer value.

//=============================================

EXPORT_C TInt CNSmlDSAgentLog::IntValueL( TNSmlAgentLogData aType )

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::IntValueL begins"));

	HBufC* sql = AgentLogRowSqlLC();

	TBuf<30>columnName;

	switch ( aType )

		{

		case ( EAgentLogSlowSyncRequest ) :

			columnName = KNSmlAgentLogSlowSyncRequest;

			break;

		case ( EAgentLogServerSupportsNOC ) :

			columnName = KNSmlAgentLogServerSupportsNOC;

			break;

		case ( EAgentLogServerSyncTypes ) :

			columnName = KNSmlAgentLogServerSyncTypes;

			break;

		case EAgentLogServerSupportsHierarchicalSync:

			columnName = KNSmlAgentLogServerSupportsHierarchicalSync;

			break;

		//RD_SUSPEND_RESUME

		case (EAgentLogSyncSuspendedState) :

			columnName = KNSmlAgentLogSuspendedState;

			break;

		case (EAgentLogPreviousSyncType) :

		     columnName=KNSmlAgentLogPreviousSyncType;

             break;

		case(EAgentLogPreviousClientSyncType):

		    columnName=KNSmlAgentLogPreviousClientSyncType;

		    break;

		 //RD_SUSPEND_RESUME

		default:

			{

			User::Panic( KNSmlIndexOutOfBoundStr, KNSmlPanicIndexOutOfBound );

			}

		}

	PrepareViewL( *sql, iView.EReadOnly );

	TInt status( 0 );

	if ( iView.FirstL() )

		{

		iView.GetL();

		status = iView.ColInt( iColSet->ColNo( columnName ) );

		}

	CleanupStack::PopAndDestroy( 1 ); // sql 

	DBG_FILE(_S8("CNSmlDSAgentLog::IntValueL ends"));

	return status;

	}

//=============================================

//		CNSmlDSAgentLog::SetTimeValueL()

//		Sets given datetime value.

//=============================================

EXPORT_C void CNSmlDSAgentLog::SetTimeValueL( TNSmlAgentLogData aType, const TTime& aNewValue )

	{

	DBG_FILE(_S8("CNSmlDSAgentLog::SetTimeValueL begins"));

	if ( iLocalDB == NULL || iServerId == NULL || iRemoteDB == NULL )

		{

		return;

		}

	HBufC* sql = AgentLogRowSqlLC();

	TBuf<20> columnName;

	switch ( aType )

		{

		case ( EAgentLogLastSyncronised ) :

			{

			columnName.Format( KColumn, &KNSmlAgentLogLastSyncronised );

			}

		break;

		case ( EAgentLogLastSyncAnchor ) :

			{

			columnName.Format( KColumn, &KNSmlAgentLogLastSyncAnchor );

			}

		break;