Adding upstream version 4:7.4.7.upstream/4%7.4.7upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 496 insertions, 0 deletions

diff --git a/ucbhelper/source/provider/providerhelper.cxx b/ucbhelper/source/provider/providerhelper.cxx
new file mode 100644
index 000000000..c0bbc8616
--- /dev/null
+++ b/ucbhelper/source/provider/providerhelper.cxx
@@ -0,0 +1,496 @@
+/* -*- 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 <com/sun/star/beans/IllegalTypeException.hpp>
+#include <com/sun/star/beans/PropertyExistException.hpp>
+#include <com/sun/star/beans/XPropertyAccess.hpp>
+#include <com/sun/star/container/XNameAccess.hpp>
+#include <com/sun/star/container/XNamed.hpp>
+#include <com/sun/star/ucb/Store.hpp>
+#include <com/sun/star/ucb/XPropertySetRegistry.hpp>
+#include <com/sun/star/ucb/XPropertySetRegistryFactory.hpp>
+#include <cppuhelper/supportsservice.hxx>
+#include <ucbhelper/contenthelper.hxx>
+#include <ucbhelper/providerhelper.hxx>
+
+#include <osl/diagnose.h>
+#include <osl/mutex.hxx>
+#include <cppuhelper/weakref.hxx>
+
+#include <unordered_map>
+
+using namespace com::sun::star;
+
+namespace ucbhelper_impl
+{
+
+typedef std::unordered_map
+<
+    OUString,
+    uno::WeakReference< ucb::XContent >
+>
+Contents;
+
+struct ContentProviderImplHelper_Impl
+{
+    uno::Reference< css::ucb::XPropertySetRegistry >  m_xPropertySetRegistry;
+    Contents                                          m_aContents;
+};
+
+} // namespace ucbhelper_impl
+
+namespace ucbhelper {
+
+ContentProviderImplHelper::ContentProviderImplHelper(
+    const uno::Reference< uno::XComponentContext >& rxContext )
+: m_pImpl( new ucbhelper_impl::ContentProviderImplHelper_Impl ),
+  m_xContext( rxContext )
+{
+}
+
+// virtual
+ContentProviderImplHelper::~ContentProviderImplHelper()
+{
+}
+
+// virtual
+sal_Bool SAL_CALL ContentProviderImplHelper::supportsService(
+                                            const OUString& ServiceName )
+{
+    return cppu::supportsService(this, ServiceName);
+}
+
+// virtual
+sal_Int32 SAL_CALL ContentProviderImplHelper::compareContentIds(
+        const uno::Reference< css::ucb::XContentIdentifier >& Id1,
+        const uno::Reference< css::ucb::XContentIdentifier >& Id2 )
+{
+    // Simply do a string compare.
+
+    OUString aURL1( Id1->getContentIdentifier() );
+    OUString aURL2( Id2->getContentIdentifier() );
+
+    return aURL1.compareTo( aURL2 );
+}
+
+void ContentProviderImplHelper::cleanupRegisteredContents()
+{
+    osl::MutexGuard aGuard( m_aMutex );
+
+    ucbhelper_impl::Contents::iterator it
+        = m_pImpl->m_aContents.begin();
+    while( it != m_pImpl->m_aContents.end() )
+    {
+        uno::Reference< ucb::XContent > xContent( (*it).second );
+        if ( !xContent.is() )
+        {
+            ucbhelper_impl::Contents::iterator tmp = it;
+            ++it;
+            m_pImpl->m_aContents.erase( tmp );
+        }
+        else
+        {
+            ++it;
+        }
+    }
+}
+
+void ContentProviderImplHelper::removeContent( ContentImplHelper* pContent )
+{
+    osl::MutexGuard aGuard( m_aMutex );
+
+    cleanupRegisteredContents();
+
+    const OUString aURL(
+        pContent->getIdentifier()->getContentIdentifier() );
+
+    ucbhelper_impl::Contents::iterator it = m_pImpl->m_aContents.find( aURL );
+
+    if ( it != m_pImpl->m_aContents.end() )
+        m_pImpl->m_aContents.erase( it );
+}
+
+rtl::Reference< ContentImplHelper >
+ContentProviderImplHelper::queryExistingContent(
+    const uno::Reference< css::ucb::XContentIdentifier >& Identifier )
+{
+    return queryExistingContent( Identifier->getContentIdentifier() );
+}
+
+rtl::Reference< ContentImplHelper >
+ContentProviderImplHelper::queryExistingContent( const OUString& rURL )
+{
+    osl::MutexGuard aGuard( m_aMutex );
+
+    cleanupRegisteredContents();
+
+    // Check, if a content with given id already exists...
+
+    ucbhelper_impl::Contents::const_iterator it
+        = m_pImpl->m_aContents.find( rURL );
+    if ( it != m_pImpl->m_aContents.end() )
+    {
+        uno::Reference< ucb::XContent > xContent( (*it).second );
+        if ( xContent.is() )
+        {
+            return rtl::Reference< ContentImplHelper >(
+                static_cast< ContentImplHelper * >( xContent.get() ) );
+        }
+    }
+    return rtl::Reference< ContentImplHelper >();
+}
+
+void ContentProviderImplHelper::queryExistingContents(
+        ContentRefList& rContents )
+{
+    osl::MutexGuard aGuard( m_aMutex );
+
+    cleanupRegisteredContents();
+
+    for ( const auto& rContent : m_pImpl->m_aContents )
+    {
+        uno::Reference< ucb::XContent > xContent( rContent.second );
+        if ( xContent.is() )
+        {
+            rContents.emplace_back(
+                    static_cast< ContentImplHelper * >( xContent.get() ) );
+        }
+    }
+}
+
+void ContentProviderImplHelper::registerNewContent(
+    const uno::Reference< ucb::XContent > & xContent )
+{
+    if ( !xContent.is() )
+        return;
+
+    osl::MutexGuard aGuard( m_aMutex );
+
+    cleanupRegisteredContents();
+
+    const OUString aURL(
+        xContent->getIdentifier()->getContentIdentifier() );
+    ucbhelper_impl::Contents::const_iterator it
+        = m_pImpl->m_aContents.find( aURL );
+    if ( it == m_pImpl->m_aContents.end() )
+        m_pImpl->m_aContents[ aURL ] = xContent;
+}
+
+uno::Reference< css::ucb::XPropertySetRegistry >
+ContentProviderImplHelper::getAdditionalPropertySetRegistry()
+{
+    // Get propertyset registry.
+
+    osl::MutexGuard aGuard( m_aMutex );
+
+    if ( !m_pImpl->m_xPropertySetRegistry.is() )
+    {
+        uno::Reference< css::ucb::XPropertySetRegistryFactory >
+            xRegFac = css::ucb::Store::create( m_xContext );
+
+        // Open/create a registry.
+        m_pImpl->m_xPropertySetRegistry
+            = xRegFac->createPropertySetRegistry( OUString() );
+
+        OSL_ENSURE( m_pImpl->m_xPropertySetRegistry.is(),
+                "ContentProviderImplHelper::getAdditionalPropertySet - "
+                "Error opening registry!" );
+    }
+
+    return m_pImpl->m_xPropertySetRegistry;
+}
+
+uno::Reference< css::ucb::XPersistentPropertySet >
+ContentProviderImplHelper::getAdditionalPropertySet(
+    const OUString& rKey, bool bCreate )
+{
+    // Get propertyset registry.
+    getAdditionalPropertySetRegistry();
+
+    if ( m_pImpl->m_xPropertySetRegistry.is() )
+    {
+        // Open/create persistent property set.
+        return m_pImpl->m_xPropertySetRegistry->openPropertySet(
+                rKey, bCreate );
+    }
+
+    return uno::Reference< css::ucb::XPersistentPropertySet >();
+}
+
+bool ContentProviderImplHelper::renameAdditionalPropertySet(
+    const OUString& rOldKey,
+    const OUString& rNewKey,
+    bool bRecursive )
+{
+    if ( rOldKey == rNewKey )
+        return true;
+
+    osl::MutexGuard aGuard( m_aMutex );
+
+    if ( bRecursive )
+    {
+        // Get propertyset registry.
+        getAdditionalPropertySetRegistry();
+
+        if ( !m_pImpl->m_xPropertySetRegistry.is() )
+            return false;
+
+        uno::Reference< container::XNameAccess > xNameAccess(
+            m_pImpl->m_xPropertySetRegistry, uno::UNO_QUERY );
+        if ( !xNameAccess.is() )
+            return false;
+
+        const uno::Sequence< OUString > aKeys
+            = xNameAccess->getElementNames();
+        if ( aKeys.hasElements() )
+        {
+            OUString aOldKeyWithSlash = rOldKey;
+            OUString aOldKeyWithoutSlash;
+            if ( !aOldKeyWithSlash.endsWith("/") )
+            {
+                aOldKeyWithSlash += "/";
+                aOldKeyWithoutSlash = rOldKey;
+            }
+            else if ( !rOldKey.isEmpty() )
+                aOldKeyWithoutSlash
+                    = rOldKey.copy( 0, rOldKey.getLength() - 1 );
+
+            for ( const OUString& rKey : aKeys )
+            {
+                if ( rKey.startsWith( aOldKeyWithSlash )
+                     || rKey == aOldKeyWithoutSlash )
+                {
+                    OUString aNewKey
+                        = rKey.replaceAt(
+                            0, rOldKey.getLength(), rNewKey );
+                    if ( !renameAdditionalPropertySet(
+                            rKey, aNewKey, false ) )
+                        return false;
+                }
+            }
+        }
+    }
+    else
+    {
+        // Get old property set, if exists.
+        uno::Reference< css::ucb::XPersistentPropertySet > xOldSet
+            = getAdditionalPropertySet( rOldKey, false );
+        if ( xOldSet.is() )
+        {
+            // Rename property set.
+            uno::Reference< container::XNamed > xNamed(
+                xOldSet, uno::UNO_QUERY );
+            if ( !xNamed.is() )
+                return false;
+
+            // ??? throws no exceptions and has no return value ???
+            xNamed->setName( rNewKey );
+        }
+    }
+    return true;
+}
+
+bool ContentProviderImplHelper::copyAdditionalPropertySet(
+    const OUString& rSourceKey,
+    const OUString& rTargetKey,
+    bool bRecursive )
+{
+    if ( rSourceKey == rTargetKey )
+        return true;
+
+    osl::MutexGuard aGuard( m_aMutex );
+
+    if ( bRecursive )
+    {
+        // Get propertyset registry.
+        getAdditionalPropertySetRegistry();
+
+        if ( !m_pImpl->m_xPropertySetRegistry.is() )
+            return false;
+
+        uno::Reference< container::XNameAccess > xNameAccess(
+            m_pImpl->m_xPropertySetRegistry, uno::UNO_QUERY );
+        if ( !xNameAccess.is() )
+            return false;
+
+        const uno::Sequence< OUString > aKeys
+            = xNameAccess->getElementNames();
+        if ( aKeys.hasElements() )
+        {
+            OUString aSrcKeyWithSlash = rSourceKey;
+            OUString aSrcKeyWithoutSlash;
+            if ( !aSrcKeyWithSlash.endsWith("/") )
+            {
+                aSrcKeyWithSlash += "/";
+                aSrcKeyWithoutSlash = rSourceKey;
+            }
+            else if ( !rSourceKey.isEmpty() )
+                aSrcKeyWithoutSlash = rSourceKey.copy(
+                    0, rSourceKey.getLength() - 1 );
+
+            for ( const OUString& rKey : aKeys )
+            {
+                if ( rKey.startsWith(aSrcKeyWithSlash )
+                     || rKey == aSrcKeyWithoutSlash )
+                {
+                    OUString aNewKey
+                        = rKey.replaceAt(
+                            0, rSourceKey.getLength(), rTargetKey );
+                    if ( !copyAdditionalPropertySet(
+                            rKey, aNewKey, false ) )
+                        return false;
+                }
+            }
+        }
+    }
+    else
+    {
+        // Get old property set, if exists.
+        uno::Reference< css::ucb::XPersistentPropertySet >
+            xOldPropSet = getAdditionalPropertySet( rSourceKey, false );
+        if ( !xOldPropSet.is() )
+            return false;
+
+        uno::Reference< beans::XPropertySetInfo > xPropSetInfo
+            = xOldPropSet->getPropertySetInfo();
+        if ( !xPropSetInfo.is() )
+            return false;
+
+        uno::Reference< beans::XPropertyAccess > xOldPropAccess(
+            xOldPropSet, uno::UNO_QUERY );
+        if ( !xOldPropAccess.is() )
+            return false;
+
+        // Obtain all values from old set.
+        const uno::Sequence< beans::PropertyValue > aValues
+            = xOldPropAccess->getPropertyValues();
+
+        const uno::Sequence< beans::Property > aProps
+            = xPropSetInfo->getProperties();
+
+        if ( aValues.hasElements() )
+        {
+            // Fail, if property set with new key already exists.
+            uno::Reference< css::ucb::XPersistentPropertySet >
+                xNewPropSet
+                    = getAdditionalPropertySet( rTargetKey, false );
+            if ( xNewPropSet.is() )
+                return false;
+
+            // Create new, empty set.
+            xNewPropSet = getAdditionalPropertySet( rTargetKey, true );
+            if ( !xNewPropSet.is() )
+                return false;
+
+            uno::Reference< beans::XPropertyContainer > xNewPropContainer(
+                xNewPropSet, uno::UNO_QUERY );
+            if ( !xNewPropContainer.is() )
+                return false;
+
+            for ( const beans::PropertyValue& rValue : aValues )
+            {
+                sal_Int16 nAttribs = 0;
+                auto pProp = std::find_if(aProps.begin(), aProps.end(),
+                    [&rValue](const beans::Property& rProp) { return rProp.Name == rValue.Name; });
+                if (pProp != aProps.end())
+                    nAttribs = pProp->Attributes;
+
+                try
+                {
+                    xNewPropContainer->addProperty(
+                        rValue.Name, nAttribs, rValue.Value );
+                }
+                catch ( beans::PropertyExistException & )
+                {
+                }
+                   catch ( beans::IllegalTypeException & )
+                {
+                }
+                catch ( lang::IllegalArgumentException & )
+                {
+                }
+            }
+        }
+    }
+    return true;
+}
+
+bool ContentProviderImplHelper::removeAdditionalPropertySet(
+    const OUString& rKey, bool bRecursive )
+{
+    osl::MutexGuard aGuard( m_aMutex );
+
+    if ( bRecursive )
+    {
+        // Get propertyset registry.
+        getAdditionalPropertySetRegistry();
+
+        if ( !m_pImpl->m_xPropertySetRegistry.is() )
+            return false;
+
+        uno::Reference< container::XNameAccess > xNameAccess(
+            m_pImpl->m_xPropertySetRegistry, uno::UNO_QUERY );
+        if ( !xNameAccess.is() )
+            return false;
+
+        const uno::Sequence< OUString > aKeys
+            = xNameAccess->getElementNames();
+        if ( aKeys.hasElements() )
+        {
+            OUString aKeyWithSlash = rKey;
+            OUString aKeyWithoutSlash;
+            if ( !aKeyWithSlash.endsWith("/") )
+            {
+                aKeyWithSlash += "/";
+                aKeyWithoutSlash = rKey;
+            }
+            else if ( !rKey.isEmpty() )
+                aKeyWithoutSlash
+                    = rKey.copy( 0, rKey.getLength() - 1 );
+
+            for ( const OUString& rCurrKey : aKeys )
+            {
+                if ( rCurrKey.startsWith(aKeyWithSlash )
+                     || rCurrKey == aKeyWithoutSlash )
+                {
+                    if ( !removeAdditionalPropertySet(
+                             rCurrKey, false ) )
+                        return false;
+                }
+            }
+        }
+    }
+    else
+    {
+        // Get propertyset registry.
+        getAdditionalPropertySetRegistry();
+
+        if ( !m_pImpl->m_xPropertySetRegistry.is() )
+            return false;
+
+        m_pImpl->m_xPropertySetRegistry->removePropertySet( rKey );
+    }
+    return true;
+}
+
+} // namespace ucbhelper
+
+/* vim:set shiftwidth=4 softtabstop=4 expandtab: */