/*

* Copyright (c) 2004 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:  DS-settings 

*

*/

// INCLUDE FILES

#include <sysutil.h>

#include <nsmlconstants.h>

#include <nsmldsconstants.h>

#include "nsmldssettings.h"

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

//

//		CNSmlDSProfile

//

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

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

//		CNSmlDSProfile::NewL()

//		Creates a new instance of CNSmlDSProfile object. 

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

CNSmlDSProfile* CNSmlDSProfile::NewL( RDbNamedDatabase* aDatabase )

	{

	CNSmlDSProfile* self = CNSmlDSProfile::NewLC( aDatabase );

	CleanupStack::Pop();

	return self;

	}

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

//		CNSmlDSProfile::NewLC()

//		Creates a new instance of CNSmlDSProfile object. 

//		Pushes and leaves new instance into CleanupStack.

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

CNSmlDSProfile* CNSmlDSProfile::NewLC( RDbNamedDatabase* aDatabase )

	{

	CNSmlDSProfile* self = new( ELeave ) CNSmlDSProfile;

	CleanupStack::PushL( self );

	self->ConstructL( aDatabase );

	return self;

	}

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

//		CNSmlDSProfile::ConstructL()

//		Second phase constructor.

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

void CNSmlDSProfile::ConstructL( RDbNamedDatabase* aDatabase )

	{

	iDatabase = aDatabase;

	iId = KNSmlNewObject;

	User::LeaveIfError( iTableProfiles.Open( *iDatabase, KNSmlTableProfiles ) );

    iColSetProfiles = iTableProfiles.ColSetL();

	User::LeaveIfError( iTableAdapters.Open( *iDatabase, KNSmlTableAdapters ) );	

	iColSetAdapters = iTableAdapters.ColSetL();

	iDisplayName = HBufC::NewL( KNSmlMaxProfileNameLength );

	iSyncServerUsername = HBufC::NewL( KNSmlMaxUsernameLength );

	iSyncServerPassword = HBufC::NewL( KNSmlMaxPasswordLength );

	iServerURL = HBufC::NewL( KNSmlMaxURLLength );

	iServerId = HBufC::NewL( KNSmlMaxServerIdLength );

	iHttpAuthUsername = HBufC::NewL( KNSmlMaxHttpAuthUsernameLength );

	iHttpAuthPassword = HBufC::NewL( KNSmlMaxHttpAuthPasswordLength );

	iContentTypes = new ( ELeave ) CArrayPtrFlat<CNSmlDSContentType>( KSmlArrayGranularity );

	}

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

//		CNSmlDSProfile::~CNSmlDSProfile()

//		Destructor.

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

EXPORT_C CNSmlDSProfile::~CNSmlDSProfile()

	{

	delete iDisplayName;

	delete iSyncServerUsername;

	delete iSyncServerPassword;

	delete iServerURL;

	delete iServerId;

	delete iHttpAuthUsername;

	delete iHttpAuthPassword;

	iView.Close();

	iRSView.Close();

	iWSView.Close();

	delete iColSetProfiles;

	delete iColSetAdapters;

	iTableAdapters.Close();

	iTableProfiles.Close();

	iContentTypes->ResetAndDestroy();

	delete iContentTypes;

	}

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

//		CNSmlDSProfile::AddContentTypeL()

//		Appends a new content type to iContentTypes -list,

//		if it doesn't exist before.

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

 EXPORT_C CNSmlDSContentType* CNSmlDSProfile::AddContentTypeL( TInt aImplementationUID, TDesC& aClientDataSource, TDesC& aServerDataSource )

	{

	if ( ContentType( aImplementationUID ) ) // Check if type already on the list

		{

		return NULL;

		}

	iAdapterId = KNSmlNewObject;

	iContentTypes->AppendL( CNSmlDSContentType::NewLC( this->iDatabase ) );

	CleanupStack::Pop();

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetIntValue( EDSAdapterTableId,   iAdapterId);	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetIntValue( EDSAdapterProfileId, iId);	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetIntValue( EDSAdapterImplementationId, aImplementationUID);	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetIntValue( EDSAdapterEnabled, TRUE);	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetIntValue( EDSAdapterCreatorId, iCreatorId);	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetStrValue( EDSAdapterServerDataSource, aServerDataSource );	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetStrValue( EDSAdapterClientDataSource, aClientDataSource );	

	( iContentTypes->At( iContentTypes->Count() -1 ) )->SetIntValue( EDSAdapterFilterMatchType, ESyncMLMatchDisabled );	

	return iContentTypes->At( iContentTypes->Count() - 1 );

	}

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

//		CNSmlDSProfile::ContentType()

//		Returns a pointer to a CNSmlDSContentType 

//		object with given ImplementationUID.

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

EXPORT_C CNSmlDSContentType* CNSmlDSProfile::ContentType( TInt aImplementationUID ) const

	{

	for ( TInt i = 0; i < iContentTypes->Count(); i++ )

		{

		if ( iContentTypes->At( i )->IntValue( EDSAdapterImplementationId ) == aImplementationUID )

			{

			return iContentTypes->At( i );

			}

		}

	return NULL;

	}

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

//		CNSmlDSProfile::ContentTypeId()

//		Returns a pointer to a CNSmlDSContentType 

//		object with given content id.

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

EXPORT_C CNSmlDSContentType* CNSmlDSProfile::ContentTypeId( TInt aId ) const

	{

	for ( TInt i = 0; i < iContentTypes->Count(); i++ )

		{

		if ( iContentTypes->At( i )->IntValue( EDSAdapterTableId ) == aId )

			{

			return iContentTypes->At( i );

			}

		}

	return NULL;

	}

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

//		CNSmlDSProfile::DeleteContentTypeL()

//		Delete object with given task id.

//		

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

EXPORT_C TBool CNSmlDSProfile::DeleteContentTypeL( TInt aTaskId ) 

	{

	HBufC* sqlStatement = HBufC::NewLC( KDSSQLGetAdapterId().Length() + KNSmlDsSettingsMaxIntegerLength);

	TPtr sqlStatementPtr = sqlStatement->Des();

	TInt err;

	for ( TInt i = 0; i < iContentTypes->Count(); i++ )

		{

		if ( iContentTypes->At( i )->IntValue( EDSAdapterTableId ) == aTaskId )

			{

//

//			Remove first from database

//

			iDatabase->Begin();

			sqlStatementPtr.Format( KDSSQLGetAdapterId, aTaskId );

			PrepareViewL( sqlStatementPtr, iView.EUpdatable );

			if ( iView.FirstL() )

				{

				iView.GetL();

				iAdapterId = iView.ColUint( iColSetAdapters->ColNo( KNSmlAdapterId ) );

				}

			sqlStatementPtr.Format( KDSSQLDeleteAdapterById, iAdapterId );

			err = iDatabase->Execute( sqlStatementPtr );

			CleanupStack::PopAndDestroy(); // sqlStatement

			if ( err < KErrNone )

				{

				iDatabase->Rollback();

				return EFalse;

				}

			CommitAndCompact();

//

//			Delete object from list

//

			CNSmlDSContentType* contentType = ContentTypeId( iAdapterId );

			delete contentType;

			contentType = 0;

//

//			Remove it also from list

//

			iContentTypes->Delete( i );

			iContentTypes->Compress();

			return ETrue;

			}

		}

	CleanupStack::PopAndDestroy(); // sqlStatement

	return EFalse;

	}

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

//		CNSmlDSProfile::SaveL()

//		Saves a profile ie. writes all profile data to the database.

//		If save is successful returns KErrNone,

//		otherwise returns negative integer (defined in EPOC error codes).

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

EXPORT_C TInt CNSmlDSProfile::SaveL()

	{

	if ( iDatabase->InTransaction() )

		{

		return ( KErrAccessDenied );

		}	

	iDatabase->Begin();

	CNSmlDSCrypt* crypt = new( ELeave ) CNSmlDSCrypt;

	CleanupStack::PushL( crypt );

	if ( iId == KNSmlNewObject )

		{

		// Check OOD before saving a New profile

		RFs fs;

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

		CleanupClosePushL(fs);

		if (SysUtil::FFSSpaceBelowCriticalLevelL(&fs, KNSmlDsSettingsFatMinSize))

			{

			CleanupStack::PopAndDestroy(2); // fs, crypt

			iDatabase->Rollback();

			return KErrDiskFull;

			// do not write

			}

		CleanupStack::PopAndDestroy(); //fs

		//new profile

		iTableProfiles.InsertL();

		TableProfilesSetColDesL( KNSmlDSProfileDisplayName,	*iDisplayName );

		TableProfilesSetColIntL( KNSmlDSProfileTransportId, iTransportId );

		TableProfilesSetColIntL( KNSmlDSProfileIAPId, iIAPId );

		TableProfilesSetColDesL( KNSmlDSProfileSyncServerUsername, *iSyncServerUsername );

		TableProfilesSetColDesL( KNSmlDSProfileSyncServerPassword, crypt->EncryptedL( *iSyncServerPassword) );	

		TableProfilesSetColDesL( KNSmlDSProfileServerURL,	*iServerURL );

		TableProfilesSetColDesL( KNSmlDSProfileServerId,	*iServerId );

		TableProfilesSetColIntL( KNSmlDSProfileServerAlertedAction, iServerAlertedAction );

		TableProfilesSetColIntL( KNSmlDSProfileDeleteAllowed, iDeleteAllowed );

		TableProfilesSetColIntL( KNSmlDSProfileHidden, iProfileHidden );

		TableProfilesSetColIntL( KNSmlDSProfileHttpAuthUsed, iHttpAuthUsed );

		TableProfilesSetColDesL( KNSmlDSProfileHttpAuthUsername, *iHttpAuthUsername );

		TableProfilesSetColDesL( KNSmlDSProfileHttpAuthPassword, crypt->EncryptedL( *iHttpAuthPassword) );	

		TableProfilesSetColIntL( KNSmlDSProfileAutoChangeIAP, iAutoChangeIAP );

		TableProfilesSetColIntL( KNSmlDSProfileCreatorID, iCreatorId );

		HBufC* v = GetVisibilityStrL();

		CleanupStack::PushL(v);

		TableProfilesSetColDesL( KNSmlDSProfileVisibilityStr, *v);

		CleanupStack::PopAndDestroy(); // v

		TableProfilesSetColIntL( KNSmlDSProfileProtocolVersion, iProtocolVersion );

        TBuf<64> sqlStatement;

        sqlStatement.Format( KDSSQLCountProfiles );

    	PrepareViewL( sqlStatement, iView.EReadOnly );

		iId = iTableProfiles.ColUint( iColSetProfiles->ColNo( KNSmlDSProfileId) ); // Use autoincrement

  		iTableProfiles.PutL();

		for ( TInt i = 0; i < iContentTypes->Count(); i++ )

			{

			if( iContentTypes->At(i)->StrValue( EDSAdapterClientDataSource ).Compare( 

				iContentTypes->At(i)->StrValue( EDSAdapterServerDataSource ) ) == 0 )

				{

				iDatabase->Rollback();

				CleanupStack::PopAndDestroy();  //crypt

				return KErrArgument;			

				}

			InsertTableAdaptersL( i );

			}

		}

	else

		{

		//existing profile

		TBuf<64> sqlStatement;

		sqlStatement.Format( KDSSQLGetProfile, iId );

		PrepareViewL( sqlStatement, iView.EUpdatable );

		if ( iView.FirstL() )

			{

			iView.GetL();

			iView.UpdateL();

			ViewSetColDesL( KNSmlDSProfileDisplayName, *iDisplayName );

			ViewSetColIntL( KNSmlDSProfileTransportId, iTransportId );

			ViewSetColIntL( KNSmlDSProfileIAPId, iIAPId );

			ViewSetColDesL( KNSmlDSProfileSyncServerUsername, *iSyncServerUsername );

			ViewSetColDesL( KNSmlDSProfileSyncServerPassword, crypt->EncryptedL( *iSyncServerPassword ) );

			ViewSetColDesL( KNSmlDSProfileServerURL, *iServerURL );

			ViewSetColDesL( KNSmlDSProfileServerId, *iServerId );

			ViewSetColIntL( KNSmlDSProfileServerAlertedAction, iServerAlertedAction );

			ViewSetColIntL( KNSmlDSProfileDeleteAllowed, iDeleteAllowed );

			ViewSetColIntL( KNSmlDSProfileHidden, iProfileHidden );

			ViewSetColIntL( KNSmlDSProfileHttpAuthUsed, iHttpAuthUsed );

			ViewSetColDesL( KNSmlDSProfileHttpAuthUsername, *iHttpAuthUsername );

			ViewSetColDesL( KNSmlDSProfileHttpAuthPassword, crypt->EncryptedL( *iHttpAuthPassword) );	

			ViewSetColIntL( KNSmlDSProfileAutoChangeIAP, iAutoChangeIAP );

			ViewSetColIntL( KNSmlDSProfileCreatorID, iCreatorId );

			HBufC* v = GetVisibilityStrL();

			CleanupStack::PushL(v);

			ViewSetColDesL( KNSmlDSProfileVisibilityStr, *v);

			CleanupStack::PopAndDestroy(); // v

			ViewSetColIntL( KNSmlDSProfileProtocolVersion, iProtocolVersion );

			iView.PutL();

			}

		else

			{

			iDatabase->Rollback();

			CleanupStack::PopAndDestroy();  //crypt

			return KErrNotFound;

			}

		for ( TInt i = 0; i < iContentTypes->Count(); i++ )

			{

			if( iContentTypes->At(i)->StrValue( EDSAdapterClientDataSource ).Compare( 

				iContentTypes->At(i)->StrValue( EDSAdapterServerDataSource ) ) == 0 )

				{

				iDatabase->Rollback();

				CleanupStack::PopAndDestroy();  //crypt

				return KErrArgument;			

				}

			if ( iContentTypes->At( i )->IntValue( EDSAdapterTableId ) == KNSmlNewObject )

				{

				//existing profile & new contentType

				InsertTableAdaptersL( i );

				}

			else

				{

				//existing profile & existing contentType

				sqlStatement.Format( KDSSQLFindContentType, iContentTypes->At( i )->IntValue( EDSAdapterTableId ) );

				PrepareViewL( sqlStatement, iView.EUpdatable );

				if ( iView.FirstL() )

					{

					iView.GetL();

					iView.UpdateL();

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterEnabled ), ( TInt ) iContentTypes->At( i )->IntValue( EDSAdapterEnabled ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterImlementationUID ), ( TInt ) iContentTypes->At( i )->IntValue( EDSAdapterImplementationId ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterCreatorID ), ( TInt ) iContentTypes->At( i )->IntValue( EDSAdapterCreatorId ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterDisplayName ), iContentTypes->At( i )->StrValue( EDSAdapterDisplayName ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterClientDataSource ), iContentTypes->At( i )->StrValue( EDSAdapterClientDataSource ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterServerDataSource ), iContentTypes->At( i )->StrValue( EDSAdapterServerDataSource ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterSyncType ), ( TInt ) iContentTypes->At( i )->IntValue( EDSAdapterSyncType ) );

					iView.SetColL( iColSetAdapters->ColNo( KNSmlAdapterFilterMatchType ), ( TInt ) iContentTypes->At( i )->IntValue( EDSAdapterFilterMatchType ) );

					iView.PutL();

					}

				else

					{

					iDatabase->Rollback();

					CleanupStack::PopAndDestroy();  //crypt

					return KErrNotFound;

					}

				}

			}

		}

	CleanupStack::PopAndDestroy();  //crypt

	CommitAndCompact();

	return KErrNone;

	}

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

//		CNSmlDSProfile::IsNew()

//		Returns true if profile is new, otherwise false.

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

EXPORT_C TBool CNSmlDSProfile::IsNew() const

	{

	return ( iId == KNSmlNewObject );

	}

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

//		CNSmlDSProfile::SetHiddenL()

//		Returns true if update done otherwise false.

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

EXPORT_C TBool CNSmlDSProfile::SetHiddenL(TBool aHidden)

	{

	TBool ret = EFalse;

	if (iId < 1) 

		{

		return ret;			

		}

	HBufC* sqlStatement = HBufC::NewLC( KDSSQLGetProfile().Length() + KNSmlDsSettingsMaxIntegerLength);

	TPtr sqlStatementPtr = sqlStatement->Des();

	sqlStatementPtr.Format( KDSSQLGetProfile, iId );

	PrepareViewL( sqlStatementPtr, iView.EUpdatable );

	CleanupStack::PopAndDestroy(); // sqlStatement

	if ( iView.FirstL() )

		{

		iView.GetL();

		iView.UpdateL();

		iView.SetColL( iColSetProfiles->ColNo( KNSmlDSProfileHidden ), aHidden );

		iView.PutL();

		ret = ETrue;

		// Also profile value set for SaveL()

		SetIntValue( EDSProfileHidden, aHidden);

		}

	return ret;

	}

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

//		CNSmlDSProfile::IsNullL()

//		Returns true if profile data is NULL, 

//      otherwise false.

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

EXPORT_C TBool CNSmlDSProfile::IsNullL( const TDesC& aFieldName ) 

	{

	HBufC* sqlStatement = HBufC::NewLC( KDSSQLGetProfile().Length() + KNSmlDsSettingsMaxIntegerLength);

	TPtr sqlStatementPtr = sqlStatement->Des();

	sqlStatementPtr.Format( KDSSQLGetProfile, iId );

	PrepareViewL( sqlStatementPtr, iView.EReadOnly );

	CleanupStack::PopAndDestroy(); // sqlStatement

	if ( iView.FirstL() )

		{

		iView.GetL();

		if ( iView.IsColNull( iColSetProfiles->ColNo( aFieldName ) ) )

			{

			return ETrue;

			}

		}

	return EFalse;

	}

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

//		CNSmlDSProfile::StrValue()

//		Returns a given string value.

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

EXPORT_C const TDesC& CNSmlDSProfile::StrValue( TNSmlDSProfileData aProfileItem ) const

	{	

	HBufC* result = 0;

	switch ( aProfileItem )

		{

		case ( EDSProfileDisplayName ) :

			{

			result = iDisplayName;

			}

		break;

		case ( EDSProfileSyncServerUsername ) :

			{

			result = iSyncServerUsername;