diff options
Diffstat (limited to 'fileaccess')
| -rw-r--r-- | fileaccess/prj/build.lst | 3 | ||||
| -rw-r--r-- | fileaccess/prj/d.lst | 5 | ||||
| -rw-r--r-- | fileaccess/source/FileAccess.cxx | 967 | ||||
| -rw-r--r-- | fileaccess/source/fileacc.xml | 62 | ||||
| -rw-r--r-- | fileaccess/source/makefile.mk | 68 |
5 files changed, 1105 insertions, 0 deletions
diff --git a/fileaccess/prj/build.lst b/fileaccess/prj/build.lst new file mode 100644 index 000000000000..a60a92e9c12b --- /dev/null +++ b/fileaccess/prj/build.lst @@ -0,0 +1,3 @@ +fa fileaccess : unotools rdbmaker tools ucbhelper NULL +fa fileaccess usr1 - all fa_mkout NULL +fa fileaccess\source nmake - all fa_src NULL diff --git a/fileaccess/prj/d.lst b/fileaccess/prj/d.lst new file mode 100644 index 000000000000..695487c56035 --- /dev/null +++ b/fileaccess/prj/d.lst @@ -0,0 +1,5 @@ +..\%__SRC%\bin\*.dll %_DEST%\bin%_EXT%\* +..\%__SRC%\bin\*.rdb %_DEST%\rdb%_EXT%\* +..\%__SRC%\lib\lib*.so %_DEST%\lib%_EXT% +..\%__SRC%\lib\*.dylib %_DEST%\lib%_EXT%\* +..\source\fileacc.xml %_DEST%\xml%_EXT%\fileacc.xml diff --git a/fileaccess/source/FileAccess.cxx b/fileaccess/source/FileAccess.cxx new file mode 100644 index 000000000000..a7b08778dbdd --- /dev/null +++ b/fileaccess/source/FileAccess.cxx @@ -0,0 +1,967 @@ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org 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 version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ + +#include <osl/mutex.hxx> +#include <osl/diagnose.h> + +#include <uno/mapping.hxx> + +#include <cppuhelper/factory.hxx> +#include <cppuhelper/implbase1.hxx> + +#include <tools/ref.hxx> +#include <tools/urlobj.hxx> +#include <ucbhelper/content.hxx> +#include <unotools/streamwrap.hxx> +#include <tools/stream.hxx> + +#include <com/sun/star/beans/Property.hpp> +#include <com/sun/star/beans/XPropertySet.hpp> +#include <com/sun/star/container/XChild.hpp> +#include <com/sun/star/io/XActiveDataSink.hpp> +#include <com/sun/star/io/XActiveDataSource.hpp> +#include <com/sun/star/io/XActiveDataStreamer.hpp> +#include <com/sun/star/sdbc/XResultSet.hpp> +#include <com/sun/star/ucb/CommandFailedException.hpp> +#include <com/sun/star/ucb/ContentInfo.hpp> +#include <com/sun/star/ucb/ContentInfoAttribute.hpp> +#include <com/sun/star/ucb/InsertCommandArgument.hpp> +#include <com/sun/star/ucb/InteractiveIOException.hpp> +#include <com/sun/star/ucb/NameClash.hpp> +#include <com/sun/star/ucb/NameClashException.hpp> +#include <com/sun/star/ucb/OpenCommandArgument2.hpp> +#include <com/sun/star/ucb/OpenMode.hpp> +#include <com/sun/star/ucb/XCommandEnvironment.hpp> +#include <com/sun/star/ucb/XContent.hpp> +#include <com/sun/star/ucb/XContentAccess.hpp> +#include <com/sun/star/ucb/XSimpleFileAccess3.hpp> +#include <com/sun/star/util/XMacroExpander.hpp> + +#define IMPLEMENTATION_NAME "com.sun.star.comp.ucb.SimpleFileAccess" +#define SERVICE_NAME "com.sun.star.ucb.SimpleFileAccess" + +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::ucb; +using namespace ::com::sun::star::sdbc; +using namespace ::com::sun::star::task; +using namespace ::com::sun::star::util; +using namespace ::com::sun::star::beans; +using namespace ::com::sun::star::registry; +using namespace ::com::sun::star::container; + +namespace io_FileAccess +{ + + +//=========================================================================== +// Implementation XSimpleFileAccess + +typedef cppu::WeakImplHelper1< XSimpleFileAccess3 > FileAccessHelper; +class OCommandEnvironment; + +class OFileAccess : public FileAccessHelper +{ + Reference< XMultiServiceFactory > mxSMgr; + Reference< XCommandEnvironment > mxEnvironment; + OCommandEnvironment* mpEnvironment; + + void transferImpl( const rtl::OUString& rSource, const rtl::OUString& rDest, sal_Bool bMoveData ) + throw(CommandAbortedException, Exception, RuntimeException); + bool createNewFile( const rtl::OUString & rParentURL, + const rtl::OUString & rTitle, + const Reference< XInputStream >& data ) + throw ( Exception ); + +public: + OFileAccess( const Reference< XMultiServiceFactory > & xSMgr ) + : mxSMgr( xSMgr), mpEnvironment( NULL ) {} + + // Methods + virtual void SAL_CALL copy( const ::rtl::OUString& SourceURL, const ::rtl::OUString& DestURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL move( const ::rtl::OUString& SourceURL, const ::rtl::OUString& DestURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL kill( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual sal_Bool SAL_CALL isFolder( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual sal_Bool SAL_CALL isReadOnly( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL setReadOnly( const ::rtl::OUString& FileURL, sal_Bool bReadOnly ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL createFolder( const ::rtl::OUString& NewFolderURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual sal_Int32 SAL_CALL getSize( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual ::rtl::OUString SAL_CALL getContentType( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::util::DateTime SAL_CALL getDateTimeModified( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Sequence< ::rtl::OUString > SAL_CALL getFolderContents( const ::rtl::OUString& FolderURL, sal_Bool bIncludeFolders ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual sal_Bool SAL_CALL exists( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream > SAL_CALL openFileRead( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XOutputStream > SAL_CALL openFileWrite( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XStream > SAL_CALL openFileReadWrite( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL setInteractionHandler( const ::com::sun::star::uno::Reference< ::com::sun::star::task::XInteractionHandler >& Handler ) throw(::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL writeFile( const ::rtl::OUString& FileURL, const ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream >& data ) throw (::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual sal_Bool SAL_CALL isHidden( const ::rtl::OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL setHidden( const ::rtl::OUString& FileURL, sal_Bool bHidden ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException); +}; + + +//=========================================================================== +// Implementation XActiveDataSink + +typedef cppu::WeakImplHelper1< XActiveDataSink > ActiveDataSinkHelper; + +class OActiveDataSink : public ActiveDataSinkHelper +{ + Reference< XInputStream > mxStream; + +public: + + // Methods + virtual void SAL_CALL setInputStream( const Reference< XInputStream >& aStream ) + throw(RuntimeException); + virtual Reference< XInputStream > SAL_CALL getInputStream( ) + throw(RuntimeException); +}; + +void OActiveDataSink::setInputStream( const Reference< XInputStream >& aStream ) + throw(RuntimeException) +{ + mxStream = aStream; +} + +Reference< XInputStream > OActiveDataSink::getInputStream() + throw(RuntimeException) +{ + return mxStream; +} + + +//=========================================================================== +// Implementation XActiveDataSource + +typedef cppu::WeakImplHelper1< XActiveDataSource > ActiveDataSourceHelper; + +class OActiveDataSource : public ActiveDataSourceHelper +{ + Reference< XOutputStream > mxStream; + +public: + + // Methods + virtual void SAL_CALL setOutputStream( const Reference< XOutputStream >& aStream ) + throw(RuntimeException); + virtual Reference< XOutputStream > SAL_CALL getOutputStream() + throw(RuntimeException); +}; + +void OActiveDataSource::setOutputStream( const Reference< XOutputStream >& aStream ) + throw(RuntimeException) +{ + mxStream = aStream; +} + +Reference< XOutputStream > OActiveDataSource::getOutputStream() + throw(RuntimeException) +{ + return mxStream; +} + + +//=========================================================================== +// Implementation XActiveDataStreamer + +typedef cppu::WeakImplHelper1< XActiveDataStreamer > ActiveDataStreamerHelper; + +class OActiveDataStreamer : public ActiveDataStreamerHelper +{ + Reference< XStream > mxStream; + +public: + + // Methods + virtual void SAL_CALL setStream( const Reference< XStream >& aStream ) + throw(RuntimeException); + virtual Reference< XStream > SAL_CALL getStream() + throw(RuntimeException); +}; + +void OActiveDataStreamer::setStream( const Reference< XStream >& aStream ) + throw(RuntimeException) +{ + mxStream = aStream; +} + +Reference< XStream > OActiveDataStreamer::getStream() + throw(RuntimeException) +{ + return mxStream; +} + + + +//=========================================================================== +// Implementation XCommandEnvironment + +typedef cppu::WeakImplHelper1< XCommandEnvironment > CommandEnvironmentHelper; + +class OCommandEnvironment : public CommandEnvironmentHelper +{ + Reference< XInteractionHandler > mxInteraction; + +public: + void setHandler( Reference< XInteractionHandler > xInteraction_ ) + { + mxInteraction = xInteraction_; + } + + // Methods + virtual Reference< XInteractionHandler > SAL_CALL getInteractionHandler() + throw(RuntimeException); + virtual Reference< XProgressHandler > SAL_CALL getProgressHandler() + throw(RuntimeException); +}; + +Reference< XInteractionHandler > OCommandEnvironment::getInteractionHandler() + throw(RuntimeException) +{ + return mxInteraction; +} + +Reference< XProgressHandler > OCommandEnvironment::getProgressHandler() + throw(RuntimeException) +{ + Reference< XProgressHandler > xRet; + return xRet; +} + +//=========================================================================== + +void OFileAccess::transferImpl( const rtl::OUString& rSource, + const rtl::OUString& rDest, + sal_Bool bMoveData ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + // SfxContentHelper::Transfer_Impl + INetURLObject aSourceObj( rSource, INET_PROT_FILE ); + INetURLObject aDestObj( rDest, INET_PROT_FILE ); + String aName = aDestObj.getName( + INetURLObject::LAST_SEGMENT, true, INetURLObject::DECODE_WITH_CHARSET ); + String aDestURL; + String aSourceURL = aSourceObj.GetMainURL( INetURLObject::NO_DECODE ); + if ( aDestObj.removeSegment() ) + { + // hierarchical URL. + + aDestObj.setFinalSlash(); + aDestURL = aDestObj.GetMainURL( INetURLObject::NO_DECODE ); + } + else + { + // non-hierachical URL + + // #i29648# + // +#if 0 + // Note: A hierachical UCB content implements interface XChild, which + // has a method getParent(). Unfortunately this does not always help + // here, because it is not guaranteed that a content object for a + // non-existing resource can be created. Thus, it will happen that an + // exception is thrown when trying to create a UCB content for the + // destination URL. + + try + { + ucbhelper::Content aFullDest( + aDestObj.GetMainURL( + INetURLObject::NO_DECODE ), mxEnvironment ); + + Reference< XChild > xChild( aFullDest.get(), UNO_QUERY_THROW ); + Reference< com::sun::star::ucb::XContent > + xParent( xChild->getParent(), UNO_QUERY_THROW ); + ucbhelper::Content aParent( xParent, mxEnvironment ); + + aDestURL = aParent.getURL(); + + rtl::OUString aNameTmp; + aFullDest.getPropertyValue( + rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Title" ) ) ) + >>= aNameTmp; + aName = aNameTmp; + } + catch ( Exception const & ) + { + throw RuntimeException( + rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( + "OFileAccess::transferrImpl - Unable to " + "obtain destination folder URL!" ) ), + static_cast< cppu::OWeakObject * >( this ) ); + } +#else + if ( aDestObj.GetProtocol() == INET_PROT_VND_SUN_STAR_EXPAND ) + { + // Hack: Expand destination URL using Macro Expander and try again + // with the hopefully hierarchical expanded URL... + + try + { + Reference< XComponentContext > xCtx; + Reference< XPropertySet > xPropSet( mxSMgr, UNO_QUERY_THROW ); + if ( xPropSet.is() ) + { + xPropSet->getPropertyValue( + rtl::OUString( + RTL_CONSTASCII_USTRINGPARAM( "DefaultContext" ) ) ) + >>= xCtx; + } + + Reference< XMacroExpander > xExpander; + + xCtx->getValueByName( + rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( + "/singletons/com.sun.star.util.theMacroExpander" ) ) ) + >>= xExpander; + + OSL_ENSURE( xExpander.is(), + "Unable to obtain macro expander singleton!" ); + + aDestURL = xExpander->expandMacros( + aDestObj.GetURLPath( INetURLObject::DECODE_WITH_CHARSET ) ); + } + catch ( Exception const & ) + { + throw RuntimeException( + rtl::OUString( + RTL_CONSTASCII_USTRINGPARAM( + "OFileAccess::transferrImpl - Unable to obtain " + "destination folder URL!" ) ), + static_cast< cppu::OWeakObject * >( this ) ); + } + + transferImpl( rSource, aDestURL, bMoveData ); + return; + } + + throw RuntimeException( + rtl::OUString( + RTL_CONSTASCII_USTRINGPARAM( + "OFileAccess::transferrImpl - Unable to obtain " + "destination folder URL!" ) ), + static_cast< cppu::OWeakObject * >( this ) ); +#endif + } + + ucbhelper::Content aDestPath( aDestURL, mxEnvironment ); + ucbhelper::Content aSrc ( aSourceURL, mxEnvironment ); + + try + { + aDestPath.transferContent( aSrc, + bMoveData + ? ucbhelper::InsertOperation_MOVE + : ucbhelper::InsertOperation_COPY, + aName, + ::com::sun::star::ucb::NameClash::OVERWRITE ); + } + catch ( ::com::sun::star::ucb::CommandFailedException const & ) + { + // Interaction Handler already handled the error that has occured... + } +} + +void OFileAccess::copy( const rtl::OUString& SourceURL, const rtl::OUString& DestURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + transferImpl( SourceURL, DestURL, sal_False ); +} + +void OFileAccess::move( const rtl::OUString& SourceURL, const rtl::OUString& DestURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + transferImpl( SourceURL, DestURL, sal_True ); +} + +void OFileAccess::kill( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + // SfxContentHelper::Kill + INetURLObject aDeleteObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aDeleteObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + try + { + aCnt.executeCommand( rtl::OUString::createFromAscii( "delete" ), makeAny( sal_Bool( sal_True ) ) ); + } + catch ( ::com::sun::star::ucb::CommandFailedException const & ) + { + // Interaction Handler already handled the error that has occured... + } +} + +sal_Bool OFileAccess::isFolder( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + sal_Bool bRet = sal_False; + try + { + INetURLObject aURLObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + bRet = aCnt.isFolder(); + } + catch (Exception &) {} + return bRet; +} + +sal_Bool OFileAccess::isReadOnly( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + INetURLObject aURLObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + Any aRetAny = aCnt.getPropertyValue( rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "IsReadOnly" ) ) ); + sal_Bool bRet = sal_False; + aRetAny >>= bRet; + return bRet; +} + +void OFileAccess::setReadOnly( const rtl::OUString& FileURL, sal_Bool bReadOnly ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + INetURLObject aURLObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + Any aAny; + aAny <<= bReadOnly; + aCnt.setPropertyValue( rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "IsReadOnly" ) ), aAny ); +} + +void OFileAccess::createFolder( const rtl::OUString& NewFolderURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + // Does the folder already exist? + if( !NewFolderURL.getLength() || isFolder( NewFolderURL ) ) + return; + + // SfxContentHelper::MakeFolder + INetURLObject aURL( NewFolderURL, INET_PROT_FILE ); + String aNewFolderURLStr = aURL.GetMainURL( INetURLObject::NO_DECODE ); + String aTitle = aURL.getName( INetURLObject::LAST_SEGMENT, true, INetURLObject::DECODE_WITH_CHARSET ); + if ( aTitle.Len() ) + { + aURL.removeSegment(); + + // Does the base folder exist? Otherwise create it first + String aBaseFolderURLStr = aURL.GetMainURL( INetURLObject::NO_DECODE ); + if( !isFolder( aBaseFolderURLStr ) ) + { + createFolder( aBaseFolderURLStr ); + } + } + + ucbhelper::Content aCnt( aURL.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + + Sequence< ContentInfo > aInfo = aCnt.queryCreatableContentsInfo(); + sal_Int32 nCount = aInfo.getLength(); + if ( nCount == 0 ) + return; + + for ( sal_Int32 i = 0; i < nCount; ++i ) + { + // Simply look for the first KIND_FOLDER... + const ContentInfo & rCurr = aInfo[i]; + if ( rCurr.Attributes & ContentInfoAttribute::KIND_FOLDER ) + { + // Make sure the only required bootstrap property is "Title", + const Sequence< Property > & rProps = rCurr.Properties; + if ( rProps.getLength() != 1 ) + continue; + + if ( !rProps[ 0 ].Name.equalsAsciiL( + RTL_CONSTASCII_STRINGPARAM( "Title" ) ) ) + continue; + + Sequence<rtl::OUString> aNames(1); + rtl::OUString* pNames = aNames.getArray(); + pNames[0] = rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "Title" ) ); + Sequence< Any > aValues(1); + Any* pValues = aValues.getArray(); + pValues[0] = makeAny( rtl::OUString( aTitle ) ); + + ucbhelper::Content aNew; + try + { + if ( !aCnt.insertNewContent( rCurr.Type, aNames, aValues, aNew ) ) + continue; + + // Success. We're done. + return; + } + catch ( ::com::sun::star::ucb::CommandFailedException const & ) + { + // Interaction Handler already handled the error that has occured... + continue; + } + } + } +} + +sal_Int32 OFileAccess::getSize( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + // SfxContentHelper::GetSize + sal_Int32 nSize = 0; + sal_Int64 nTemp = 0; + INetURLObject aObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + aCnt.getPropertyValue( rtl::OUString::createFromAscii( "Size" ) ) >>= nTemp; + nSize = (sal_Int32)nTemp; + return nSize; +} + +rtl::OUString OFileAccess::getContentType( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + INetURLObject aObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + + Reference< XContent > xContent = aCnt.get(); + rtl::OUString aTypeStr = xContent->getContentType(); + return aTypeStr; +} + +DateTime OFileAccess::getDateTimeModified( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + INetURLObject aFileObj( FileURL, INET_PROT_FILE ); + DateTime aDateTime; + + Reference< XCommandEnvironment > aCmdEnv; + ucbhelper::Content aYoung( aFileObj.GetMainURL( INetURLObject::NO_DECODE ), aCmdEnv ); + aYoung.getPropertyValue( rtl::OUString::createFromAscii( "DateModified" ) ) >>= aDateTime; + return aDateTime; +} + + +DECLARE_LIST( StringList_Impl, rtl::OUString* ) + +Sequence< rtl::OUString > OFileAccess::getFolderContents( const rtl::OUString& FolderURL, sal_Bool bIncludeFolders ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + // SfxContentHelper::GetFolderContents + + StringList_Impl* pFiles = NULL; + INetURLObject aFolderObj( FolderURL, INET_PROT_FILE ); + + ucbhelper::Content aCnt( aFolderObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + Reference< XResultSet > xResultSet; + Sequence< rtl::OUString > aProps(0); + //Sequence< rtl::OUString > aProps(1); + //rtl::OUString* pProps = aProps.getArray(); + //pProps[0] == rtl::OUString::createFromAscii( "Url" ); + + ucbhelper::ResultSetInclude eInclude = bIncludeFolders ? ucbhelper::INCLUDE_FOLDERS_AND_DOCUMENTS : ucbhelper::INCLUDE_DOCUMENTS_ONLY; + + try + { + xResultSet = aCnt.createCursor( aProps, eInclude ); + } + catch ( ::com::sun::star::ucb::CommandFailedException const & ) + { + // Interaction Handler already handled the error that has occured... + } + + if ( xResultSet.is() ) + { + pFiles = new StringList_Impl; + Reference< com::sun::star::ucb::XContentAccess > xContentAccess( xResultSet, UNO_QUERY ); + + while ( xResultSet->next() ) + { + rtl::OUString aId = xContentAccess->queryContentIdentifierString(); + INetURLObject aURL( aId, INET_PROT_FILE ); + rtl::OUString* pFile = new rtl::OUString( aURL.GetMainURL( INetURLObject::NO_DECODE ) ); + pFiles->Insert( pFile, LIST_APPEND ); + } + } + + if ( pFiles ) + { + ULONG nCount = pFiles->Count(); + Sequence < rtl::OUString > aRet( nCount ); + rtl::OUString* pRet = aRet.getArray(); + for ( USHORT i = 0; i < nCount; ++i ) + { + rtl::OUString* pFile = pFiles->GetObject(i); + pRet[i] = *( pFile ); + delete pFile; + } + delete pFiles; + return aRet; + } + else + return Sequence < rtl::OUString > (); +} + +sal_Bool OFileAccess::exists( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + sal_Bool bRet = sal_False; + try + { + bRet = isFolder( FileURL ); + if( !bRet ) + { + Reference< XInputStream > xStream = openFileRead( FileURL ); + bRet = xStream.is(); + if( bRet ) + xStream->closeInput(); + } + } + catch (Exception &) {} + return bRet; +} + +Reference< XInputStream > OFileAccess::openFileRead( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + Reference< XInputStream > xRet; + INetURLObject aObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + + Reference< XActiveDataSink > xSink = (XActiveDataSink*)(new OActiveDataSink()); + + try + { + sal_Bool bRet = aCnt.openStream( xSink ); + if( bRet ) + xRet = xSink->getInputStream(); + } + catch ( ::com::sun::star::ucb::CommandFailedException const & ) + { + // Interaction Handler already handled the error that has occured... + } + + return xRet; +} + +Reference< XOutputStream > OFileAccess::openFileWrite( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + Reference< XOutputStream > xRet; + Reference< XStream > xStream = OFileAccess::openFileReadWrite( FileURL ); + if( xStream.is() ) + xRet = xStream->getOutputStream(); + return xRet; +} + +Reference< XStream > OFileAccess::openFileReadWrite( const rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + Reference< XActiveDataStreamer > xSink = (XActiveDataStreamer*)new OActiveDataStreamer(); + Reference< XInterface > xSinkIface = Reference< XInterface >::query( xSink ); + + OpenCommandArgument2 aArg; + aArg.Mode = OpenMode::DOCUMENT; + aArg.Priority = 0; // unused + aArg.Sink = xSink; + aArg.Properties = Sequence< Property >( 0 ); // unused + + Any aCmdArg; + aCmdArg <<= aArg; + + INetURLObject aFileObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aFileObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + + // Be silent... + Reference< XInteractionHandler > xIH; + if ( mpEnvironment ) + { + xIH = mpEnvironment->getInteractionHandler(); + mpEnvironment->setHandler( 0 ); + } + + try + { + aCnt.executeCommand( rtl::OUString::createFromAscii( "open" ), aCmdArg ); + } + catch ( InteractiveIOException const & e ) + { + if ( xIH.is() ) + mpEnvironment->setHandler( xIH ); + + if ( e.Code == IOErrorCode_NOT_EXISTING ) + { + // Create file... + SvMemoryStream aStream(0,0); + ::utl::OInputStreamWrapper* pInput = new ::utl::OInputStreamWrapper( aStream ); + Reference< XInputStream > xInput( pInput ); + InsertCommandArgument aInsertArg; + aInsertArg.Data = xInput; + aInsertArg.ReplaceExisting = sal_False; + + aCmdArg <<= aInsertArg; + aCnt.executeCommand( rtl::OUString::createFromAscii( "insert" ), aCmdArg ); + + // Retry... + return openFileReadWrite( FileURL ); + } + + throw; + } + + if ( xIH.is() ) + mpEnvironment->setHandler( xIH ); + + Reference< XStream > xRet = xSink->getStream(); + return xRet; +} + +void OFileAccess::setInteractionHandler( const Reference< XInteractionHandler >& Handler ) + throw(RuntimeException) +{ + if( !mpEnvironment ) + { + mpEnvironment = new OCommandEnvironment(); + mxEnvironment = (XCommandEnvironment*)mpEnvironment; + } + mpEnvironment->setHandler( Handler ); +} + +bool OFileAccess::createNewFile( const rtl::OUString & rParentURL, + const rtl::OUString & rTitle, + const Reference< XInputStream >& data ) + throw ( Exception ) +{ + ucbhelper::Content aParentCnt( rParentURL, mxEnvironment ); + + Sequence< ContentInfo > aInfo = aParentCnt.queryCreatableContentsInfo(); + sal_Int32 nCount = aInfo.getLength(); + if ( nCount == 0 ) + return false; + + for ( sal_Int32 i = 0; i < nCount; ++i ) + { + const ContentInfo & rCurr = aInfo[i]; + if ( ( rCurr.Attributes + & ContentInfoAttribute::KIND_DOCUMENT ) && + ( rCurr.Attributes + & ContentInfoAttribute::INSERT_WITH_INPUTSTREAM ) ) + { + // Make sure the only required bootstrap property is + // "Title", + const Sequence< Property > & rProps = rCurr.Properties; + if ( rProps.getLength() != 1 ) + continue; + + if ( !rProps[ 0 ].Name.equalsAsciiL( + RTL_CONSTASCII_STRINGPARAM( "Title" ) ) ) + continue; + + Sequence<rtl::OUString> aNames(1); + rtl::OUString* pNames = aNames.getArray(); + pNames[0] = rtl::OUString( + RTL_CONSTASCII_USTRINGPARAM( "Title" ) ); + Sequence< Any > aValues(1); + Any* pValues = aValues.getArray(); + pValues[0] = makeAny( rtl::OUString( rTitle ) ); + + try + { + ucbhelper::Content aNew; + if ( aParentCnt.insertNewContent( + rCurr.Type, aNames, aValues, data, aNew ) ) + return true; // success. + else + continue; + } + catch ( CommandFailedException const & ) + { + // Interaction Handler already handled the + // error that has occured... + continue; + } + } + } + + return false; +} + +void SAL_CALL OFileAccess::writeFile( const rtl::OUString& FileURL, + const Reference< XInputStream >& data ) + throw ( Exception, RuntimeException ) +{ + INetURLObject aURL( FileURL, INET_PROT_FILE ); + try + { + ucbhelper::Content aCnt( + aURL.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + + try + { + aCnt.writeStream( data, sal_True /* bReplaceExisting */ ); + } + catch ( CommandFailedException const & ) + { + // Interaction Handler already handled the error that has occured... + } + } + catch ( ContentCreationException const & e ) + { + // Most probably file does not exist. Try to create. + if ( e.eError == ContentCreationError_CONTENT_CREATION_FAILED ) + { + INetURLObject aParentURLObj( aURL ); + if ( aParentURLObj.removeSegment() ) + { + String aParentURL + = aParentURLObj.GetMainURL( INetURLObject::NO_DECODE ); + + // ensure all parent folders exist. + createFolder( aParentURL ); + + // create the new file... + String aTitle + = aURL.getName( INetURLObject::LAST_SEGMENT, + true, + INetURLObject::DECODE_WITH_CHARSET ); + if ( createNewFile( aParentURL, aTitle, data ) ) + { + // success + return; + } + } + } + + throw; + } +} + +sal_Bool OFileAccess::isHidden( const ::rtl::OUString& FileURL ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + INetURLObject aURLObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + Any aRetAny = aCnt.getPropertyValue( rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "IsHidden" ) ) ); + sal_Bool bRet = sal_False; + aRetAny >>= bRet; + return bRet; +} + +void OFileAccess::setHidden( const ::rtl::OUString& FileURL, sal_Bool bHidden ) + throw(CommandAbortedException, Exception, RuntimeException) +{ + INetURLObject aURLObj( FileURL, INET_PROT_FILE ); + ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment ); + Any aAny; + aAny <<= bHidden; + aCnt.setPropertyValue( rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "IsHidden" ) ), aAny ); +} + +//================================================================================================== +//================================================================================================== +//================================================================================================== + +Reference< XInterface > SAL_CALL FileAccess_CreateInstance( const Reference< XMultiServiceFactory > & xSMgr ) +{ + return Reference < XInterface >( ( cppu::OWeakObject * ) new OFileAccess( xSMgr ) ); +} + + +Sequence< rtl::OUString > FileAccess_getSupportedServiceNames() +{ + static Sequence < rtl::OUString > *pNames = 0; + if( ! pNames ) + { + osl::MutexGuard guard( osl::Mutex::getGlobalMutex() ); + if( !pNames ) + { + static Sequence< rtl::OUString > seqNames(1); + seqNames.getArray()[0] = rtl::OUString::createFromAscii( SERVICE_NAME ); + pNames = &seqNames; + } + } + return *pNames; +} + + +} + +//================================================================================================== +// Component exports + +extern "C" +{ +//================================================================================================== +void SAL_CALL component_getImplementationEnvironment( + const sal_Char ** ppEnvTypeName, uno_Environment ** /*ppEnv*/ ) +{ + *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME; +} +//================================================================================================== +sal_Bool SAL_CALL component_writeInfo( + void * /*pServiceManager*/, void * pRegistryKey ) +{ + if (pRegistryKey) + { + try + { + Reference< XRegistryKey > xNewKey( + reinterpret_cast< XRegistryKey * >( pRegistryKey )->createKey( + rtl::OUString::createFromAscii("/" IMPLEMENTATION_NAME "/UNO/SERVICES" ) ) ); + + const Sequence< rtl::OUString > & rSNL = io_FileAccess::FileAccess_getSupportedServiceNames(); + const rtl::OUString * pArray = rSNL.getConstArray(); + for ( sal_Int32 nPos = rSNL.getLength(); nPos--; ) + xNewKey->createKey( pArray[nPos] ); + + return sal_True; + } + catch (InvalidRegistryException &) + { + OSL_ENSURE( sal_False, "### InvalidRegistryException!" ); + } + } + return sal_False; +} +//================================================================================================== +void * SAL_CALL component_getFactory( + const sal_Char * pImplName, void * pServiceManager, void * /*pRegistryKey*/ ) +{ + void * pRet = 0; + + if (pServiceManager && rtl_str_compare( pImplName, IMPLEMENTATION_NAME ) == 0) + { + Reference< XSingleServiceFactory > xFactory( cppu::createSingleFactory( + reinterpret_cast< XMultiServiceFactory * >( pServiceManager ), + rtl::OUString::createFromAscii( pImplName ), + io_FileAccess::FileAccess_CreateInstance, + io_FileAccess::FileAccess_getSupportedServiceNames() ) ); + + if (xFactory.is()) + { + xFactory->acquire(); + pRet = xFactory.get(); + } + } + + return pRet; +} +} + + diff --git a/fileaccess/source/fileacc.xml b/fileaccess/source/fileacc.xml new file mode 100644 index 000000000000..82f731f3e5d0 --- /dev/null +++ b/fileaccess/source/fileacc.xml @@ -0,0 +1,62 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE module-description PUBLIC "-//StarOffice//DTD ComponentDescription 1.0//EN" "module-description.dtd"> +<module-description xmlns:xlink="http://www.w3.org/1999/xlink"> + <module-name> + fileacc + </module-name> + + <component-description> + <author> + Andreas Bregas + </author> + <name> + com.sun.star.comp.ucb.SimpleFileAccess + </name> + <description> + This component provides a simple set of methods to access content that + is provided by the Universal Content Broker (i.e. file system contents). + </description> + <loader-name> + com.sun.star.loader.SharedLibrary + </loader-name> + <language> + c++ + </language> + <status value="final"/> + <supported-service> + com.sun.star.ucb.SimpleFileAccess + </supported-service> + + <type> com.sun.star.beans.Property </type> + <type> com.sun.star.io.XActiveDataSink </type> + <type> com.sun.star.io.XActiveDataSource </type> + <type> com.sun.star.io.XActiveDataStreamer </type> + <type> com.sun.star.sdbc.XResultSet </type> + <type> com.sun.star.ucb.CommandFailedException </type> + <type> com.sun.star.ucb.ContentInfo </type> + <type> com.sun.star.ucb.ContentInfoAttribute </type> + <type> com.sun.star.ucb.InsertCommandArgument </type> + <type> com.sun.star.ucb.InteractiveIOException </type> + <type> com.sun.star.ucb.NameClash </type> + <type> com.sun.star.ucb.OpenCommandArgument2 </type> + <type> com.sun.star.ucb.OpenMode </type> + <type> com.sun.star.ucb.XCommandEnvironment </type> + <type> com.sun.star.ucb.XContentAccess </type> + <type> com.sun.star.ucb.XContentCreator </type> + <type> com.sun.star.ucb.XSimpleFileAccess3 </type> + </component-description> + + <project-build-dependency> cppuhelper </project-build-dependency> + <project-build-dependency> ucbhelper </project-build-dependency> + <project-build-dependency> tools </project-build-dependency> + <project-build-dependency> cppu </project-build-dependency> + <project-build-dependency> vos </project-build-dependency> + <project-build-dependency> sal </project-build-dependency> + + <runtime-module-dependency> cppuhelper$(COM) </runtime-module-dependency> + <runtime-module-dependency> ucbhelper1MSC </runtime-module-dependency> + <runtime-module-dependency> cppu3 </runtime-module-dependency> + <runtime-module-dependency> vos2$(COM) </runtime-module-dependency> + <runtime-module-dependency> sal3 </runtime-module-dependency> + <runtime-module-dependency> tl </runtime-module-dependency> +</module-description> diff --git a/fileaccess/source/makefile.mk b/fileaccess/source/makefile.mk new file mode 100644 index 000000000000..2b7826534618 --- /dev/null +++ b/fileaccess/source/makefile.mk @@ -0,0 +1,68 @@ +#************************************************************************* +# +# DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. +# +# Copyright 2000, 2010 Oracle and/or its affiliates. +# +# OpenOffice.org - a multi-platform office productivity suite +# +# This file is part of OpenOffice.org. +# +# OpenOffice.org is free software: you can redistribute it and/or modify +# it under the terms of the GNU Lesser General Public License version 3 +# only, as published by the Free Software Foundation. +# +# OpenOffice.org 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 version 3 for more details +# (a copy is included in the LICENSE file that accompanied this code). +# +# You should have received a copy of the GNU Lesser General Public License +# version 3 along with OpenOffice.org. If not, see +# <http://www.openoffice.org/license.html> +# for a copy of the LGPLv3 License. +# +#************************************************************************* + +PRJ=.. + +PRJNAME=fileaccess +TARGET=fileacc +ENABLE_EXCEPTIONS=TRUE +NO_BSYMBOLIC=TRUE +COMP1TYPELIST=$(TARGET) +COMPRDB=$(SOLARBINDIR)$/types.rdb + +# --- Settings ----------------------------------------------------- +.INCLUDE : settings.mk +.IF "$(L10N_framework)"=="" +# ------------------------------------------------------------------ + +SLOFILES= \ + $(SLO)$/FileAccess.obj +# $(SLO)$/$(COMP1TYPELIST)_description.obj + +SHL1TARGET= $(TARGET) +SHL1IMPLIB= i$(TARGET) + +SHL1VERSIONMAP=$(SOLARENV)/src/component.map +SHL1DEF=$(MISC)$/$(SHL1TARGET).def +DEF1NAME=$(SHL1TARGET) + +SHL1STDLIBS= \ + $(UNOTOOLSLIB) \ + $(TOOLSLIB) \ + $(UCBHELPERLIB) \ + $(CPPUHELPERLIB) \ + $(CPPULIB) \ + $(SALLIB) + +SHL1DEPN= +SHL1LIBS=$(SLB)$/$(TARGET).lib + +# --- Targets ------------------------------------------------------ +.ENDIF # L10N_framework + +.INCLUDE : target.mk + |