949 lines
36 KiB
C++
949 lines
36 KiB
C++
/*************************************************************************
|
|
*
|
|
* $RCSfile: providerimpl.cxx,v $
|
|
*
|
|
* $Revision: 1.56 $
|
|
*
|
|
* last change: $Author: hr $ $Date: 2003-03-19 16:18:36 $
|
|
*
|
|
* The Contents of this file are made available subject to the terms of
|
|
* either of the following licenses
|
|
*
|
|
* - GNU Lesser General Public License Version 2.1
|
|
* - Sun Industry Standards Source License Version 1.1
|
|
*
|
|
* Sun Microsystems Inc., October, 2000
|
|
*
|
|
* GNU Lesser General Public License Version 2.1
|
|
* =============================================
|
|
* Copyright 2000 by Sun Microsystems, Inc.
|
|
* 901 San Antonio Road, Palo Alto, CA 94303, USA
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License version 2.1, as published by the Free Software Foundation.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
|
|
* MA 02111-1307 USA
|
|
*
|
|
*
|
|
* Sun Industry Standards Source License Version 1.1
|
|
* =================================================
|
|
* The contents of this file are subject to the Sun Industry Standards
|
|
* Source License Version 1.1 (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.openoffice.org/license.html.
|
|
*
|
|
* Software provided under this License is provided on an "AS IS" basis,
|
|
* WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
|
|
* WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
|
|
* MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
|
|
* See the License for the specific provisions governing your rights and
|
|
* obligations concerning the Software.
|
|
*
|
|
* The Initial Developer of the Original Code is: Sun Microsystems, Inc.
|
|
*
|
|
* Copyright: 2000 by Sun Microsystems, Inc.
|
|
*
|
|
* All Rights Reserved.
|
|
*
|
|
* Contributor(s): _______________________________________
|
|
*
|
|
*
|
|
************************************************************************/
|
|
|
|
#include <stdio.h>
|
|
#include "providerimpl.hxx"
|
|
|
|
#ifndef CONFIGMGR_MISC_OPTIONS_HXX_
|
|
#include "options.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_API_FACTORYIMPL_HXX_
|
|
#include "apifactoryimpl.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_API_TREEIMPLOBJECTS_HXX_
|
|
#include "apitreeimplobj.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_API_TREEACCESS_HXX_
|
|
#include "apitreeaccess.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_ROOTTREE_HXX_
|
|
#include "roottree.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_CONFIGNODE_HXX_
|
|
#include "noderef.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_API_OBJECTREGISTRY_HXX_
|
|
#include "objectregistry.hxx"
|
|
#endif
|
|
|
|
#ifndef CONFIGMGR_BOOTSTRAP_HXX_
|
|
#include "bootstrap.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_CACHEFACTORY_HXX_
|
|
#include "cachefactory.hxx"
|
|
#endif
|
|
|
|
#ifndef CONFIGMGR_API_PROVIDER_HXX_
|
|
#include "provider.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_TREEPROVIDER_HXX
|
|
#include "treeprovider.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_TREEMANAGER_HXX_
|
|
#include "treemanager.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_TREEACCESSOR_HXX
|
|
#include "treeaccessor.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_GROUPNODEACCESS_HXX
|
|
#include "groupnodeaccess.hxx"
|
|
#endif
|
|
#ifndef CONFIGMGR_VALUENODEACCESS_HXX
|
|
#include "valuenodeaccess.hxx"
|
|
#endif
|
|
#ifndef _CONFIGMGR_TRACER_HXX_
|
|
#include "tracer.hxx"
|
|
#endif
|
|
|
|
#ifndef _OSL_INTERLOCK_H_
|
|
#include <osl/interlck.h>
|
|
#endif
|
|
|
|
#ifndef _COM_SUN_STAR_BEANS_PROPERTYVALUE_HPP_
|
|
#include <com/sun/star/beans/PropertyValue.hpp>
|
|
#endif
|
|
#ifndef _COM_SUN_STAR_LANG_DISPOSEDEXCEPTION_HPP_
|
|
#include <com/sun/star/lang/DisposedException.hpp>
|
|
#endif
|
|
#ifndef _COM_SUN_STAR_LANG_LOCALE_HPP_
|
|
#include <com/sun/star/lang/Locale.hpp>
|
|
#endif
|
|
|
|
#ifndef _RTL_USTRBUF_HXX_
|
|
#include <rtl/ustrbuf.hxx>
|
|
#endif
|
|
#ifndef _RTL_LOGFILE_HXX_
|
|
#include <rtl/logfile.hxx>
|
|
#endif
|
|
|
|
#define RTL_LOGFILE_OU2A(rtlOUString) (::rtl::OUStringToOString((rtlOUString), RTL_TEXTENCODING_ASCII_US).getStr())
|
|
|
|
namespace configmgr
|
|
{
|
|
namespace css = ::com::sun::star;
|
|
namespace uno = css::uno;
|
|
namespace beans = css::beans;
|
|
using ::rtl::OUString;
|
|
|
|
using configapi::NodeElement;
|
|
using configuration::RootTree;
|
|
using configuration::SpecialTemplateProvider;
|
|
|
|
namespace configapi
|
|
{
|
|
|
|
class ApiProviderInstances
|
|
{
|
|
ObjectRegistryHolder m_aObjectRegistry;
|
|
ReadOnlyObjectFactory m_aReaderFactory;
|
|
UpdateObjectFactory m_aWriterFactory;
|
|
ApiProvider m_aReaderProvider;
|
|
ApiProvider m_aWriterProvider;
|
|
public:
|
|
ApiProviderInstances(OProviderImpl& rProviderImpl)
|
|
: m_aObjectRegistry(new ObjectRegistry())
|
|
, m_aReaderFactory(m_aReaderProvider,m_aObjectRegistry)
|
|
, m_aWriterFactory(m_aWriterProvider,m_aObjectRegistry)
|
|
, m_aReaderProvider(m_aReaderFactory,rProviderImpl)
|
|
, m_aWriterProvider(m_aWriterFactory,rProviderImpl)
|
|
{
|
|
}
|
|
|
|
~ApiProviderInstances()
|
|
{}
|
|
|
|
ApiProvider& getReaderProvider() { return m_aReaderProvider; }
|
|
ApiProvider& getWriterProvider() { return m_aWriterProvider; }
|
|
Factory& getReaderFactory() { return m_aReaderFactory; }
|
|
Factory& getWriterFactory() { return m_aWriterFactory; }
|
|
};
|
|
}
|
|
|
|
//=============================================================================
|
|
|
|
//=============================================================================
|
|
//= OProviderImpl
|
|
//=============================================================================
|
|
//-----------------------------------------------------------------------------
|
|
OProviderImpl::OProviderImpl(OProvider* _pProvider, CreationContext const & _xContext)
|
|
:m_pNewProviders(0)
|
|
,m_pProvider(_pProvider)
|
|
,m_aTreeManagerMutex()
|
|
,m_pTreeManager(NULL)
|
|
,m_aDefaultOptions()
|
|
{
|
|
OSL_ENSURE(_xContext.is(), "OProviderImpl : NULL context !");
|
|
|
|
uno::Reference< lang::XMultiComponentFactory > xFactory = _xContext->getServiceManager();
|
|
OSL_ENSURE(xFactory.is(), "OProviderImpl : missing service factory !");
|
|
|
|
m_xTypeConverter = m_xTypeConverter.query(
|
|
xFactory->createInstanceWithContext( OUString(RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.script.Converter" )),
|
|
_xContext));
|
|
|
|
OSL_ENSURE(m_xTypeConverter.is(), "Module::Module : could not create an instance of the type converter !");
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
rtl::Reference< TreeManager > OProviderImpl::maybeGetTreeManager() const CFG_NOTHROW()
|
|
{
|
|
osl::MutexGuard aGuard(m_aTreeManagerMutex);
|
|
rtl::Reference< TreeManager > xResult(m_pTreeManager);
|
|
return xResult;
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
rtl::Reference< TreeManager > OProviderImpl::getTreeManager() const CFG_UNO_THROW_RTE()
|
|
{
|
|
osl::MutexGuard aGuard(m_aTreeManagerMutex);
|
|
if (m_pTreeManager == NULL)
|
|
{
|
|
OUString sMsg = OUString::createFromAscii("OProviderImpl: No cache available - provider was already disposed.");
|
|
throw com::sun::star::lang::DisposedException(sMsg,static_cast<lang::XMultiServiceFactory*>(m_pProvider));
|
|
}
|
|
rtl::Reference< TreeManager > xResult(m_pTreeManager);
|
|
return xResult;
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::setTreeManager(TreeManager * pTreeManager) CFG_UNO_THROW_RTE()
|
|
{
|
|
osl::MutexGuard aGuard(m_aTreeManagerMutex);
|
|
|
|
OSL_PRECOND(m_pTreeManager == NULL, "OProviderImpl: TreeManager is already set");
|
|
OSL_PRECOND(pTreeManager != NULL, "OProviderImpl: Trying to set a NULL TreeManager");
|
|
|
|
if (pTreeManager == NULL)
|
|
{
|
|
OUString sMsg = OUString::createFromAscii("OProviderImpl: No cache available - cache creation failed.");
|
|
throw com::sun::star::uno::RuntimeException(sMsg,NULL);
|
|
}
|
|
|
|
(m_pTreeManager = pTreeManager) -> acquire();
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::clearTreeManager() CFG_NOTHROW()
|
|
{
|
|
osl::ClearableMutexGuard aGuard(m_aTreeManagerMutex);
|
|
if (TreeManager * pTM = m_pTreeManager)
|
|
{
|
|
m_pTreeManager = NULL;
|
|
pTM->release();
|
|
}
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
bool OProviderImpl::initSession(const ContextReader& _rSettings)
|
|
{
|
|
bool bNeedProfile = false;
|
|
rtl::Reference< TreeManager > xNewTreeManager;
|
|
if (_rSettings.isUnoBackend())
|
|
{
|
|
this->implInitFromSettings(_rSettings,bNeedProfile);
|
|
|
|
xNewTreeManager = CacheFactory::instance().createCacheManager(_rSettings.getBaseContext());
|
|
}
|
|
else
|
|
{
|
|
throw com::sun::star::uno::RuntimeException(OUString::createFromAscii("OProviderImpl: Only UNO Backends Supported"),NULL);
|
|
}
|
|
|
|
setTreeManager( xNewTreeManager.get() );
|
|
OSL_ASSERT( xNewTreeManager.get() );
|
|
|
|
// put out of line to get rid of the order dependency (and to have a acquired configuration)
|
|
m_pNewProviders = new configapi::ApiProviderInstances(*this);
|
|
|
|
// now complete our state from the user's profile, if necessary
|
|
if (bNeedProfile)
|
|
try
|
|
{
|
|
static ::rtl::OUString ssUserProfile(RTL_CONSTASCII_USTRINGPARAM("org.openoffice.Setup"));
|
|
AbsolutePath aProfileModule = AbsolutePath::makeModulePath(ssUserProfile, AbsolutePath::NoValidate());
|
|
|
|
data::NodeAccess aProfileTree = xNewTreeManager->requestSubtree(aProfileModule, m_aDefaultOptions);
|
|
if (aProfileTree.isValid())
|
|
{
|
|
implInitFromProfile(aProfileTree);
|
|
|
|
// should we clean this up ?
|
|
// xNewTreeManager->releaseSubtree(aProfileModule, xTempOptions);
|
|
}
|
|
}
|
|
catch (uno::Exception& e)
|
|
{
|
|
// could not read profile
|
|
CFG_TRACE_ERROR_NI("Provider bootstrapping: Caught an exception trying to get 'Setup' data: ", OUSTRING2ASCII(e.Message));
|
|
}
|
|
|
|
return true;
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
|
|
// these can be overridden. default does nothing
|
|
void OProviderImpl::initFromSettings(const ContextReader& , bool& )
|
|
{
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::initFromProfile(data::NodeAccess const& )
|
|
{
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
// these implement the base class behavior
|
|
void OProviderImpl::implInitFromSettings(const ContextReader& _rSettings, bool& rNeedProfile)
|
|
{
|
|
bool bIntrinsicNeedProfile = true;
|
|
|
|
if (_rSettings.hasLocale())
|
|
{
|
|
bIntrinsicNeedProfile = false;
|
|
rtl::OUString sDefaultLocale = _rSettings.getLocale();
|
|
m_aDefaultOptions.setLocale(sDefaultLocale);
|
|
}
|
|
else if (_rSettings.isAdminService())
|
|
{
|
|
bIntrinsicNeedProfile = false;
|
|
m_aDefaultOptions.setAllLocales();
|
|
}
|
|
else
|
|
OSL_ASSERT(!m_aDefaultOptions.hasLocale());
|
|
|
|
if (_rSettings.hasAsyncSetting())
|
|
{
|
|
m_aDefaultOptions.enableAsync( !!_rSettings.getAsyncSetting() );
|
|
}
|
|
|
|
// call the template method
|
|
this->initFromSettings(_rSettings, rNeedProfile);
|
|
|
|
if (bIntrinsicNeedProfile)
|
|
rNeedProfile = true; // to get locale
|
|
}
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::implInitFromProfile(data::NodeAccess const& aProfile)
|
|
{
|
|
OSL_ASSERT(aProfile.isValid());
|
|
|
|
data::GroupNodeAccess aProfileNode( aProfile );
|
|
|
|
OSL_ASSERT(aProfileNode.isValid());
|
|
|
|
// read the default locale for the user
|
|
if (!m_aDefaultOptions.hasLocale())
|
|
{
|
|
using configuration::Name;
|
|
using configuration::makeNodeName;
|
|
static Name ssSubGroup = makeNodeName(OUString(RTL_CONSTASCII_USTRINGPARAM("L10N")), Name::NoValidate());
|
|
static Name ssLocale = makeNodeName(OUString(RTL_CONSTASCII_USTRINGPARAM("ooLocale")), Name::NoValidate());
|
|
|
|
data::GroupNodeAccess aL10NNode( aProfileNode.getChildNode(ssSubGroup) );
|
|
if (aL10NNode.isValid())
|
|
{
|
|
data::ValueNodeAccess aValue( aL10NNode.getChildNode(ssLocale) );
|
|
|
|
if (aValue.isValid())
|
|
{
|
|
rtl::OUString sDefaultLocale;
|
|
if (aValue.getValue() >>= sDefaultLocale)
|
|
{
|
|
m_aDefaultOptions.setLocale(sDefaultLocale);
|
|
}
|
|
else
|
|
OSL_ENSURE(false, "Could not extract locale parameter into string");
|
|
}
|
|
}
|
|
}
|
|
|
|
// call the template method
|
|
this->initFromProfile(aProfile);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
OProviderImpl::~OProviderImpl()
|
|
{
|
|
clearTreeManager();
|
|
|
|
delete m_pNewProviders;
|
|
}
|
|
|
|
// --------------------------------- disposing ---------------------------------
|
|
void SAL_CALL OProviderImpl::dispose() throw()
|
|
{
|
|
try
|
|
{
|
|
rtl::Reference< TreeManager > xTM = maybeGetTreeManager();
|
|
|
|
if (xTM.is())
|
|
xTM->dispose();
|
|
|
|
clearTreeManager();
|
|
}
|
|
catch (uno::Exception& e)
|
|
{
|
|
CFG_TRACE_ERROR("Disposing the TreeManager or closing the session caused an exception: %s", OUSTRING2ASCII(e.Message));
|
|
clearTreeManager();
|
|
}
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
// access to the factory for writable elements
|
|
configapi::Factory& OProviderImpl::getWriterFactory() {return m_pNewProviders->getWriterFactory();}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
// access to the raw notifications
|
|
IConfigBroadcaster* OProviderImpl::getNotifier() CFG_NOTHROW()
|
|
{
|
|
rtl::Reference< TreeManager > xTM = maybeGetTreeManager();
|
|
return xTM.is() ? xTM->getBroadcaster() : NULL;
|
|
}
|
|
|
|
// DefaultProvider access
|
|
//-----------------------------------------------------------------------------
|
|
rtl::Reference< IConfigDefaultProvider > OProviderImpl::getDefaultProvider() const CFG_UNO_THROW_RTE( )
|
|
{
|
|
return getTreeManager().get();
|
|
}
|
|
|
|
// TemplateManager access
|
|
//-----------------------------------------------------------------------------
|
|
rtl::Reference< IConfigTemplateManager > OProviderImpl::getTemplateProvider() const CFG_UNO_THROW_RTE( )
|
|
{
|
|
return getTreeManager().get();
|
|
}
|
|
|
|
// ITreeProvider /ITreeManager
|
|
//-----------------------------------------------------------------------------
|
|
data::NodeAccess OProviderImpl::requestSubtree( AbsolutePath const& aSubtreePath,
|
|
RequestOptions const & _aOptions
|
|
) CFG_UNO_THROW_ALL( )
|
|
{
|
|
rtl::Reference< TreeManager > xTreeManager = getTreeManager();
|
|
|
|
data::NodeAccess aTree = data::NodeAccess::emptyNode();
|
|
try
|
|
{
|
|
aTree = xTreeManager->requestSubtree(aSubtreePath, _aOptions);
|
|
|
|
}
|
|
catch(uno::Exception&e)
|
|
{
|
|
::rtl::OUString sMessage = getErrorMessage(aSubtreePath, _aOptions);
|
|
// append the error message given by the tree provider
|
|
sMessage += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("\n\nThe backend returned the following error:\n"));
|
|
sMessage += e.Message;
|
|
|
|
throw lang::WrappedTargetException(sMessage, getProviderInstance(), uno::makeAny(e));
|
|
}
|
|
|
|
if (!aTree.isValid())
|
|
{
|
|
::rtl::OUString sMessage = getErrorMessage(aSubtreePath, _aOptions);
|
|
|
|
sMessage += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("\n\nNo backend error message available\n"));
|
|
|
|
throw uno::Exception(sMessage, getProviderInstance());
|
|
}
|
|
|
|
return aTree;
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::updateTree(memory::UpdateAccessor& _aAccessToken, TreeChangeList& aChanges) CFG_UNO_THROW_ALL( )
|
|
{
|
|
getTreeManager()->updateTree(_aAccessToken, aChanges);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::releaseSubtree( AbsolutePath const& aSubtreePath, RequestOptions const& _aOptions ) CFG_NOTHROW()
|
|
{
|
|
rtl::Reference< TreeManager > xTM = maybeGetTreeManager();
|
|
if (xTM.is())
|
|
xTM->releaseSubtree(aSubtreePath, _aOptions);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::disposeData(RequestOptions const& _aOptions) CFG_NOTHROW()
|
|
{
|
|
rtl::Reference< TreeManager > xTM = maybeGetTreeManager();
|
|
if (xTM.is())
|
|
xTM->disposeData(_aOptions);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::saveAndNotifyUpdate(data::Accessor const& _aChangedDataAccessor, TreeChangeList const& aChanges) CFG_UNO_THROW_ALL( )
|
|
{
|
|
getTreeManager()->saveAndNotifyUpdate(_aChangedDataAccessor,aChanges);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void OProviderImpl::fetchSubtree(AbsolutePath const& aSubtreePath, RequestOptions const& _aOptions) CFG_NOTHROW()
|
|
{
|
|
rtl::Reference< TreeManager > xTM = maybeGetTreeManager();
|
|
if (xTM.is())
|
|
xTM->fetchSubtree(aSubtreePath, _aOptions);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
sal_Bool OProviderImpl::fetchDefaultData(memory::UpdateAccessor& _aAccessToken, AbsolutePath const& aSubtreePath, RequestOptions const& _aOptions) CFG_UNO_THROW_ALL( )
|
|
{
|
|
return getTreeManager()->fetchDefaultData(_aAccessToken, aSubtreePath, _aOptions);
|
|
}
|
|
|
|
// IInterface
|
|
//-----------------------------------------------------------------------------
|
|
void SAL_CALL OProviderImpl::acquire( ) throw ()
|
|
{
|
|
m_pProvider->acquire();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void SAL_CALL OProviderImpl::release( ) throw ()
|
|
{
|
|
m_pProvider->release();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
uno::XInterface* OProviderImpl::getProviderInstance()
|
|
{
|
|
return static_cast<com::sun::star::lang::XMultiServiceFactory*>(m_pProvider);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
memory::Segment* OProviderImpl::getDataSegment(AbsolutePath const& _rAccessor, RequestOptions const& _aOptions)
|
|
{
|
|
return getTreeManager()->getDataSegment(_rAccessor, _aOptions);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
OUString OProviderImpl::getErrorMessage(AbsolutePath const& _rAccessor, RequestOptions const& _aOptions)
|
|
{
|
|
OUString const sAccessor = _rAccessor.toString();
|
|
|
|
CFG_TRACE_ERROR("config provider: the cache manager could not provide the tree (neither from the cache nor from the session)");
|
|
::rtl::OUString sMessage;
|
|
::rtl::OUString sEntity(_aOptions.getEntity());
|
|
::rtl::OUString sLocale(_aOptions.getLocale());
|
|
CFG_TRACE_INFO_NI("config provider: the entity we tried this for is \"%s\", the locale \"%s\", the path \"%s\"", OUSTRING2ASCII(sEntity), OUSTRING2ASCII(sLocale), OUSTRING2ASCII(sAccessor));
|
|
sMessage += sAccessor;
|
|
|
|
if (sEntity.getLength())
|
|
{
|
|
sMessage += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(" (and for entity "));
|
|
sMessage += sEntity;
|
|
sMessage += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(")"));
|
|
}
|
|
|
|
if (sLocale.getLength())
|
|
{
|
|
sMessage += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(" (and for locale "));
|
|
sMessage += sLocale;
|
|
sMessage += ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(")"));
|
|
}
|
|
|
|
sMessage += ::rtl::OUString::createFromAscii(" could not be created. Unable to retrieve the node from the configuration server.");
|
|
return sMessage;
|
|
}
|
|
|
|
// actual factory methods
|
|
//-----------------------------------------------------------------------------------
|
|
NodeElement* OProviderImpl::buildReadAccess(OUString const& _rAccessor, RequestOptions const& _aOptions, sal_Int32 nMinLevels) CFG_UNO_THROW_ALL( )
|
|
{
|
|
CFG_TRACE_INFO("config provider: requesting the tree from the cache manager");
|
|
|
|
OSL_ASSERT(sal_Int16(nMinLevels) == nMinLevels);
|
|
|
|
RTL_LOGFILE_CONTEXT_AUTHOR(aLog, "configmgr::OProviderImpl", "jb99855", "configmgr::OProviderImpl::buildReadAccess()");
|
|
RTL_LOGFILE_CONTEXT_TRACE1(aLog, "request path: %s", RTL_LOGFILE_OU2A(_rAccessor) );
|
|
|
|
try
|
|
{
|
|
using namespace configuration;
|
|
|
|
AbsolutePath aAccessorPath = AbsolutePath::parse(_rAccessor);
|
|
|
|
data::NodeAccess aTree = this->requestSubtree(aAccessorPath,_aOptions);
|
|
|
|
RTL_LOGFILE_CONTEXT_TRACE(aLog, "data loaded" );
|
|
|
|
TreeDepth nDepth = (nMinLevels == treeop::ALL_LEVELS) ? C_TreeDepthAll : TreeDepth(nMinLevels);
|
|
|
|
RTL_LOGFILE_CONTEXT_AUTHOR(aLog2, "configmgr::OProviderImpl", "jb99855", "configmgr: createReadOnlyTree()");
|
|
|
|
RootTree aRootTree( createReadOnlyTree(
|
|
aAccessorPath, this->getDataSegment(aAccessorPath,_aOptions),
|
|
aTree, nDepth,
|
|
TemplateProvider( this->getTemplateProvider(), _aOptions )
|
|
));
|
|
|
|
return m_pNewProviders->getReaderFactory().makeAccessRoot(aRootTree, _aOptions);
|
|
}
|
|
catch (configuration::Exception& e)
|
|
{
|
|
configapi::ExceptionMapper ec(e);
|
|
ec.setContext(this->getProviderInstance());
|
|
//ec.unhandled();
|
|
throw lang::WrappedTargetException(ec.message(), ec.context(), uno::Any());
|
|
}
|
|
}
|
|
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
NodeElement* OProviderImpl::buildUpdateAccess(OUString const& _rAccessor, RequestOptions const& _aOptions,
|
|
sal_Int32 nMinLevels) CFG_UNO_THROW_ALL( )
|
|
{
|
|
CFG_TRACE_INFO("config provider: requesting the tree from the cache manager");
|
|
OSL_ASSERT(sal_Int16(nMinLevels) == nMinLevels);
|
|
|
|
RTL_LOGFILE_CONTEXT_AUTHOR(aLog, "configmgr::OProviderImpl", "jb99855", "configmgr: buildUpdateAccess()");
|
|
RTL_LOGFILE_CONTEXT_TRACE1(aLog, "request path: %s", RTL_LOGFILE_OU2A(_rAccessor) );
|
|
|
|
try
|
|
{
|
|
using namespace configuration;
|
|
|
|
AbsolutePath aAccessorPath = AbsolutePath::parse(_rAccessor);
|
|
|
|
data::NodeAccess aTree = requestSubtree(aAccessorPath, _aOptions);
|
|
|
|
RTL_LOGFILE_CONTEXT_TRACE(aLog, "data loaded" );
|
|
|
|
TreeDepth nDepth = (nMinLevels == treeop::ALL_LEVELS) ? C_TreeDepthAll : TreeDepth(nMinLevels);
|
|
|
|
RTL_LOGFILE_CONTEXT_AUTHOR(aLog2, "configmgr::OProviderImpl", "jb99855", "createUpdatableTree()");
|
|
|
|
RootTree aRootTree( createUpdatableTree(
|
|
aAccessorPath, this->getDataSegment(aAccessorPath,_aOptions),
|
|
aTree, nDepth,
|
|
TemplateProvider( this->getTemplateProvider(), _aOptions )
|
|
));
|
|
|
|
|
|
return m_pNewProviders->getWriterFactory().makeAccessRoot(aRootTree, _aOptions);
|
|
}
|
|
catch (configuration::Exception& e)
|
|
{
|
|
configapi::ExceptionMapper ec(e);
|
|
ec.setContext(this->getProviderInstance());
|
|
//ec.unhandled();
|
|
throw lang::WrappedTargetException(ec.message(), ec.context(), uno::Any());
|
|
}
|
|
}
|
|
|
|
//=============================================================================
|
|
//= OProvider::FactoryArguments
|
|
//=============================================================================
|
|
|
|
sal_Char const * const OProviderImpl::FactoryArguments::asciiArgumentNames[] =
|
|
{
|
|
"nodepath", // ARG_NODEPATH, // requested node path
|
|
"depth", // ARG_DEPTH, // depth of the tree
|
|
"user", // ARG_USER_DEPRECATED, // name of the user - only for admin
|
|
"locale", // ARG_LOCALE, // desired locale
|
|
"nocache", // ARG_NOCACHE_OBSOLETE, // cache disabling
|
|
"lazywrite", // ARG_ASYNC_DEPRECATED, // lasy write data
|
|
"enableasync", // ARG_ASYNC, // lasy write data
|
|
"entity", // ARG_ENTITY, // name of the entity to be manipulated - only for admin
|
|
|
|
};
|
|
|
|
OUString OProviderImpl::FactoryArguments::getArgumentName(Argument _which) CFG_NOTHROW()
|
|
{
|
|
OSL_ASSERT(sizeof asciiArgumentNames/sizeof 0[asciiArgumentNames] == _arg_count);
|
|
OSL_PRECOND(_which < _arg_count, "Illegal argument selector in OProviderImpl::FactoryArguments::getArgumentName");
|
|
|
|
return OUString::createFromAscii(asciiArgumentNames[_which]);
|
|
}
|
|
|
|
OProviderImpl::FactoryArguments::Argument
|
|
OProviderImpl::FactoryArguments::lookupArgument(const rtl::OUString& rName)
|
|
CFG_NOTHROW()
|
|
{
|
|
OUString sCheck( rName.toAsciiLowerCase() );
|
|
|
|
typedef sal_Char const * const * ArgNameIter;
|
|
|
|
ArgNameIter const pFirst = asciiArgumentNames;
|
|
ArgNameIter const pLast = pFirst + _arg_count;
|
|
|
|
ArgNameIter it = pFirst;
|
|
|
|
for(; it != pLast; ++it)
|
|
{
|
|
if (0 == sCheck.compareToAscii(*it))
|
|
{
|
|
break;
|
|
}
|
|
}
|
|
|
|
OSL_ASSERT( Argument(pLast-pFirst) == ARG_NOT_FOUND );
|
|
return static_cast<Argument>(it - pFirst);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
|
|
static OUString makeLocaleString(lang::Locale const & aLocale)
|
|
{
|
|
const sal_Unicode sep = '-';
|
|
|
|
rtl::OUStringBuffer aBuf(aLocale.Language);
|
|
|
|
if (aLocale.Country.getLength())
|
|
aBuf.append(sep). append(aLocale.Country);
|
|
|
|
return aBuf.makeStringAndClear();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
bool OProviderImpl::FactoryArguments::extractOneArgument(
|
|
OUString const& aName, uno::Any const& aValue,
|
|
OUString& /* [out] */ _rNodeAccessor,
|
|
sal_Int32& /* [out] */ _nLevels,
|
|
RequestOptions& /* [in/out] */ _rOptions )
|
|
CFG_NOTHROW()
|
|
{
|
|
switch ( lookupArgument(aName) )
|
|
{
|
|
case ARG_NODEPATH:
|
|
{
|
|
OUString sStringVal;
|
|
if (aValue >>= sStringVal)
|
|
_rNodeAccessor = sStringVal;
|
|
else
|
|
return false;
|
|
}
|
|
break;
|
|
|
|
case ARG_DEPTH:
|
|
{
|
|
sal_Int32 nIntVal;
|
|
if (aValue >>= nIntVal)
|
|
_nLevels = nIntVal;
|
|
else
|
|
return false;
|
|
}
|
|
break;
|
|
|
|
case ARG_ENTITY:
|
|
case ARG_USER_DEPRECATED:
|
|
{
|
|
OUString sStringVal;
|
|
if (aValue >>= sStringVal)
|
|
_rOptions.setEntity(sStringVal);
|
|
else
|
|
return false;
|
|
}
|
|
break;
|
|
|
|
case ARG_LOCALE:
|
|
{
|
|
OUString sStringVal;
|
|
if (aValue >>= sStringVal)
|
|
{
|
|
_rOptions.setLocale(sStringVal);
|
|
break;
|
|
}
|
|
|
|
lang::Locale aLocale;
|
|
if (aValue >>= aLocale)
|
|
{
|
|
_rOptions.setLocale(makeLocaleString(aLocale));
|
|
break;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
break;
|
|
|
|
case ARG_NOCACHE_OBSOLETE:
|
|
{
|
|
sal_Bool bBoolVal;
|
|
if (aValue >>= bBoolVal)
|
|
OSL_ENSURE(false,"ConfigurationProvider: Parameter \"nocache\" is obsolete and has no effect");
|
|
else
|
|
return false;
|
|
}
|
|
break;
|
|
|
|
case ARG_ASYNC:
|
|
case ARG_ASYNC_DEPRECATED:
|
|
{
|
|
sal_Bool bBoolVal;
|
|
if (aValue >>= bBoolVal)
|
|
_rOptions.enableAsync(!!bBoolVal);
|
|
else
|
|
return false;
|
|
}
|
|
break;
|
|
|
|
case ARG_NOT_FOUND:
|
|
{
|
|
rtl::OString sMessage(RTL_CONSTASCII_STRINGPARAM("Unknown argument \""));
|
|
sMessage += rtl::OUStringToOString(aName, RTL_TEXTENCODING_ASCII_US);
|
|
sMessage += rtl::OString(RTL_CONSTASCII_STRINGPARAM("\" !\n- Parameter will be ignored -\n"));
|
|
CFG_TRACE_WARNING( "provider: %s", sMessage.getStr() );
|
|
#ifdef DBG_UTIL
|
|
OSL_ENSURE(false, sMessage.getStr());
|
|
#endif
|
|
}
|
|
break;
|
|
|
|
default:
|
|
CFG_TRACE_ERROR( "Known argument is not handled" );
|
|
OSL_ENSURE(false, "Known argument is not handled");
|
|
break;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
static
|
|
void failInvalidArg(uno::Any const & aArg, sal_Int32 _nArg = -1)
|
|
CFG_THROW1 (lang::IllegalArgumentException)
|
|
{
|
|
OSL_ENSURE( sal_Int16(_nArg) == _nArg, "Argument number out of range. Raising imprecise exception.");
|
|
|
|
rtl::OUStringBuffer sMessage;
|
|
sMessage.appendAscii("Configuration Provider: An argument");
|
|
sMessage.appendAscii(" has the wrong type.");
|
|
sMessage.appendAscii("\n- Expected a NamedValue or PropertyValue");
|
|
sMessage.appendAscii("\n- Found type ").append( aArg.getValueType().getTypeName() );
|
|
|
|
throw lang::IllegalArgumentException( sMessage.makeStringAndClear(),
|
|
uno::Reference<uno::XInterface>(),
|
|
sal_Int16(_nArg+1));
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
static
|
|
void failInvalidArgValue(OUString const & aName, uno::Any const & aValue, sal_Int32 _nArg = -1)
|
|
CFG_THROW1 (lang::IllegalArgumentException)
|
|
{
|
|
OSL_ENSURE( sal_Int16(_nArg) == _nArg, "Argument number out of range. Raising imprecise exception.");
|
|
|
|
rtl::OUStringBuffer sMessage;
|
|
sMessage.appendAscii("Configuration Provider: The argument ").append(aName);
|
|
sMessage.appendAscii(" has the wrong type.");
|
|
sMessage.appendAscii("\n- Found type ").append( aValue.getValueType().getTypeName() );
|
|
|
|
throw lang::IllegalArgumentException( sMessage.makeStringAndClear(),
|
|
uno::Reference<uno::XInterface>(),
|
|
sal_Int16(_nArg+1));
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
static
|
|
bool extractLegacyArguments( const uno::Sequence<uno::Any>& _rArgs,
|
|
OUString& /* [out] */ _rNodeAccessor,
|
|
sal_Int32& /* [out] */ _nLevels )
|
|
CFG_NOTHROW()
|
|
{
|
|
OSL_ASSERT( _rArgs.getLength() != 0 );
|
|
|
|
// compatibility : formerly, you could specify the node path as first arg and the (optional) depth
|
|
// as second arg
|
|
if (! (_rArgs[0] >>= _rNodeAccessor) )
|
|
return false;
|
|
|
|
switch (_rArgs.getLength() )
|
|
{
|
|
case 1:
|
|
// valid single argument
|
|
return true;
|
|
|
|
case 2:
|
|
// valid second argument
|
|
if (_rArgs[1] >>= _nLevels)
|
|
return true;
|
|
|
|
break;
|
|
|
|
default:
|
|
if (_rArgs[1] >>= _nLevels)
|
|
{
|
|
// valid second argument, but too many arguments altogether
|
|
throw lang::IllegalArgumentException(
|
|
OUString(RTL_CONSTASCII_USTRINGPARAM(
|
|
"Configuration Provider: Too many arguments. "
|
|
"Additional arguments are not supported when passing the node path as string (deprecated convention).")),
|
|
uno::Reference<uno::XInterface>(),
|
|
sal_Int16(3)
|
|
);
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
// here we have an invalid second argument
|
|
|
|
if (_rArgs[1].getValueTypeClass() != uno::TypeClass_STRUCT)
|
|
{
|
|
// completely invalid second argument
|
|
failInvalidArgValue(OUString::createFromAscii("<depth>"),_rArgs[1],1);
|
|
}
|
|
|
|
// Assume PropertyValue or NamedValue,
|
|
// which should be handled consistently by caller
|
|
return false;
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------------
|
|
void OProviderImpl::FactoryArguments::extractArgs( const uno::Sequence<uno::Any>& _rArgs,
|
|
OUString& /* [out] */ _rNodeAccessor,
|
|
sal_Int32& /* [out] */ _nLevels,
|
|
RequestOptions & /* [in/out] */ _aOptions )
|
|
CFG_THROW1 (lang::IllegalArgumentException)
|
|
{
|
|
_nLevels = treeop::ALL_LEVELS; // setting a fallback
|
|
|
|
// the args have to be a sequence of property values
|
|
bool bLegacyFormat = false;
|
|
|
|
beans::NamedValue aNV;
|
|
beans::PropertyValue aPV;
|
|
for (sal_Int32 i=0; i<_rArgs.getLength(); ++i)
|
|
{
|
|
if (_rArgs[i] >>= aPV)
|
|
{
|
|
if ( !extractOneArgument(aPV.Name,aPV.Value,_rNodeAccessor,_nLevels,_aOptions) )
|
|
failInvalidArgValue(aPV.Name,aPV.Value,i);
|
|
}
|
|
else if (_rArgs[i] >>= aNV)
|
|
{
|
|
if ( !extractOneArgument(aNV.Name,aNV.Value,_rNodeAccessor,_nLevels,_aOptions) )
|
|
failInvalidArgValue(aNV.Name,aNV.Value,i);
|
|
}
|
|
else
|
|
{
|
|
if (i == 0)// try compatibility format
|
|
if ( extractLegacyArguments(_rArgs,_rNodeAccessor,_nLevels))
|
|
break;
|
|
|
|
failInvalidArg(_rArgs[i],i);
|
|
OSL_ASSERT(false);
|
|
}
|
|
}
|
|
|
|
if (_rNodeAccessor.getLength() == 0)
|
|
{
|
|
OUString sMessage(RTL_CONSTASCII_USTRINGPARAM("Configuration Provider: Missing argument: no nodepath was provided"));
|
|
throw lang::IllegalArgumentException(sMessage,uno::Reference<uno::XInterface>(),0);
|
|
}
|
|
}
|
|
|
|
} // namespace configmgr
|
|
|
|
|