ucb/source/core/FileAccess.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include <osl/mutex.hxx>
  21 #include <osl/diagnose.h>
  22
  23 #include <uno/mapping.hxx>
  24 #include <comphelper/processfactory.hxx>
  25 #include <cppuhelper/factory.hxx>
  26 #include <cppuhelper/implbase1.hxx>
  27
  28 #include <tools/urlobj.hxx>
  29 #include <ucbhelper/content.hxx>
  30 #include <unotools/streamwrap.hxx>
  31 #include <tools/stream.hxx>
  32
  33 #include <com/sun/star/beans/Property.hpp>
  34 #include <com/sun/star/container/XChild.hpp>
  35 #include <com/sun/star/io/XActiveDataSink.hpp>
  36 #include <com/sun/star/io/XActiveDataSource.hpp>
  37 #include <com/sun/star/io/XActiveDataStreamer.hpp>
  38 #include <com/sun/star/sdbc/XResultSet.hpp>
  39 #include <com/sun/star/ucb/CommandFailedException.hpp>
  40 #include <com/sun/star/ucb/ContentInfo.hpp>
  41 #include <com/sun/star/ucb/ContentInfoAttribute.hpp>
  42 #include <com/sun/star/ucb/InsertCommandArgument.hpp>
  43 #include <com/sun/star/ucb/InteractiveIOException.hpp>
  44 #include <com/sun/star/ucb/NameClash.hpp>
  45 #include <com/sun/star/ucb/NameClashException.hpp>
  46 #include <com/sun/star/ucb/OpenCommandArgument2.hpp>
  47 #include <com/sun/star/ucb/OpenMode.hpp>
  48 #include <com/sun/star/ucb/XCommandEnvironment.hpp>
  49 #include <com/sun/star/ucb/XContent.hpp>
  50 #include <com/sun/star/ucb/XContentAccess.hpp>
  51 #include <com/sun/star/ucb/XSimpleFileAccess3.hpp>
  52 #include <com/sun/star/util/theMacroExpander.hpp>
  53
  54 #include <vector>
  55
  56 #include "FileAccess.hxx"
  57
  58 #define SERVICE_NAME "com.sun.star.ucb.SimpleFileAccess"
  59
  60 using namespace ::com::sun::star::uno;
  61 using namespace ::com::sun::star::lang;
  62 using namespace ::com::sun::star::io;
  63 using namespace ::com::sun::star::ucb;
  64 using namespace ::com::sun::star::sdbc;
  65 using namespace ::com::sun::star::task;
  66 using namespace ::com::sun::star::util;
  67 using namespace ::com::sun::star::beans;
  68 using namespace ::com::sun::star::registry;
  69 using namespace ::com::sun::star::container;
  70
  71 using ::std::vector;
  72
  73 namespace
  74 {
  75
  76 // Implementation XSimpleFileAccess
  77 typedef cppu::WeakImplHelper1< XSimpleFileAccess3 > FileAccessHelper;
  78 class OCommandEnvironment;
  79
  80 class OFileAccess : public FileAccessHelper
  81 {
  82     Reference< XComponentContext > m_xContext;
  83     Reference< XCommandEnvironment > mxEnvironment;
  84     OCommandEnvironment* mpEnvironment;
  85
  86     void transferImpl( const OUString& rSource, const OUString& rDest, bool bMoveData )
  87         throw(CommandAbortedException, Exception, RuntimeException);
  88     bool createNewFile( const OUString & rParentURL,
  89                         const OUString & rTitle,
  90                         const Reference< XInputStream >& data )
  91         throw ( Exception );
  92
  93 public:
  94     OFileAccess( const Reference< XComponentContext > & xContext )
  95         : m_xContext( xContext), mpEnvironment( NULL ) {}
  96     // Methods
  97     virtual void SAL_CALL copy( const OUString& SourceURL, const OUString& DestURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
  98     virtual void SAL_CALL move( const OUString& SourceURL, const OUString& DestURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
  99     virtual void SAL_CALL kill( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 100     virtual sal_Bool SAL_CALL isFolder( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 101     virtual sal_Bool SAL_CALL isReadOnly( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 102     virtual void SAL_CALL setReadOnly( const OUString& FileURL, sal_Bool bReadOnly ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 103     virtual void SAL_CALL createFolder( const OUString& NewFolderURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 104     virtual sal_Int32 SAL_CALL getSize( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 105     virtual OUString SAL_CALL getContentType( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 106     virtual ::com::sun::star::util::DateTime SAL_CALL getDateTimeModified( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 107     virtual ::com::sun::star::uno::Sequence< OUString > SAL_CALL getFolderContents( const OUString& FolderURL, sal_Bool bIncludeFolders ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 108     virtual sal_Bool SAL_CALL exists( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 109     virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XInputStream > SAL_CALL openFileRead( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 110     virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XOutputStream > SAL_CALL openFileWrite( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 111     virtual ::com::sun::star::uno::Reference< ::com::sun::star::io::XStream > SAL_CALL openFileReadWrite( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 112     virtual void SAL_CALL setInteractionHandler( const ::com::sun::star::uno::Reference< ::com::sun::star::task::XInteractionHandler >& Handler ) throw(::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 113     virtual void SAL_CALL writeFile( const 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, std::exception) SAL_OVERRIDE;
 114     virtual sal_Bool SAL_CALL isHidden( const OUString& FileURL ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 115     virtual void SAL_CALL setHidden( const OUString& FileURL, sal_Bool bHidden ) throw(::com::sun::star::ucb::CommandAbortedException, ::com::sun::star::uno::Exception, ::com::sun::star::uno::RuntimeException, std::exception) SAL_OVERRIDE;
 116 };
 117
 118 // Implementation XActiveDataSink
 119 typedef cppu::WeakImplHelper1< XActiveDataSink > ActiveDataSinkHelper;
 120
 121 class OActiveDataSink : public ActiveDataSinkHelper
 122 {
 123     Reference< XInputStream > mxStream;
 124
 125 public:
 126
 127     // Methods
 128     virtual void SAL_CALL setInputStream( const Reference< XInputStream >& aStream )
 129         throw(RuntimeException, std::exception) SAL_OVERRIDE;
 130     virtual Reference< XInputStream > SAL_CALL getInputStream(  )
 131         throw(RuntimeException, std::exception) SAL_OVERRIDE;
 132 };
 133
 134 // Implementation XActiveDataStreamer
 135 typedef cppu::WeakImplHelper1< XActiveDataStreamer > ActiveDataStreamerHelper;
 136
 137 class OActiveDataStreamer : public ActiveDataStreamerHelper
 138 {
 139     Reference< XStream > mxStream;
 140
 141 public:
 142
 143     // Methods
 144     virtual void SAL_CALL setStream( const Reference< XStream >& aStream )
 145         throw(RuntimeException, std::exception) SAL_OVERRIDE;
 146     virtual Reference< XStream > SAL_CALL getStream()
 147         throw(RuntimeException, std::exception) SAL_OVERRIDE;
 148 };
 149
 150 // Implementation XCommandEnvironment
 151 typedef cppu::WeakImplHelper1< XCommandEnvironment > CommandEnvironmentHelper;
 152
 153 class OCommandEnvironment : public CommandEnvironmentHelper
 154 {
 155     Reference< XInteractionHandler > mxInteraction;
 156
 157 public:
 158     void setHandler( Reference< XInteractionHandler > xInteraction_ )
 159     {
 160         mxInteraction = xInteraction_;
 161     }
 162
 163     // Methods
 164     virtual Reference< XInteractionHandler > SAL_CALL getInteractionHandler()
 165         throw(RuntimeException, std::exception) SAL_OVERRIDE;
 166     virtual Reference< XProgressHandler > SAL_CALL getProgressHandler()
 167         throw(RuntimeException, std::exception) SAL_OVERRIDE;
 168 };
 169
 170 void OActiveDataSink::setInputStream( const Reference< XInputStream >& aStream )
 171     throw(RuntimeException, std::exception)
 172 {
 173     mxStream = aStream;
 174 }
 175
 176 Reference< XInputStream > OActiveDataSink::getInputStream()
 177     throw(RuntimeException, std::exception)
 178 {
 179     return mxStream;
 180 }
 181
 182 void OActiveDataStreamer::setStream( const Reference< XStream >& aStream )
 183     throw(RuntimeException, std::exception)
 184 {
 185     mxStream = aStream;
 186 }
 187
 188 Reference< XStream > OActiveDataStreamer::getStream()
 189     throw(RuntimeException, std::exception)
 190 {
 191     return mxStream;
 192 }
 193
 194 Reference< XInteractionHandler > OCommandEnvironment::getInteractionHandler()
 195     throw(RuntimeException, std::exception)
 196 {
 197     return mxInteraction;
 198 }
 199
 200 Reference< XProgressHandler > OCommandEnvironment::getProgressHandler()
 201     throw(RuntimeException, std::exception)
 202 {
 203     Reference< XProgressHandler > xRet;
 204     return xRet;
 205 }
 206
 207 void OFileAccess::transferImpl( const OUString& rSource,
 208                                 const OUString& rDest,
 209                                 bool bMoveData )
 210     throw(CommandAbortedException, Exception, RuntimeException)
 211 {
 212     // SfxContentHelper::Transfer_Impl
 213     INetURLObject aSourceObj( rSource, INET_PROT_FILE );
 214     INetURLObject aDestObj( rDest, INET_PROT_FILE );
 215     OUString aName = aDestObj.getName(
 216         INetURLObject::LAST_SEGMENT, true, INetURLObject::DECODE_WITH_CHARSET );
 217     OUString aDestURL;
 218     OUString aSourceURL = aSourceObj.GetMainURL( INetURLObject::NO_DECODE );
 219     if ( aDestObj.removeSegment() )
 220     {
 221         // hierarchical URL.
 222
 223         aDestObj.setFinalSlash();
 224         aDestURL = aDestObj.GetMainURL( INetURLObject::NO_DECODE );
 225     }
 226     else
 227     {
 228         // non-hierachical URL
 229
 230         // #i29648#
 231
 232
 233         if ( aDestObj.GetProtocol() == INET_PROT_VND_SUN_STAR_EXPAND )
 234         {
 235             // Hack: Expand destination URL using Macro Expander and try again
 236             //       with the hopefully hierarchical expanded URL...
 237
 238             try
 239             {
 240                 Reference< XMacroExpander > xExpander = theMacroExpander::get(m_xContext);
 241
 242                 aDestURL = xExpander->expandMacros(
 243                     aDestObj.GetURLPath( INetURLObject::DECODE_WITH_CHARSET ) );
 244             }
 245             catch ( Exception const & )
 246             {
 247                 throw RuntimeException(
 248                     OUString( "OFileAccess::transferrImpl - Unable to obtain "
 249                             "destination folder URL!"  ),
 250                     static_cast< cppu::OWeakObject * >( this ) );
 251             }
 252
 253             transferImpl( rSource, aDestURL, bMoveData );
 254             return;
 255         }
 256
 257         throw RuntimeException(
 258             OUString( "OFileAccess::transferrImpl - Unable to obtain "
 259                     "destination folder URL!"  ),
 260                 static_cast< cppu::OWeakObject * >( this ) );
 261
 262     }
 263
 264     ucbhelper::Content aDestPath( aDestURL,   mxEnvironment, comphelper::getProcessComponentContext() );
 265     ucbhelper::Content aSrc     ( aSourceURL, mxEnvironment, comphelper::getProcessComponentContext() );
 266
 267     try
 268     {
 269         aDestPath.transferContent( aSrc,
 270                                    bMoveData
 271                                     ? ucbhelper::InsertOperation_MOVE
 272                                     : ucbhelper::InsertOperation_COPY,
 273                                    aName,
 274                                    ::com::sun::star::ucb::NameClash::OVERWRITE );
 275     }
 276     catch ( ::com::sun::star::ucb::CommandFailedException const & )
 277     {
 278         // Interaction Handler already handled the error that has occurred...
 279     }
 280 }
 281
 282 void OFileAccess::copy( const OUString& SourceURL, const OUString& DestURL )
 283     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 284 {
 285     transferImpl( SourceURL, DestURL, false );
 286 }
 287
 288 void OFileAccess::move( const OUString& SourceURL, const OUString& DestURL )
 289     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 290 {
 291     transferImpl( SourceURL, DestURL, true );
 292 }
 293
 294 void OFileAccess::kill( const OUString& FileURL )
 295     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 296 {
 297     // SfxContentHelper::Kill
 298     INetURLObject aDeleteObj( FileURL, INET_PROT_FILE );
 299     ucbhelper::Content aCnt( aDeleteObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 300     try
 301     {
 302         aCnt.executeCommand( OUString("delete" ), makeAny( true ) );
 303     }
 304     catch ( ::com::sun::star::ucb::CommandFailedException const & )
 305     {
 306         // Interaction Handler already handled the error that has occurred...
 307     }
 308 }
 309
 310 sal_Bool OFileAccess::isFolder( const OUString& FileURL )
 311     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 312 {
 313     bool bRet = false;
 314     try
 315     {
 316         INetURLObject aURLObj( FileURL, INET_PROT_FILE );
 317         ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 318         bRet = aCnt.isFolder();
 319     }
 320     catch (const Exception &) {}
 321     return bRet;
 322 }
 323
 324 sal_Bool OFileAccess::isReadOnly( const OUString& FileURL )
 325     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 326 {
 327     INetURLObject aURLObj( FileURL, INET_PROT_FILE );
 328     ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 329     Any aRetAny = aCnt.getPropertyValue("IsReadOnly");
 330     bool bRet = false;
 331     aRetAny >>= bRet;
 332     return bRet;
 333 }
 334
 335 void OFileAccess::setReadOnly( const OUString& FileURL, sal_Bool bReadOnly )
 336     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 337 {
 338     INetURLObject aURLObj( FileURL, INET_PROT_FILE );
 339     ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 340     Any aAny;
 341     aAny <<= bReadOnly;
 342     aCnt.setPropertyValue("IsReadOnly", aAny );
 343 }
 344
 345 void OFileAccess::createFolder( const OUString& NewFolderURL )
 346     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 347 {
 348     // Does the folder already exist?
 349     if( NewFolderURL.isEmpty() || isFolder( NewFolderURL ) )
 350         return;
 351
 352     // SfxContentHelper::MakeFolder
 353     INetURLObject aURL( NewFolderURL, INET_PROT_FILE );
 354     OUString aTitle = aURL.getName( INetURLObject::LAST_SEGMENT, true, INetURLObject::DECODE_WITH_CHARSET );
 355     if ( !aTitle.isEmpty() )
 356     {
 357         aURL.removeSegment();
 358
 359         // Does the base folder exist? Otherwise create it first
 360         OUString aBaseFolderURLStr = aURL.GetMainURL( INetURLObject::NO_DECODE );
 361         if( !isFolder( aBaseFolderURLStr ) )
 362         {
 363             createFolder( aBaseFolderURLStr );
 364         }
 365     }
 366
 367     ucbhelper::Content aCnt( aURL.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 368
 369     Sequence< ContentInfo > aInfo = aCnt.queryCreatableContentsInfo();
 370     sal_Int32 nCount = aInfo.getLength();
 371     if ( nCount == 0 )
 372         return;
 373
 374     for ( sal_Int32 i = 0; i < nCount; ++i )
 375     {
 376         // Simply look for the first KIND_FOLDER...
 377         const ContentInfo & rCurr = aInfo[i];
 378         if ( rCurr.Attributes & ContentInfoAttribute::KIND_FOLDER )
 379         {
 380             // Make sure the only required bootstrap property is "Title",
 381             const Sequence< Property > & rProps = rCurr.Properties;
 382             if ( rProps.getLength() != 1 )
 383                 continue;
 384
 385             if ( rProps[ 0 ].Name != "Title" )
 386                 continue;
 387
 388             Sequence<OUString> aNames(1);
 389             OUString* pNames = aNames.getArray();
 390             pNames[0] = "Title";
 391             Sequence< Any > aValues(1);
 392             Any* pValues = aValues.getArray();
 393             pValues[0] = makeAny( OUString( aTitle ) );
 394
 395             ucbhelper::Content aNew;
 396             try
 397             {
 398                 if ( !aCnt.insertNewContent( rCurr.Type, aNames, aValues, aNew ) )
 399                     continue;
 400
 401                 // Success. We're done.
 402                 return;
 403             }
 404             catch ( ::com::sun::star::ucb::CommandFailedException const & )
 405             {
 406                 // Interaction Handler already handled the error that has occurred...
 407                 continue;
 408             }
 409         }
 410     }
 411 }
 412
 413 sal_Int32 OFileAccess::getSize( const OUString& FileURL )
 414     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 415 {
 416     // SfxContentHelper::GetSize
 417     sal_Int32 nSize = 0;
 418     sal_Int64 nTemp = 0;
 419     INetURLObject aObj( FileURL, INET_PROT_FILE );
 420     ucbhelper::Content aCnt( aObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 421     aCnt.getPropertyValue( "Size" ) >>= nTemp;
 422     nSize = (sal_Int32)nTemp;
 423     return nSize;
 424 }
 425
 426 OUString OFileAccess::getContentType( const OUString& FileURL )
 427     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 428 {
 429     INetURLObject aObj( FileURL, INET_PROT_FILE );
 430     ucbhelper::Content aCnt( aObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 431
 432     Reference< XContent > xContent = aCnt.get();
 433     OUString aTypeStr = xContent->getContentType();
 434     return aTypeStr;
 435 }
 436
 437 ::com::sun::star::util::DateTime OFileAccess::getDateTimeModified( const OUString& FileURL )
 438     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 439 {
 440     INetURLObject aFileObj( FileURL, INET_PROT_FILE );
 441     ::com::sun::star::util::DateTime aDateTime;
 442
 443     Reference< XCommandEnvironment > aCmdEnv;
 444     ucbhelper::Content aYoung( aFileObj.GetMainURL( INetURLObject::NO_DECODE ), aCmdEnv, comphelper::getProcessComponentContext() );
 445     aYoung.getPropertyValue("DateModified") >>= aDateTime;
 446     return aDateTime;
 447 }
 448
 449 typedef vector< OUString* > StringList_Impl;
 450
 451 Sequence< OUString > OFileAccess::getFolderContents( const OUString& FolderURL, sal_Bool bIncludeFolders )
 452     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 453 {
 454     // SfxContentHelper::GetFolderContents
 455
 456     StringList_Impl* pFiles = NULL;
 457     INetURLObject aFolderObj( FolderURL, INET_PROT_FILE );
 458
 459     ucbhelper::Content aCnt( aFolderObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 460     Reference< XResultSet > xResultSet;
 461     Sequence< OUString > aProps(0);
 462
 463     ucbhelper::ResultSetInclude eInclude = bIncludeFolders ? ucbhelper::INCLUDE_FOLDERS_AND_DOCUMENTS : ucbhelper::INCLUDE_DOCUMENTS_ONLY;
 464
 465     try
 466     {
 467         xResultSet = aCnt.createCursor( aProps, eInclude );
 468     }
 469     catch ( ::com::sun::star::ucb::CommandFailedException const & )
 470     {
 471         // Interaction Handler already handled the error that has occurred...
 472     }
 473
 474     if ( xResultSet.is() )
 475     {
 476         pFiles = new StringList_Impl();
 477         Reference< com::sun::star::ucb::XContentAccess > xContentAccess( xResultSet, UNO_QUERY );
 478
 479         while ( xResultSet->next() )
 480         {
 481             OUString aId = xContentAccess->queryContentIdentifierString();
 482             INetURLObject aURL( aId, INET_PROT_FILE );
 483             OUString* pFile = new OUString( aURL.GetMainURL( INetURLObject::NO_DECODE ) );
 484             pFiles->push_back( pFile );
 485         }
 486     }
 487
 488     if ( pFiles )
 489     {
 490         size_t nCount = pFiles->size();
 491         Sequence < OUString > aRet( nCount );
 492         OUString* pRet = aRet.getArray();
 493         for ( size_t i = 0; i < nCount; ++i )
 494         {
 495             OUString* pFile = pFiles->at( i );
 496             pRet[i] = *( pFile );
 497             delete pFile;
 498         }
 499         pFiles->clear();
 500         delete pFiles;
 501         return aRet;
 502     }
 503     else
 504         return Sequence < OUString > ();
 505 }
 506
 507 sal_Bool OFileAccess::exists( const OUString& FileURL )
 508     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 509 {
 510     bool bRet = false;
 511     try
 512     {
 513         bRet = isFolder( FileURL );
 514         if( !bRet )
 515         {
 516             Reference< XInputStream > xStream = openFileRead( FileURL );
 517             bRet = xStream.is();
 518             if( bRet )
 519                 xStream->closeInput();
 520         }
 521     }
 522     catch (const Exception &) {}
 523     return bRet;
 524 }
 525
 526 Reference< XInputStream > OFileAccess::openFileRead( const OUString& FileURL )
 527     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 528 {
 529     Reference< XInputStream > xRet;
 530     INetURLObject aObj( FileURL, INET_PROT_FILE );
 531     ucbhelper::Content aCnt( aObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 532
 533     Reference< XActiveDataSink > xSink = (XActiveDataSink*)(new OActiveDataSink());
 534
 535     try
 536     {
 537         bool bRet = aCnt.openStream( xSink );
 538         if( bRet )
 539             xRet = xSink->getInputStream();
 540     }
 541     catch ( ::com::sun::star::ucb::CommandFailedException const & )
 542     {
 543         // Interaction Handler already handled the error that has occurred...
 544     }
 545
 546     return xRet;
 547 }
 548
 549 Reference< XOutputStream > OFileAccess::openFileWrite( const OUString& FileURL )
 550     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 551 {
 552     Reference< XOutputStream > xRet;
 553     Reference< XStream > xStream = OFileAccess::openFileReadWrite( FileURL );
 554     if( xStream.is() )
 555         xRet = xStream->getOutputStream();
 556     return xRet;
 557 }
 558
 559 Reference< XStream > OFileAccess::openFileReadWrite( const OUString& FileURL )
 560     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 561 {
 562     Reference< XActiveDataStreamer > xSink = (XActiveDataStreamer*)new OActiveDataStreamer();
 563     Reference< XInterface > xSinkIface = Reference< XInterface >::query( xSink );
 564
 565     OpenCommandArgument2 aArg;
 566     aArg.Mode       = OpenMode::DOCUMENT;
 567     aArg.Priority   = 0; // unused
 568     aArg.Sink       = xSink;
 569     aArg.Properties = Sequence< Property >( 0 ); // unused
 570
 571     Any aCmdArg;
 572     aCmdArg <<= aArg;
 573
 574     INetURLObject aFileObj( FileURL, INET_PROT_FILE );
 575     ucbhelper::Content aCnt( aFileObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 576
 577     // Be silent...
 578     Reference< XInteractionHandler > xIH;
 579     if ( mpEnvironment )
 580     {
 581         xIH = mpEnvironment->getInteractionHandler();
 582         mpEnvironment->setHandler( 0 );
 583     }
 584
 585     try
 586     {
 587         aCnt.executeCommand( OUString("open" ), aCmdArg );
 588     }
 589     catch ( InteractiveIOException const & e )
 590     {
 591         if ( xIH.is() && mpEnvironment )
 592             mpEnvironment->setHandler( xIH );
 593
 594         if ( e.Code == IOErrorCode_NOT_EXISTING )
 595         {
 596             // Create file...
 597             SvMemoryStream aStream(0,0);
 598             ::utl::OInputStreamWrapper* pInput = new ::utl::OInputStreamWrapper( aStream );
 599             Reference< XInputStream > xInput( pInput );
 600             InsertCommandArgument aInsertArg;
 601             aInsertArg.Data = xInput;
 602             aInsertArg.ReplaceExisting = sal_False;
 603
 604             aCmdArg <<= aInsertArg;
 605             aCnt.executeCommand( OUString("insert" ), aCmdArg );
 606
 607             // Retry...
 608             return openFileReadWrite( FileURL );
 609         }
 610
 611         throw;
 612     }
 613
 614     if ( xIH.is() && mpEnvironment )
 615         mpEnvironment->setHandler( xIH );
 616
 617     Reference< XStream > xRet = xSink->getStream();
 618     return xRet;
 619 }
 620
 621 void OFileAccess::setInteractionHandler( const Reference< XInteractionHandler >& Handler )
 622     throw(RuntimeException, std::exception)
 623 {
 624     if( !mpEnvironment )
 625     {
 626         mpEnvironment = new OCommandEnvironment();
 627         mxEnvironment = (XCommandEnvironment*)mpEnvironment;
 628     }
 629     mpEnvironment->setHandler( Handler );
 630 }
 631
 632 bool OFileAccess::createNewFile( const OUString & rParentURL,
 633                                  const OUString & rTitle,
 634                                  const Reference< XInputStream >& data )
 635     throw ( Exception )
 636 {
 637     ucbhelper::Content aParentCnt( rParentURL, mxEnvironment, comphelper::getProcessComponentContext() );
 638
 639     Sequence< ContentInfo > aInfo = aParentCnt.queryCreatableContentsInfo();
 640     sal_Int32 nCount = aInfo.getLength();
 641     if ( nCount == 0 )
 642         return false;
 643
 644     for ( sal_Int32 i = 0; i < nCount; ++i )
 645     {
 646         const ContentInfo & rCurr = aInfo[i];
 647         if ( ( rCurr.Attributes
 648                & ContentInfoAttribute::KIND_DOCUMENT ) &&
 649              ( rCurr.Attributes
 650                & ContentInfoAttribute::INSERT_WITH_INPUTSTREAM ) )
 651         {
 652             // Make sure the only required bootstrap property is
 653             // "Title",
 654             const Sequence< Property > & rProps = rCurr.Properties;
 655             if ( rProps.getLength() != 1 )
 656                 continue;
 657
 658             if ( rProps[ 0 ].Name != "Title" )
 659                 continue;
 660
 661             Sequence<OUString> aNames(1);
 662             OUString* pNames = aNames.getArray();
 663             pNames[0] = "Title";
 664             Sequence< Any > aValues(1);
 665             Any* pValues = aValues.getArray();
 666             pValues[0] = makeAny( OUString( rTitle ) );
 667
 668             try
 669             {
 670                 ucbhelper::Content aNew;
 671                 if ( aParentCnt.insertNewContent(
 672                          rCurr.Type, aNames, aValues, data, aNew ) )
 673                     return true; // success.
 674                 else
 675                     continue;
 676             }
 677             catch ( CommandFailedException const & )
 678             {
 679                 // Interaction Handler already handled the
 680                 // error that has occurred...
 681                 continue;
 682             }
 683         }
 684     }
 685
 686     return false;
 687 }
 688
 689 void SAL_CALL OFileAccess::writeFile( const OUString& FileURL,
 690                                       const Reference< XInputStream >& data )
 691     throw ( Exception, RuntimeException, std::exception )
 692 {
 693     INetURLObject aURL( FileURL, INET_PROT_FILE );
 694     try
 695     {
 696         ucbhelper::Content aCnt(
 697             aURL.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment,
 698             comphelper::getProcessComponentContext() );
 699
 700         try
 701         {
 702             aCnt.writeStream( data, true /* bReplaceExisting */ );
 703         }
 704         catch ( CommandFailedException const & )
 705         {
 706             // Interaction Handler already handled the error that has occurred...
 707         }
 708     }
 709     catch ( ContentCreationException const & e )
 710     {
 711         // Most probably file does not exist. Try to create.
 712         if ( e.eError == ContentCreationError_CONTENT_CREATION_FAILED )
 713         {
 714             INetURLObject aParentURLObj( aURL );
 715             if ( aParentURLObj.removeSegment() )
 716             {
 717                 OUString aParentURL
 718                     = aParentURLObj.GetMainURL( INetURLObject::NO_DECODE );
 719
 720                 // ensure all parent folders exist.
 721                 createFolder( aParentURL );
 722
 723                 // create the new file...
 724                 OUString aTitle
 725                     = aURL.getName( INetURLObject::LAST_SEGMENT,
 726                                     true,
 727                                     INetURLObject::DECODE_WITH_CHARSET );
 728                 if ( createNewFile( aParentURL, aTitle, data ) )
 729                 {
 730                     // success
 731                     return;
 732                 }
 733             }
 734         }
 735
 736         throw;
 737     }
 738 }
 739
 740 sal_Bool OFileAccess::isHidden( const OUString& FileURL )
 741     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 742 {
 743     INetURLObject aURLObj( FileURL, INET_PROT_FILE );
 744     ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 745     Any aRetAny = aCnt.getPropertyValue("IsHidden");
 746     bool bRet = false;
 747     aRetAny >>= bRet;
 748     return bRet;
 749 }
 750
 751 void OFileAccess::setHidden( const OUString& FileURL, sal_Bool bHidden )
 752     throw(CommandAbortedException, Exception, RuntimeException, std::exception)
 753 {
 754     INetURLObject aURLObj( FileURL, INET_PROT_FILE );
 755     ucbhelper::Content aCnt( aURLObj.GetMainURL( INetURLObject::NO_DECODE ), mxEnvironment, comphelper::getProcessComponentContext() );
 756     Any aAny;
 757     aAny <<= bHidden;
 758     aCnt.setPropertyValue("IsHidden", aAny );
 759 }
 760
 761 }; // namespace end
 762
 763 Reference< XInterface > SAL_CALL FileAccess_CreateInstance( const Reference< XMultiServiceFactory > & xSMgr )
 764 {
 765     return Reference < XInterface >( ( cppu::OWeakObject * ) new OFileAccess( comphelper::getComponentContext(xSMgr) ) );
 766 }
 767
 768 Sequence< OUString > FileAccess_getSupportedServiceNames()
 769 {
 770     Sequence< OUString > seqNames(1);
 771     seqNames.getArray()[0] = SERVICE_NAME;
 772     return seqNames;
 773 }
 774
 775 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */