1b61a652c1
and cid#1556585 COPY_INSTEAD_OF_MOVE cid#1556588 COPY_INSTEAD_OF_MOVE cid#1556593 COPY_INSTEAD_OF_MOVE cid#1556597 COPY_INSTEAD_OF_MOVE cid#1556605 COPY_INSTEAD_OF_MOVE cid#1556617 COPY_INSTEAD_OF_MOVE cid#1556635 COPY_INSTEAD_OF_MOVE cid#1556790 COPY_INSTEAD_OF_MOVE cid#1556792 COPY_INSTEAD_OF_MOVE cid#1556796 COPY_INSTEAD_OF_MOVE cid#1556799 COPY_INSTEAD_OF_MOVE cid#1556815 COPY_INSTEAD_OF_MOVE cid#1556836 COPY_INSTEAD_OF_MOVE cid#1556840 COPY_INSTEAD_OF_MOVE cid#1556842 COPY_INSTEAD_OF_MOVE cid#1556859 COPY_INSTEAD_OF_MOVE cid#1556860 COPY_INSTEAD_OF_MOVE cid#1556866 COPY_INSTEAD_OF_MOVE cid#1556869 COPY_INSTEAD_OF_MOVE cid#1556870 COPY_INSTEAD_OF_MOVE Change-Id: I3df8698a4aecbb03999c084517e37e12ff46ee97 Reviewed-on: https://gerrit.libreoffice.org/c/core/+/171435 Tested-by: Jenkins Reviewed-by: Caolán McNamara <caolan.mcnamara@collabora.com>
377 lines
13 KiB
C++
377 lines
13 KiB
C++
/* -*- 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 <oox/ole/olestorage.hxx>
|
|
|
|
#include <com/sun/star/container/XNameContainer.hpp>
|
|
#include <com/sun/star/embed/XTransactedObject.hpp>
|
|
#include <com/sun/star/io/IOException.hpp>
|
|
#include <com/sun/star/io/NotConnectedException.hpp>
|
|
#include <com/sun/star/io/TempFile.hpp>
|
|
#include <com/sun/star/io/XInputStream.hpp>
|
|
#include <com/sun/star/io/XOutputStream.hpp>
|
|
#include <com/sun/star/io/XSeekable.hpp>
|
|
#include <com/sun/star/io/XStream.hpp>
|
|
#include <com/sun/star/lang/XMultiServiceFactory.hpp>
|
|
#include <com/sun/star/uno/XComponentContext.hpp>
|
|
#include <cppuhelper/implbase.hxx>
|
|
#include <osl/diagnose.h>
|
|
#include <oox/helper/binaryinputstream.hxx>
|
|
#include <oox/helper/binaryoutputstream.hxx>
|
|
#include <oox/helper/containerhelper.hxx>
|
|
#include <utility>
|
|
|
|
namespace oox::ole {
|
|
|
|
using namespace ::com::sun::star::container;
|
|
using namespace ::com::sun::star::embed;
|
|
using namespace ::com::sun::star::io;
|
|
using namespace ::com::sun::star::lang;
|
|
using namespace ::com::sun::star::uno;
|
|
|
|
namespace {
|
|
|
|
/** Implementation of an OLE storage output stream that inserts itself into the
|
|
storage when it is closed.
|
|
*/
|
|
class OleOutputStream : public ::cppu::WeakImplHelper< XSeekable, XOutputStream >
|
|
{
|
|
public:
|
|
explicit OleOutputStream(
|
|
const Reference< XComponentContext >& rxContext,
|
|
const Reference< XNameContainer >& rxStorage,
|
|
OUString aElementName );
|
|
|
|
virtual void SAL_CALL seek( sal_Int64 nPos ) override;
|
|
virtual sal_Int64 SAL_CALL getPosition() override;
|
|
virtual sal_Int64 SAL_CALL getLength() override;
|
|
|
|
virtual void SAL_CALL writeBytes( const Sequence< sal_Int8 >& rData ) override;
|
|
virtual void SAL_CALL flush() override;
|
|
virtual void SAL_CALL closeOutput() override;
|
|
|
|
private:
|
|
/// @throws IOException
|
|
void ensureSeekable() const;
|
|
/// @throws NotConnectedException
|
|
void ensureConnected() const;
|
|
|
|
private:
|
|
Reference< XNameContainer > mxStorage;
|
|
Reference< XStream > mxTempFile;
|
|
Reference< XOutputStream > mxOutStrm;
|
|
Reference< XSeekable > mxSeekable;
|
|
OUString maElementName;
|
|
};
|
|
|
|
OleOutputStream::OleOutputStream( const Reference< XComponentContext >& rxContext,
|
|
const Reference< XNameContainer >& rxStorage, OUString aElementName ) :
|
|
mxStorage( rxStorage ),
|
|
maElementName(std::move( aElementName ))
|
|
{
|
|
try
|
|
{
|
|
mxTempFile.set( TempFile::create(rxContext), UNO_QUERY_THROW );
|
|
mxOutStrm = mxTempFile->getOutputStream();
|
|
mxSeekable.set( mxOutStrm, UNO_QUERY );
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
}
|
|
|
|
void SAL_CALL OleOutputStream::seek( sal_Int64 nPos )
|
|
{
|
|
ensureSeekable();
|
|
mxSeekable->seek( nPos );
|
|
}
|
|
|
|
sal_Int64 SAL_CALL OleOutputStream::getPosition()
|
|
{
|
|
ensureSeekable();
|
|
return mxSeekable->getPosition();
|
|
}
|
|
|
|
sal_Int64 SAL_CALL OleOutputStream::getLength()
|
|
{
|
|
ensureSeekable();
|
|
return mxSeekable->getLength();
|
|
}
|
|
|
|
void SAL_CALL OleOutputStream::writeBytes( const Sequence< sal_Int8 >& rData )
|
|
{
|
|
ensureConnected();
|
|
mxOutStrm->writeBytes( rData );
|
|
}
|
|
|
|
void SAL_CALL OleOutputStream::flush()
|
|
{
|
|
ensureConnected();
|
|
mxOutStrm->flush();
|
|
}
|
|
|
|
void SAL_CALL OleOutputStream::closeOutput()
|
|
{
|
|
ensureConnected();
|
|
ensureSeekable();
|
|
// remember the class members
|
|
Reference< XOutputStream > xOutStrm = mxOutStrm;
|
|
Reference< XSeekable > xSeekable = mxSeekable;
|
|
// reset all class members
|
|
mxOutStrm.clear();
|
|
mxSeekable.clear();
|
|
// close stream (and let it throw something if needed)
|
|
xOutStrm->closeOutput();
|
|
// on success, insert the stream into the OLE storage (must be seek-ed back before)
|
|
xSeekable->seek( 0 );
|
|
if( !ContainerHelper::insertByName( mxStorage, maElementName, Any( mxTempFile ) ) )
|
|
throw IOException();
|
|
}
|
|
|
|
void OleOutputStream::ensureSeekable() const
|
|
{
|
|
if( !mxSeekable.is() )
|
|
throw IOException();
|
|
}
|
|
|
|
void OleOutputStream::ensureConnected() const
|
|
{
|
|
if( !mxOutStrm.is() )
|
|
throw NotConnectedException();
|
|
}
|
|
|
|
} // namespace
|
|
|
|
OleStorage::OleStorage( const Reference< XComponentContext >& rxContext,
|
|
const Reference< XInputStream >& rxInStream, bool bBaseStreamAccess ) :
|
|
StorageBase( rxInStream, bBaseStreamAccess ),
|
|
mxContext( rxContext ),
|
|
mpParentStorage( nullptr )
|
|
{
|
|
OSL_ENSURE( mxContext.is(), "OleStorage::OleStorage - missing component context" );
|
|
initStorage( rxInStream );
|
|
}
|
|
|
|
OleStorage::OleStorage( const Reference< XComponentContext >& rxContext,
|
|
const Reference< XStream >& rxOutStream, bool bBaseStreamAccess ) :
|
|
StorageBase( rxOutStream, bBaseStreamAccess ),
|
|
mxContext( rxContext ),
|
|
mpParentStorage( nullptr )
|
|
{
|
|
OSL_ENSURE( mxContext.is(), "OleStorage::OleStorage - missing component context" );
|
|
initStorage( rxOutStream );
|
|
}
|
|
|
|
OleStorage::OleStorage( const OleStorage& rParentStorage,
|
|
const Reference< XNameContainer >& rxStorage, const OUString& rElementName, bool bReadOnly ) :
|
|
StorageBase( rParentStorage, rElementName, bReadOnly ),
|
|
mxContext( rParentStorage.mxContext ),
|
|
mxStorage( rxStorage ),
|
|
mpParentStorage( &rParentStorage )
|
|
{
|
|
OSL_ENSURE( mxStorage.is(), "OleStorage::OleStorage - missing substorage elements" );
|
|
}
|
|
|
|
OleStorage::OleStorage( const OleStorage& rParentStorage,
|
|
const Reference< XStream >& rxOutStream, const OUString& rElementName ) :
|
|
StorageBase( rParentStorage, rElementName, false ),
|
|
mxContext( rParentStorage.mxContext ),
|
|
mpParentStorage( &rParentStorage )
|
|
{
|
|
initStorage( rxOutStream );
|
|
}
|
|
|
|
OleStorage::~OleStorage()
|
|
{
|
|
}
|
|
|
|
void OleStorage::initStorage( const Reference< XInputStream >& rxInStream )
|
|
{
|
|
// if stream is not seekable, create temporary copy
|
|
Reference< XInputStream > xInStrm = rxInStream;
|
|
if( !Reference< XSeekable >( xInStrm, UNO_QUERY ).is() ) try
|
|
{
|
|
Reference< XStream > xTempFile( TempFile::create(mxContext), UNO_QUERY_THROW );
|
|
{
|
|
Reference< XOutputStream > xOutStrm( xTempFile->getOutputStream(), UNO_SET_THROW );
|
|
/* Pass false to both binary stream objects to keep the UNO
|
|
streams alive. Life time of these streams is controlled by the
|
|
tempfile implementation. */
|
|
BinaryXOutputStream aOutStrm( xOutStrm, false );
|
|
BinaryXInputStream aInStrm( xInStrm, false );
|
|
aInStrm.copyToStream( aOutStrm );
|
|
} // scope closes output stream of tempfile
|
|
xInStrm = xTempFile->getInputStream();
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
OSL_FAIL( "OleStorage::initStorage - cannot create temporary copy of input stream" );
|
|
}
|
|
|
|
// create base storage object
|
|
if( xInStrm.is() ) try
|
|
{
|
|
Reference< XMultiServiceFactory > xFactory( mxContext->getServiceManager(), UNO_QUERY_THROW );
|
|
Sequence< Any > aArgs{ Any(xInStrm),
|
|
Any(true) };// true = do not create a copy of the input stream
|
|
mxStorage.set( xFactory->createInstanceWithArguments(u"com.sun.star.embed.OLESimpleStorage"_ustr, aArgs ), UNO_QUERY_THROW );
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
}
|
|
|
|
void OleStorage::initStorage( const Reference< XStream >& rxOutStream )
|
|
{
|
|
// create base storage object
|
|
if( rxOutStream.is() ) try
|
|
{
|
|
Reference< XMultiServiceFactory > xFactory( mxContext->getServiceManager(), UNO_QUERY_THROW );
|
|
Sequence< Any > aArgs{ Any(rxOutStream),
|
|
Any(true) }; // true = do not create a copy of the stream
|
|
mxStorage.set( xFactory->createInstanceWithArguments(u"com.sun.star.embed.OLESimpleStorage"_ustr, aArgs ), UNO_QUERY_THROW );
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
}
|
|
|
|
// StorageBase interface ------------------------------------------------------
|
|
|
|
bool OleStorage::implIsStorage() const
|
|
{
|
|
if( mxStorage.is() ) try
|
|
{
|
|
/* If this is not an OLE storage, hasElements() of the OLESimpleStorage
|
|
implementation throws an exception. But we do not return the result
|
|
of hasElements(), because an empty storage is a valid storage too. */
|
|
(void)mxStorage->hasElements();
|
|
return true;
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
return false;
|
|
}
|
|
|
|
Reference< XStorage > OleStorage::implGetXStorage() const
|
|
{
|
|
OSL_FAIL( "OleStorage::getXStorage - not implemented" );
|
|
return Reference< XStorage >();
|
|
}
|
|
|
|
void OleStorage::implGetElementNames( ::std::vector< OUString >& orElementNames ) const
|
|
{
|
|
if( mxStorage.is() ) try
|
|
{
|
|
const Sequence<OUString> aNames = mxStorage->getElementNames();
|
|
if( aNames.hasElements() )
|
|
orElementNames.insert( orElementNames.end(), aNames.begin(), aNames.end() );
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
}
|
|
|
|
StorageRef OleStorage::implOpenSubStorage( const OUString& rElementName, bool bCreateMissing )
|
|
{
|
|
StorageRef xSubStorage;
|
|
if( mxStorage.is() && !rElementName.isEmpty() )
|
|
{
|
|
try
|
|
{
|
|
Reference< XNameContainer > xSubElements( mxStorage->getByName( rElementName ), UNO_QUERY_THROW );
|
|
xSubStorage.reset( new OleStorage( *this, xSubElements, rElementName, true ) );
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
|
|
/* The OLESimpleStorage API implementation seems to be buggy in the
|
|
area of writable inplace substorage (sometimes it overwrites other
|
|
unrelated streams with zero bytes). We go the save way and create a
|
|
new OLE storage based on a temporary file. All operations are
|
|
performed on this clean storage. On committing, the storage will be
|
|
completely re-inserted into the parent storage. */
|
|
if( !isReadOnly() && (bCreateMissing || xSubStorage) ) try
|
|
{
|
|
// create new storage based on a temp file
|
|
Reference< XStream > xTempFile( TempFile::create(mxContext), UNO_QUERY_THROW );
|
|
StorageRef xTempStorage( new OleStorage( *this, xTempFile, rElementName ) );
|
|
// copy existing substorage into temp storage
|
|
if( xSubStorage )
|
|
xSubStorage->copyStorageToStorage( *xTempStorage );
|
|
// return the temp storage to caller
|
|
xSubStorage = std::move(xTempStorage);
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
}
|
|
return xSubStorage;
|
|
}
|
|
|
|
Reference< XInputStream > OleStorage::implOpenInputStream( const OUString& rElementName )
|
|
{
|
|
Reference< XInputStream > xInStream;
|
|
if( mxStorage.is() ) try
|
|
{
|
|
xInStream.set( mxStorage->getByName( rElementName ), UNO_QUERY );
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
return xInStream;
|
|
}
|
|
|
|
Reference< XOutputStream > OleStorage::implOpenOutputStream( const OUString& rElementName )
|
|
{
|
|
Reference< XOutputStream > xOutStream;
|
|
if( mxStorage.is() && !rElementName.isEmpty() )
|
|
xOutStream.set( new OleOutputStream( mxContext, mxStorage, rElementName ) );
|
|
return xOutStream;
|
|
}
|
|
|
|
void OleStorage::implCommit() const
|
|
{
|
|
try
|
|
{
|
|
// commit this storage (finalizes the file this storage is based on)
|
|
Reference< XTransactedObject >( mxStorage, UNO_QUERY_THROW )->commit();
|
|
// re-insert this storage into the parent storage
|
|
if( mpParentStorage )
|
|
{
|
|
if( mpParentStorage->mxStorage->hasByName( getName() ) )
|
|
{
|
|
// replaceByName() does not work (#i109539#)
|
|
mpParentStorage->mxStorage->removeByName( getName() );
|
|
Reference< XTransactedObject >( mpParentStorage->mxStorage, UNO_QUERY_THROW )->commit();
|
|
}
|
|
mpParentStorage->mxStorage->insertByName( getName(), Any( mxStorage ) );
|
|
// this requires another commit(), which will be performed by the parent storage
|
|
}
|
|
}
|
|
catch(const Exception& )
|
|
{
|
|
}
|
|
}
|
|
|
|
} // namespace oox::ole
|
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|