/*

 * Copyright (c) 2008 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:  Encapsulates cps liw service

 *

 */

// System include files

#include <liwservicehandler.h>

#include <liwvariant.h>

#include <liwgenericparam.h>

#include <bamdesca.h>

// User include files

#include "publisherinfo.h"

#include "publishermap.h"

#include "cpswrapper.h"

#include "cpsconst.h"

#include "cpsobserver.h"

namespace cpswrapper

    {

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

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

    // CCpsWrapper::NewL()

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

    //

    EXPORT_C CCpsWrapper* CCpsWrapper::NewL( MCpsWrapperObserver& aObserver )

        {

        CCpsWrapper* self = CCpsWrapper::NewLC( aObserver );

        CleanupStack::Pop( self );

        return self;

        }

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

    // CCpsWrapper::NewLC()

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

    //

    EXPORT_C CCpsWrapper* CCpsWrapper::NewLC(MCpsWrapperObserver& aObserver)

        {

        CCpsWrapper* self = new ( ELeave ) CCpsWrapper( aObserver );

        CleanupStack::PushL( self );

        self->ConstructL();

        return self;

        }

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

    // CCpsWrapper::ConstructL()

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

    //

    void CCpsWrapper::ConstructL()

        {

        iServiceHandler = CLiwServiceHandler::NewL();

        RCriteriaArray interestList;

        // Attach to CPS:

        iCpsService = CLiwCriteriaItem::NewL( 1, KCPSConfigurationIf, KCPS );

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

        interestList.AppendL( iCpsService );

        iServiceHandler->AttachL( interestList );

        interestList.Reset();

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

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

        iServiceHandler->ExecuteServiceCmdL(

                *iCpsService,

                inParamList,

                outParamList );

        TInt pos( 0 );

        outParamList.FindFirst( pos, KCPSConfigurationIf );

        if ( pos != KErrNotFound )

            {

            iCpsInterface = (outParamList)[pos].Value().AsInterface();

            inParamList.Reset();

            outParamList.Reset();

            }

        else

            {

            inParamList.Reset();

            outParamList.Reset();

            User::Leave( KErrNotFound );

            }

        StartListeningPublisherRegistryL();

        }

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

    // CCpsWrapper::CCpsWrapper()

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

    //

    CCpsWrapper::CCpsWrapper( MCpsWrapperObserver& aObserver )

        : iObserver( aObserver ),

        iCpsInterface( NULL )

        {

        }

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

    // CCpsWrapper::~CCpsWrapper()

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

    //

    EXPORT_C CCpsWrapper::~CCpsWrapper()

        {

        iObservers.ResetAndDestroy();

        if ( iCpsInterface )

            {

            // Close interface

            iCpsInterface->Close();

            }

        if ( iServiceHandler && iCpsService )

            {

            // Detach services from the handler

            RCriteriaArray interestList;

            TRAP_IGNORE( interestList.AppendL( iCpsService );

                         iServiceHandler->DetachL( interestList ); );

            interestList.Reset();

            }

        delete iCpsService;

        delete iServiceHandler;

        }

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

    // CCpsWrapper::GetTemplatedPublishersL()

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

    //

    EXPORT_C CPublisherMap* CCpsWrapper::GetTemplatedPublishersL()

        {

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

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

        TLiwGenericParam type( KType, TLiwVariant( KPublisher16 ) );

        inParamList.AppendL( type );

        CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

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

        //append filter to input param

        TLiwGenericParam item( KFilter, TLiwVariant( filter ));

        inParamList.AppendL( item );

        // Get all the publiser from CPS with publiser id ai3templatewidget

        iCpsInterface->ExecuteCmdL( KGetList, inParamList, outParamList );

        inParamList.Reset();

        CleanupStack::PopAndDestroy(filter);

        TInt pos(0);

        outParamList.FindFirst( pos, KResults );

        CPublisherMap* publishers = CPublisherMap::NewL();

        CleanupStack::PushL( publishers );

        if ( pos != KErrNotFound )

            {

            //extract iterator on results list

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

            CLiwIterable* iterable( variant.AsIterable() );

            iterable->Reset();

            //get all the templated widget publishers

            while ( iterable->NextL( variant ) )

                {

                //extract content map

                CLiwDefaultMap *publisherMap = CLiwDefaultMap::NewLC();

                variant.Get( *publisherMap );

                variant.Reset();

                CPublisherInfo* publisherInfo = CPublisherInfo::NewLC();

                if ( publisherMap->FindL( KPublisher, variant ) )

                    {

                    publisherInfo->SetPublisherIdL( variant.AsDes() );

                    variant.Reset();

                    }

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

                    {

                    CLiwDefaultMap* dataMap = CLiwDefaultMap::NewLC();

                    variant.Get( *dataMap );

                    variant.Reset();

                    if ( dataMap->FindL( KTemplateType, variant) )

                        {

                        publisherInfo->SetTemplateTypeL( variant.AsDes() );

                        variant.Reset();

                        }

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

                        {

                        publisherInfo->SetWidgetNameL( variant.AsDes() );

                        variant.Reset();

                        }

                    if ( dataMap->FindL( KMaxWidgets, variant ) )

                        {

                        publisherInfo->SetMaxWidgets(

                                variant.AsTInt32() );

                        variant.Reset();

                        }

                    else

                        {

                        // Use default value 1

                        publisherInfo->SetMaxWidgets( 1 );

                        }

                    if ( dataMap->FindL( KWidgetDesc, variant ) )

                        {

                        publisherInfo->SetDescriptionL( variant.AsDes() );

                        variant.Reset();

                        }

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

                        {

                        publisherInfo->SetLogoIconL( variant.AsDes() );

                        variant.Reset();

                        }

                    CleanupStack::PopAndDestroy( dataMap );

                    }

                publisherInfo->SetContentTypeL( KHSTemplate() );

                publishers->AddPublisherInfoL( publisherInfo );

                CleanupStack::Pop( publisherInfo );

                variant.Reset();

                CleanupStack::PopAndDestroy( publisherMap );

                }

            }

        GetWRTWidgetsL( *publishers );

        CleanupStack::Pop( publishers );

        outParamList.Reset();

        return publishers;

        }

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

   // CCpsWrapper::GetWRTWidgetsL()

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

   //

	void CCpsWrapper::GetWRTWidgetsL(CPublisherMap& aPublisherMap)

		{

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

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

		TLiwGenericParam type( KType, TLiwVariant( KPublisher16 ) );

		inParamList.AppendL( type );

		CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

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

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

		//append filter to input param

		TLiwGenericParam item( KFilter, TLiwVariant( filter ));

		inParamList.AppendL( item );

		// Get all the publiser from CPS with publiser id ai3templatewidget

		iCpsInterface->ExecuteCmdL( KGetList, inParamList, outParamList );

		inParamList.Reset();

		CleanupStack::PopAndDestroy(filter);

		TInt pos(0);

		outParamList.FindFirst( pos, KResults );

		if ( pos != KErrNotFound )

			{

			//extract iterator on results list

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

			CLiwIterable* iterable( variant.AsIterable() );

			iterable->Reset();

			//get all the templated widget publishers

			while ( iterable->NextL( variant ) )

				{

				//extract content map

				CLiwDefaultMap *publisherMap = CLiwDefaultMap::NewLC();

				variant.Get( *publisherMap );

				variant.Reset();

				CPublisherInfo* publisherInfo = CPublisherInfo::NewLC();

				if ( publisherMap->FindL( KContentId, variant ) )

					{

					publisherInfo->SetPublisherIdL( variant.AsDes() );

					variant.Reset();

					}

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

					{

					CLiwDefaultMap* dataMap = CLiwDefaultMap::NewLC();

					variant.Get( *dataMap );

					variant.Reset();

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

						{

						CLiwDefaultMap* widgetInfoMap = CLiwDefaultMap::NewLC();

						variant.Get( *widgetInfoMap );

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

							{

							publisherInfo->SetTemplateTypeL( variant.AsDes() );

							variant.Reset();

							}

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

							{

							publisherInfo->SetWidgetNameL( variant.AsDes() );

							variant.Reset();

							}

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

							{

							publisherInfo->SetDescriptionL( variant.AsDes() );

							variant.Reset();

							}

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

							{

							publisherInfo->SetLogoIconL( variant.AsDes() );

							variant.Reset();

							}

						CleanupStack::PopAndDestroy( widgetInfoMap );

						}

					CleanupStack::PopAndDestroy( dataMap );

					}

				publisherInfo->SetContentTypeL( KWRTTemplate() );

				publisherInfo->SetMaxWidgets(1);

				aPublisherMap.AddPublisherInfoL( publisherInfo );

				CleanupStack::Pop( publisherInfo );

				variant.Reset();

				CleanupStack::PopAndDestroy( publisherMap );

				}

			}

		outParamList.Reset();

		}

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

	// CCpsWrapper::RequestForNotificationL()

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

	//

    void CCpsWrapper::RequestForNotificationL(

    		const TDesC& aPublisher, 

    		const TDesC& aContentType,

    		const TDesC& aContentId,

    		const TDesC8& aOperation,

    		const TDesC& aRegistry)

    	{

    	CCpsObserver* observer = CCpsObserver::NewLC( this );

		CLiwDefaultMap* filter = CLiwDefaultMap::NewLC();

		filter->InsertL( KPublisher, TLiwVariant( aPublisher ) );

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

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

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

		observer->RegisterL( filter, aRegistry );

		iObservers.AppendL( observer );

		CleanupStack::PopAndDestroy(filter);

		CleanupStack::Pop( observer );

    	}

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

    // CCpsWrapper::StartListeningPublisherRegistryL()

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

    //

    void CCpsWrapper::StartListeningPublisherRegistryL()

        {

        // Start Listening all the WRT widgets registrations

        RequestForNotificationL( KAll, KWRTTemplate, KAll, KAddUpdateDelete, KPublisher16 );

        // Start Listening all the HS template widgets registrations

        RequestForNotificationL( KAll, KHSTemplate, KAll, KAddUpdateDelete , KPublisher16 );

        }

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

	// CCpsWrapper::HandleChangedPublisherL()

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

	//

    void CCpsWrapper::HandleChangedPublisherL(const TDesC& aPublisher, 

            const TDesC& aOperation)

    	{       

        if ( aOperation == KDelete16 )

            {

            iObserver.NotifyWidgetUnregisteredL( aPublisher );

            }

        else if ( aOperation == KAdd16 )

            {

            iObserver.NotifyWidgetRegisteredL();

            }

        else if ( aOperation == KUpdate16 )

            {

            iObserver.NotifyWidgetUpdatedL();

            }

    	}

    }

// End of file