/*

* Copyright (c) 2005-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:  Homescreen Data plug-in publisher

*

*/

#include <ecom/ecom.h>

#include <liwservicehandler.h>

#include <aipluginsettings.h>

#include <utf.h>

#include "sapidata.h"

#include "sapidatapluginconst.h"

#include "sapidataobserver.h"

#include "sapidataplugin.h"

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

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

// Symbian 2nd phase constructor can leave

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

//

CContentItem* CContentItem::NewL()

    {

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

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

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

// Default constructor

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

//

CContentItem::CContentItem()

    {

    }

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

// Symbian 2nd phase constructor can leave

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

//

void CContentItem::ConstructL()

    { 

    iId = KErrNotFound;

    iName = NULL;

	iContentType = NULL;

	iType = NULL;

    }

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

// Destructor

// Deletes all data created to heap

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

//

CContentItem::~CContentItem()

	{

	delete iName;

	delete iContentType;

	delete iType;

	}

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

// Symbian 2nd phase constructor can leave

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

//

CSapiData* CSapiData::NewL(CSapiDataPlugin* aPlugin)

    {

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

    CleanupStack::PushL( self );

    self->ConstructL(aPlugin);

    CleanupStack::Pop( self );

    return self;

    }

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

// Default constructor

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

//

CSapiData::CSapiData()

    {

    }

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

// Symbian 2nd phase constructor can leave

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

//

void CSapiData::ConstructL(CSapiDataPlugin* aPlugin)

    { 

     iPlugin = aPlugin;

     iCommandName = NULL;

	 iContentId = NULL;

	 iContentType = NULL;

	 iUpdateNeeded = EFalse;

    }

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

// Destructor

// Deletes all data created to heap

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

//

CSapiData::~CSapiData()

    {

    delete iCommandName;

	delete iPublisher;

	delete iContentType;

	delete iContentId;

	if(iPubObserver)

		{

		TRAP_IGNORE(iPubObserver->ReleaseL() );

		delete iPubObserver;

		iPubObserver = NULL;

		}

    if(iContentObserver)

        {

        TRAP_IGNORE(iContentObserver->ReleaseL() );

        delete iContentObserver;

        iContentObserver = NULL;

        }

    if( iInterface )

         {

         iInterface->Close();

         iInterface = NULL;

         }

    if( iServiceHandler )

         {

         iServiceHandler->Reset();

         delete iServiceHandler;

         iServiceHandler = NULL;

         }

    iMenuItems.ResetAndDestroy();

    iMenuTriggers.ResetAndDestroy();

    iItemList.ResetAndDestroy();

    // not owned

    iPlugin = NULL;

    }

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

// ConfigureL

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

//

void CSapiData::ConfigureL(RAiSettingsItemArray& aConfigurations )

    {

    HBufC8* serviceName = NULL;

    HBufC8* interfaceName = NULL;

    TInt count = aConfigurations.Count();

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

       {

       MAiPluginConfigurationItem& confItem = ( aConfigurations[i] )->AiPluginConfigurationItem();

       // if owner is plugin then it (key,value) is for plugin configurations items

       if(confItem.Owner() == KPlugin())

           {

           if(confItem.Name() ==  KService())

               {

               serviceName = CnvUtfConverter::ConvertFromUnicodeToUtf8L(confItem.Value());

               }

           else if( confItem.Name() == KInterface() )

                 {

                 interfaceName = CnvUtfConverter::ConvertFromUnicodeToUtf8L(confItem.Value());

                 }

           else if( confItem.Name() == KCommand() )

                 {

                 iCommandName  = CnvUtfConverter::ConvertFromUnicodeToUtf8L(confItem.Value());

                 }

           else if( confItem.Name()  == KPublisher16() ) 

				  {

				  iPublisher = confItem.Value().AllocL();

				  }

           }

       else if ( confItem.Name() == KContentType16() )

           { 

           HBufC* objectId = confItem.Owner().AllocLC();

           objectId->Des().Delete(0, objectId->LocateReverse(KPluginNameSeprator) + 1);

           CContentItem *conItem = CContentItem::NewL();

           conItem->iName = objectId->AllocL();

           conItem->iContentType =  confItem.Value().AllocL();

           conItem->iType = iPlugin->GetTypeL( *objectId ).AllocL();

           conItem->iId = iPlugin->GetIdL(*objectId  );

           iItemList.AppendL( conItem );

           CleanupStack::PopAndDestroy(objectId);

           }

       }

    iItemCount = iItemList.Count();  

    if( !serviceName || !interfaceName || !iCommandName  

    		|| !iContentId || !iPublisher || !iItemCount )

        {

        // No service to offer without plugin configurations 

        User::Leave( KErrNotSupported );

        }

    iServiceHandler = CLiwServiceHandler::NewL(); 

    // for convenience keep pointers to Service Handler param lists 

    CLiwGenericParamList* inParamList  = &iServiceHandler->InParamListL();

    CLiwGenericParamList* outParamList = &iServiceHandler->OutParamListL();

    CLiwCriteriaItem* criteriaItem = CLiwCriteriaItem::NewLC( KLiwCmdAsStr, *interfaceName , *serviceName );

    criteriaItem->SetServiceClass( TUid::Uid( KLiwClassBase ) );

    // Interface name 

    RCriteriaArray criteriaArray;

    criteriaArray.AppendL( criteriaItem );

    // attach Liw criteria

    iServiceHandler->AttachL( criteriaArray );

    iServiceHandler->ExecuteServiceCmdL( *criteriaItem, *inParamList, *outParamList );

    CleanupStack::PopAndDestroy(criteriaItem);

    criteriaArray.Reset();

    // extract CPS interface from output params

    TInt pos( 0 );

    outParamList->FindFirst( pos, *interfaceName );

    if( pos != KErrNotFound )

        {

        //iInterface is MLiwInterface*

        iInterface = (*outParamList)[pos].Value().AsInterface(); 

        User::LeaveIfNull( iInterface );

        }

    else

        {

        User::Leave( KErrNotFound );

        }

    inParamList->Reset();

    outParamList->Reset();

    delete interfaceName;

    delete serviceName;

	//Gets the menu items from the publisher registry    

    GetMenuItemsL();

    iContentObserver = CSapiDataObserver::NewL( iInterface, this );   

    iPubObserver = CSapiDataObserver::NewL( iInterface, this );

    }

void CSapiData::SetContentIdL(const TDesC8& aId)

	{

	iContentId = CnvUtfConverter::ConvertToUnicodeFromUtf8L(aId);

	}

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

// GetMenuItemsL

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

//

void CSapiData::GetMenuItemsL()

	{

	if(iInterface && iItemCount > 0)

		{

		CLiwGenericParamList* outParamList = &iServiceHandler->OutParamListL();

		CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

		filter->InsertL( KPublisherId, TLiwVariant(iPublisher ));

		//append filter to input param

        ExecuteCommandL( KPubData, filter, outParamList );

        CleanupStack::PopAndDestroy( filter );

    	//extracts data map

    	TInt pos = 0;

    	outParamList->FindFirst( pos, KResults );

    	if( pos != KErrNotFound )

    		// results present

    		{

    		//extract iterator on results list

    		TLiwVariant variant = (*outParamList)[pos].Value();

    		variant.PushL();

    		CLiwIterable* iterable = variant.AsIterable();

    		iterable->Reset();

    	    CLiwDefaultMap *map = CLiwDefaultMap::NewLC();

    		//considering publisher is unique reading only first entry

    		if( iterable->NextL( variant ) )

    			{

    			//extract content map

    			variant.Get( *map );

    			if( map->FindL( KDataMap, variant) )

    				{

    				 variant.Get( *map );

    				}

    			}

    		iterable->Reset();

    		variant.Reset();

    		if (  map->FindL( KMenuItems, variant ) )

				{

				CLiwDefaultMap *menuMap = CLiwDefaultMap::NewLC();

				variant.Get( *menuMap );

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

					{

					menuMap->FindL(menuMap->AtL(i), variant );

					HBufC8* menuItem = variant.AsData().AllocLC();

					if ( menuItem->Length()> 0 )

						{

						iMenuTriggers.AppendL( menuItem );

						CleanupStack::Pop( menuItem );

						HBufC* triggerName = CnvUtfConverter::ConvertToUnicodeFromUtf8L(menuMap->AtL(i));

						CleanupStack::PushL( triggerName );

						iMenuItems.AppendL( triggerName );

						CleanupStack::Pop( triggerName );

						}

					else

						{

						CleanupStack::PopAndDestroy( menuItem );	

						}

					variant.Reset();

					}

				CleanupStack::PopAndDestroy( menuMap );

				}

    		CleanupStack::PopAndDestroy( map );

    		CleanupStack::PopAndDestroy( &variant );

    		}

    	outParamList->Reset();

		}

	}

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

// CreateFilterL

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

//

CLiwDefaultMap* CSapiData::CreateFilterLC(const TDesC& aContentType,

		const TDesC& aContentId)

    {

    CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

    filter->InsertL( KPublisherId, TLiwVariant(iPublisher ));

    filter->InsertL( KContentId, TLiwVariant(aContentId ));

    filter->InsertL( KContentType, TLiwVariant(aContentType ));

    return filter;

    }

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

// CreateFilterL

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

//

CLiwDefaultMap* CSapiData::CreateFilterLC(const TDesC& aContentType)

    {

    CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

    filter->InsertL( KPublisherId, TLiwVariant(iPublisher ));

    filter->InsertL( KContentId, TLiwVariant(iContentId ));

    filter->InsertL( KContentType, TLiwVariant(aContentType ));

    return filter;

    }

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

// CreateFilterL

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

//

CLiwDefaultMap* CSapiData::CreateFilterLC()

    {

    CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

    filter->InsertL( KPublisherId, TLiwVariant(iPublisher ));

    filter->InsertL( KContentId, TLiwVariant(iContentId ));

    filter->InsertL( KContentType, TLiwVariant(KAll));

    return filter;

    }

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

// Update

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

//

TBool CSapiData::CanUpdate( TDesC& aPublisher, TDesC& aContentType,

    		TDesC& aContentId)

	{

    TBool res = EFalse;

    if( aPublisher == *iPublisher  

	   && aContentId == *iContentId  )

	   {

	   if ( aContentType != KAll )

		   {

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

			   {

			   if ( aContentType == iItemList[i]->iContentType )

				   {

				   res = ETrue;

				   break;

				   }

			   }

		   }

	   else

		   {

		   res = ETrue;

		   }

	   }

    else

	   {

	   res = EFalse;

	   }

    return res;

	}

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

// RemoveL

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

//

void CSapiData::RemoveL( MAiContentObserver* aObserver, TDesC& aContentType  )

	{

	for(TInt index = 0; index < iItemCount; index++)

		{

		if ( aContentType == iItemList[index]->iContentType )

			{

			iPlugin->Clean( aObserver, iItemList[index]->iId );

			}

		}

	}

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

// HasMenuItem

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

//

TBool CSapiData::HasMenuItem(const TDesC& aMenuItem )

	{

	TBool found = EFalse;

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

		{

		if( aMenuItem == iMenuItems[i] )

			{

			found =  ETrue;

			break;

			}

		}

	return found;

	}

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

// PublishL

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

//

void CSapiData::PublishL( MAiContentObserver* aObserver, const TDesC& aContentType ) 

    {

	CLiwGenericParamList* outParamList = &iServiceHandler->OutParamListL();

    //Create filter criteria for requested entries in form of LIW map:

    CLiwDefaultMap* filter = CreateFilterLC( aContentType );

    ExecuteCommandL( KCpData, filter, outParamList );

    CleanupStack::PopAndDestroy( filter );

	TInt pos = 0;

	outParamList->FindFirst( pos, KResults );

	if( pos != KErrNotFound )

		// results present

		{

		//extract iterator on results list

		TLiwVariant variant = (*outParamList)[pos].Value();

		variant.PushL();

		CLiwIterable* iterable = variant.AsIterable();

		iterable->Reset();

		CLiwDefaultMap *map = CLiwDefaultMap::NewLC();

		while( iterable->NextL( variant ) )

			{

			//extract content map

			if( variant.Get( *map ) &&

					// Find the data map 

					map->FindL( KDataMap, variant) )

				{

				 CLiwDefaultMap *datamap = CLiwDefaultMap::NewLC();

				 if ( variant.Get( *datamap ) )

					 {

					 PublishDataL(aObserver, datamap);

					 }

				 CleanupStack::PopAndDestroy( datamap );

				}

			}

		CleanupStack::PopAndDestroy( map );

		CleanupStack::PopAndDestroy( &variant );

		}

	outParamList->Reset();

    }

void CSapiData::PublishDataL(MAiContentObserver* aObserver, CLiwDefaultMap* aDataMap )

	{

    for(TInt pIndex = 0; pIndex < iItemCount; pIndex++)

	    {

	    // result name to find

		TLiwVariant variant;

		HBufC8* itemName = CnvUtfConverter::ConvertFromUnicodeToUtf8L(*iItemList[pIndex]->iName);

		CleanupStack::PushL( itemName );

		if ( aDataMap->FindL( *itemName, variant ) )

		    {

			TPtrC valPtr;

			if(  iItemList[pIndex]->iType->Des() == KText )

				{

				valPtr.Set( variant.AsDes() );

				iPlugin->PublishTextL( aObserver, iItemList[pIndex]->iId, valPtr  );

				}

			else if( iItemList[pIndex]->iType->Des() == KImage )

				{

				TInt handle = KErrBadHandle;

				// read as a image handle

					{

					// no handle, so read as image path

					variant.Get( valPtr );

					iPlugin->PublishImageL(aObserver, iItemList[pIndex]->iId, valPtr );

					}

				else

					{

					TInt maskHandle = KErrBadHandle;

					//Look for image mask

					HBufC8* maskKey = HBufC8::NewLC( itemName->Length() + KMask().Length() );

					TPtr8 maskKeyPtr = maskKey->Des();

					maskKeyPtr.Append( *itemName );

					maskKeyPtr.Append( KMask );

					if ( aDataMap->FindL( maskKeyPtr, variant ) )

						{