/* -*- 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 #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include 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: */