/*

* Copyright (c) 2008-2010 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

*

*/

// System includes

#include <ecom/ecom.h>

#include <liwservicehandler.h>

#include <aipluginsettings.h>

#include <utf.h>

// User includes

#include <aicpscommandbuffer.h>

#include "sapidata.h"

#include "sapidatapluginconst.h"

#include "sapidataobserver.h"

#include "sapidataplugin.h"

const TUint KDisableNotification = 0x2000;

// ======== 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;

	 iUpdateNeeded = EFalse;

	 iGetMenuItems = ETrue;

    }

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

// Destructor

// Deletes all data created to heap

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

//

CSapiData::~CSapiData()

    {

	delete iPublisher;

	delete iContentId;

	delete iStartupReason;

	if(iPubObserver)

		{

		delete iPubObserver;

		iPubObserver = NULL;

		}

    if(iContentObserver)

        {

        delete iContentObserver;

        iContentObserver = NULL;

        }

    iMenuItems.ResetAndDestroy();

    iMenuTriggers.ResetAndDestroy();

    iItemList.ResetAndDestroy();

    // not owned

    iPlugin = NULL;

    iInterface = NULL;

    iServiceHandler = NULL;

    iCpsExecute = NULL;

    }

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

// ConfigureL

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

//

void CSapiData::ConfigureL(RAiSettingsItemArray& aConfigurations )

    {

    TInt count = aConfigurations.Count();

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

       {

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

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

           {

           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( iPublisher->Des().Length() == 0 ) 

        {

        // No service to offer without plugin configurations 

        User::Leave( KErrNotSupported );

        }

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

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

    }

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

// SetContentIdL

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

//

void CSapiData::SetContentIdL(const TDesC8& aId)

	{

	iContentId = CnvUtfConverter::ConvertToUnicodeFromUtf8L(aId);

	}

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

// SetStartupReasonL

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

//

void CSapiData::SetStartupReasonL(const TDesC8& aStartupReason)

    {

    delete iStartupReason;

    iStartupReason = NULL;

    iStartupReason = aStartupReason.AllocL();

    ChangePublisherStatusL( aStartupReason );

    }

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

// 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 )

	{

    if ( iGetMenuItems )

        {

        //Gets the menu items from the publisher registry

        TRAP_IGNORE( GetMenuItemsL() );

        iGetMenuItems = EFalse;

        }

	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 ) )

		    {			

            const TDesC& type( *iItemList[pIndex]->iType );

            TPtrC valPtr;

			if ( type == KText )

				{

				valPtr.Set( variant.AsDes() );

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

				}

			else if( type == KImage )

				{

				TInt handle = KErrBadHandle;

                TUint uintHandle = 0;

                if ( variant.Get( uintHandle ) )

                    {

                    handle = uintHandle;

                    }

                else if ( !variant.Get( handle ) )

                    {

                    handle = KErrBadHandle;

                    }				

				// read as a image handle

				if( handle == KErrBadHandle )

					{

					// no handle, so read as image path

					variant.Get( valPtr );

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

					}

				else

					{

					TInt maskHandle = KErrBadHandle;

					TUint uintmaskHandle = 0;

					//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 ) )

						{

                        if ( variant.Get( uintmaskHandle ) )

                            {

                            maskHandle = uintmaskHandle;

                            }

                        else if ( !variant.Get( maskHandle ) )

                            {

                            maskHandle = KErrBadHandle;

                            }                           

						}

					CleanupStack::PopAndDestroy( maskKey );

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

					}

				}

			else if ( type == KData )

			    {

                TPtrC8 ptr;

                ptr.Set( variant.AsData() );

                iPlugin->PublishData( aObserver, iItemList[pIndex]->iId, ptr );                

			    }

		    }

        variant.Reset();

        CleanupStack::PopAndDestroy( itemName );

	    }

    }

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

// ExecuteCommandL

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

//

void CSapiData::ExecuteCommandL(const TDesC& aRegistry, CLiwDefaultMap* aInFilter, 

		CLiwGenericParamList* aOutParamList)

	{

    if( iInterface == NULL )

        {

        User::Leave( KErrNotSupported );

        }

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

    TLiwGenericParam type( KType, TLiwVariant( aRegistry ) );

    inParamList->AppendL( type );