/************************************************************************* * * $RCSfile: owriteablestream.cxx,v $ * * $Revision: 1.8 $ * * last change: $Author: hr $ $Date: 2004-11-26 20:45:20 $ * * 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 "owriteablestream.hxx" #ifndef _COM_SUN_STAR_UCB_XSIMPLEFILEACCESS_HPP_ #include #endif #ifndef _COM_SUN_STAR_UCB_XCOMMANDENVIRONMENT_HPP_ #include #endif #ifndef _COM_SUN_STAR_LANG_DISPOSEDEXCEPTION_HPP_ #include #endif #ifndef _COM_SUN_STAR_LANG_XUNOTUNNEL_HPP_ #include #endif #ifndef _COM_SUN_STAR_IO_IOEXCEPTION_HPP_ #include #endif #ifndef _COM_SUN_STAR_EMBED_ELEMENTMODES_HPP_ #include #endif #ifndef _CPPUHELPER_TYPEPROVIDER_HXX_ #include #endif #ifndef _OSL_DIAGNOSE_H_ #include #endif #ifndef _COMPHELPER_PROCESSFACTORY_HXX #include #endif #include "oseekinstream.hxx" #include "mutexholder.hxx" #include "xstorage.hxx" #include using namespace ::com::sun::star; //----------------------------------------------- void SetEncryptionKeyProperty_Impl( const uno::Reference< beans::XPropertySet >& xPropertySet, const uno::Sequence< sal_Int8 >& aKey ) { OSL_ENSURE( xPropertySet.is(), "No property set is provided!\n" ); if ( !xPropertySet.is() ) throw uno::RuntimeException(); ::rtl::OUString aString_EncryptionKey = ::rtl::OUString::createFromAscii( "EncryptionKey" ); try { xPropertySet->setPropertyValue( aString_EncryptionKey, uno::makeAny( aKey ) ); } catch ( uno::Exception& ) { OSL_ENSURE( sal_False, "Can't write encryption related properties!\n" ); throw io::IOException(); // TODO } } //----------------------------------------------- uno::Any GetEncryptionKeyProperty_Impl( const uno::Reference< beans::XPropertySet >& xPropertySet ) { OSL_ENSURE( xPropertySet.is(), "No property set is provided!\n" ); if ( !xPropertySet.is() ) throw uno::RuntimeException(); ::rtl::OUString aString_EncryptionKey = ::rtl::OUString::createFromAscii( "EncryptionKey" ); try { return xPropertySet->getPropertyValue( aString_EncryptionKey ); } catch ( uno::Exception& ) { OSL_ENSURE( sal_False, "Can't get encryption related properties!\n" ); throw io::IOException(); // TODO } } //----------------------------------------------- void completeStorageStreamCopy_Impl( const uno::Reference< io::XStream >& xSource, const uno::Reference< io::XStream >& xDest ); //----------------------------------------------- sal_Bool SequencesEqual( uno::Sequence< sal_Int8 > aSequence1, uno::Sequence< sal_Int8 > aSequence2 ) { if ( aSequence1.getLength() != aSequence2.getLength() ) return sal_False; for ( sal_Int32 nInd = 0; nInd < aSequence1.getLength(); nInd++ ) if ( aSequence1[nInd] != aSequence2[nInd] ) return sal_False; return sal_True; } //----------------------------------------------- sal_Bool KillFile( const ::rtl::OUString& aURL, const uno::Reference< lang::XMultiServiceFactory >& xFactory ) { if ( !xFactory.is() ) return sal_False; sal_Bool bRet = sal_False; try { uno::Reference < ucb::XSimpleFileAccess > xAccess( xFactory->createInstance ( ::rtl::OUString::createFromAscii( "com.sun.star.ucb.SimpleFileAccess" ) ), uno::UNO_QUERY ); if ( xAccess.is() ) { xAccess->kill( aURL ); bRet = sal_True; } } catch( uno::Exception& ) { } return bRet; } const sal_Int32 n_ConstBufferSize = 32000; //----------------------------------------------- void copyInputToOutput_Impl( const uno::Reference< io::XInputStream >& aIn, const uno::Reference< io::XOutputStream >& aOut ) { sal_Int32 nRead; uno::Sequence < sal_Int8 > aSequence ( n_ConstBufferSize ); do { nRead = aIn->readBytes ( aSequence, n_ConstBufferSize ); if ( nRead < n_ConstBufferSize ) { uno::Sequence < sal_Int8 > aTempBuf ( aSequence.getConstArray(), nRead ); aOut->writeBytes ( aTempBuf ); } else aOut->writeBytes ( aSequence ); } while ( nRead == n_ConstBufferSize ); } ::rtl::OUString GetNewTempFileURL( const uno::Reference< lang::XMultiServiceFactory > xFactory ) { ::rtl::OUString aTempURL; uno::Reference < beans::XPropertySet > xTempFile( xFactory->createInstance( ::rtl::OUString::createFromAscii( "com.sun.star.io.TempFile" ) ), uno::UNO_QUERY ); if ( !xTempFile.is() ) throw uno::RuntimeException(); // TODO try { xTempFile->setPropertyValue( ::rtl::OUString::createFromAscii( "RemoveFile" ), uno::makeAny( sal_False ) ); uno::Any aUrl = xTempFile->getPropertyValue( ::rtl::OUString::createFromAscii( "Uri" ) ); aUrl >>= aTempURL; } catch ( uno::Exception& ) { } if ( !aTempURL.getLength() ) throw uno::RuntimeException(); // TODO: can not create tempfile return aTempURL; } uno::Sequence< sal_Int8 > MakeKeyFromPass( ::rtl::OUString aPass, sal_Bool bUseUTF ) { // MS_1252 encoding was used for SO60 document format password encoding, // this encoding supports only a minor subset of nonascii characters, // but for compatibility reasons it has to be used for old document formats ::rtl::OString aByteStrPass; if ( bUseUTF ) aByteStrPass = ::rtl::OUStringToOString( aPass, RTL_TEXTENCODING_UTF8 ); else aByteStrPass = ::rtl::OUStringToOString( aPass, RTL_TEXTENCODING_MS_1252 ); sal_uInt8 pBuffer[RTL_DIGEST_LENGTH_SHA1]; rtlDigestError nError = rtl_digest_SHA1( aByteStrPass.getStr(), aByteStrPass.getLength(), pBuffer, RTL_DIGEST_LENGTH_SHA1 ); if ( nError != rtl_Digest_E_None ) throw uno::RuntimeException(); return uno::Sequence< sal_Int8 >( (sal_Int8*)pBuffer, RTL_DIGEST_LENGTH_SHA1 ); } // ================================================================ //----------------------------------------------- OWriteStream_Impl::OWriteStream_Impl( OStorage_Impl* pParent, uno::Reference< packages::XDataSinkEncrSupport > xPackageStream, uno::Reference< ::com::sun::star::lang::XSingleServiceFactory > xPackage, uno::Reference< lang::XMultiServiceFactory > xFactory, sal_Bool bForceEncrypted ) : m_pAntiImpl( NULL ) , m_bHasDataToFlush( sal_False ) , m_bFlushed( sal_False ) , m_xPackageStream( xPackageStream ) , m_xFactory( xFactory ) , m_pParent( pParent ) , m_bHasCachedPassword( sal_False ) , m_bForceEncrypted( bForceEncrypted ) , m_bUseCommonPass( sal_False ) , m_xPackage( xPackage ) { OSL_ENSURE( xPackageStream.is(), "No package stream is provided!\n" ); OSL_ENSURE( xPackage.is(), "No package component is provided!\n" ); OSL_ENSURE( m_xFactory.is(), "No package stream is provided!\n" ); OSL_ENSURE( pParent, "No parent storage is provided!\n" ); } //----------------------------------------------- OWriteStream_Impl::~OWriteStream_Impl() { DisposeWrappers(); if ( m_aTempURL.getLength() ) { KillFile( m_aTempURL, GetServiceFactory() ); m_aTempURL = ::rtl::OUString(); } } //----------------------------------------------- void OWriteStream_Impl::InsertIntoPackageFolder( const ::rtl::OUString& aName, const uno::Reference< container::XNameContainer >& xParentPackageFolder ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); OSL_ENSURE( m_bFlushed, "This method must not be called for nonflushed streams!\n" ); if ( m_bFlushed ) { OSL_ENSURE( m_xPackageStream.is(), "An inserted stream is incomplete!\n" ); uno::Reference< lang::XUnoTunnel > xTunnel( m_xPackageStream, uno::UNO_QUERY ); if ( !xTunnel.is() ) throw uno::RuntimeException(); // TODO xParentPackageFolder->insertByName( aName, uno::makeAny( xTunnel ) ); m_bFlushed = sal_False; } } //----------------------------------------------- sal_Bool OWriteStream_Impl::IsEncrypted() { if ( m_bUseCommonPass ) return sal_False; if ( m_bForceEncrypted || m_bHasCachedPassword ) return sal_True; if ( m_aTempURL.getLength() ) return sal_False; GetStreamProperties(); // the following value can not be cached since it can change after root commit sal_Bool bWasEncr = sal_False; uno::Reference< beans::XPropertySet > xPropSet( m_xPackageStream, uno::UNO_QUERY ); if ( xPropSet.is() ) { uno::Any aValue = xPropSet->getPropertyValue( ::rtl::OUString::createFromAscii( "WasEncrypted" ) ); if ( !( aValue >>= bWasEncr ) ) { OSL_ENSURE( sal_False, "The property WasEncrypted has wrong type!\n" ); } } sal_Bool bToBeEncr = sal_False; for ( sal_Int32 nInd = 0; nInd < m_aProps.getLength(); nInd++ ) { if ( m_aProps[nInd].Name.equalsAscii( "Encrypted" ) ) { if ( !( m_aProps[nInd].Value >>= bToBeEncr ) ) { OSL_ENSURE( sal_False, "The property has wrong type!\n" ); } } } // since a new key set to the package stream it should not be removed except the case when // the stream becomes nonencrypted uno::Sequence< sal_Int8 > aKey; if ( bToBeEncr ) GetEncryptionKeyProperty_Impl( xPropSet ) >>= aKey; // If the properties must be investigated the stream is either // was never changed or was changed, the parent was commited // and the stream was closed. // That means that if it is intended to use common storage key // it is already has no encryption but is marked to be stored // encrypted and the key is empty. if ( !bWasEncr && bToBeEncr && !aKey.getLength() ) { // the stream is intended to use common storage password m_bUseCommonPass = sal_True; return sal_False; } else return bToBeEncr; OSL_ENSURE( sal_False, "Can't read encryption related properties!\n" ); throw io::IOException(); // TODO return sal_False; // not reachable } //----------------------------------------------- void OWriteStream_Impl::SetDecrypted() { GetStreamProperties(); // let the stream be modified GetFilledTempFile(); m_bHasDataToFlush = sal_True; if ( m_pParent ) m_pParent->SetModifiedInternally( sal_True ); // remove encryption m_bForceEncrypted = sal_False; m_bHasCachedPassword = sal_False; m_aPass = ::rtl::OUString(); for ( sal_Int32 nInd = 0; nInd < m_aProps.getLength(); nInd++ ) { if ( m_aProps[nInd].Name.equalsAscii( "Encrypted" ) ) m_aProps[nInd].Value <<= sal_False; } } //----------------------------------------------- void OWriteStream_Impl::SetEncryptedWithPass( const ::rtl::OUString& aPass ) { GetStreamProperties(); // let the stream be modified GetFilledTempFile(); m_bHasDataToFlush = sal_True; if ( m_pParent ) m_pParent->SetModifiedInternally( sal_True ); // introduce encryption info for ( sal_Int32 nInd = 0; nInd < m_aProps.getLength(); nInd++ ) { if ( m_aProps[nInd].Name.equalsAscii( "Encrypted" ) ) m_aProps[nInd].Value <<= sal_True; } m_bUseCommonPass = sal_False; // very important to set it to false m_bHasCachedPassword = sal_True; m_aPass = aPass; m_bHasDataToFlush = sal_True; } //----------------------------------------------- void OWriteStream_Impl::DisposeWrappers() { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); if ( m_pAntiImpl ) { try { m_pAntiImpl->dispose(); } catch ( uno::RuntimeException& ) {} m_pAntiImpl = NULL; } m_pParent = NULL; if ( !m_aInputStreamsList.empty() ) { for ( InputStreamsList_Impl::iterator pStreamIter = m_aInputStreamsList.begin(); pStreamIter != m_aInputStreamsList.end(); pStreamIter++ ) { if ( (*pStreamIter) ) { (*pStreamIter)->InternalDispose(); (*pStreamIter) = NULL; } } m_aInputStreamsList.clear(); } } //----------------------------------------------- uno::Reference< lang::XMultiServiceFactory > OWriteStream_Impl::GetServiceFactory() { if ( m_xFactory.is() ) return m_xFactory; return ::comphelper::getProcessServiceFactory(); } //----------------------------------------------- ::rtl::OUString OWriteStream_Impl::GetFilledTempFile() { if ( !m_aTempURL.getLength() ) { m_aTempURL = GetNewTempFileURL( GetServiceFactory() ); try { if ( m_aTempURL ) { uno::Reference < ucb::XSimpleFileAccess > xTempAccess( GetServiceFactory()->createInstance ( ::rtl::OUString::createFromAscii( "com.sun.star.ucb.SimpleFileAccess" ) ), uno::UNO_QUERY ); if ( !xTempAccess.is() ) throw uno::RuntimeException(); // TODO: // in case of new inserted package stream it is possible that input stream still was not set uno::Reference< io::XInputStream > xOrigStream = m_xPackageStream->getDataStream(); if ( xOrigStream.is() ) { uno::Reference< io::XOutputStream > xTempOutStream = xTempAccess->openFileWrite( m_aTempURL ); if ( xTempOutStream.is() ) { // copy stream contents to the file copyInputToOutput_Impl( xOrigStream, xTempOutStream ); xTempOutStream->closeOutput(); xTempOutStream = uno::Reference< io::XOutputStream >(); } else throw io::IOException(); // TODO: } } } catch( packages::WrongPasswordException& ) { KillFile( m_aTempURL, GetServiceFactory() ); m_aTempURL = ::rtl::OUString(); throw; } catch( uno::Exception& ) { KillFile( m_aTempURL, GetServiceFactory() ); m_aTempURL = ::rtl::OUString(); } } return m_aTempURL; } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::GetTempFileAsStream() { uno::Reference< io::XStream > xTempStream; if ( !m_aTempURL.getLength() ) m_aTempURL = GetFilledTempFile(); uno::Reference < ucb::XSimpleFileAccess > xTempAccess( GetServiceFactory()->createInstance ( ::rtl::OUString::createFromAscii( "com.sun.star.ucb.SimpleFileAccess" ) ), uno::UNO_QUERY ); if ( !xTempAccess.is() ) throw uno::RuntimeException(); // TODO: try { xTempStream = xTempAccess->openFileReadWrite( m_aTempURL ); } catch( uno::Exception& ) { } // the method must always return a stream // in case the stream can not be open // an exception should be thrown if ( !xTempStream.is() ) throw io::IOException(); //TODO: return xTempStream; } //----------------------------------------------- uno::Reference< io::XInputStream > OWriteStream_Impl::GetTempFileAsInputStream() { uno::Reference< io::XInputStream > xInputStream; if ( !m_aTempURL.getLength() ) m_aTempURL = GetFilledTempFile(); uno::Reference < ucb::XSimpleFileAccess > xTempAccess( GetServiceFactory()->createInstance ( ::rtl::OUString::createFromAscii( "com.sun.star.ucb.SimpleFileAccess" ) ), uno::UNO_QUERY ); if ( !xTempAccess.is() ) throw uno::RuntimeException(); // TODO: try { xInputStream = xTempAccess->openFileRead( m_aTempURL ); } catch( uno::Exception& ) { } // the method must always return a stream // in case the stream can not be open // an exception should be thrown if ( !xInputStream.is() ) throw io::IOException(); // TODO: return xInputStream; } //----------------------------------------------- void OWriteStream_Impl::CopyTempFileToOutput( uno::Reference< io::XOutputStream > xOutStream ) { OSL_ENSURE( xOutStream.is(), "The stream must be specified!\n" ); OSL_ENSURE( m_aTempURL.getLength(), "The temporary must exist!\n" ); uno::Reference < ucb::XSimpleFileAccess > xTempAccess( GetServiceFactory()->createInstance ( ::rtl::OUString::createFromAscii( "com.sun.star.ucb.SimpleFileAccess" ) ), uno::UNO_QUERY ); if ( !xTempAccess.is() ) throw uno::RuntimeException(); // TODO: uno::Reference< io::XInputStream > xTempInStream; try { xTempInStream = xTempAccess->openFileRead( m_aTempURL ); } catch( uno::Exception& ) { } if ( !xTempInStream.is() ) throw io::IOException(); //TODO: copyInputToOutput_Impl( xTempInStream, xOutStream ); } // ================================================================================================= //----------------------------------------------- void OWriteStream_Impl::Commit() { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; // this call can be made only during parent storage commit // the parent storage is responsible for the correct handling // of deleted and renamed contents OSL_ENSURE( m_xPackageStream.is(), "No package stream is set!\n" ); if ( !m_bHasDataToFlush ) return; OSL_ENSURE( m_aTempURL.getLength(), "The temporary must exist!\n" ); uno::Reference < io::XOutputStream > xTempOut( GetServiceFactory()->createInstance ( ::rtl::OUString::createFromAscii( "com.sun.star.io.TempFile" ) ), uno::UNO_QUERY ); uno::Reference < io::XInputStream > xTempIn( xTempOut, uno::UNO_QUERY ); if ( !xTempOut.is() || !xTempIn.is() ) throw io::IOException(); // Copy temporary file to a new one CopyTempFileToOutput( xTempOut ); xTempOut->closeOutput(); uno::Sequence< uno::Any > aSeq( 1 ); aSeq[0] <<= sal_False; uno::Reference< packages::XDataSinkEncrSupport > xNewPackageStream( m_xPackage->createInstanceWithArguments( aSeq ), uno::UNO_QUERY ); if ( !xNewPackageStream.is() ) throw uno::RuntimeException(); // use new file as current persistent representation // the new file will be removed after it's stream is closed xNewPackageStream->setDataStream( xTempIn ); // copy properties to the package stream uno::Reference< beans::XPropertySet > xPropertySet( xNewPackageStream, uno::UNO_QUERY ); if ( !xPropertySet.is() ) throw uno::RuntimeException(); for ( sal_Int32 nInd = 0; nInd < m_aProps.getLength(); nInd++ ) { if ( m_aProps[nInd].Name.equalsAscii( "Size" ) && m_pAntiImpl ) m_aProps[nInd].Value <<= ((sal_Int32)m_pAntiImpl->m_xSeekable->getLength()); xPropertySet->setPropertyValue( m_aProps[nInd].Name, m_aProps[nInd].Value ); } if ( m_bUseCommonPass ) { // set to be encrypted but do not use encryption key xPropertySet->setPropertyValue( ::rtl::OUString::createFromAscii( "EncryptionKey" ), uno::makeAny( uno::Sequence< sal_Int8 >() ) ); xPropertySet->setPropertyValue( ::rtl::OUString::createFromAscii( "Encrypted" ), uno::makeAny( sal_True ) ); } else if ( m_bHasCachedPassword ) xPropertySet->setPropertyValue( ::rtl::OUString::createFromAscii( "EncryptionKey" ), uno::makeAny( MakeKeyFromPass( m_aPass, sal_True ) ) ); // the stream should be free soon, after package is stored m_xPackageStream = xNewPackageStream; m_bHasDataToFlush = sal_False; m_bFlushed = sal_True; // will allow to use transaction on stream level if will need it } //----------------------------------------------- void OWriteStream_Impl::Revert() { // can be called only from parent storage // means complete reload of the stream ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; if ( !m_bHasDataToFlush ) return; // nothing to do // The stream must be free OSL_ENSURE( !m_pAntiImpl, "Reverting storage while a write stream is open!\n" ); if ( m_pAntiImpl ) throw io::IOException(); // TODO OSL_ENSURE( m_aTempURL.getLength(), "The temporary must exist!\n" ); if ( m_aTempURL.getLength() ) { KillFile( m_aTempURL, GetServiceFactory() ); m_aTempURL = ::rtl::OUString(); } m_aProps.realloc( 0 ); m_bHasDataToFlush = sal_False; m_bUseCommonPass = sal_False; m_bHasCachedPassword = sal_False; m_aPass = ::rtl::OUString(); } //----------------------------------------------- uno::Sequence< beans::PropertyValue > OWriteStream_Impl::GetStreamProperties() { if ( !m_aProps.getLength() ) m_aProps = ReadStreamProperties(); return m_aProps; } //----------------------------------------------- uno::Sequence< beans::PropertyValue > OWriteStream_Impl::InsertOwnProps( const uno::Sequence< beans::PropertyValue >& aProps, sal_Bool bUseCommonPass ) { uno::Sequence< beans::PropertyValue > aResult( aProps ); sal_Int32 nLen = aResult.getLength(); for ( sal_Int32 nInd = 0; nInd < nLen; nInd++ ) if ( aResult[nInd].Name.equalsAscii( "UseCommonStoragePasswordEncryption" ) ) { aResult[nInd].Value <<= bUseCommonPass; return aResult; } aResult.realloc( ++nLen ); aResult[nLen - 1].Name = ::rtl::OUString::createFromAscii("UseCommonStoragePasswordEncryption"); aResult[nLen - 1].Value <<= bUseCommonPass; return aResult; } //----------------------------------------------- uno::Sequence< beans::PropertyValue > OWriteStream_Impl::ReadStreamProperties() { uno::Sequence< beans::PropertyValue > aResult( 4 ); aResult[0].Name = ::rtl::OUString::createFromAscii("MediaType"); aResult[1].Name = ::rtl::OUString::createFromAscii("Size"); aResult[2].Name = ::rtl::OUString::createFromAscii("Encrypted"); aResult[3].Name = ::rtl::OUString::createFromAscii("Compressed"); // TODO: may be also raw stream should be marked uno::Reference< beans::XPropertySet > xPropSet( m_xPackageStream, uno::UNO_QUERY ); if ( xPropSet.is() ) { for ( sal_Int32 nInd = 0; nInd < aResult.getLength(); nInd++ ) { try { aResult[nInd].Value = xPropSet->getPropertyValue( aResult[nInd].Name ); } catch( uno::Exception& ) { OSL_ENSURE( sal_False, "A property can't be retrieved!\n" ); } } } else { OSL_ENSURE( sal_False, "Can not get properties from a package stream!\n" ); throw uno::RuntimeException(); } return aResult; } //----------------------------------------------- void OWriteStream_Impl::CopyInternallyTo_Impl( const uno::Reference< io::XStream >& xDestStream, const ::rtl::OUString& aPass ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; OSL_ENSURE( !m_bUseCommonPass, "The stream can not be encrypted!" ); if ( m_pAntiImpl ) { m_pAntiImpl->CopyToStreamInternally_Impl( xDestStream ); } else { uno::Reference< io::XStream > xOwnStream = GetStream( embed::ElementModes::READ, aPass ); if ( !xOwnStream.is() ) throw io::IOException(); // TODO completeStorageStreamCopy_Impl( xOwnStream, xDestStream ); } uno::Reference< embed::XEncryptionProtectedSource > xEncr( xDestStream, uno::UNO_QUERY ); if ( xEncr.is() ) xEncr->setEncryptionPassword( aPass ); } //----------------------------------------------- void OWriteStream_Impl::CopyInternallyTo_Impl( const uno::Reference< io::XStream >& xDestStream ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; if ( m_pAntiImpl ) { m_pAntiImpl->CopyToStreamInternally_Impl( xDestStream ); } else { uno::Reference< io::XStream > xOwnStream = GetStream( embed::ElementModes::READ ); if ( !xOwnStream.is() ) throw io::IOException(); // TODO completeStorageStreamCopy_Impl( xOwnStream, xDestStream ); } } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::GetStream( sal_Int32 nStreamMode, const ::rtl::OUString& aPass ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; OSL_ENSURE( m_xPackageStream.is(), "No package stream is set!\n" ); if ( m_pAntiImpl ) throw io::IOException(); // TODO: if ( !IsEncrypted() ) throw packages::NoEncryptionException(); uno::Reference< io::XStream > xResultStream; uno::Reference< beans::XPropertySet > xPropertySet( m_xPackageStream, uno::UNO_QUERY ); if ( !xPropertySet.is() ) throw uno::RuntimeException(); if ( m_bHasCachedPassword ) { if ( !m_aPass.equals( aPass ) ) throw packages::WrongPasswordException(); // the correct key must be set already xResultStream = GetStream_Impl( nStreamMode ); } else { SetEncryptionKeyProperty_Impl( xPropertySet, MakeKeyFromPass( aPass, sal_True ) ); try { xResultStream = GetStream_Impl( nStreamMode ); m_bHasCachedPassword = sal_True; m_aPass = aPass; } catch( packages::WrongPasswordException& ) { // retry with different encoding SetEncryptionKeyProperty_Impl( xPropertySet, MakeKeyFromPass( aPass, sal_False ) ); try { // the stream must be cashed to be resaved xResultStream = GetStream_Impl( nStreamMode | embed::ElementModes::SEEKABLE ); m_bHasCachedPassword = sal_True; m_aPass = aPass; // the stream must be resaved with new password encryption if ( nStreamMode & embed::ElementModes::WRITE ) { GetFilledTempFile(); m_bHasDataToFlush = sal_True; if ( m_pParent ) m_pParent->SetModifiedInternally( sal_True ); } } catch( packages::WrongPasswordException& ) { SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); } catch ( uno::Exception& ) { OSL_ENSURE( sal_False, "Can't write encryption related properties!\n" ); throw io::IOException(); // TODO: } throw; } catch( uno::Exception& ) { SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); throw; } } OSL_ENSURE( xResultStream.is(), "In case stream can not be retrieved an exception must be thrown!\n" ); return xResultStream; } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::GetStream( sal_Int32 nStreamMode ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; OSL_ENSURE( m_xPackageStream.is(), "No package stream is set!\n" ); if ( m_pAntiImpl ) throw io::IOException(); // TODO: uno::Reference< io::XStream > xResultStream; if ( IsEncrypted() ) { ::rtl::OUString aGlobalPass; try { aGlobalPass = GetCommonRootPass(); } catch( packages::NoEncryptionException& ) { throw packages::WrongPasswordException(); } xResultStream = GetStream( nStreamMode, aGlobalPass ); } else xResultStream = GetStream_Impl( nStreamMode ); return xResultStream; } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::GetStream_Impl( sal_Int32 nStreamMode ) { // private method, no mutex is used GetStreamProperties(); if ( ( nStreamMode & embed::ElementModes::READWRITE ) == embed::ElementModes::READ ) { uno::Reference< io::XInputStream > xInStream; if ( m_aTempURL.getLength() ) xInStream = GetTempFileAsInputStream(); //TODO: else xInStream = m_xPackageStream->getDataStream(); // The stream does not exist in the storage if ( !xInStream.is() ) throw io::IOException(); OInputCompStream* pStream = new OInputCompStream( *this, xInStream, InsertOwnProps( m_aProps, m_bUseCommonPass ) ); uno::Reference< io::XStream > xCompStream( static_cast< ::cppu::OWeakObject* >( pStream ), uno::UNO_QUERY ); OSL_ENSURE( xCompStream.is(), "OInputCompStream MUST provide XStream interfaces!\n" ); m_aInputStreamsList.push_back( pStream ); return xCompStream; } else if ( ( nStreamMode & embed::ElementModes::READWRITE ) == embed::ElementModes::SEEKABLEREAD ) { if ( !m_aTempURL.getLength() && !( m_xPackageStream->getDataStream().is() ) ) { // The stream does not exist in the storage throw io::IOException(); } uno::Reference< io::XInputStream > xInStream; xInStream = GetTempFileAsInputStream(); //TODO: if ( !xInStream.is() ) throw io::IOException(); OInputSeekStream* pStream = new OInputSeekStream( *this, xInStream, InsertOwnProps( m_aProps, m_bUseCommonPass ) ); uno::Reference< io::XStream > xSeekStream( static_cast< ::cppu::OWeakObject* >( pStream ), uno::UNO_QUERY ); OSL_ENSURE( xSeekStream.is(), "OInputSeekStream MUST provide XStream interfaces!\n" ); m_aInputStreamsList.push_back( pStream ); return xSeekStream; } else if ( ( nStreamMode & embed::ElementModes::WRITE ) == embed::ElementModes::WRITE ) { if ( !m_aInputStreamsList.empty() ) throw io::IOException(); // TODO: uno::Reference< io::XStream > xStream; if ( ( nStreamMode & embed::ElementModes::TRUNCATE ) == embed::ElementModes::TRUNCATE ) { if ( m_aTempURL.getLength() ) KillFile( m_aTempURL, GetServiceFactory() ); // open new empty temp file m_aTempURL = GetNewTempFileURL( GetServiceFactory() ); m_bHasDataToFlush = sal_True; xStream = GetTempFileAsStream(); } else { if ( !m_aTempURL.getLength() && !( m_xPackageStream->getDataStream().is() ) ) { // The stream does not exist in the storage m_bHasDataToFlush = sal_True; } xStream = GetTempFileAsStream(); } m_pAntiImpl = new OWriteStream( this, xStream ); uno::Reference< io::XStream > xWriteStream = uno::Reference< io::XStream >( static_cast< ::cppu::OWeakObject* >( m_pAntiImpl ), uno::UNO_QUERY ); OSL_ENSURE( xWriteStream.is(), "OWriteStream MUST implement XStream && XComponent interfaces!\n" ); return xWriteStream; } throw lang::IllegalArgumentException(); // TODO // not reachable return uno::Reference< io::XStream >(); } //----------------------------------------------- uno::Reference< io::XInputStream > OWriteStream_Impl::GetPlainRawInStream() { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; OSL_ENSURE( m_xPackageStream.is(), "No package stream is set!\n" ); // this method is used only internally, this stream object should not go outside of this implementation // if ( m_pAntiImpl ) // throw io::IOException(); // TODO: return m_xPackageStream->getPlainRawStream(); } //----------------------------------------------- uno::Reference< io::XInputStream > OWriteStream_Impl::GetRawInStream() { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; OSL_ENSURE( m_xPackageStream.is(), "No package stream is set!\n" ); if ( m_pAntiImpl ) throw io::IOException(); // TODO: OSL_ENSURE( IsEncrypted(), "Impossible to get raw representation for nonencrypted stream!\n" ); if ( !IsEncrypted() ) throw packages::NoEncryptionException(); return m_xPackageStream->getRawStream(); } //----------------------------------------------- ::rtl::OUString OWriteStream_Impl::GetCommonRootPass() throw ( packages::NoEncryptionException ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; if ( !m_pParent ) throw packages::NoEncryptionException(); return m_pParent->GetCommonRootPass(); } //----------------------------------------------- void OWriteStream_Impl::InputStreamDisposed( OInputCompStream* pStream ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); m_aInputStreamsList.remove( pStream ); } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::CreateReadonlyCopyBasedOnData( const uno::Reference< io::XInputStream >& xDataToCopy, const uno::Sequence< beans::PropertyValue >& aProps, sal_Bool bUseCommonKey ) { uno::Reference < io::XStream > xTempFile( m_xFactory->createInstance( ::rtl::OUString::createFromAscii( "com.sun.star.io.TempFile" ) ), uno::UNO_QUERY ); uno::Reference < io::XSeekable > xTempSeek( xTempFile, uno::UNO_QUERY ); if ( !xTempSeek.is() ) throw uno::RuntimeException(); // TODO uno::Reference < io::XOutputStream > xTempOut = xTempFile->getOutputStream(); if ( !xTempOut.is() ) throw uno::RuntimeException(); if ( xDataToCopy.is() ) copyInputToOutput_Impl( xDataToCopy, xTempOut ); xTempOut->closeOutput(); xTempSeek->seek( 0 ); uno::Reference< io::XInputStream > xInStream = xTempFile->getInputStream(); if ( !xInStream.is() ) throw io::IOException(); // TODO: remember last state of m_bUseCommonPass uno::Reference< io::XStream > xResult( static_cast< ::cppu::OWeakObject* >( new OInputSeekStream( xInStream, InsertOwnProps( aProps, m_bUseCommonPass ) ) ), uno::UNO_QUERY ); if ( !xResult.is() ) throw uno::RuntimeException(); return xResult; } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::GetCopyOfLastCommit() { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); OSL_ENSURE( m_xPackageStream.is(), "The source stream for copying is incomplete!\n" ); if ( !m_xPackageStream.is() ) throw uno::RuntimeException(); uno::Reference< io::XInputStream > xDataToCopy; if ( IsEncrypted() ) { // an encrypted stream must contain input stream ::rtl::OUString aGlobalPass; try { aGlobalPass = GetCommonRootPass(); } catch( packages::NoEncryptionException& ) { throw packages::WrongPasswordException(); } return GetCopyOfLastCommit( aGlobalPass ); } else xDataToCopy = m_xPackageStream->getDataStream(); // in case of new inserted package stream it is possible that input stream still was not set return CreateReadonlyCopyBasedOnData( xDataToCopy, ReadStreamProperties(), m_bUseCommonPass ); } //----------------------------------------------- uno::Reference< io::XStream > OWriteStream_Impl::GetCopyOfLastCommit( const ::rtl::OUString& aPass ) { ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); OSL_ENSURE( m_xPackageStream.is(), "The source stream for copying is incomplete!\n" ); if ( !m_xPackageStream.is() ) throw uno::RuntimeException(); if ( !IsEncrypted() ) throw packages::NoEncryptionException(); uno::Reference< io::XInputStream > xDataToCopy; if ( m_bHasCachedPassword ) { // TODO: introduce last commited cashed password information and use it here // that means "use common pass" also should be remembered on flash uno::Sequence< sal_Int8 > aNewKey = MakeKeyFromPass( aPass, sal_True ); uno::Sequence< sal_Int8 > aOldKey = MakeKeyFromPass( aPass, sal_False ); uno::Reference< beans::XPropertySet > xProps( m_xPackageStream, uno::UNO_QUERY ); if ( !xProps.is() ) throw uno::RuntimeException(); sal_Bool bEncr = sal_False; xProps->getPropertyValue( ::rtl::OUString::createFromAscii( "Encrypted" ) ) >>= bEncr; if ( !bEncr ) throw packages::NoEncryptionException(); uno::Sequence< sal_Int8 > aEncrKey; xProps->getPropertyValue( ::rtl::OUString::createFromAscii( "EncryptionKey" ) ) >>= aEncrKey; if ( !SequencesEqual( aNewKey, aEncrKey ) && !SequencesEqual( aOldKey, aEncrKey ) ) throw packages::WrongPasswordException(); // the correct key must be set already xDataToCopy = m_xPackageStream->getDataStream(); } else { uno::Reference< beans::XPropertySet > xPropertySet( m_xPackageStream, uno::UNO_QUERY ); SetEncryptionKeyProperty_Impl( xPropertySet, MakeKeyFromPass( aPass, sal_True ) ); try { xDataToCopy = m_xPackageStream->getDataStream(); if ( !xDataToCopy.is() ) { OSL_ENSURE( sal_False, "Encrypted ZipStream must already have input stream inside!\n" ); SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); } } catch( packages::WrongPasswordException& ) { SetEncryptionKeyProperty_Impl( xPropertySet, MakeKeyFromPass( aPass, sal_False ) ); try { xDataToCopy = m_xPackageStream->getDataStream(); if ( !xDataToCopy.is() ) { OSL_ENSURE( sal_False, "Encrypted ZipStream must already have input stream inside!\n" ); SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); } } catch( uno::Exception& ) { SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); } throw; } catch( uno::Exception& ) { OSL_ENSURE( sal_False, "Can't open encrypted stream!\n" ); SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); throw; } SetEncryptionKeyProperty_Impl( xPropertySet, uno::Sequence< sal_Int8 >() ); } // in case of new inserted package stream it is possible that input stream still was not set return CreateReadonlyCopyBasedOnData( xDataToCopy, ReadStreamProperties(), sal_False ); } //=============================================== // OWriteStream implementation //=============================================== //----------------------------------------------- OWriteStream::OWriteStream( OWriteStream_Impl* pImpl, uno::Reference< io::XStream > xStream ) : m_pImpl( pImpl ) , m_bInStreamDisconnected( sal_False ) { OSL_ENSURE( pImpl && xStream.is(), "No base implementation!\n" ); OSL_ENSURE( m_pImpl->m_rMutexRef.Is(), "No mutex!\n" ); if ( !m_pImpl || !m_pImpl->m_rMutexRef.Is() ) throw uno::RuntimeException(); // just a disaster m_pData = new WSInternalData_Impl( pImpl->m_rMutexRef ); if ( xStream.is() ) { m_xInStream = xStream->getInputStream(); m_xOutStream = xStream->getOutputStream(); m_xSeekable = uno::Reference< io::XSeekable >( xStream, uno::UNO_QUERY ); OSL_ENSURE( m_xInStream.is() && m_xOutStream.is() && m_xSeekable.is(), "Stream implementation is incomplete!\n" ); } } //----------------------------------------------- OWriteStream::~OWriteStream() { { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( m_pImpl ) { m_refCount++; try { dispose(); } catch( uno::RuntimeException& ) {} } } if ( m_pData ) delete m_pData; } void OWriteStream::CopyToStreamInternally_Impl( const uno::Reference< io::XStream >& xDest ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_xInStream.is() ) throw uno::RuntimeException(); if ( !m_xSeekable.is() ) throw uno::RuntimeException(); uno::Reference< beans::XPropertySet > xDestProps( xDest, uno::UNO_QUERY ); if ( !xDestProps.is() ) throw uno::RuntimeException(); //TODO uno::Reference< io::XOutputStream > xDestOutStream = xDest->getOutputStream(); if ( !xDestOutStream.is() ) throw io::IOException(); // TODO sal_Int64 nCurPos = m_xSeekable->getPosition(); m_xSeekable->seek( 0 ); uno::Exception eThrown; sal_Bool bThrown = sal_False; try { copyInputToOutput_Impl( m_xInStream, xDestOutStream ); } catch ( uno::Exception& e ) { eThrown = e; bThrown = sal_True; } // position-related section below is critical // if it fails the stream will become invalid try { m_xSeekable->seek( nCurPos ); } catch ( uno::Exception& ) { // TODO: set the stoream in invalid state or dispose OSL_ENSURE( sal_False, "The stream become invalid during copiing!\n" ); throw uno::RuntimeException(); } if ( bThrown ) throw eThrown; // now the properties can be copied const char* pStrings[3] = { "MediaType", "Compressed", "UseCommonStoragePasswordEncryption" }; for ( int ind = 0; ind < 3; ind++ ) { ::rtl::OUString aPropName = ::rtl::OUString::createFromAscii( pStrings[ind] ); xDestProps->setPropertyValue( aPropName, getPropertyValue( aPropName ) ); } } //----------------------------------------------- sal_Int32 SAL_CALL OWriteStream::readBytes( uno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xInStream.is() ) throw io::NotConnectedException(); return m_xInStream->readBytes( aData, nBytesToRead ); } //----------------------------------------------- sal_Int32 SAL_CALL OWriteStream::readSomeBytes( uno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xInStream.is() ) throw io::NotConnectedException(); return m_xInStream->readSomeBytes( aData, nMaxBytesToRead ); } //----------------------------------------------- void SAL_CALL OWriteStream::skipBytes( sal_Int32 nBytesToSkip ) throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xInStream.is() ) throw io::NotConnectedException(); m_xInStream->skipBytes( nBytesToSkip ); } //----------------------------------------------- sal_Int32 SAL_CALL OWriteStream::available( ) throw ( io::NotConnectedException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xInStream.is() ) throw io::NotConnectedException(); return m_xInStream->available(); } //----------------------------------------------- void SAL_CALL OWriteStream::closeInput( ) throw ( io::NotConnectedException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( m_bInStreamDisconnected || !m_xInStream.is() ) throw io::NotConnectedException(); // the input part of the stream stays open for internal purposes ( to allow reading during copiing ) // since it can not be reopened until output part is closed, it will be closed with output part. m_bInStreamDisconnected = sal_True; // m_xInStream->closeInput(); // m_xInStream = uno::Reference< io::XInputStream >(); if ( !m_xOutStream.is() ) dispose(); } //----------------------------------------------- uno::Reference< io::XInputStream > SAL_CALL OWriteStream::getInputStream() throw ( uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( m_bInStreamDisconnected || !m_xInStream.is() ) return uno::Reference< io::XInputStream >(); return uno::Reference< io::XInputStream >( static_cast< io::XInputStream* >( this ), uno::UNO_QUERY ); } //----------------------------------------------- uno::Reference< io::XOutputStream > SAL_CALL OWriteStream::getOutputStream() throw ( uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xOutStream.is() ) return uno::Reference< io::XOutputStream >(); return uno::Reference< io::XOutputStream >( static_cast< io::XOutputStream* >( this ), uno::UNO_QUERY ); } //----------------------------------------------- void SAL_CALL OWriteStream::writeBytes( const uno::Sequence< sal_Int8 >& aData ) throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xOutStream.is() ) throw io::NotConnectedException(); m_xOutStream->writeBytes( aData ); m_pImpl->m_bHasDataToFlush = sal_True; if ( m_pImpl->m_pParent ) m_pImpl->m_pParent->SetModifiedInternally( sal_True ); } //----------------------------------------------- void SAL_CALL OWriteStream::flush() throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException ) { // In case stream is flushed it's current version becomes visible // to the parent storage. Usually parent storage flushes the stream // during own commit but a user can explicitly flush the stream // so the changes will be available through cloning functionality. ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xOutStream.is() ) throw io::NotConnectedException(); m_xOutStream->flush(); m_pImpl->Commit(); } //----------------------------------------------- void OWriteStream::CloseOutput_Impl() { // all the checks must be done in calling method m_xOutStream->closeOutput(); m_xOutStream = uno::Reference< io::XOutputStream >(); // after the stream is disposed it can be commited // so transport correct size property if ( !m_xSeekable.is() ) throw uno::RuntimeException(); for ( sal_Int32 nInd = 0; nInd < m_pImpl->m_aProps.getLength(); nInd++ ) { if ( m_pImpl->m_aProps[nInd].Name.equalsAscii( "Size" ) ) m_pImpl->m_aProps[nInd].Value <<= ((sal_Int32)m_xSeekable->getLength()); } } //----------------------------------------------- void SAL_CALL OWriteStream::closeOutput() throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xOutStream.is() ) throw io::NotConnectedException(); CloseOutput_Impl(); if ( m_bInStreamDisconnected || !m_xInStream.is() ) dispose(); } //----------------------------------------------- void SAL_CALL OWriteStream::seek( sal_Int64 location ) throw ( lang::IllegalArgumentException, io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xSeekable.is() ) throw uno::RuntimeException(); m_xSeekable->seek( location ); } //----------------------------------------------- sal_Int64 SAL_CALL OWriteStream::getPosition() throw ( io::IOException, uno::RuntimeException) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xSeekable.is() ) throw uno::RuntimeException(); return m_xSeekable->getPosition(); } //----------------------------------------------- sal_Int64 SAL_CALL OWriteStream::getLength() throw ( io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xSeekable.is() ) throw uno::RuntimeException(); return m_xSeekable->getLength(); } //----------------------------------------------- void SAL_CALL OWriteStream::truncate() throw ( io::IOException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( !m_xOutStream.is() ) throw uno::RuntimeException(); uno::Reference< io::XTruncate > xTruncate( m_xOutStream, uno::UNO_QUERY ); if ( !xTruncate.is() ) { OSL_ENSURE( sal_False, "The output stream must support XTruncate interface!\n" ); throw uno::RuntimeException(); } xTruncate->truncate(); m_pImpl->m_bHasDataToFlush = sal_True; if ( m_pImpl->m_pParent ) m_pImpl->m_pParent->SetModifiedInternally( sal_True ); } //----------------------------------------------- void SAL_CALL OWriteStream::dispose() throw ( uno::RuntimeException ) { // should be an internal method since it can be called only from parent storage ::osl::MutexGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); if ( m_xOutStream.is() ) CloseOutput_Impl(); if ( m_xInStream.is() ) { m_xInStream->closeInput(); m_xInStream = uno::Reference< io::XInputStream >(); } lang::EventObject aSource( static_cast< ::cppu::OWeakObject* >(this) ); m_pData->m_aListenersContainer.disposeAndClear( aSource ); m_pImpl->m_pAntiImpl = NULL; m_pImpl->Commit(); m_pImpl = NULL; } //----------------------------------------------- void SAL_CALL OWriteStream::addEventListener( const uno::Reference< lang::XEventListener >& xListener ) throw ( uno::RuntimeException ) { ::osl::MutexGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); m_pData->m_aListenersContainer.addInterface( xListener ); } //----------------------------------------------- void SAL_CALL OWriteStream::removeEventListener( const uno::Reference< lang::XEventListener >& xListener ) throw ( uno::RuntimeException ) { ::osl::MutexGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); m_pData->m_aListenersContainer.removeInterface( xListener ); } //----------------------------------------------- void SAL_CALL OWriteStream::setEncryptionPassword( const ::rtl::OUString& aPass ) throw ( uno::RuntimeException, io::IOException ) { ::osl::MutexGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); OSL_ENSURE( m_pImpl->m_xPackageStream.is(), "No package stream is set!\n" ); m_pImpl->SetEncryptedWithPass( aPass ); } //----------------------------------------------- void SAL_CALL OWriteStream::removeEncryption() throw ( uno::RuntimeException, io::IOException ) { ::osl::MutexGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); OSL_ENSURE( m_pImpl->m_xPackageStream.is(), "No package stream is set!\n" ); m_pImpl->SetDecrypted(); } //----------------------------------------------- uno::Reference< beans::XPropertySetInfo > SAL_CALL OWriteStream::getPropertySetInfo() throw ( uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); //TODO: return uno::Reference< beans::XPropertySetInfo >(); } //----------------------------------------------- void SAL_CALL OWriteStream::setPropertyValue( const ::rtl::OUString& aPropertyName, const uno::Any& aValue ) throw ( beans::UnknownPropertyException, beans::PropertyVetoException, lang::IllegalArgumentException, lang::WrappedTargetException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); m_pImpl->GetStreamProperties(); if ( aPropertyName.equalsAscii( "MediaType" ) || aPropertyName.equalsAscii( "Compressed" ) ) { for ( sal_Int32 nInd = 0; nInd < m_pImpl->m_aProps.getLength(); nInd++ ) { if ( aPropertyName.equals( m_pImpl->m_aProps[nInd].Name ) ) m_pImpl->m_aProps[nInd].Value = aValue; } } else if ( aPropertyName.equalsAscii( "UseCommonStoragePasswordEncryption" ) ) { sal_Bool bUseCommonPass = sal_False; if ( aValue >>= bUseCommonPass ) { if ( bUseCommonPass ) { if ( !m_pImpl->m_bUseCommonPass ) { m_pImpl->SetDecrypted(); m_pImpl->m_bUseCommonPass = sal_True; } } else m_pImpl->m_bUseCommonPass = sal_False; } else throw lang::IllegalArgumentException(); //TODO } else if ( aPropertyName.equalsAscii( "IsEncrypted" ) || aPropertyName.equalsAscii( "Encrypted" ) || aPropertyName.equalsAscii( "Size" ) ) throw beans::PropertyVetoException(); // TODO else throw beans::UnknownPropertyException(); // TODO m_pImpl->m_bHasDataToFlush = sal_True; if ( m_pImpl->m_pParent ) m_pImpl->m_pParent->SetModifiedInternally( sal_True ); } //----------------------------------------------- uno::Any SAL_CALL OWriteStream::getPropertyValue( const ::rtl::OUString& aProp ) throw ( beans::UnknownPropertyException, lang::WrappedTargetException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); ::rtl::OUString aPropertyName; if ( aProp.equalsAscii( "IsEncrypted" ) ) aPropertyName = ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Encrypted" ) ); else aPropertyName = aProp; if ( aPropertyName.equalsAscii( "MediaType" ) || aPropertyName.equalsAscii( "Encrypted" ) || aPropertyName.equalsAscii( "Compressed" ) ) { m_pImpl->GetStreamProperties(); for ( sal_Int32 nInd = 0; nInd < m_pImpl->m_aProps.getLength(); nInd++ ) { if ( aPropertyName.equals( m_pImpl->m_aProps[nInd].Name ) ) return m_pImpl->m_aProps[nInd].Value; } } else if ( aPropertyName.equalsAscii( "UseCommonStoragePasswordEncryption" ) ) return uno::makeAny( m_pImpl->m_bUseCommonPass ); else if ( aPropertyName.equalsAscii( "Size" ) ) { if ( !m_xSeekable.is() ) throw uno::RuntimeException(); return uno::makeAny( (sal_Int32)m_xSeekable->getLength() ); } throw beans::UnknownPropertyException(); // TODO // not reachable return uno::Any(); } //----------------------------------------------- void SAL_CALL OWriteStream::addPropertyChangeListener( const ::rtl::OUString& aPropertyName, const uno::Reference< beans::XPropertyChangeListener >& xListener ) throw ( beans::UnknownPropertyException, lang::WrappedTargetException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); //TODO: } //----------------------------------------------- void SAL_CALL OWriteStream::removePropertyChangeListener( const ::rtl::OUString& aPropertyName, const uno::Reference< beans::XPropertyChangeListener >& aListener ) throw ( beans::UnknownPropertyException, lang::WrappedTargetException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); //TODO: } //----------------------------------------------- void SAL_CALL OWriteStream::addVetoableChangeListener( const ::rtl::OUString& PropertyName, const uno::Reference< beans::XVetoableChangeListener >& aListener ) throw ( beans::UnknownPropertyException, lang::WrappedTargetException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); //TODO: } //----------------------------------------------- void SAL_CALL OWriteStream::removeVetoableChangeListener( const ::rtl::OUString& PropertyName, const uno::Reference< beans::XVetoableChangeListener >& aListener ) throw ( beans::UnknownPropertyException, lang::WrappedTargetException, uno::RuntimeException ) { ::osl::MutexGuard aGuard( m_pData->m_rSharedMutexRef->GetMutex() ); if ( !m_pImpl ) throw lang::DisposedException(); //TODO: }