configmgr/source/localbe/localdataimportsvc.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: localdataimportsvc.cxx,v $
  10  * $Revision: 1.9 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_configmgr.hxx"
  33
  34 #include "localdataimportsvc.hxx"
  35 #include "localsinglebackend.hxx"
  36
  37 #ifndef CONFIGMGR_API_FACTORY_HXX_
  38 #include "confapifactory.hxx"
  39 #endif
  40 #include <rtl/ustrbuf.hxx>
  41 #include <com/sun/star/lang/WrappedTargetRuntimeException.hpp>
  42 #include <com/sun/star/configuration/backend/XLayerImporter.hpp>
  43
  44 // -----------------------------------------------------------------------------
  45 #define OUSTRING( constascii ) rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(constascii))
  46 // -----------------------------------------------------------------------------
  47 namespace configmgr
  48 {
  49 // -----------------------------------------------------------------------------
  50     namespace localbe
  51     {
  52 // -----------------------------------------------------------------------------
  53         namespace backend = ::com::sun::star::configuration::backend;
  54 // -----------------------------------------------------------------------------
  55
  56 sal_Char const * const aLocalDataImportServices[] =
  57 {
  58     "com.sun.star.configuration.backend.LocalDataImporter",
  59     0,
  60     "com.sun.star.configuration.backend.DataImporter",
  61     0
  62 };
  63 const ServiceImplementationInfo aLocalDataImportSI =
  64 {
  65     "com.sun.star.comp.configuration.backend.LocalDataImporter",
  66     aLocalDataImportServices,
  67     aLocalDataImportServices + 3
  68 };
  69 // -----------------------------------------------------------------------------
  70
  71 const ServiceRegistrationInfo* getLocalDataImportServiceInfo()
  72 { return getRegistrationInfo(& aLocalDataImportSI); }
  73 // -----------------------------------------------------------------------------
  74
  75 inline
  76 ServiceInfoHelper LocalDataImportService::getServiceInfo()
  77 {
  78     return & aLocalDataImportSI;
  79 }
  80 // -----------------------------------------------------------------------------
  81
  82 uno::Reference< uno::XInterface > SAL_CALL instantiateLocalDataImporter
  83 ( uno::Reference< uno::XComponentContext > const& xContext )
  84 {
  85     return * new LocalDataImportService( xContext );
  86 }
  87 // -----------------------------------------------------------------------------
  88
  89 LocalDataImportService::LocalDataImportService(uno::Reference< uno::XComponentContext > const & _xContext)
  90 : m_xServiceFactory(_xContext->getServiceManager(), uno::UNO_QUERY)
  91 {
  92     if (!m_xServiceFactory.is())
  93     {
  94         rtl::OUString sMessage = OUSTRING("Configuration Importer: Context has no service manager (or interface is missing)");
  95         throw lang::NullPointerException(sMessage,NULL);
  96     }
  97 }
  98 // -----------------------------------------------------------------------------
  99
 100 LocalDataImportService::~LocalDataImportService()
 101 {}
 102 // -----------------------------------------------------------------------------
 103
 104 namespace
 105 {
 106 // -----------------------------------------------------------------------------
 107     struct JobDesc
 108     {
 109         explicit JobDesc(task::XJob * pJob, const uno::Sequence< beans::NamedValue >& aArguments);
 110
 111         rtl::OUString aLayerDataUrl;
 112         rtl::OUString aImporterService;
 113
 114         rtl::OUString aComponent;
 115         rtl::OUString aEntity;
 116
 117         uno::Reference< backend::XLayer > xLayerFilter;
 118
 119         sal_Bool overwrite;
 120         sal_Bool truncate;
 121
 122         sal_Bool use_component;
 123         sal_Bool use_entity;
 124         sal_Bool use_overwrite;
 125         sal_Bool use_truncate;
 126     };
 127     // -----------------------------------------------------------------------------
 128
 129     JobDesc::JobDesc(task::XJob * pJob, const uno::Sequence< beans::NamedValue >& aArguments)
 130     : aLayerDataUrl()
 131     , aImporterService()
 132     , aComponent()
 133     , aEntity()
 134     , xLayerFilter()
 135     , overwrite(true)
 136     , truncate(false)
 137     , use_component(false)
 138     , use_entity(false)
 139     , use_overwrite(false)
 140     , use_truncate(false)
 141     {
 142         sal_Int16 const nCount = static_cast<sal_Int16>(aArguments.getLength());
 143
 144         if (sal_Int32(nCount) != aArguments.getLength())
 145         {
 146             rtl::OUString sMessage = OUSTRING("Too many arguments for LocalDataImporter Job");
 147             throw lang::IllegalArgumentException(sMessage,pJob,0);
 148         }
 149
 150         for (sal_Int16 i=0; i < nCount; ++i)
 151         {
 152             sal_Bool bKnown = false;
 153             sal_Bool bGood  = false;
 154
 155             if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("LayerDataUrl")))
 156             {
 157                 bKnown = true;
 158                 bGood  = (aArguments[i].Value >>= aLayerDataUrl);
 159             }
 160             else if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("ImporterService")))
 161             {
 162                 bKnown = true;
 163                 bGood  = (aArguments[i].Value >>= aImporterService);
 164             }
 165             else if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("Component")))
 166             {
 167                 bKnown = true;
 168                 bGood  = (aArguments[i].Value >>= aComponent);
 169                 use_component = bGood && (aComponent.getLength() != 0);
 170             }
 171             else if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("Entity")))
 172             {
 173                 bKnown = true;
 174                 bGood  = (aArguments[i].Value >>= aEntity);
 175                 use_entity = bGood && (aEntity.getLength() != 0);
 176             }
 177             else if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("LayerFilter")))
 178             {
 179                 bKnown = true;
 180                 bGood  = (aArguments[i].Value >>= xLayerFilter);
 181                 if (xLayerFilter.is() && !uno::Reference<lang::XInitialization>::query(xLayerFilter).is())
 182                     bGood = false;
 183             }
 184             else if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("OverwriteExisting")))
 185             {
 186                 bKnown = true;
 187                 bGood  = (aArguments[i].Value >>= overwrite);
 188                 use_overwrite = bGood;
 189             }
 190             else if (aArguments[i].Name.equalsAsciiL(RTL_CONSTASCII_STRINGPARAM("TruncateExisting")))
 191             {
 192                 bKnown = true;
 193                 bGood  = (aArguments[i].Value >>= truncate);
 194                 use_truncate = bGood;
 195             }
 196
 197             if (!bGood)
 198             {
 199                 rtl::OUStringBuffer sMsg;
 200                 sMsg.appendAscii("LocalDataImportService - Illegal argument: ");
 201                 if (bKnown)
 202                     sMsg.appendAscii("Wrong value type for argument '");
 203                 else
 204                     sMsg.appendAscii("Unknown argument '");
 205
 206                 sMsg.append(aArguments[i].Name).appendAscii("'.");
 207
 208                 throw lang::IllegalArgumentException(sMsg.makeStringAndClear(),pJob,i+1);
 209             }
 210         }
 211         if (aLayerDataUrl.getLength() == 0)
 212         {
 213             rtl::OUStringBuffer sMsg;
 214             sMsg.appendAscii("LocalDataImportService - Missing argument: ");
 215             sMsg.appendAscii("No data URL available");
 216             throw lang::IllegalArgumentException(sMsg.makeStringAndClear(),pJob,0);
 217         }
 218         if (aImporterService.getLength() == 0)
 219         {
 220             if ( (use_truncate && truncate) || (use_overwrite && !overwrite) )
 221                 aImporterService = OUSTRING("com.sun.star.configuration.backend.CopyImporter");
 222             else
 223                 aImporterService = OUSTRING("com.sun.star.configuration.backend.MergeImporter");
 224         }
 225     }
 226     // -----------------------------------------------------------------------------
 227
 228     static
 229     inline
 230     uno::Type getOverwriteFailedExceptionType()
 231     {
 232         lang::IllegalAccessException const * const selected = 0;
 233         return ::getCppuType(selected);
 234     }
 235 // -----------------------------------------------------------------------------
 236 }
 237 // -----------------------------------------------------------------------------
 238 // XJob
 239
 240 uno::Any SAL_CALL
 241     LocalDataImportService::execute( const uno::Sequence< beans::NamedValue >& Arguments )
 242         throw (lang::IllegalArgumentException, uno::Exception, uno::RuntimeException)
 243 {
 244     JobDesc const aJob(this,Arguments);
 245
 246     uno::Reference< lang::XMultiServiceFactory > aFactory = this->getServiceFactory();
 247
 248     uno::Reference< backend::XLayer > xLayer = aJob.use_component ?
 249         LocalSingleBackend::createSimpleLayer(aFactory,aJob.aLayerDataUrl, aJob.aComponent ):
 250         LocalSingleBackend::createSimpleLayer(aFactory,aJob.aLayerDataUrl) ;
 251
 252     if (!xLayer.is())
 253     {
 254         rtl::OUString sMessage = OUSTRING("LocalDataImportService - Cannot create layer to import from");
 255         throw lang::NullPointerException(sMessage,*this);
 256     }
 257
 258     uno::Reference< lang::XInitialization > xFilterInit(aJob.xLayerFilter,uno::UNO_QUERY);
 259     if (xFilterInit.is())
 260     {
 261         beans::NamedValue argvalue(
 262             rtl::OUString( RTL_CONSTASCII_USTRINGPARAM("Source") ),
 263             uno::makeAny( xLayer) );
 264
 265         uno::Sequence< uno::Any > args(1);
 266         args[0] <<= argvalue;
 267
 268         xFilterInit->initialize(args);
 269
 270         xLayer = aJob.xLayerFilter;
 271     }
 272
 273     uno::Reference< backend::XLayerImporter > xImporter;
 274
 275     int nArgCount = 0;
 276     if (aJob.use_overwrite) ++nArgCount;
 277     if (aJob.use_truncate)  ++nArgCount;
 278
 279     if (nArgCount)
 280     {
 281         uno::Sequence< uno::Any > aArgs(nArgCount);
 282
 283         int n = 0;
 284         if (aJob.use_overwrite)
 285             aArgs[n++] <<= beans::NamedValue(OUSTRING("Overwrite"), uno::makeAny(aJob.overwrite));
 286
 287         if (aJob.use_truncate)
 288             aArgs[n++] <<= beans::NamedValue(OUSTRING("Truncate"),  uno::makeAny(aJob.truncate));
 289
 290         OSL_ASSERT(n == nArgCount);
 291
 292         xImporter.set( aFactory->createInstanceWithArguments(aJob.aImporterService,aArgs), uno::UNO_QUERY);
 293     }
 294     else
 295         xImporter.set( aFactory->createInstance(aJob.aImporterService), uno::UNO_QUERY);
 296
 297     if (!xImporter.is())
 298     {
 299         rtl::OUString sMessage = OUSTRING("LocalDataImportService - Cannot create importer service: ") + aJob.aImporterService;
 300         throw lang::NullPointerException(sMessage,*this);
 301     }
 302
 303     try
 304     {
 305         if (aJob.use_entity)
 306             xImporter->importLayerForEntity(xLayer,aJob.aEntity);
 307
 308         else
 309             xImporter->importLayer(xLayer);
 310     }
 311     catch (lang::WrappedTargetException & e)
 312     {
 313         if (aJob.overwrite || !e.TargetException.isExtractableTo(getOverwriteFailedExceptionType())) throw;
 314         return e.TargetException;
 315     }
 316     catch (lang::WrappedTargetRuntimeException & e)
 317     {
 318         if (aJob.overwrite || !e.TargetException.isExtractableTo(getOverwriteFailedExceptionType())) throw;
 319         return e.TargetException;
 320     }
 321
 322     return uno::Any();
 323 }
 324 // -----------------------------------------------------------------------------
 325
 326 // XServiceInfo
 327
 328 rtl::OUString SAL_CALL
 329     LocalDataImportService::getImplementationName(  )
 330         throw (uno::RuntimeException)
 331 {
 332     return getServiceInfo().getImplementationName( );
 333 }
 334 // -----------------------------------------------------------------------------
 335
 336
 337 sal_Bool SAL_CALL
 338     LocalDataImportService::supportsService( const rtl::OUString& ServiceName )
 339         throw (uno::RuntimeException)
 340 {
 341     return getServiceInfo().supportsService( ServiceName );
 342 }
 343 // -----------------------------------------------------------------------------
 344
 345
 346 uno::Sequence< ::rtl::OUString > SAL_CALL
 347     LocalDataImportService::getSupportedServiceNames(  )
 348         throw (uno::RuntimeException)
 349 {
 350     return getServiceInfo().getSupportedServiceNames( );
 351 }
 352 // -----------------------------------------------------------------------------
 353
 354 // -----------------------------------------------------------------------------
 355 // -----------------------------------------------------------------------------
 356     } // namespace
 357
 358 // -----------------------------------------------------------------------------
 359 } // namespace
 360