LCOV - code coverage report
Current view: top level - package/source/xstor - xfactory.cxx (source / functions) Hit Total Coverage
Test: commit e02a6cb2c3e2b23b203b422e4e0680877f232636 Lines: 0 111 0.0 %
Date: 2014-04-14 Functions: 0 9 0.0 %
Legend: Lines: hit not hit

          Line data    Source code
       1             : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
       2             : /*
       3             :  * This file is part of the LibreOffice project.
       4             :  *
       5             :  * This Source Code Form is subject to the terms of the Mozilla Public
       6             :  * License, v. 2.0. If a copy of the MPL was not distributed with this
       7             :  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
       8             :  *
       9             :  * This file incorporates work covered by the following license notice:
      10             :  *
      11             :  *   Licensed to the Apache Software Foundation (ASF) under one or more
      12             :  *   contributor license agreements. See the NOTICE file distributed
      13             :  *   with this work for additional information regarding copyright
      14             :  *   ownership. The ASF licenses this file to you under the Apache
      15             :  *   License, Version 2.0 (the "License"); you may not use this file
      16             :  *   except in compliance with the License. You may obtain a copy of
      17             :  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
      18             :  */
      19             : 
      20             : #include <com/sun/star/ucb/SimpleFileAccess.hpp>
      21             : #include <com/sun/star/embed/ElementModes.hpp>
      22             : #include <com/sun/star/embed/StorageFormats.hpp>
      23             : #include <com/sun/star/beans/PropertyValue.hpp>
      24             : #include <com/sun/star/io/TempFile.hpp>
      25             : #include <com/sun/star/io/XSeekable.hpp>
      26             : 
      27             : #include <comphelper/processfactory.hxx>
      28             : #include <comphelper/storagehelper.hxx>
      29             : #include <cppuhelper/supportsservice.hxx>
      30             : 
      31             : #include "xfactory.hxx"
      32             : #include "xstorage.hxx"
      33             : 
      34             : using namespace ::com::sun::star;
      35             : 
      36             : #if OSL_DEBUG_LEVEL > 0
      37             : #define THROW_WHERE SAL_WHERE
      38             : #else
      39             : #define THROW_WHERE ""
      40             : #endif
      41             : 
      42           0 : sal_Bool CheckPackageSignature_Impl( const uno::Reference< io::XInputStream >& xInputStream,
      43             :                                      const uno::Reference< io::XSeekable >& xSeekable )
      44             : {
      45           0 :     if ( !xInputStream.is() || !xSeekable.is() )
      46           0 :         throw uno::RuntimeException();
      47             : 
      48           0 :     if ( xSeekable->getLength() )
      49             :     {
      50           0 :         uno::Sequence< sal_Int8 > aData( 4 );
      51           0 :         xSeekable->seek( 0 );
      52           0 :         sal_Int32 nRead = xInputStream->readBytes( aData, 4 );
      53           0 :         xSeekable->seek( 0 );
      54             : 
      55             :         // TODO/LATER: should the disk spanned files be supported?
      56             :         // 0x50, 0x4b, 0x07, 0x08
      57           0 :         return ( nRead == 4 && aData[0] == 0x50 && aData[1] == 0x4b && aData[2] == 0x03 && aData[3] == 0x04 );
      58             :     }
      59             :     else
      60           0 :         return sal_True; // allow to create a storage based on empty stream
      61             : }
      62             : 
      63           0 : uno::Sequence< OUString > SAL_CALL OStorageFactory::impl_staticGetSupportedServiceNames()
      64             : {
      65           0 :     uno::Sequence< OUString > aRet(2);
      66           0 :     aRet[0] = "com.sun.star.embed.StorageFactory";
      67           0 :     aRet[1] = "com.sun.star.comp.embed.StorageFactory";
      68           0 :     return aRet;
      69             : }
      70             : 
      71           0 : OUString SAL_CALL OStorageFactory::impl_staticGetImplementationName()
      72             : {
      73           0 :     return OUString("com.sun.star.comp.embed.StorageFactory");
      74             : }
      75             : 
      76           0 : uno::Reference< uno::XInterface > SAL_CALL OStorageFactory::impl_staticCreateSelfInstance(
      77             :             const uno::Reference< lang::XMultiServiceFactory >& xServiceManager )
      78             : {
      79           0 :     return uno::Reference< uno::XInterface >( *new OStorageFactory( comphelper::getComponentContext(xServiceManager) ) );
      80             : }
      81             : 
      82           0 : uno::Reference< uno::XInterface > SAL_CALL OStorageFactory::createInstance()
      83             :     throw ( uno::Exception,
      84             :             uno::RuntimeException, std::exception )
      85             : {
      86             :     // TODO: reimplement TempStream service to support XStream interface
      87             :     uno::Reference < io::XStream > xTempStream(
      88             :                         io::TempFile::create(m_xContext),
      89           0 :                         uno::UNO_QUERY_THROW );
      90             : 
      91             :     return uno::Reference< uno::XInterface >(
      92             :                 static_cast< OWeakObject* >( new OStorage(  xTempStream,
      93             :                                                             embed::ElementModes::READWRITE,
      94             :                                                             uno::Sequence< beans::PropertyValue >(),
      95             :                                                             m_xContext,
      96           0 :                                                             embed::StorageFormats::PACKAGE ) ),
      97           0 :                 uno::UNO_QUERY );
      98             : }
      99             : 
     100           0 : uno::Reference< uno::XInterface > SAL_CALL OStorageFactory::createInstanceWithArguments(
     101             :             const uno::Sequence< uno::Any >& aArguments )
     102             :     throw ( uno::Exception,
     103             :             uno::RuntimeException, std::exception )
     104             : {
     105             :     // The request for storage can be done with up to three arguments
     106             : 
     107             :     // The first argument specifies a source for the storage
     108             :     // it can be URL, XStream, XInputStream.
     109             :     // The second value is a mode the storage should be open in.
     110             :     // And the third value is a media descriptor.
     111             : 
     112           0 :     sal_Int32 nArgNum = aArguments.getLength();
     113             :     OSL_ENSURE( nArgNum < 4, "Wrong parameter number" );
     114             : 
     115           0 :     if ( !nArgNum )
     116           0 :         return createInstance();
     117             : 
     118             :     // first try to retrieve storage open mode if any
     119             :     // by default the storage will be open in readonly mode
     120           0 :     sal_Int32 nStorageMode = embed::ElementModes::READ;
     121           0 :     if ( nArgNum >= 2 )
     122             :     {
     123           0 :         if( !( aArguments[1] >>= nStorageMode ) )
     124             :         {
     125             :             OSL_FAIL( "Wrong second argument!\n" );
     126           0 :             throw lang::IllegalArgumentException(); // TODO:
     127             :         }
     128             :         // it's always possible to read written storage in this implementation
     129           0 :         nStorageMode |= embed::ElementModes::READ;
     130             :     }
     131             : 
     132           0 :     if ( ( nStorageMode & embed::ElementModes::TRUNCATE ) == embed::ElementModes::TRUNCATE
     133           0 :       && ( nStorageMode & embed::ElementModes::WRITE ) != embed::ElementModes::WRITE )
     134           0 :         throw lang::IllegalArgumentException(); // TODO:
     135             : 
     136             :     // retrieve storage source stream
     137           0 :     OUString aURL;
     138           0 :     uno::Reference< io::XStream > xStream;
     139           0 :     uno::Reference< io::XInputStream > xInputStream;
     140             : 
     141           0 :     if ( aArguments[0] >>= aURL )
     142             :     {
     143           0 :         if ( aURL.isEmpty() )
     144             :         {
     145             :             OSL_FAIL( "Empty URL is provided!\n" );
     146           0 :             throw lang::IllegalArgumentException(); // TODO:
     147             :         }
     148             : 
     149           0 :         if ( aURL.startsWithIgnoreAsciiCase("vnd.sun.star.pkg:") )
     150             :         {
     151             :             OSL_FAIL( "Packages URL's are not valid for storages!\n" ); // ???
     152           0 :             throw lang::IllegalArgumentException(); // TODO:
     153             :         }
     154             : 
     155             :         uno::Reference < ucb::XSimpleFileAccess3 > xTempAccess(
     156             :             ucb::SimpleFileAccess::create(
     157           0 :                 m_xContext ) );
     158             : 
     159           0 :         if ( nStorageMode & embed::ElementModes::WRITE )
     160           0 :             xStream = xTempAccess->openFileReadWrite( aURL );
     161             :         else
     162           0 :             xInputStream = xTempAccess->openFileRead( aURL );
     163             :     }
     164           0 :     else if ( !( aArguments[0] >>= xStream ) && !( aArguments[0] >>= xInputStream ) )
     165             :     {
     166             :         OSL_FAIL( "Wrong first argument!\n" );
     167           0 :         throw uno::Exception(); // TODO: Illegal argument
     168             :     }
     169             : 
     170             :     // retrieve mediadescriptor and set storage properties
     171           0 :     uno::Sequence< beans::PropertyValue > aDescr;
     172           0 :     uno::Sequence< beans::PropertyValue > aPropsToSet;
     173             : 
     174           0 :     sal_Int32 nStorageType = embed::StorageFormats::PACKAGE;
     175             : 
     176           0 :     if ( nArgNum >= 3 )
     177             :     {
     178           0 :         if( aArguments[2] >>= aDescr )
     179             :         {
     180           0 :             if ( !aURL.isEmpty() )
     181             :             {
     182           0 :                 aPropsToSet.realloc(1);
     183           0 :                 aPropsToSet[0].Name = "URL";
     184           0 :                 aPropsToSet[0].Value <<= aURL;
     185             :             }
     186             : 
     187           0 :             for ( sal_Int32 nInd = 0, nNumArgs = 1; nInd < aDescr.getLength(); nInd++ )
     188             :             {
     189           0 :                 if ( aDescr[nInd].Name == "InteractionHandler"
     190           0 :                   || aDescr[nInd].Name == "Password"
     191           0 :                   || aDescr[nInd].Name == "RepairPackage"
     192           0 :                   || aDescr[nInd].Name == "StatusIndicator" )
     193             :                   // || aDescr[nInd].Name == "Unpacked" ) // TODO:
     194             :                 {
     195           0 :                     aPropsToSet.realloc( ++nNumArgs );
     196           0 :                     aPropsToSet[nNumArgs-1].Name = aDescr[nInd].Name;
     197           0 :                     aPropsToSet[nNumArgs-1].Value = aDescr[nInd].Value;
     198             :                 }
     199           0 :                 else if ( aDescr[nInd].Name == "StorageFormat" )
     200             :                 {
     201           0 :                     OUString aFormatName;
     202           0 :                     sal_Int32 nFormatID = 0;
     203           0 :                     if ( aDescr[nInd].Value >>= aFormatName )
     204             :                     {
     205           0 :                         if ( aFormatName.equals( PACKAGE_STORAGE_FORMAT_STRING ) )
     206           0 :                             nStorageType = embed::StorageFormats::PACKAGE;
     207           0 :                         else if ( aFormatName.equals( ZIP_STORAGE_FORMAT_STRING ) )
     208           0 :                             nStorageType = embed::StorageFormats::ZIP;
     209           0 :                         else if ( aFormatName.equals( OFOPXML_STORAGE_FORMAT_STRING ) )
     210           0 :                             nStorageType = embed::StorageFormats::OFOPXML;
     211             :                         else
     212           0 :                             throw lang::IllegalArgumentException( THROW_WHERE, uno::Reference< uno::XInterface >(), 1 );
     213             :                     }
     214           0 :                     else if ( aDescr[nInd].Value >>= nFormatID )
     215             :                     {
     216           0 :                         if ( nFormatID != embed::StorageFormats::PACKAGE
     217           0 :                           && nFormatID != embed::StorageFormats::ZIP
     218           0 :                           && nFormatID != embed::StorageFormats::OFOPXML )
     219           0 :                             throw lang::IllegalArgumentException( THROW_WHERE, uno::Reference< uno::XInterface >(), 1 );
     220             : 
     221           0 :                         nStorageType = nFormatID;
     222             :                     }
     223             :                     else
     224           0 :                         throw lang::IllegalArgumentException( THROW_WHERE, uno::Reference< uno::XInterface >(), 1 );
     225             :                 }
     226             :                 else
     227             :                     OSL_FAIL( "Unacceptable property, will be ignored!\n" );
     228             :             }
     229             :         }
     230             :         else
     231             :         {
     232             :             OSL_FAIL( "Wrong third argument!\n" );
     233           0 :             throw uno::Exception(); // TODO: Illegal argument
     234             :         }
     235             : 
     236             :     }
     237             : 
     238             :     // create storage based on source
     239           0 :     if ( xInputStream.is() )
     240             :     {
     241             :         // if xInputStream is set the storage should be open from it
     242           0 :         if ( ( nStorageMode & embed::ElementModes::WRITE ) )
     243           0 :               throw uno::Exception(); // TODO: access denied
     244             : 
     245           0 :         uno::Reference< io::XSeekable > xSeekable( xInputStream, uno::UNO_QUERY );
     246           0 :         if ( !xSeekable.is() )
     247             :         {
     248             :             // TODO: wrap stream to let it be seekable
     249             :             OSL_FAIL( "Nonseekable streams are not supported for now!\n" );
     250             :         }
     251             : 
     252           0 :         if ( !CheckPackageSignature_Impl( xInputStream, xSeekable ) )
     253           0 :             throw io::IOException(); // TODO: this is not a package file
     254             : 
     255             :         return uno::Reference< uno::XInterface >(
     256           0 :                     static_cast< OWeakObject* >( new OStorage( xInputStream, nStorageMode, aPropsToSet, m_xContext, nStorageType ) ),
     257           0 :                     uno::UNO_QUERY );
     258             :     }
     259           0 :     else if ( xStream.is() )
     260             :     {
     261           0 :                if ( ( ( nStorageMode & embed::ElementModes::WRITE ) && !xStream->getOutputStream().is() )
     262           0 :           || !xStream->getInputStream().is() )
     263           0 :               throw uno::Exception(); // TODO: access denied
     264             : 
     265           0 :         uno::Reference< io::XSeekable > xSeekable( xStream, uno::UNO_QUERY );
     266           0 :         if ( !xSeekable.is() )
     267             :         {
     268             :             // TODO: wrap stream to let it be seekable
     269             :             OSL_FAIL( "Nonseekable streams are not supported for now!\n" );
     270             :         }
     271             : 
     272           0 :         if ( !CheckPackageSignature_Impl( xStream->getInputStream(), xSeekable ) )
     273           0 :             throw io::IOException(); // TODO: this is not a package file
     274             : 
     275             :         return uno::Reference< uno::XInterface >(
     276           0 :                     static_cast< OWeakObject* >( new OStorage( xStream, nStorageMode, aPropsToSet, m_xContext, nStorageType ) ),
     277           0 :                     uno::UNO_QUERY );
     278             :     }
     279             : 
     280           0 :     throw uno::Exception(); // general error during creation
     281             : }
     282             : 
     283           0 : OUString SAL_CALL OStorageFactory::getImplementationName()
     284             :     throw ( uno::RuntimeException, std::exception )
     285             : {
     286           0 :     return impl_staticGetImplementationName();
     287             : }
     288             : 
     289           0 : sal_Bool SAL_CALL OStorageFactory::supportsService( const OUString& ServiceName )
     290             :     throw ( uno::RuntimeException, std::exception )
     291             : {
     292           0 :     return cppu::supportsService(this, ServiceName);
     293             : }
     294             : 
     295           0 : uno::Sequence< OUString > SAL_CALL OStorageFactory::getSupportedServiceNames()
     296             :     throw ( uno::RuntimeException, std::exception )
     297             : {
     298           0 :     return impl_staticGetSupportedServiceNames();
     299             : }
     300             : 
     301             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10