/*

* Copyright (c) 2007 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:  

*

*/

// INCLUDE FILES

#include "CPsDataPluginInterface.h"

#include "CPsDataPlugin.h"

#include "CPcsDebug.h"

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

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

// CPsDataPluginInterface::NewL

// Two Phase Construction

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

CPsDataPluginInterface* CPsDataPluginInterface::NewL(MDataStoreObserver* aObserverForDataStore,

													MStoreListObserver* aStoreListObserver)

{

    PRINT ( _L("Enter CPsDataPluginInterface::NewL") );

    CPsDataPluginInterface* self = CPsDataPluginInterface::NewLC(aObserverForDataStore, aStoreListObserver);

    CleanupStack::Pop( self );

    PRINT ( _L("End CPsDataPluginInterface::NewL") );

    return self;

}

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

// CPsDataPluginInterface::NewLC

// Two Phase Construction

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

CPsDataPluginInterface* CPsDataPluginInterface::NewLC(MDataStoreObserver* aObserverForDataStore,

													MStoreListObserver* aStoreListObserver)

{

    PRINT ( _L("Enter CPsDataPluginInterface::NewLC") );

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

    CleanupStack::PushL( self );

    self->ConstructL(aObserverForDataStore, aStoreListObserver);

    PRINT ( _L("End CPsDataPluginInterface::NewLC") );

    return self;

}

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

// CPsDataPluginInterface::CPsDataPluginInterface

// Constructor

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

CPsDataPluginInterface::CPsDataPluginInterface()

{

    PRINT ( _L("Enter CPsDataPluginInterface::CPsDataPluginInterface") );

    PRINT ( _L("End CPsDataPluginInterface::CPsDataPluginInterface") );

}

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

// CPsDataPluginInterface::ConstructL

// 2nd phase constructor

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

void CPsDataPluginInterface::ConstructL(MDataStoreObserver* aObserverForDataStore,

										MStoreListObserver* aStoreListObserver)

{

    PRINT ( _L("Enter CPsDataPluginInterface::ConstructL") );

    iObserverForDataStore = aObserverForDataStore;

    iStoreListObserver = aStoreListObserver;

    PRINT ( _L("End CPsDataPluginInterface::ConstructL") );

}

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

// CPsDataPluginInterface::~CPsDataPluginInterface

// Constructor

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

CPsDataPluginInterface::~CPsDataPluginInterface( ) 

{

    PRINT ( _L("Enter CPsDataPluginInterface::~CPsDataPluginInterface") );

    UnloadPlugIns();

    iPsDataPluginInstances.ResetAndDestroy();

    PRINT ( _L("End CPsDataPluginInterface::~CPsDataPluginInterface") );

}

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

// CPsDataPluginInterface::InstantiateAllPlugInsL

// Instantiates all plugins

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

void CPsDataPluginInterface::InstantiateAllPlugInsL( )

{

    PRINT ( _L("Enter CPsDataPluginInterface::InstantiateAllPlugInsL") );

    RImplInfoPtrArray infoArray;

    // Get list of all implementations

    ListAllImplementationsL( infoArray );

    // Instantiate plugins for all impUIds by calling 

    // InstantiatePlugInFromImpUidL

    const TInt infoArrayCount = infoArray.Count();

    for ( TInt i=0; i < infoArrayCount; i++ )

    {

        // Get imp info

        CImplementationInformation& info( *infoArray[i] );

        // Get imp UID

        TUid impUid ( info.ImplementationUid() );

        PRINT ( _L("------------- PS Data Store Details -----------"));

        PRINT1 ( _L("Name: %S"), &(info.DisplayName()) );

        PRINT1 ( _L("UID: %X"), impUid.iUid );

        PRINT ( _L("-----------------------------------------------"));

        CPsDataPlugin* plugin = NULL;

        //instantiate plugin for impUid

        plugin = InstantiatePlugInFromImpUidL( impUid, iObserverForDataStore, iStoreListObserver ) ;

        if ( plugin )

        {

            iPsDataPluginInstances.AppendL( plugin );

        }    	        	     

    }

    infoArray.ResetAndDestroy();

    PRINT ( _L("End CPsDataPluginInterface::InstantiateAllPlugInsL") );

}

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

// CPsDataPluginInterface::UnloadPlugIns

// Unloads plugins

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

void CPsDataPluginInterface::UnloadPlugIns()

{

    PRINT ( _L("Enter CPsDataPluginInterface::UnloadPlugIns") );

    REComSession::FinalClose();

    PRINT ( _L("End CPsDataPluginInterface::UnloadPlugIns") );

}

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

// CPsDataPluginInterface::InstantiatePlugInFromImpUidL

// Instantiates plugin

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

CPsDataPlugin* CPsDataPluginInterface::InstantiatePlugInFromImpUidL( const TUid& aImpUid, 

																	 MDataStoreObserver* aObserverForDataStore,

																	 MStoreListObserver* aStoreListObserver )

{

    PRINT ( _L("Enter CPsDataPluginInterface::InstantiatePlugInFromImpUidL") );

    CPsDataPlugin* plugin = CPsDataPlugin::NewL(aImpUid, aObserverForDataStore, aStoreListObserver);

    PRINT ( _L("End CPsDataPluginInterface::InstantiatePlugInFromImpUidL") );

    return plugin;

}

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

// CPsDataPluginInterface::RequestForDataL

// Requests for data from the data store

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

void  CPsDataPluginInterface::RequestForDataL(TDesC& aDataStore)

{

    PRINT ( _L("Enter CPsDataPluginInterface::RequestForDataL") );

   const TInt instancesCount = iPsDataPluginInstances.Count();

    for ( TInt idx = 0; idx < instancesCount; idx++ )

    {

        if(iPsDataPluginInstances[idx]->IsDataStoresSupportedL(aDataStore))

        {

       		iPsDataPluginInstances[idx]->RequestForDataL(aDataStore);

    		break; 

        }

    }

    PRINT ( _L("End CPsDataPluginInterface::RequestForDataL") );

}

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

// CPsDataPluginInterface::GetAllSupportedDataStoresL

// Requests all the supported data stores from data adapters

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

void  CPsDataPluginInterface::GetAllSupportedDataStoresL(RPointerArray<TDesC>& aDataStores)

{

    PRINT ( _L("Enter CPsDataPluginInterface::GetAllSupportedDataStoresL") );

    const TInt instancesCount = iPsDataPluginInstances.Count();

    for ( TInt idx = 0; idx < instancesCount; idx++ )

    {       

       iPsDataPluginInstances[idx]->GetSupportedDataStoresL(aDataStores);

    }

    PRINT ( _L("End CPsDataPluginInterface::GetAllSupportedDataStoresL") );

}

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

// CPsDataPluginInterface::GetAllSupportedDataFieldsL

// Requests all the supported data fields from from data adapters

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

void  CPsDataPluginInterface::GetSupportedDataFieldsL(TDesC& aUri, RArray<TInt>& aDataFields)

{

    PRINT ( _L("Enter CPsDataPluginInterface::GetAllSupportedDataStoresL") );

    const TInt instancesCount = iPsDataPluginInstances.Count();

    for ( TInt idx = 0; idx < instancesCount; idx++ )

    {

       RPointerArray<TDesC> dataStores;

       CleanupClosePushL( dataStores );

       iPsDataPluginInstances[idx]->GetSupportedDataStoresL(dataStores);

       const TInt dataStoresCount = dataStores.Count();

       for ( TInt i(0); i < dataStoresCount; i++)

       {

	       	if ( dataStores[i]->Compare(aUri) == 0)

	       	{

	       		iPsDataPluginInstances[idx]->GetSupportedDataFieldsL(aDataFields);

	       		break;

	       	}

       }

       CleanupStack::PopAndDestroy( &dataStores ); // Close

    }

    PRINT ( _L("End CPsDataPluginInterface::GetAllSupportedDataStoresL") );

}

// End of file