ucb/source/ucp/ftp/ftpcontent.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: ftpcontent.cxx,v $
  10  * $Revision: 1.29 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_ucb.hxx"
  33
  34 /**************************************************************************
  35                                 TODO
  36  **************************************************************************
  37
  38  *************************************************************************/
  39 #include <com/sun/star/beans/PropertyAttribute.hpp>
  40
  41 #include "ftpdynresultset.hxx"
  42 #include "ftpresultsetfactory.hxx"
  43 #include "ftpresultsetI.hxx"
  44 #include "ftpcontent.hxx"
  45 #include "ftpcontentprovider.hxx"
  46 #include "ftpinpstr.hxx"
  47 #include "ftpdirp.hxx"
  48 #include "ftpcontentidentifier.hxx"
  49 #include "ftpcfunc.hxx"
  50 #include "ftpstrcont.hxx"
  51 #include "ftpintreq.hxx"
  52
  53 #include <memory>
  54 #include <vector>
  55 #include <rtl/memory.h>
  56 #include "curl.hxx"
  57 #include <curl/easy.h>
  58 #include <ucbhelper/cancelcommandexecution.hxx>
  59 #include <ucbhelper/contentidentifier.hxx>
  60 #include <ucbhelper/propertyvalueset.hxx>
  61 #include <ucbhelper/contentidentifier.hxx>
  62 #include <ucbhelper/cancelcommandexecution.hxx>
  63 #include <ucbhelper/simpleauthenticationrequest.hxx>
  64 #include <com/sun/star/lang/IllegalAccessException.hpp>
  65 #include <com/sun/star/ucb/ContentInfoAttribute.hpp>
  66 #include <com/sun/star/beans/UnknownPropertyException.hpp>
  67 #include <com/sun/star/beans/Property.hpp>
  68 #include <com/sun/star/beans/PropertyValue.hpp>
  69 #include <com/sun/star/ucb/XCommandInfo.hpp>
  70 #include <com/sun/star/io/XActiveDataSink.hpp>
  71 #include <com/sun/star/io/XOutputStream.hpp>
  72 #include <com/sun/star/io/XActiveDataStreamer.hpp>
  73 #include <com/sun/star/ucb/UnsupportedDataSinkException.hpp>
  74 #include <com/sun/star/ucb/OpenCommandArgument2.hpp>
  75 #include <com/sun/star/ucb/UnsupportedOpenModeException.hpp>
  76 #include <com/sun/star/ucb/InteractiveNetworkConnectException.hpp>
  77 #include <com/sun/star/ucb/InteractiveNetworkResolveNameException.hpp>
  78 #include <com/sun/star/ucb/InteractiveIOException.hpp>
  79 #include <com/sun/star/ucb/MissingPropertiesException.hpp>
  80 #include <com/sun/star/ucb/MissingInputStreamException.hpp>
  81 #include <com/sun/star/ucb/UnsupportedNameClashException.hpp>
  82 #include <com/sun/star/ucb/NameClashException.hpp>
  83 //#include <com/sun/star/ucb/NameClash.hpp>
  84 #include <com/sun/star/ucb/OpenMode.hpp>
  85 #include <com/sun/star/ucb/IOErrorCode.hpp>
  86
  87 using namespace ftp;
  88 using namespace com::sun::star::task;
  89 using namespace com::sun::star::container;
  90 using namespace com::sun::star::lang;
  91 using namespace com::sun::star::uno;
  92 using namespace com::sun::star::ucb;
  93 using namespace com::sun::star::beans;
  94 using namespace com::sun::star::io;
  95 using namespace com::sun::star::sdbc;
  96
  97
  98
  99 //=========================================================================
 100 //=========================================================================
 101 //
 102 // Content Implementation.
 103 //
 104 //=========================================================================
 105 //=========================================================================
 106
 107 FTPContent::FTPContent( const Reference< XMultiServiceFactory >& rxSMgr,
 108                         FTPContentProvider* pProvider,
 109                         const Reference< XContentIdentifier >& Identifier)
 110     : ContentImplHelper(rxSMgr,pProvider,Identifier),
 111       m_pFCP(pProvider),
 112       m_aFTPURL(Identifier->getContentIdentifier(),
 113                 pProvider),
 114       m_bInserted(false),
 115       m_bTitleSet(false)
 116 {
 117 }
 118
 119
 120 FTPContent::FTPContent( const Reference< XMultiServiceFactory >& rxSMgr,
 121                         FTPContentProvider* pProvider,
 122                         const Reference< XContentIdentifier >& Identifier,
 123                         const FTPURL& aFTPURL)
 124     : ContentImplHelper(rxSMgr,pProvider,Identifier),
 125       m_pFCP(pProvider),
 126       m_aFTPURL(aFTPURL),
 127       m_bInserted(false),
 128       m_bTitleSet(false)
 129 {
 130 }
 131
 132
 133
 134 FTPContent::FTPContent( const Reference< XMultiServiceFactory >& rxSMgr,
 135                         FTPContentProvider* pProvider,
 136                         const Reference< XContentIdentifier >& Identifier,
 137                         const ContentInfo& Info)
 138     : ContentImplHelper(rxSMgr,pProvider,Identifier),
 139       m_pFCP(pProvider),
 140       m_aFTPURL(Identifier->getContentIdentifier(),
 141                 pProvider),
 142       m_bInserted(true),
 143       m_bTitleSet(false),
 144       m_aInfo(Info)
 145 {
 146 }
 147
 148
 149
 150 //=========================================================================
 151
 152 FTPContent::~FTPContent()
 153 {
 154 }
 155
 156
 157 //=========================================================================
 158 //
 159 // XInterface methods.
 160 //
 161 //=========================================================================
 162
 163 XINTERFACE_IMPL_6( FTPContent,
 164                    XTypeProvider,
 165                    XServiceInfo,
 166                    XContent,
 167                    XCommandProcessor,
 168                    XContentCreator,
 169                    XChild);
 170
 171 //=========================================================================
 172 //
 173 // XTypeProvider methods.
 174 //
 175 //=========================================================================
 176
 177 XTYPEPROVIDER_IMPL_6( FTPContent,
 178                          XTypeProvider,
 179                          XServiceInfo,
 180                          XContent,
 181                       XCommandProcessor,
 182                       XContentCreator,
 183                       XChild);
 184
 185 //=========================================================================
 186 //
 187 // XServiceInfo methods.
 188 //
 189 //=========================================================================
 190
 191 // needed, because the service shall not be creatable!!
 192 #undef XSERVICEINFO_CREATE_INSTANCE_IMPL
 193 #define XSERVICEINFO_CREATE_INSTANCE_IMPL( Class )
 194
 195 XSERVICEINFO_IMPL_1( FTPContent,
 196                      rtl::OUString::createFromAscii(
 197                          "com.sun.star.comp.FTPContent"),
 198                      rtl::OUString::createFromAscii(
 199                          "com.sun.star.ucb.FTPContent"));
 200
 201
 202
 203 //=========================================================================
 204 //
 205 // XContent methods.
 206 //
 207 //=========================================================================
 208
 209 // virtual
 210 rtl::OUString SAL_CALL FTPContent::getContentType()
 211     throw( RuntimeException )
 212 {
 213     return rtl::OUString::createFromAscii(FTP_CONTENT_TYPE);
 214 }
 215
 216
 217 //=========================================================================
 218 //
 219 // XCommandProcessor methods.
 220 //
 221 //=========================================================================
 222
 223
 224 //virtual
 225 void SAL_CALL FTPContent::abort( sal_Int32 /*CommandId*/ )
 226     throw( RuntimeException )
 227 {
 228 }
 229
 230
 231
 232 /***************************************************************************/
 233 /*                                                                         */
 234 /*                           Interne Implklasse                            */
 235 /*                                                                         */
 236 /***************************************************************************/
 237
 238
 239 class ResultSetFactoryI
 240     : public ResultSetFactory
 241 {
 242 public:
 243
 244     ResultSetFactoryI(const Reference<XMultiServiceFactory >&  xSMgr,
 245                       const Reference<XContentProvider >&  xProvider,
 246                       sal_Int32 nOpenMode,
 247                       const Sequence<Property>& seq,
 248                       const Sequence<NumberedSortingInfo>& seqSort,
 249                       const std::vector<FTPDirentry>& dirvec)
 250         : m_xSMgr(xSMgr),
 251           m_xProvider(xProvider),
 252           m_nOpenMode(nOpenMode),
 253           m_seq(seq),
 254           m_seqSort(seqSort),
 255           m_dirvec(dirvec)
 256     {
 257     }
 258
 259     virtual ResultSetBase* createResultSet()
 260     {
 261         return new ResultSetI(m_xSMgr,
 262                               m_xProvider,
 263                               m_nOpenMode,
 264                               m_seq,
 265                               m_seqSort,
 266                               m_dirvec);
 267     }
 268
 269 public:
 270
 271     Reference< XMultiServiceFactory >               m_xSMgr;
 272     Reference< XContentProvider >                   m_xProvider;
 273     sal_Int32                                       m_nOpenMode;
 274     Sequence< Property >                            m_seq;
 275     Sequence< NumberedSortingInfo >                 m_seqSort;
 276     std::vector<FTPDirentry>                        m_dirvec;
 277 };
 278
 279
 280
 281 //=========================================================================
 282 //
 283 // XCommandProcessor methods.
 284 //
 285 //=========================================================================
 286
 287 enum ACTION { NOACTION,
 288               THROWAUTHENTICATIONREQUEST,
 289               THROWACCESSDENIED,
 290               THROWINTERACTIVECONNECT,
 291               THROWRESOLVENAME,
 292               THROWQUOTE,
 293               THROWNOFILE,
 294               THROWGENERAL };
 295
 296
 297 // virtual
 298 Any SAL_CALL FTPContent::execute(
 299     const Command& aCommand,
 300     sal_Int32 /*CommandId*/,
 301     const Reference<
 302     XCommandEnvironment >& Environment
 303 )
 304     throw(
 305         Exception,
 306         CommandAbortedException,
 307         RuntimeException
 308     )
 309 {
 310     ACTION action(NOACTION);
 311     Any aRet;
 312
 313     while(true)
 314         try {
 315             if(action == THROWAUTHENTICATIONREQUEST) {
 316                 // try to get a continuation first
 317                 rtl::OUString aRealm,aPassword,aAccount;
 318                 m_pFCP->forHost(m_aFTPURL.host(),
 319                                 m_aFTPURL.port(),
 320                                 m_aFTPURL.username(),
 321                                 aPassword,
 322                                 aAccount);
 323                 rtl::Reference<ucbhelper::SimpleAuthenticationRequest>
 324                     p( new ucbhelper::SimpleAuthenticationRequest(
 325                         m_aFTPURL.ident(false, false),
 326                         m_aFTPURL.host(),      // ServerName
 327                         ucbhelper::SimpleAuthenticationRequest::ENTITY_NA,
 328                         aRealm,
 329                         ucbhelper::SimpleAuthenticationRequest
 330                         ::ENTITY_FIXED,
 331                         m_aFTPURL.username(),
 332                         ucbhelper::SimpleAuthenticationRequest
 333                         ::ENTITY_MODIFY,
 334                         aPassword));
 335
 336                 Reference<XInteractionHandler> xInteractionHandler;
 337                 if(Environment.is())
 338                     xInteractionHandler =
 339                         Environment->getInteractionHandler();
 340
 341                 if( xInteractionHandler.is()) {
 342                     xInteractionHandler->handle(p.get());
 343
 344                     Reference<XInterface> xSelection(
 345                         p->getSelection().get());
 346
 347                     if(Reference<XInteractionRetry>(
 348                         xSelection,UNO_QUERY).is())
 349                         action = NOACTION;
 350                     else if(Reference<XInteractionSupplyAuthentication>(
 351                         xSelection,UNO_QUERY).is()) {
 352                         m_pFCP->setHost(
 353                             m_aFTPURL.host(),
 354                             m_aFTPURL.port(),
 355                             m_aFTPURL.username(),
 356                             p->getAuthenticationSupplier()->getPassword(),
 357                             aAccount);
 358                         action = NOACTION;
 359                     }
 360                 }
 361                 aRet = p->getRequest();
 362             }
 363
 364 //                      if(aCommand.Name.compareToAscii(
 365 //                              "getPropertyValues") == 0 &&
 366 //                         action != NOACTION) {
 367 //                              // It is not allowed to throw if
 368 //                              // command is getPropertyValues
 369 //                              rtl::Reference<ucbhelper::PropertyValueSet> xRow =
 370 //                                      new ucbhelper::PropertyValueSet(m_xSMgr);
 371 //                              Sequence<Property> Properties;
 372 //                              aCommand.Argument >>= Properties;
 373 //                              for(int i = 0; i < Properties.getLength(); ++i)
 374 //                                      xRow->appendVoid(Properties[i]);
 375 //                              aRet <<= Reference<XRow>(xRow.get());
 376 //                              return aRet;
 377 //                      }
 378
 379             if(action == THROWAUTHENTICATIONREQUEST) {
 380                 ucbhelper::cancelCommandExecution(
 381                     aRet,
 382                     Reference<XCommandEnvironment>(0));
 383             } else if(action == THROWACCESSDENIED) {
 384                 Sequence<Any> seq(1);
 385                 PropertyValue value;
 386                 value.Name =
 387                     rtl::OUString::createFromAscii("Uri");
 388                 value.Handle = -1;
 389                 value.Value <<= m_aFTPURL.ident(false,false);
 390                 value.State = PropertyState_DIRECT_VALUE;
 391                 seq[0] <<= value;
 392                 ucbhelper::cancelCommandExecution(
 393                     IOErrorCode_ACCESS_DENIED,
 394                     seq,
 395                     Environment);
 396             } else if(action == THROWINTERACTIVECONNECT) {
 397                 InteractiveNetworkConnectException
 398                     excep;
 399                 excep.Server = m_aFTPURL.host();
 400                 aRet <<= excep;
 401                 ucbhelper::cancelCommandExecution(
 402                     aRet,
 403                     Environment);
 404             } else if(action == THROWRESOLVENAME) {
 405                 InteractiveNetworkResolveNameException
 406                     excep;
 407                 excep.Server = m_aFTPURL.host();
 408                 aRet <<= excep;
 409                 ucbhelper::cancelCommandExecution(
 410                     aRet,
 411                     Environment);
 412             } else if(action == THROWNOFILE) {
 413                 Sequence<Any> seq(1);
 414                 PropertyValue value;
 415                 value.Name =
 416                     rtl::OUString::createFromAscii("Uri");
 417                 value.Handle = -1;
 418                 value.Value <<= m_aFTPURL.ident(false,false);
 419                 value.State = PropertyState_DIRECT_VALUE;
 420                 seq[0] <<= value;
 421                 ucbhelper::cancelCommandExecution(
 422                     IOErrorCode_NO_FILE,
 423                     seq,
 424                     Environment);
 425             } else if(action == THROWQUOTE ||
 426                       action == THROWGENERAL) {
 427                 ucbhelper::cancelCommandExecution(
 428                     IOErrorCode_GENERAL,
 429                     Sequence<Any>(0),
 430                     Environment);
 431             }
 432
 433
 434             if(aCommand.Name.compareToAscii("getPropertyValues") == 0) {
 435                 Sequence<Property> Properties;
 436                 if(!(aCommand.Argument >>= Properties))
 437                 {
 438                     aRet <<= IllegalArgumentException();
 439                     ucbhelper::cancelCommandExecution(aRet,Environment);
 440                 }
 441
 442                 aRet <<= getPropertyValues(Properties,Environment);
 443             }
 444             else if(aCommand.Name.compareToAscii("setPropertyValues") == 0)
 445             {
 446                 Sequence<PropertyValue> propertyValues;
 447
 448                 if( ! ( aCommand.Argument >>= propertyValues ) ) {
 449                     aRet <<= IllegalArgumentException();
 450                     ucbhelper::cancelCommandExecution(aRet,Environment);
 451                 }
 452
 453                 aRet <<= setPropertyValues(propertyValues);
 454             }
 455             else if(aCommand.Name.compareToAscii("getCommandInfo") == 0) {
 456                 // Note: Implemented by base class.
 457                 aRet <<= getCommandInfo(Environment);
 458             }
 459             else if(aCommand.Name.compareToAscii("getPropertySetInfo") == 0) {
 460                 // Note: Implemented by base class.
 461                 aRet <<= getPropertySetInfo(Environment);
 462             }
 463             else if(aCommand.Name.compareToAscii( "insert" ) == 0)
 464             {
 465                 InsertCommandArgument aInsertArgument;
 466                 if ( ! ( aCommand.Argument >>= aInsertArgument ) ) {
 467                     aRet <<= IllegalArgumentException();
 468                     ucbhelper::cancelCommandExecution(aRet,Environment);
 469                 }
 470                 insert(aInsertArgument,Environment);
 471             }
 472             else if(aCommand.Name.compareToAscii("delete") == 0) {
 473                 m_aFTPURL.del();
 474                 deleted();
 475             }
 476             else if(aCommand.Name.compareToAscii( "open" ) == 0) {
 477                 OpenCommandArgument2 aOpenCommand;
 478                 if ( !( aCommand.Argument >>= aOpenCommand ) ) {
 479                     aRet <<= IllegalArgumentException();
 480                     ucbhelper::cancelCommandExecution(aRet,Environment);
 481                 }
 482
 483                 if(aOpenCommand.Mode == OpenMode::DOCUMENT) {
 484                     // Open as a document
 485                     Reference<XActiveDataSink>
 486                         xActiveDataSink(aOpenCommand.Sink,UNO_QUERY);
 487                     Reference< XOutputStream >
 488                         xOutputStream(aOpenCommand.Sink,UNO_QUERY);
 489
 490                     if(xActiveDataSink.is()) {
 491                         xActiveDataSink->setInputStream(
 492                             new FTPInputStream(m_aFTPURL.open()));
 493                     }
 494                     else if(xOutputStream.is()) {
 495                         Reference<XInputStream> xStream(
 496                             new FTPInputStream(m_aFTPURL.open()));
 497                         Sequence<sal_Int8> byte_seq(4096);
 498                         sal_Int32 n = 1000; // value does not matter here
 499                         for (;;) {
 500                             n = xStream->readBytes(byte_seq,4096);
 501                             if (n == 0) {
 502                                 break;
 503                             }
 504                             try {
 505                                 if(byte_seq.getLength() != n)
 506                                     byte_seq.realloc(n);
 507                                 xOutputStream->writeBytes(byte_seq);
 508                             } catch(const NotConnectedException&) {
 509
 510                             } catch(const BufferSizeExceededException&) {
 511
 512                             } catch(const IOException&) {
 513
 514                             }
 515                         }
 516                         if(n) {
 517                             Sequence<Any> seq(1);
 518                             PropertyValue value;
 519                             value.Name =
 520                                 rtl::OUString::createFromAscii("Uri");
 521                             value.Handle = -1;
 522                             value.Value <<= m_aFTPURL.ident(false,false);
 523                             value.State = PropertyState_DIRECT_VALUE;
 524                             seq[0] <<= value;
 525                             ucbhelper::cancelCommandExecution(
 526                                 IOErrorCode_UNKNOWN,
 527                                 seq,
 528                                 Environment);
 529                         }
 530                     }
 531                     else {
 532                         aRet <<= UnsupportedDataSinkException();
 533                         ucbhelper::cancelCommandExecution(aRet,Environment);
 534                     }
 535                 }
 536                 else if(aOpenCommand.Mode == OpenMode::ALL ||
 537                         aOpenCommand.Mode == OpenMode::DOCUMENTS ||
 538                         aOpenCommand.Mode == OpenMode::FOLDERS ) {
 539                     std::vector<FTPDirentry> resvec =
 540                         m_aFTPURL.list(sal_Int16(aOpenCommand.Mode));
 541                     Reference< XDynamicResultSet > xSet
 542                         = new DynamicResultSet(
 543                             m_xSMgr,
 544                             this,
 545                             aOpenCommand,
 546                             Environment,
 547                             new ResultSetFactoryI(m_xSMgr,
 548                                                   m_xProvider.get(),
 549                                                   aOpenCommand.Mode,
 550                                                   aOpenCommand.Properties,
 551                                                   aOpenCommand.SortingInfo,
 552                                                   resvec));
 553                     aRet <<= xSet;
 554                 }
 555                 else if(aOpenCommand.Mode ==
 556                         OpenMode::DOCUMENT_SHARE_DENY_NONE ||
 557                         aOpenCommand.Mode ==
 558                         OpenMode::DOCUMENT_SHARE_DENY_WRITE) {
 559                     // Unsupported OpenMode
 560                     aRet <<= UnsupportedOpenModeException();
 561                     ucbhelper::cancelCommandExecution(aRet,Environment);
 562                 }
 563                 else {
 564                     // IllegalArgumentException:: No OpenMode
 565                     aRet <<= IllegalArgumentException();
 566                     ucbhelper::cancelCommandExecution(aRet,Environment);
 567                 }
 568             }
 569             else {
 570                 aRet <<= UnsupportedCommandException();
 571                 ucbhelper::cancelCommandExecution(aRet,Environment);
 572             }
 573
 574             return aRet;
 575         } catch(const curl_exception& e) {
 576             if(e.code() == CURLE_COULDNT_CONNECT)
 577                 action = THROWINTERACTIVECONNECT;
 578             else if(e.code() == CURLE_COULDNT_RESOLVE_HOST )
 579                 action = THROWRESOLVENAME;
 580             else if(e.code() == CURLE_FTP_USER_PASSWORD_INCORRECT ||
 581                     e.code() == CURLE_BAD_PASSWORD_ENTERED ||
 582                     e.code() == CURLE_FTP_WEIRD_PASS_REPLY )
 583                 action = THROWAUTHENTICATIONREQUEST;
 584             else if(e.code() == CURLE_FTP_ACCESS_DENIED)
 585                 action = THROWACCESSDENIED;
 586             else if(e.code() == CURLE_FTP_QUOTE_ERROR)
 587                 action = THROWQUOTE;
 588             else if(e.code() == CURLE_FTP_COULDNT_RETR_FILE)
 589                 action = THROWNOFILE;
 590             else
 591                 // nothing known about the course of the error
 592                 action = THROWGENERAL;
 593         }
 594 }
 595
 596 #define FTP_FILE rtl::OUString::createFromAscii(     \
 597                                    "application/"    \
 598                                    "vnd.sun.staroffice.ftp-file")
 599
 600 #define FTP_FOLDER rtl::OUString::createFromAscii(     \
 601                                    "application/"    \
 602                                    "vnd.sun.staroffice.ftp-folder")
 603
 604 Sequence<ContentInfo > SAL_CALL
 605 FTPContent::queryCreatableContentsInfo(  )
 606     throw (RuntimeException)
 607 {
 608     Sequence< ContentInfo > seq(2);
 609
 610     seq[0].Type = FTP_FILE;
 611     seq[0].Attributes = ContentInfoAttribute::INSERT_WITH_INPUTSTREAM
 612         | ContentInfoAttribute::KIND_DOCUMENT;
 613     Sequence< Property > props( 1 );
 614     props[0] = Property(
 615         rtl::OUString::createFromAscii( "Title" ),
 616         -1,
 617         getCppuType( static_cast< rtl::OUString* >( 0 ) ),
 618         PropertyAttribute::MAYBEVOID
 619         | PropertyAttribute::BOUND );
 620     seq[0].Properties = props;
 621
 622     // folder
 623     seq[1].Type           = FTP_FOLDER;
 624     seq[1].Attributes = ContentInfoAttribute::KIND_FOLDER;
 625     seq[1].Properties = props;
 626
 627     return seq;
 628 }
 629
 630
 631 Reference<XContent > SAL_CALL
 632 FTPContent::createNewContent( const ContentInfo& Info )
 633     throw (RuntimeException)
 634 {
 635     if(Info.Type.equalsAscii("application/"
 636                              "vnd.sun.staroffice.ftp-file") ||
 637        Info.Type.equalsAscii("application/"
 638                              "vnd.sun.staroffice.ftp-folder"))
 639         return new FTPContent(m_xSMgr,
 640                               m_pFCP,
 641                               m_xIdentifier,Info);
 642     else
 643         return Reference<XContent>(0);
 644 }
 645
 646
 647
 648
 649 Reference<XInterface > SAL_CALL
 650 FTPContent::getParent(  )
 651     throw (RuntimeException)
 652 {
 653     Reference<XContentIdentifier>
 654         xIdent(new FTPContentIdentifier(m_aFTPURL.parent(false)));
 655     Reference<XContent> xContent(m_xProvider->queryContent(xIdent));
 656     return Reference<XInterface>(xContent,UNO_QUERY);
 657 }
 658
 659
 660 void SAL_CALL
 661 FTPContent::setParent(const Reference<XInterface >& /*Parent*/ )
 662     throw (NoSupportException,
 663            RuntimeException)
 664 {
 665     throw NoSupportException();
 666 }
 667
 668
 669
 670 rtl::OUString FTPContent::getParentURL()
 671 {
 672     return m_aFTPURL.parent();
 673 }
 674
 675
 676 class InsertData
 677     : public CurlInput {
 678
 679 public:
 680
 681     InsertData(const Reference<XInputStream>& xInputStream)
 682         : m_xInputStream(xInputStream) { }
 683     virtual ~InsertData() {}
 684
 685     // returns the number of bytes actually read
 686     virtual sal_Int32 read(sal_Int8 *dest,sal_Int32 nBytesRequested);
 687
 688 private:
 689
 690     Reference<XInputStream> m_xInputStream;
 691 };
 692
 693
 694
 695 sal_Int32 InsertData::read(sal_Int8 *dest,sal_Int32 nBytesRequested)
 696 {
 697     sal_Int32 m = 0;
 698
 699     if(m_xInputStream.is()) {
 700            Sequence<sal_Int8> seq(nBytesRequested);
 701         m = m_xInputStream->readBytes(seq,nBytesRequested);
 702         rtl_copyMemory(dest,seq.getConstArray(),m);
 703     }
 704     return m;
 705 }
 706
 707
 708 void FTPContent::insert(const InsertCommandArgument& aInsertCommand,
 709                         const Reference<XCommandEnvironment>& Env)
 710 {
 711     osl::MutexGuard aGuard(m_aMutex);
 712
 713     if(m_bInserted && !m_bTitleSet) {
 714         MissingPropertiesException excep;
 715         excep.Properties.realloc(1);
 716         excep.Properties[0] = rtl::OUString::createFromAscii("Title");
 717         Any aAny; aAny <<= excep;
 718         ucbhelper::cancelCommandExecution(aAny,Env);
 719     }
 720
 721     if(m_bInserted &&
 722        m_aInfo.Type == FTP_FILE &&
 723        !aInsertCommand.Data.is())
 724     {
 725         MissingInputStreamException excep;
 726         Any aAny; aAny <<= excep;
 727         ucbhelper::cancelCommandExecution(aAny,Env);
 728     }
 729
 730     bool bReplace(aInsertCommand.ReplaceExisting);
 731
 732  retry:
 733     try {
 734         if(m_aInfo.Type == FTP_FILE) {
 735             InsertData data(aInsertCommand.Data);
 736             m_aFTPURL.insert(bReplace,&data);
 737         } else if(m_aInfo.Type == FTP_FOLDER)
 738             m_aFTPURL.mkdir(bReplace);
 739     } catch(const curl_exception& e) {
 740         if(e.code() == FILE_EXIST_DURING_INSERT ||
 741            e.code() == FOLDER_EXIST_DURING_INSERT) {
 742             // Deprecated, not used anymore:
 743             NameClashException excep;
 744             excep.Name = m_aFTPURL.child();
 745             Any aAny;
 746             aAny <<= excep;
 747             ucbhelper::cancelCommandExecution(aAny,Env);
 748         } else if(e.code() == FOLDER_MIGHT_EXIST_DURING_INSERT ||
 749                   e.code() == FILE_MIGHT_EXIST_DURING_INSERT) {
 750             // Interact
 751             Reference<XInteractionHandler> xInt;
 752             if(Env.is())
 753                 xInt = Env->getInteractionHandler();
 754
 755             UnsupportedNameClashException excep;
 756             excep.NameClash = 0; //NameClash::ERROR;
 757
 758             if(!xInt.is()) {
 759                 Any aAny;
 760                 aAny <<= excep;
 761                 ucbhelper::cancelCommandExecution(aAny,Env);
 762             }
 763
 764             XInteractionRequestImpl* p =
 765                 new XInteractionRequestImpl(m_aFTPURL.child());
 766             Reference<XInteractionRequest> req(p);
 767             xInt->handle(req);
 768             if(p->approved()) {
 769                 bReplace = true;
 770                 goto retry;
 771             }
 772             else
 773                 throw excep;
 774         }
 775         else
 776             throw;
 777     }
 778
 779     // May not be reached, because both mkdir and insert can throw curl-
 780     // exceptions
 781     m_bInserted = false;
 782     inserted();
 783 }
 784
 785
 786
 787 Reference< XRow > FTPContent::getPropertyValues(
 788     const Sequence< Property >& seqProp,
 789     const Reference<XCommandEnvironment>& /*environment*/
 790 )
 791 {
 792     rtl::Reference<ucbhelper::PropertyValueSet> xRow =
 793         new ucbhelper::PropertyValueSet(m_xSMgr);
 794
 795     FTPDirentry aDirEntry = m_aFTPURL.direntry();
 796
 797     for(sal_Int32 i = 0; i < seqProp.getLength(); ++i) {
 798         const rtl::OUString& Name = seqProp[i].Name;
 799         if(Name.compareToAscii("Title") == 0)
 800             xRow->appendString(seqProp[i],aDirEntry.m_aName);
 801         else if(aDirEntry.m_nMode != INETCOREFTP_FILEMODE_UNKNOWN) {
 802             if(Name.compareToAscii("ContentType") == 0)
 803                 xRow->appendString(seqProp[i],
 804                                    aDirEntry.m_nMode&INETCOREFTP_FILEMODE_ISDIR
 805                                    ? FTP_FOLDER
 806                                    : FTP_FILE );
 807             else if(Name.compareToAscii("IsReadOnly") == 0)
 808                 xRow->appendBoolean(seqProp[i],
 809                                     aDirEntry.m_nMode
 810                                     & INETCOREFTP_FILEMODE_WRITE
 811                                     ? 0
 812                                     : 1 );
 813             else if(Name.compareToAscii("IsDocument") == 0)
 814                 xRow->appendBoolean(seqProp[i],
 815                                     ! sal_Bool(aDirEntry.m_nMode &
 816                                                INETCOREFTP_FILEMODE_ISDIR));
 817             else if(Name.compareToAscii("IsFolder") == 0)
 818                 xRow->appendBoolean(seqProp[i],
 819                                     sal_Bool(aDirEntry.m_nMode &
 820                                              INETCOREFTP_FILEMODE_ISDIR));
 821             else if(Name.compareToAscii("Size") == 0)
 822                 xRow->appendLong(seqProp[i],
 823                                  aDirEntry.m_nSize);
 824             else if(Name.compareToAscii("DateCreated") == 0)
 825                 xRow->appendTimestamp(seqProp[i],
 826                                       aDirEntry.m_aDate);
 827             else
 828                 xRow->appendVoid(seqProp[i]);
 829         } else
 830             xRow->appendVoid(seqProp[i]);
 831     }
 832
 833     return Reference<XRow>(xRow.get());
 834 }
 835
 836
 837
 838 Sequence<Any> FTPContent::setPropertyValues(
 839     const Sequence<PropertyValue>& seqPropVal)
 840 {
 841     Sequence<Property> props =
 842         getProperties(Reference<XCommandEnvironment>(0));
 843
 844     Sequence<Any> ret(seqPropVal.getLength());
 845     Sequence<PropertyChangeEvent > evt;
 846
 847     osl::MutexGuard aGuard(m_aMutex);
 848     for(sal_Int32 i = 0; i < ret.getLength(); ++i) {
 849         if(seqPropVal[i].Name.equalsAscii("Title")) {
 850             rtl::OUString Title;
 851             if(!(seqPropVal[i].Value >>= Title)) {
 852                 ret[i] <<= IllegalTypeException();
 853                 continue;
 854             } else if(!Title.getLength()) {
 855                 ret[i] <<= IllegalArgumentException();
 856                 continue;
 857             }
 858
 859             if(m_bInserted) {
 860                 m_aFTPURL.child(Title);
 861                 m_xIdentifier =
 862                     new FTPContentIdentifier(m_aFTPURL.ident(false,false));
 863                 m_bTitleSet = true;
 864             } else
 865                 try {
 866                     rtl::OUString OldTitle = m_aFTPURL.ren(Title);
 867                     evt.realloc(1);
 868                     evt[0].PropertyName =
 869                         rtl::OUString::createFromAscii("Title");
 870                     evt[0].Further = false;
 871                     evt[0].PropertyHandle = -1;
 872                     evt[0].OldValue <<= OldTitle;
 873                     evt[0].NewValue <<= Title;
 874                 } catch(const curl_exception&) {
 875                     InteractiveIOException excep;
 876                     // any better possibility here?
 877                     // ( the error code is always CURLE_FTP_QUOTE_ERROR )
 878                     excep.Code = IOErrorCode_ACCESS_DENIED;
 879                     ret[i] <<= excep;
 880                 }
 881         } else {
 882             // either not unknown or illegal
 883             ret[i] <<= UnknownPropertyException();
 884             for(sal_Int32 j = 0; j < props.getLength(); ++j)
 885                 if(props[j].Name == seqPropVal[i].Name) {
 886                     ret[i] <<= IllegalAccessException();
 887                     break;
 888                 }
 889         }
 890     }
 891
 892     if(evt.getLength()) {
 893         // title has changed
 894         notifyPropertiesChange(evt);
 895         exchange(new FTPContentIdentifier(m_aFTPURL.ident(false,false)));
 896     }
 897
 898     return ret;
 899 }