/*

* 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:

* Profile plug-in publisher

*

*/

// INCLUDE FILES

#include <ecom/ecom.h>

#include <liwservicehandler.h>

#include <aipluginsettings.h>

#include <apgcli.h>

#include <apgicnfl.h> 

#include <bautils.h> 

#include <aicpscommandbuffer.h>

#include "wrtdata.h"

#include "wrtdatapluginconst.h"

#include "wrtdataobserver.h"

#include "wrtdataplugin.h"

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

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

// Symbian 2nd phase constructor can leave

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

//

CWrtData* CWrtData::NewL(CWrtDataPlugin* aPlugin)

    {

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

    CleanupStack::PushL( self );

    self->ConstructL(aPlugin);

    CleanupStack::Pop( self );

    return self;

    }

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

// Default constructor

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

//

CWrtData::CWrtData()

    {

    }

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

// Symbian 2nd phase constructor can leave

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

//

void CWrtData::ConstructL(CWrtDataPlugin* aPlugin)

    { 

     iPlugin = aPlugin;

    }

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

// Destructor

// Deletes all data created to heap

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

//

CWrtData::~CWrtData()

    {

    if(iObserver)

        delete iObserver;

        iObserver = NULL;

        }

    if ( iContentId )

    	{

    	delete iContentId;

    	iContentId = NULL;

    	}

    // not owned

    iCpsExecute = NULL;

    iPlugin = NULL;

    }

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

// CWrtData::ConfigureL

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

//

void CWrtData::ConfigureL(RAiSettingsItemArray& aConfigurations )

    {

    TInt count = aConfigurations.Count();

       {

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

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

           {

       }

        {

        // No service to offer without plugin configurations 

        User::Leave( KErrNotSupported );

        }

    iObserver = CWrtDataObserver::NewL( iInterface, this );   

    }

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

// CWrtData::RegisterL

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

//

void CWrtData::RegisterL()

    {

    CLiwDefaultMap* filter = CreateFilterLC();

    filter->InsertL( KOperation, TLiwVariant( KAddUpdateDelete ) );

    iObserver->RegisterL(filter);

    CleanupStack::PopAndDestroy( filter );

    }

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

// CWrtData::UpdatePublisherStatusL

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

//

void CWrtData::UpdatePublisherStatusL()

    {

     // Resent the plugin status to publisher

    CLiwDefaultList* actions= CLiwDefaultList::NewLC();

    actions->AppendL( TLiwVariant( KActive ));

     if ( iPlugin->IsActive() )

         {

         actions->AppendL( TLiwVariant( KResume ) );

         }

     else

         {

         actions->AppendL( TLiwVariant( KSuspend ));

         }

      // forward the network status if it uses.

    if ( iPlugin->NetworkStatus() == CWrtDataPlugin::EOnline )

        {

        actions->AppendL( TLiwVariant( KOnLine ));

        }

    else if ( iPlugin->NetworkStatus() == CWrtDataPlugin::EOffline )

        {

        actions->AppendL( TLiwVariant(  KOffLine));

        }

    ReSendNotificationL( actions );

    CleanupStack::PopAndDestroy( actions );

    }

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

// CWrtData::PublishDefaultImageL

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

//

void CWrtData::PublishDefaultImageL( MAiContentObserver* aObserver )

    {

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

// CWrtData::PublishL

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

//

void CWrtData::PublishL( MAiContentObserver* aObserver, CLiwDefaultMap* aDataMap ) 

    {

    TLiwVariant variant;

    iPlugin->HideLoadingIcon(aObserver);

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

        {

        TInt handle = KErrBadHandle;

        TUint uintHandle = 0;

        TPtrC16 valPtr;

        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, CWrtDataPlugin::EImage1, valPtr );

            }

        else

            {

            TInt maskHandle = KErrBadHandle;

            //Look for image mask

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

               {

               variant.Get( maskHandle );                           

               }

            iPlugin->PublishImageL(aObserver, CWrtDataPlugin::EImage1, handle, maskHandle );

            }

        }

    variant.Reset();

    }

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

// CWrtData::RefreshL

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

//

void CWrtData::RefreshL( TDesC& aContentId, TDesC& aOperation, 

        CLiwDefaultMap* aDataMap )

    {

     if ( aContentId == iContentId )

         {

         iPlugin->RefreshL( aOperation, aDataMap);

         }

    }

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

// CWrtData::ExecuteActionL

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

//

void CWrtData::ExecuteActionL(const TDesC& aObjectId, const TDesC& aTrigger )

   {

   HBufC8* triggerName = HBufC8::NewLC( KWRTContentNameMaxLength );

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

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

   triggerName->Des().Copy(aTrigger);

   if ( aObjectId == KPubData )

       {

       // this trigger belongs to publisher registery.

       // in such case it is assumed that all the items in the widgets

       // belongs to same publisher, type and id.

       TLiwGenericParam cptype( KType, TLiwVariant( KPubData ) );

       inParamList->AppendL( cptype );

       cptype.Reset();

       }

   else

       {

       TLiwGenericParam cptype( KType, TLiwVariant( KCpData ) );

       inParamList->AppendL( cptype );

       cptype.Reset();

       }

    filter->InsertL( KActionTrigger, TLiwVariant( triggerName->Des() ) );

   //append filter to input param

    TLiwGenericParam item( KFilter, TLiwVariant( filter ) );

    inParamList->AppendL( item );

    iInterface->ExecuteCmdL( KExecuteAction,  *inParamList, *outParamList );

    CleanupStack::PopAndDestroy( filter );

    CleanupStack::PopAndDestroy( triggerName );

    inParamList->Reset();

    }

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

// CWrtData::IsPluginActive

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

//

TBool CWrtData::IsPluginActive()

    {

    return iPlugin->IsActive();

    }

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

// CWrtData::CreateFilterL

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

//

CLiwDefaultMap* CWrtData::CreateFilterLC()

    {

    CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

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

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

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

    return filter;

    }

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

// CWrtData::ExecuteCommandL

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

//

void CWrtData::ExecuteCommandL(CLiwDefaultMap* aInFilter, CLiwDefaultMap* aOutDataMap, const TDesC16& aRegistry  )

    {

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

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

    TLiwGenericParam type( KType, TLiwVariant( aRegistry ) );

    inParamList->AppendL( type );

    //append filter to input param

     TLiwGenericParam item( KFilter, TLiwVariant( aInFilter ));

     inParamList->AppendL( item );

    // execute service.It is assumed that iInterface is already initiatedd

    if(iInterface)

        {

        }

    else

        {

        User::Leave( KErrNotSupported );

        }

    type.Reset();

    item.Reset();

    inParamList->Reset();

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

        CLiwIterable* iterable = variant.AsIterable();

        iterable->Reset();

        //get next result

        if( iterable->NextL( variant ) )

            {

            //extract content map

            CLiwDefaultMap *map = CLiwDefaultMap::NewLC();

            variant.Get( *map );

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

                {

                 variant.Get( *aOutDataMap );

                }

            CleanupStack::PopAndDestroy( map );

            }

        iterable->Reset();

        variant.Reset();

        }

    outParamList->Reset();

    }

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

// NotifyPublisherL

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

//

void CWrtData::NotifyPublisherL(const TDesC8& aStatus)

    {

    if( iCpsExecute == NULL )

        {

        User::Leave( KErrNotSupported );

        }

    CLiwDefaultMap* filter = CreateFilterLC();

    // Add execute command triggers. Idle framework will execute 

    iCpsExecute->AddCommand( iPluginId, KPubData, filter, aStatus );

    CleanupStack::PopAndDestroy( filter );

    }

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

// CWrtData::GetWidgetNameAndUidL

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

//

void CWrtData::GetWidgetNameAndUidL(TDes& aName, TDes& aAppUID )

    {

    CLiwDefaultMap *outDataMap = CLiwDefaultMap::NewLC();

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

    CLiwDefaultMap* filter = CreateFilterLC();

    ExecuteCommandL( filter, outDataMap, KPubData  );

    CleanupStack::PopAndDestroy( filter );

    TLiwVariant variant;

    if ( outDataMap->FindL(KWidgetInfo, variant) )

        {

        CLiwDefaultMap* widgetInfoMap = CLiwDefaultMap::NewLC();

        variant.Get( *widgetInfoMap );

        variant.Reset();

        if ( widgetInfoMap->FindL( KWidgetName, variant ) )

            {

            aName.Copy(variant.AsDes());

            variant.Reset();

            if ( widgetInfoMap->FindL( KWidgetIcon, variant ) )

               {

               aAppUID.Copy(variant.AsDes());

               }

            }

        CleanupStack::PopAndDestroy( widgetInfoMap );

        }

    variant.Reset();

    CleanupStack::PopAndDestroy( outDataMap );

    }

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

// CWrtData::ResolveUid

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

//

TBool CWrtData::ResolveUid(const TDesC& aUidDes, TUid& aUid )

    {

    // Syntax: uid(0x12345678)

    TInt error = KErrNotFound;

    TInt pos = aUidDes.FindF( KUid );

    if( pos == 0 )

        {

        // Skip skin token

        pos += KUid().Length();

        // Initialize lexer

        TLex lex( aUidDes.Mid( pos ) );

        // Check left parenthesis

        if ( lex.Get() == KLeftParenthesis )

            {

            lex.SkipSpaceAndMark();

            lex.SkipCharacters();

            TPtrC mtoken = lex.MarkedToken();

            pos = mtoken.FindF( KHexPrefix );

            if ( pos == 0 )

                {

                TLex lex( mtoken.Mid( KHexPrefix().Length() ) );

                TUint id = 0;

                error = lex.Val( id, EHex );

                aUid = TUid::Uid( (TInt)id );

                }

            else

                {

                TInt id( 0 );

                error = lex.Val( id );

                aUid.iUid = id;

                }

            }

        }

    }

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

// CWrtData::CreateIconFromUidL

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

//

    {

    RApaLsSession lsSession;

    User::LeaveIfError( lsSession.Connect() );

    CleanupClosePushL( lsSession ); // lsSession (1)

    CArrayFixFlat<TSize>* sizeArray = new(ELeave) CArrayFixFlat<TSize>( 5 );

    CleanupStack::PushL( sizeArray );

        {