/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */

/*

 * This file is part of the LibreOffice project.

 *

 * This Source Code Form is subject to the terms of the Mozilla Public

 * License, v. 2.0. If a copy of the MPL was not distributed with this

 * file, You can obtain one at http://mozilla.org/MPL/2.0/.

 *

 * This file incorporates work covered by the following license notice:

 *

 *   Licensed to the Apache Software Foundation (ASF) under one or more

 *   contributor license agreements. See the NOTICE file distributed

 *   with this work for additional information regarding copyright

 *   ownership. The ASF licenses this file to you under the Apache

 *   License, Version 2.0 (the "License"); you may not use this file

 *   except in compliance with the License. You may obtain a copy of

 *   the License at http://www.apache.org/licenses/LICENSE-2.0 .

 */

#include <sal/config.h>

#include <map>

#include <com/sun/star/lang/XServiceInfo.hpp>

#include <com/sun/star/lang/XTypeProvider.hpp>

#include <com/sun/star/uno/XAggregation.hpp>

#include <cppuhelper/supportsservice.hxx>

#include <comphelper/multiinterfacecontainer4.hxx>

#include <comphelper/propertysethelper.hxx>

#include <mutex>

#include <rtl/ref.hxx>

#include <comphelper/genericpropertyset.hxx>

#include <comphelper/propertysetinfo.hxx>

using namespace ::cppu;

using namespace ::comphelper;

using namespace ::com::sun::star;

using namespace ::com::sun::star::uno;

using namespace ::com::sun::star::beans;

using namespace ::com::sun::star::lang;

namespace comphelper

{

    namespace {

    class GenericPropertySet :  public OWeakObject,

                                public XServiceInfo,

                                public XTypeProvider,

                                public PropertySetHelper

    {

    private:

        std::map<OUString, Any>   maAnyMap;

        std::mutex                maMutex;

        comphelper::OMultiTypeInterfaceContainerHelperVar4<OUString, XPropertyChangeListener> m_aListener;

    protected:

        virtual void _setPropertyValues( const PropertyMapEntry** ppEntries, const  Any* pValues ) override;

        virtual void _getPropertyValues( const PropertyMapEntry** ppEntries,  Any* pValue ) override;

    public:

        explicit GenericPropertySet( PropertySetInfo* pInfo ) noexcept;

        // XInterface

        virtual  Any SAL_CALL queryInterface( const  Type & rType ) override;

        virtual void SAL_CALL acquire() noexcept override;

        virtual void SAL_CALL release() noexcept override;

        // XTypeProvider

        virtual  Sequence<  Type > SAL_CALL getTypes(  ) override;

        virtual  Sequence< sal_Int8 > SAL_CALL getImplementationId(  ) override;

        // XServiceInfo

        virtual OUString SAL_CALL getImplementationName() override;

        virtual sal_Bool SAL_CALL supportsService( const OUString& ServiceName ) override;

        virtual  Sequence< OUString > SAL_CALL getSupportedServiceNames() override;

        // XPropertySet

        virtual void SAL_CALL addPropertyChangeListener( const OUString& aPropertyName, const css::uno::Reference< css::beans::XPropertyChangeListener >& xListener ) override;

        virtual void SAL_CALL removePropertyChangeListener( const OUString& aPropertyName, const css::uno::Reference< css::beans::XPropertyChangeListener >& aListener ) override;

    };

    }

}

GenericPropertySet::GenericPropertySet( PropertySetInfo* pInfo ) noexcept

: PropertySetHelper( pInfo )

{

}

void SAL_CALL GenericPropertySet::addPropertyChangeListener( const OUString& aPropertyName, const Reference< XPropertyChangeListener >& xListener )

{

    Reference < XPropertySetInfo > xInfo = getPropertySetInfo(  );

    if ( !xInfo.is() )

        return;

    std::unique_lock aGuard(maMutex);

    if ( aPropertyName.isEmpty() )

    {

        for (auto& prop : xInfo->getProperties())

        {

            m_aListener.addInterface(aGuard, prop.Name, xListener);

        }

    }

    else if ( xInfo->hasPropertyByName(aPropertyName) )

        m_aListener.addInterface(aGuard, aPropertyName,xListener);

    else

        throw UnknownPropertyException( aPropertyName, *this );

}

void SAL_CALL GenericPropertySet::removePropertyChangeListener( const OUString& aPropertyName, const Reference< XPropertyChangeListener >& xListener )

{

    Reference < XPropertySetInfo > xInfo = getPropertySetInfo(  );

    if ( !xInfo.is() )

        return;

    std::unique_lock aGuard(maMutex);

    if ( aPropertyName.isEmpty() )

    {

        for (auto& prop : xInfo->getProperties())

        {

            m_aListener.removeInterface(aGuard, prop.Name, xListener);

        }

    }

    else if ( xInfo->hasPropertyByName(aPropertyName) )

        m_aListener.removeInterface(aGuard, aPropertyName,xListener);

    else

        throw UnknownPropertyException( aPropertyName, *this );

}

void GenericPropertySet::_setPropertyValues( const PropertyMapEntry** ppEntries, const Any* pValues )

{

    std::unique_lock aGuard(maMutex);

    while( *ppEntries )

    {

        OInterfaceContainerHelper4<XPropertyChangeListener> * pHelper = m_aListener.getContainer(aGuard, (*ppEntries)->maName);

        maAnyMap[ (*ppEntries)->maName ] = *pValues;

        if ( pHelper )

        {

            PropertyChangeEvent aEvt;

            aEvt.PropertyName = (*ppEntries)->maName;

            aEvt.NewValue = *pValues;

            pHelper->notifyEach( aGuard, &XPropertyChangeListener::propertyChange, aEvt );

        }

        ppEntries++;

        pValues++;

    }

}

void GenericPropertySet::_getPropertyValues( const comphelper::PropertyMapEntry** ppEntries, Any* pValue )

{

    std::unique_lock aGuard(maMutex);

    while( *ppEntries )

    {

        *pValue = maAnyMap[ (*ppEntries)->maName ];

        ppEntries++;

        pValue++;

    }

}

// XInterface

Any SAL_CALL GenericPropertySet::queryInterface( const Type & rType )

{

    Any aAny;

    if( rType == cppu::UnoType<XServiceInfo>::get())

        aAny <<= Reference< XServiceInfo >(this);

    else if( rType == cppu::UnoType<XTypeProvider>::get())

        aAny <<= Reference< XTypeProvider >(this);

    else if( rType == cppu::UnoType<XPropertySet>::get())

        aAny <<= Reference< XPropertySet >(this);

    else if( rType == cppu::UnoType<XMultiPropertySet>::get())

        aAny <<= Reference< XMultiPropertySet >(this);

    else

        aAny = OWeakObject::queryInterface( rType );

    return aAny;

}

void SAL_CALL GenericPropertySet::acquire() noexcept

{

    OWeakObject::acquire();

}

void SAL_CALL GenericPropertySet::release() noexcept

{

    OWeakObject::release();

}

uno::Sequence< uno::Type > SAL_CALL GenericPropertySet::getTypes()

{

    return uno::Sequence {

        cppu::UnoType<XAggregation>::get(),

        cppu::UnoType<XServiceInfo>::get(),

        cppu::UnoType<XTypeProvider>::get(),

        cppu::UnoType<XPropertySet>::get(),

        cppu::UnoType<XMultiPropertySet>::get() };

}

uno::Sequence< sal_Int8 > SAL_CALL GenericPropertySet::getImplementationId()

{

    return css::uno::Sequence<sal_Int8>();

}

// XServiceInfo

sal_Bool SAL_CALL GenericPropertySet::supportsService( const  OUString& ServiceName )

{

    return cppu::supportsService(this, ServiceName);

}

OUString SAL_CALL GenericPropertySet::getImplementationName()

{

    return u"com.sun.star.comp.comphelper.GenericPropertySet"_ustr;

}

Sequence< OUString > SAL_CALL GenericPropertySet::getSupportedServiceNames(  )

{

    return { u"com.sun.star.beans.XPropertySet"_ustr };

}

css::uno::Reference< css::beans::XPropertySet > comphelper::GenericPropertySet_CreateInstance( comphelper::PropertySetInfo* pInfo )

{

    return static_cast<XPropertySet*>(new GenericPropertySet( pInfo ));

}

/* vim:set shiftwidth=4 softtabstop=4 expandtab: */