/*

* 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:    DS-settings adapter

*

*/

// INCLUDE FILES

#include "NSmlDSSettingsAdapter.h"

#include "nsmldebug.h"

#include "nsmlconstants.h"

#include "nsmldmconstants.h"

#include "nsmldmimpluids.h"

#include "nsmldmiapmatcher.h"

#include <implementationproxy.h>

#include <badesca.h>

#include <utf.h>

#include <SyncMLTransportProperties.h>

#ifndef __WINS__

// This lowers the unnecessary compiler warning (armv5) to remark.

// "Warning:  #174-D: expression has no effect..." is caused by 

// DBG_ARGS8 macro in no-debug builds.

#pragma diag_remark 174

#endif

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

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

//  CNSmlDSSettingsAdapter::NewL

//  Two-phased constructor.

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

CNSmlDSSettingsAdapter* CNSmlDSSettingsAdapter::NewL( MSmlDmCallback* aDmCallback )

	{

	_DBG_FILE("CNSmlDSSettingsAdapter::NewL(): begin");

	CNSmlDSSettingsAdapter* self = NewLC( aDmCallback );

	CleanupStack::Pop();

	_DBG_FILE("CNSmlDSSettingsAdapter::NewL(): end");

	return self;

	}

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

//  CNSmlDSSettingsAdapter::NewLC

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

CNSmlDSSettingsAdapter* CNSmlDSSettingsAdapter::NewLC(MSmlDmCallback* aDmCallback )

	{

	_DBG_FILE("CNSmlDSSettingsAdapter::NewLC(): begin");

	CNSmlDSSettingsAdapter* self = new ( ELeave ) CNSmlDSSettingsAdapter( aDmCallback );

	CleanupStack::PushL( self );

	self->iCallBack = aDmCallback;

	self->ConstructL();

	self->iLeafType = EDSUnset;

	_DBG_FILE("CNSmlDSSettingsAdapter::NewLC(): end");

	return self;

	}

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

// CNSmlDSSettingsAdapter::CNSmlDSSettingsAdapter

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

CNSmlDSSettingsAdapter::CNSmlDSSettingsAdapter(TAny* aEcomArguments) : CSmlDmAdapter(aEcomArguments)

	{

	_DBG_FILE("CNSmlDSSettingsAdapter::CNSmlDSSettingsAdapter(): begin");

	_DBG_FILE("CNSmlDSSettingsAdapter::CNSmlDSSettingsAdapter(): end");

	}

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

//  CNSmlDSSettingsAdapter::~CNSmlDSSettingsAdapter()

//  Class destructor.

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

CNSmlDSSettingsAdapter::~CNSmlDSSettingsAdapter()

	{

	_DBG_FILE("CNSmlDSSettingsAdapter::~CNSmlDSSettingsAdapter(): begin");

    delete iPrevURI;

    delete iField;

	// Command buffer cleaning

	if ( iBuffer )

		{

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

			{

			delete iBuffer->At(i).iMappingName;

			delete iBuffer->At(i).iName;

			for( TInt j=0; j<iBuffer->At(i).iNodeBuf->Count(); j++ )

				{

				delete iBuffer->At(i).iNodeBuf->At(j).iUri;

				if( iBuffer->At(i).iNodeBuf->At(j).iData )

					{

					delete iBuffer->At(i).iNodeBuf->At(j).iData;

					}

				}

			iBuffer->At(i).iNodeBuf->Reset();

			delete iBuffer->At(i).iNodeBuf;

			}

		iBuffer->Reset();

		delete iBuffer;

		}

    iDSProfile.Close();

    iSyncSession.Close();

    iSyncSessionOpen = EFalse;

    delete iPortNbr;

    delete iPortBuf;

    delete iRdbDataStore;

    iBufferExecution = EFalse;

    iCallBack = 0;

	_DBG_FILE("CNSmlDSSettingsAdapter::~CNSmlDSSettingsAdapter(): end");

	}

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

//		CNSmlDSSettingsAdapter::ConstructL

//		Second phase constructor.

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

void CNSmlDSSettingsAdapter::ConstructL()

	{

	iField = HBufC8::NewL( KNSmlMaxURLLength );

	iPrevURI = HBufC8::NewL( KNSmlMaxURLLength );

    iRdbDataStore = HBufC16::NewL( KNSmlMaxRemoteNameLength );

//

//	Command buffering used for AddNode + AddLeaf

//

	iBuffer = new ( ELeave ) CArrayFixFlat <TNSmlDSBufferElement> ( KNSmlDSGranularity );

    iSyncSessionOpen = EFalse;

    iPortNbr = 0;

    iBufferExecution = EFalse;

	}

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

//  CNSmlDSSettingsAdapter::DDFVersionL

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

void CNSmlDSSettingsAdapter::DDFVersionL(CBufBase& aVersion)

	{

	aVersion.InsertL( 0, KVersion );

    }

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

//  CNSmlDSSettingsAdapter::DDFStructureL

//  Fills the DDF structure of the adapter.

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

void CNSmlDSSettingsAdapter::DDFStructureL( MSmlDmDDFObject& aDDF )

	{

	_DBG_FILE("CNSmlDSSettingsAdapter::DDFStructureL(): begin");

	TSmlDmAccessTypes *aclTypes = new ( ELeave ) TSmlDmAccessTypes();

	CleanupStack::PushL( aclTypes );

    //  Set Get as acceptable operations

	aclTypes->SetGet();

    MSmlDmDDFObject* ddfRoot = &aDDF;

    MSmlDmDDFObject& ddf = ddfRoot->AddChildObjectL( KNSmlDdfRoot );

    FillNodeInfoL( ddf, *aclTypes, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EPermanent, MSmlDmDDFObject::ENode, 

                    KNSmlDdfRootDescription, KNullDesC8, KMimeType );

    ddf.SetDFTitleL( KDSSettingsTitle );

	MSmlDmDDFObject& nDSAcc = ddf.AddChildObjectL( KNSmlDefDSAcc );

	nDSAcc.SetOccurenceL( MSmlDmDDFObject::EOne );

	nDSAcc.SetDefaultValueL( KNullDesC8 );

	nDSAcc.SetScopeL( MSmlDmDDFObject::EPermanent );

	nDSAcc.SetAccessTypesL( *aclTypes );

	nDSAcc.SetDFFormatL( MSmlDmDDFObject::ENode );

//

//  Set rest acceptable operations for data itself

//

    aclTypes->SetAdd();

	aclTypes->SetReplace();

	aclTypes->SetDelete();

	TSmlDmAccessTypes aclTypesLimit;

	aclTypesLimit.SetGet();

	aclTypesLimit.SetAdd();

	TSmlDmAccessTypes aclTypesGet;

	aclTypesGet.SetGet();

	TSmlDmAccessTypes aclTypesNoGet;

	aclTypesNoGet.SetReplace();

	aclTypesNoGet.SetAdd();

	aclTypesNoGet.SetDelete();

	TSmlDmAccessTypes aclTypesNoDelete;

	aclTypesNoDelete.SetGet();

	aclTypesNoDelete.SetAdd();

	aclTypesNoDelete.SetReplace();

	MSmlDmDDFObject& nProDDF = nDSAcc.AddChildObjectGroupL();

    FillNodeInfoL( nProDDF, *aclTypes, MSmlDmDDFObject::EZeroOrMore, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::ENode, 

                    KNullDesC8, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nAddrDDF = nProDDF.AddChildObjectL(KNSmlDdfAddr);	// Addr

	FillNodeInfoL( nAddrDDF, *aclTypes, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfAddrDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nAddrTypeDDF = nProDDF.AddChildObjectL(KNSmlDdfAddrType);	// AddrType

    FillNodeInfoL( nAddrTypeDDF, *aclTypes, MSmlDmDDFObject::EZeroOrOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfAddrTypeDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nPortNbrDDF = nProDDF.AddChildObjectL(KNSmlDdfPortNbr);// PortNbr

	FillNodeInfoL( nPortNbrDDF, *aclTypes, MSmlDmDDFObject::EZeroOrOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EInt, 

                    KNSmlDdfPortNbrDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nNameDDF = nProDDF.AddChildObjectL(KNSmlDdfName);	// Name

	FillNodeInfoL( nNameDDF, *aclTypes, MSmlDmDDFObject::EZeroOrOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfNameDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nDBrootDDF = nProDDF.AddChildObjectL(KNSmlDdfDB);	// DB

    FillNodeInfoL( nDBrootDDF, *aclTypes, MSmlDmDDFObject::EZeroOrOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::ENode, 

                    KNSmlDdfDBDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nDBDDF = nDBrootDDF.AddChildObjectGroupL(); // DB/<X>

    FillNodeInfoL( nDBDDF, *aclTypes, MSmlDmDDFObject::EZeroOrMore, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::ENode, 

                    KNullDesC8, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nCTTypeDDF = nDBDDF.AddChildObjectL(KNSmlDdfCTType);	// CTType

	FillNodeInfoL( nCTTypeDDF, aclTypesLimit, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfCTTypeDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nRDBURIDDF = nDBDDF.AddChildObjectL(KNSmlDdfRDBURI);	// RDBURI

	FillNodeInfoL( nRDBURIDDF, aclTypesNoDelete, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfRDBURIDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nLDBURIDDF = nDBDDF.AddChildObjectL(KNSmlDdfLDBURI);	// LDBURI

    FillNodeInfoL( nLDBURIDDF, aclTypesNoDelete, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfLDBURIDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nClientUserNameDDF = nProDDF.AddChildObjectL(KNSmlDdfClientUserName);

    FillNodeInfoL( nClientUserNameDDF, *aclTypes, MSmlDmDDFObject::EZeroOrOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfClientUserNameDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nServerIdDDF = nProDDF.AddChildObjectL(KNSmlDdfServerId);

    FillNodeInfoL( nServerIdDDF, *aclTypes, MSmlDmDDFObject::EZeroOrOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfServerIdDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nClientPWDDF = nProDDF.AddChildObjectL(KNSmlDdfClientPW);// ClientPW

	FillNodeInfoL( nClientPWDDF, aclTypesNoGet, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfClientPWDescription, KNullDesC8, KMimeType );

	MSmlDmDDFObject& nToNAPIDDDF = nProDDF.AddChildObjectL(KNSmlDdfToNAPID);// ToNAPID

    FillNodeInfoL( nToNAPIDDDF, aclTypesNoDelete, MSmlDmDDFObject::EOne, 

                    MSmlDmDDFObject::EDynamic, MSmlDmDDFObject::EChr, 

                    KNSmlDdfToNAPIDDescription, KNullDesC8, KMimeType );

	CleanupStack::PopAndDestroy(); //aclTypes

	_DBG_FILE("CNSmlDSSettingsAdapter::DDFStructureL(): end");

	}

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

//  CNSmlDSSettingsAdapter::UpdateLeafObjectL

//  The function updates the leaf object data.

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

void CNSmlDSSettingsAdapter::UpdateLeafObjectL( const TDesC8& aURI, 

                                                const TDesC8& aParentLUID, 

                                                const TDesC8& aObject, 

                                                const TDesC8& /*aType*/, 

                                                const TInt aStatusRef )

	{

	_DBG_FILE("CNSmlDSSettingsAdapter::UpdateLeafObjectL(): begin");

//

//	Check which field going to be handled

//

	// Static node feature start

		TInt profileLUID = -1;

		if(aParentLUID.Length() == 0 )

		{

			iLUID = -1;

			if( IsDSAccUriFormatMatchPredefined(aURI) )

    	{

    		iLUID = ConstructTreeL(aURI);

    		profileLUID = GetProfileIdFromURIL( aURI ); 

    	}    	

    	if ((iLUID == 0 ) && (aURI.Match(_L8("SyncML/DSAcc/DSId*/DB/CTId*"))  == KErrNone))

			{

				_DBG_FILE("CNSmlDSSettingsAdapter::FetchObjectL(): ENotFound end");

				iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ENotFound );

				return;

    	}

    }

		// Static node feature end

	SetField( aURI );

    TInt fieldID = GetDSField();

	TInt fieldType = GetDSFieldTypeL();

	if ( fieldType == EWrong || fieldID < 0 )

		{

		_DBG_FILE("CNSmlDSSettingsAdapter::UpdateLeafObjectL(): EError end");

		iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EError );

		return;

		}

	if(profileLUID == -1)

    	profileLUID = GetIntObject( aParentLUID );

	if( profileLUID == -1 && fieldType != EParam )

		{

		_DBG_FILE("CNSmlDSSettingsAdapter::UpdateLeafObjectL( ): ENotFound end");

		iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ENotFound );

		return;

		}	

    if ( fieldType == EParam )

		{

		if( GetBufferIndex( aURI ) >= 0 && iBufferExecution == EFalse )

			{

			AddLeafBufferL( aURI, aParentLUID, aObject, aStatusRef );

            return;

			}

		profileLUID = GetProfileIdFromURIL( aURI );

        if( FindProfileIdL( profileLUID ) == EFalse )

            {

            iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ENotFound );

			return;

            }

        if( iField->Compare( KNSmlDdfCTType ) == 0 )

            {

            if( MimeTypeAllreadyExitsL( profileLUID, aObject ) )

                {

                iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EAlreadyExists );

                return;

                }

            if( aObject.Length() == 0 )

                {

                iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EInvalidObject );

                return;

                }

            }

        }

	if( profileLUID != iParentLUID && fieldType != EParam )

		{											    

		if( FindProfileIdL( profileLUID ) )

			{

			iParentLUID = profileLUID;

			}

		else

			{

			iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ENotFound );

			return;

			}

		}

	if ( fieldType == EStr || fieldType == EInt )

		{

//

//		Check if Object length id valid

//

		if( NotValidStrLenght( fieldID, aObject ) )

			{

			_DBG_FILE("CNSmlDSSettingsAdapter::AddLeafObjectL(): KErr length end");

			iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ETooLargeObject );

			return;

			}

		}

    TInt ret = 0;

	if ( fieldType == EStr || fieldType == EInt )

		{

		if( fieldID == EProfileURL )

			{

			TInt num=0;

            ret = ParseUri( aObject, num );

            if( ret == KErrNone )

				{

			    ret = SetProfileServerURIL( iParentLUID, aObject );

                if( ret != 0 )

					{

					_DBG_FILE("CNSmlDSSettingsAdapter::AddLeafObjectL(): URI set failed");

					iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EError );

					return;

					}

				}

			else //if port number not included in URL

				{

                ret = SetProfileServerURIL( iParentLUID, aObject );

                if( ret != 0 )

					{

					_DBG_FILE("CNSmlDSSettingsAdapter::AddLeafObjectL(): URI set failed");

					iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EError );

					return;

					}

				}

			}

			{

			if ( iLeafType == EDSDelete )

			    {

                iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EOk );

	            return;            

			    }

            iObject = GetIntObject( aObject );

            ret = SetProfileAddrTypeL( iParentLUID, iObject );

			}

        else

			{

			ret = SetProfileStrValueL( iParentLUID, aObject, fieldID );

			}

		}

	else if ( fieldType == EParam )

		{

        TInt sRet = KErrGeneral;

        if( iField->Compare( KNSmlDdfCTType ) == 0 ) //Task Mime Type

			{

//			DBG_ARGS8(_S8("NEW: Object <%S>"), &aObject);

			TInt dataProviderId(-1);

			if(aParentLUID.Length() == 0 )

			{

				dataProviderId = iLUID ;

			}

			else

			{

				dataProviderId = GetIntObject( aParentLUID );

			}

            if( FindTaskIDL( profileLUID, dataProviderId ) == EFalse )

                {

                sRet = AddNewDataProviderL( profileLUID, aObject, dataProviderId );

                }

            else

                {

                sRet = KErrAlreadyExists;

                }

            if( sRet == KErrDiskFull )

			    {

				iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EDiskFull );

				}

			else if( sRet == KErrNotFound )

                {

                iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ENotFound );

                }

            else if( sRet == KErrAlreadyExists )

                {

                iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EAlreadyExists );

                }

            else if( sRet != KErrNone )

			    {

				iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EError );

				}

            else

                {

                TPtrC8 addDBURI = RemoveLastURISeg( aURI ); 

				TBuf8<16> dataProvider;

				dataProvider.Num( dataProviderId );

		    	iCallBack->SetMappingL( addDBURI, dataProvider );

				SetBufferLUID( aURI,dataProviderId );

				iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EOk ); 

                }                        

            return;

            }

        //

        // Only database values handled

        //

/*		if( iField->Compare( KNSmlDdfLDBURI ) == 0 )

		    {

			iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::ENotFound );

			return;

		    }

*/

		if( !(iField->Compare( KNSmlDdfLDBURI ) == 0) &&

		    !(iField->Compare( KNSmlDdfRDBURI ) == 0) )	

		    {

			_DBG_FILE("CNSmlDSSettingsAdapter::AddLeafObjectL(): Param header end");

			iCallBack->SetStatusL( aStatusRef, CSmlDmAdapter::EOk );

			return;

			}

        TInt dataProviderId(-1);

		if(aParentLUID.Length() == 0 )

		{

			dataProviderId = iLUID ;

		}

		else

		{

        	dataProviderId = GetIntObject( aParentLUID );

		}

        if( FindTaskIDL( profileLUID, dataProviderId ) )

            {

            ret = UpdateDataSourceL( profileLUID, dataProviderId, aObject, *iField);

            if( ret != KErrNone )

                {

                ret = KErrGeneral;

                }

            TPtrC8 dbURI = RemoveLastURISeg( aURI ); 

		    TBuf8<16> dataProvider;

		    dataProvider.Num( dataProviderId );

		    iCallBack->SetMappingL( dbURI, dataProvider );

			}