/*

* 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:  Client module of DS Host Servers

*

*/

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

// Includes

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

#include <s32mem.h>

#include <SmlDataProvider.h>

#include "nsmldshostclient.h"

#include "nsmldshostconstants.h"

#ifdef __USE_FAKE_CLIENT__

#include "fakeclient.cpp"

#else

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

// CNSmlDSHostClient - public methods

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

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

// CNSmlDSHostClient::NewL

// Creates new instance of CNSmlDSHostClient based class.

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

EXPORT_C CNSmlDSHostClient* CNSmlDSHostClient::NewL()

	{

	CNSmlDSHostClient* self = NewLC();

	CleanupStack::Pop();

	return self;

	}

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

// CNSmlDSHostClient::NewLC

// Creates new instance of CNSmlDSHostClient based class.

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

EXPORT_C CNSmlDSHostClient* CNSmlDSHostClient::NewLC()

	{

	CNSmlDSHostClient* self = new (ELeave) CNSmlDSHostClient();

	CleanupStack::PushL( self );

	self->ConstructL();

	return self;

	}

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

// CNSmlDSHostClient::~CNSmlDSHostClient

// C++ Destructor.

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

EXPORT_C CNSmlDSHostClient::~CNSmlDSHostClient()

	{

	iClient1.Close();

	iClient2.Close();

	iDataProviders1.Close();

	iDataProviders2.Close();

	}

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

// CNSmlDSHostClient::CreateDataProvidersL

// Creates Data Providers.

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

EXPORT_C void CNSmlDSHostClient::CreateDataProvidersL( const RArray<TSmlDataProviderId>& aIds, RArray<TInt>& aResultArray )

	{

	RArray<TSmlDataProviderId> tempIdsArray;

	CleanupClosePushL( tempIdsArray );

	RArray<TInt> tempResultArray;

	CleanupClosePushL( tempResultArray );

	// Find Data Providers from Host Server 2

	iClient2.CreateDataProvidersL( aIds, aResultArray );

	if ( aIds.Count() != aResultArray.Count() )

		{

		User::Leave( KErrUnknown );

		}

	for ( TInt i = 0; i < aIds.Count(); i++ )

		{

		if ( aResultArray[ i ] != KErrNone )

			{

			tempIdsArray.AppendL( aIds[ i ] );

			}

		else

			{

			// Add succesfully loaded Data Providers to client array

			iDataProviders2.AppendL( aIds[ i ] );

			}

		}

	// Find Data Providers from Host Server 1

	if ( tempIdsArray.Count() > 0)

		{		

		iClient1.CreateDataProvidersL( tempIdsArray, tempResultArray );

		if ( tempIdsArray.Count() != tempResultArray.Count() )

			{

			User::Leave( KErrUnknown );

			}

		for ( TInt j = 0; j < tempIdsArray.Count(); j++ )

			{

			for ( TInt k = 0; k < aIds.Count(); k++ )

				{

				if ( aIds[ k ] == tempIdsArray[ j ] )

					{

					aResultArray[ k ] = tempResultArray[ j ];

					}

				}

			if ( tempResultArray[ j ] == KErrNone )

				{

				// Add succesfully loaded Data Providers to client array

				iDataProviders1.AppendL( tempIdsArray[ j ] );

				}

			}

		}

		CleanupStack::PopAndDestroy(2); //tempResultArray, tempIdsArray

	}

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

// CNSmlDSHostClient::CreateAllDataProvidersL

// Creates all possible Data Providers.

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

EXPORT_C void CNSmlDSHostClient::CreateAllDataProvidersL( RArray<TSmlDataProviderId>& aIds )

	{

	// Find Data Providers from Host server 2

	// Find Data Providers from Host server 1 except those Data Providers that were found from

	// previous server

	RArray<TSmlDataProviderId> tmpArray;

	CleanupClosePushL( tmpArray );

	iClient2.CreateAllDataProvidersL( aIds, tmpArray );

	iDataProviders2.Reset();

	for ( TInt i = 0; i < aIds.Count(); i++ )

		{

		iDataProviders2.AppendL( aIds[ i ] );

		}

	iClient1.CreateAllDataProvidersL( tmpArray, aIds );

	iDataProviders1.Reset();

	for ( TInt i = 0; i < tmpArray.Count(); i++ )

		{

		iDataProviders1.AppendL( tmpArray[i] );

		aIds.AppendL( tmpArray[i] );

		}

	CleanupStack::PopAndDestroy(); //tmpArray

	}

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

// CNSmlDSHostClient::DataProviderInformationL

// 

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

EXPORT_C TNSmlDPInformation* CNSmlDSHostClient::DataProviderInformationL( const TSmlDataProviderId aId, TInt& aResultCode ) const

	{

	TNSmlDPInformation* ret = NULL;

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			ret = iClient1.DataProviderInformationL( aId, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			ret = iClient2.DataProviderInformationL( aId, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	return ret;

	}	

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

// CNSmlDSHostClient::SupportsOperationL

// Asks if Data Provider supports some operation.

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

EXPORT_C TBool CNSmlDSHostClient::SupportsOperationL( TUid aOpId, TSmlDataProviderId aId, TInt& aResultCode ) const

	{

	TBool ret( EFalse );

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			ret = iClient1.SupportsOperationL( aOpId, aId, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			ret = iClient2.SupportsOperationL( aOpId, aId, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	return ret;

	}

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

// CNSmlDSHostClient::StoreFormatL

// Creates Data Store format of Data Provider.

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

EXPORT_C CNSmlDbCaps* CNSmlDSHostClient::StoreFormatL( const TSmlDataProviderId aId, TInt& aResultCode )

	{

	CNSmlDbCaps* ret = NULL;

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			ret = iClient1.StoreFormatL( aId, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			ret = iClient2.StoreFormatL( aId, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	return ret;

	}

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

// CNSmlDSHostClient::ListStoresL

// Creates list of Data Store names of Data Provider.

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

EXPORT_C void CNSmlDSHostClient::ListStoresL( CDesCArray* aNameList, const TSmlDataProviderId aId, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.ListStoresL( aNameList, aId, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.ListStoresL( aNameList, aId, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::DefaultStoreL

// Creates default name for Data Store of Data Provider.

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

EXPORT_C HBufC* CNSmlDSHostClient::DefaultStoreL( const TSmlDataProviderId aId, TInt& aResultCode )

	{

	HBufC* ret = NULL;

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			ret = iClient1.DefaultStoreL( aId, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			ret = iClient2.DefaultStoreL( aId, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	return ret;

	}

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

// CNSmlDSHostClient::SupportedServerFiltersL

// This method returns the set of filters that can be used to send to the Sync Partner.

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

EXPORT_C RPointerArray<CSyncMLFilter>* CNSmlDSHostClient::SupportedServerFiltersL( const TSmlDataProviderId aId, 

	TSyncMLFilterMatchType& aMatchType, TSyncMLFilterChangeInfo& aChangeInfo, TInt& aResultCode ) const

	{

	RPointerArray<CSyncMLFilter>* result = NULL;

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			result = iClient1.SupportedServerFiltersL( aId, aMatchType, aChangeInfo, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			result = iClient2.SupportedServerFiltersL( aId, aMatchType, aChangeInfo, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	return result;

	}

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

// CNSmlDSHostClient::CheckServerFiltersL

// This method updates dynamic filters up-to-date.

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

EXPORT_C void CNSmlDSHostClient::CheckServerFiltersL( const TSmlDataProviderId aId, RPointerArray<CSyncMLFilter>& aFilters, TSyncMLFilterChangeInfo& aChangeInfo, TInt& aResultCode ) const

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.CheckServerFiltersL( aId, aFilters, aChangeInfo, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.CheckServerFiltersL( aId, aFilters, aChangeInfo, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::CheckSupportedServerFiltersL

// This method returns the set of filters that can be used to send to the Sync Partner.

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

EXPORT_C void CNSmlDSHostClient::CheckSupportedServerFiltersL( const TSmlDataProviderId aId, 

	const CNSmlDbCaps& aServerDataStoreFormat, const CArrayFix<TNSmlFilterCapData>& aFilterInfoArr, 

	RPointerArray<CSyncMLFilter>& aFilters, TSyncMLFilterChangeInfo& aChangeInfo, TInt& aResultCode ) const

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.CheckSupportedServerFiltersL( aId, aServerDataStoreFormat, aFilterInfoArr, aFilters, aChangeInfo, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.CheckSupportedServerFiltersL( aId, aServerDataStoreFormat, aFilterInfoArr, aFilters, aChangeInfo, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::GetFilterL

// Get Filters.

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

EXPORT_C void CNSmlDSHostClient::GetFilterL( const TSmlDataProviderId aId, const TDesC& aStoreName, 

	const RPointerArray<CSyncMLFilter>& aFilterArray, CNSmlFilter*& aFilter, 

	TSyncMLFilterMatchType aMatchType, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.GetFilterL( aId, aStoreName, aFilterArray, aFilter, aMatchType, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.GetFilterL( aId, aStoreName, aFilterArray, aFilter, aMatchType, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::OpenL

// Opens the data store specified by aStoreName asynchronously.

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

EXPORT_C void CNSmlDSHostClient::OpenL( const TSmlDataProviderId aId, const TDesC& aStoreName, const TDesC& aServerId, const TDesC& aRemoteDB, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.OpenL( aId, aStoreName, aServerId, aRemoteDB, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.OpenL( aId, aStoreName, aServerId, aRemoteDB, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::CancelRequestL

// Cancel the current asynchronous request.

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

EXPORT_C void CNSmlDSHostClient::CancelRequestL( const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.CancelRequest( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.CancelRequest( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::BeginTransactionL

// Starts the transaction mode.

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

EXPORT_C void CNSmlDSHostClient::BeginTransactionL( const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.BeginTransaction( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.BeginTransaction( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::CommitTransactionL

// Method will be called at the end of a successful transaction.

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

EXPORT_C void CNSmlDSHostClient::CommitTransactionL( const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.CommitTransaction( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.CommitTransaction( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::RevertTransactionL

// Method will be called to abort an ongoing transaction.

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

EXPORT_C void CNSmlDSHostClient::RevertTransactionL( const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.RevertTransaction( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.RevertTransaction( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::BeginBatchL

// Starts the batch mode.

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

EXPORT_C void CNSmlDSHostClient::BeginBatchL( const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.BeginBatch( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.BeginBatch( aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );		

	}

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

// CNSmlDSHostClient::CommitBatchL

// Method will be called at the end of the batch mode.

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

EXPORT_C void CNSmlDSHostClient::CommitBatchL( RArray<TInt>& aResultArray, const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{

		case ( ENSmlHostServer1 ):

			iClient1.CommitBatchL( aResultArray, aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServer2 ):

			iClient2.CommitBatchL( aResultArray, aId, aStoreName, aResultCode );

			break;

		case ( ENSmlHostServerEnd ):

		default:

			User::Leave( KErrNotFound );

		}

	aResultCode = HostErrorConversion( aResultCode );

	}

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

// CNSmlDSHostClient::CancelBatchL

// Method will be called to abort an ongoing batch mode.

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

EXPORT_C void CNSmlDSHostClient::CancelBatchL( const TSmlDataProviderId aId, const TDesC& aStoreName, TInt& aResultCode )

	{

	switch( SessionForDataProvider( aId ) )

		{