LCOV - code coverage report
Current view: top level - ucb/source/ucp/webdav-neon - DAVResourceAccess.cxx (source / functions) Hit Total Coverage
Test: commit e02a6cb2c3e2b23b203b422e4e0680877f232636 Lines: 0 465 0.0 %
Date: 2014-04-14 Functions: 0 31 0.0 %
Legend: Lines: hit not hit

          Line data    Source code
       1             : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
       2             : /*************************************************************************
       3             :  *
       4             :  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
       5             :  *
       6             :  * Copyright 2000, 2010 Oracle and/or its affiliates.
       7             :  *
       8             :  * OpenOffice.org - a multi-platform office productivity suite
       9             :  *
      10             :  * This file is part of OpenOffice.org.
      11             :  *
      12             :  * OpenOffice.org is free software: you can redistribute it and/or modify
      13             :  * it under the terms of the GNU Lesser General Public License version 3
      14             :  * only, as published by the Free Software Foundation.
      15             :  *
      16             :  * OpenOffice.org is distributed in the hope that it will be useful,
      17             :  * but WITHOUT ANY WARRANTY; without even the implied warranty of
      18             :  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      19             :  * GNU Lesser General Public License version 3 for more details
      20             :  * (a copy is included in the LICENSE file that accompanied this code).
      21             :  *
      22             :  * You should have received a copy of the GNU Lesser General Public License
      23             :  * version 3 along with OpenOffice.org.  If not, see
      24             :  * <http://www.openoffice.org/license.html>
      25             :  * for a copy of the LGPLv3 License.
      26             :  *
      27             :  ************************************************************************/
      28             : 
      29             : 
      30             : #include "osl/diagnose.h"
      31             : 
      32             : #include "com/sun/star/task/XInteractionAbort.hpp"
      33             : #include "com/sun/star/ucb/XWebDAVCommandEnvironment.hpp"
      34             : 
      35             : #include "ucbhelper/simpleauthenticationrequest.hxx"
      36             : #include "comphelper/processfactory.hxx"
      37             : #include "comphelper/seekableinput.hxx"
      38             : 
      39             : #include "DAVAuthListenerImpl.hxx"
      40             : #include "DAVResourceAccess.hxx"
      41             : 
      42             : using namespace webdav_ucp;
      43             : using namespace com::sun::star;
      44             : 
      45             : 
      46             : 
      47             : 
      48             : // DAVAuthListener_Impl Implementation.
      49             : 
      50             : 
      51             : 
      52             : 
      53             : 
      54             : // virtual
      55           0 : int DAVAuthListener_Impl::authenticate(
      56             :     const OUString & inRealm,
      57             :     const OUString & inHostName,
      58             :     OUString & inoutUserName,
      59             :     OUString & outPassWord,
      60             :     sal_Bool bCanUseSystemCredentials )
      61             : {
      62           0 :     if ( m_xEnv.is() )
      63             :     {
      64             :         uno::Reference< task::XInteractionHandler > xIH
      65           0 :             = m_xEnv->getInteractionHandler();
      66             : 
      67           0 :         if ( xIH.is() )
      68             :         {
      69             :             // #102871# - Supply username and password from previous try.
      70             :             // Password container service depends on this!
      71           0 :             if ( inoutUserName.isEmpty() )
      72           0 :                 inoutUserName = m_aPrevUsername;
      73             : 
      74           0 :             if ( outPassWord.isEmpty() )
      75           0 :                 outPassWord = m_aPrevPassword;
      76             : 
      77             :             rtl::Reference< ucbhelper::SimpleAuthenticationRequest > xRequest
      78             :                 = new ucbhelper::SimpleAuthenticationRequest(
      79             :                     m_aURL, inHostName, inRealm, inoutUserName,
      80             :                     outPassWord, OUString(),
      81             :                     true /*bAllowPersistentStoring*/,
      82           0 :                     bCanUseSystemCredentials );
      83           0 :             xIH->handle( xRequest.get() );
      84             : 
      85             :             rtl::Reference< ucbhelper::InteractionContinuation > xSelection
      86           0 :                 = xRequest->getSelection();
      87             : 
      88           0 :             if ( xSelection.is() )
      89             :             {
      90             :                 // Handler handled the request.
      91             :                 uno::Reference< task::XInteractionAbort > xAbort(
      92           0 :                     xSelection.get(), uno::UNO_QUERY );
      93           0 :                 if ( !xAbort.is() )
      94             :                 {
      95             :                     const rtl::Reference<
      96             :                         ucbhelper::InteractionSupplyAuthentication > & xSupp
      97           0 :                         = xRequest->getAuthenticationSupplier();
      98             : 
      99           0 :                     sal_Bool bUseSystemCredentials = sal_False;
     100             : 
     101           0 :                     if ( bCanUseSystemCredentials )
     102             :                         bUseSystemCredentials
     103           0 :                             = xSupp->getUseSystemCredentials();
     104             : 
     105           0 :                     if ( bUseSystemCredentials )
     106             :                     {
     107             :                         // This is the (strange) way to tell neon to use
     108             :                         // system credentials.
     109           0 :                         inoutUserName = OUString();
     110           0 :                         outPassWord   = OUString();
     111             :                     }
     112             :                     else
     113             :                     {
     114           0 :                         inoutUserName = xSupp->getUserName();
     115           0 :                         outPassWord   = xSupp->getPassword();
     116             :                     }
     117             : 
     118             :                     // #102871# - Remember username and password.
     119           0 :                     m_aPrevUsername = inoutUserName;
     120           0 :                     m_aPrevPassword = outPassWord;
     121             : 
     122             :                     // go on.
     123           0 :                     return 0;
     124           0 :                 }
     125           0 :             }
     126           0 :         }
     127             :     }
     128             :     // Abort.
     129           0 :     return -1;
     130             : }
     131             : 
     132             : 
     133             : 
     134             : 
     135             : // DAVResourceAccess Implementation.
     136             : 
     137             : 
     138             : 
     139             : 
     140             : 
     141           0 : DAVResourceAccess::DAVResourceAccess(
     142             :     const uno::Reference< uno::XComponentContext > & rxContext,
     143             :     rtl::Reference< DAVSessionFactory > const & rSessionFactory,
     144             :     const OUString & rURL )
     145             : : m_aURL( rURL ),
     146             :   m_xSessionFactory( rSessionFactory ),
     147           0 :   m_xContext( rxContext )
     148             : {
     149           0 : }
     150             : 
     151             : 
     152           0 : DAVResourceAccess::DAVResourceAccess( const DAVResourceAccess & rOther )
     153             : : m_aURL( rOther.m_aURL ),
     154             :   m_aPath( rOther.m_aPath ),
     155             :   m_aFlags( rOther.m_aFlags ),
     156             :   m_xSession( rOther.m_xSession ),
     157             :   m_xSessionFactory( rOther.m_xSessionFactory ),
     158             :   m_xContext( rOther.m_xContext ),
     159           0 :   m_aRedirectURIs( rOther.m_aRedirectURIs )
     160             : {
     161           0 : }
     162             : 
     163             : 
     164           0 : DAVResourceAccess & DAVResourceAccess::operator=(
     165             :     const DAVResourceAccess & rOther )
     166             : {
     167           0 :     m_aURL            = rOther.m_aURL;
     168           0 :     m_aPath           = rOther.m_aPath;
     169           0 :     m_aFlags          = rOther.m_aFlags;
     170           0 :     m_xSession        = rOther.m_xSession;
     171           0 :     m_xSessionFactory = rOther.m_xSessionFactory;
     172           0 :     m_xContext        = rOther.m_xContext;
     173           0 :     m_aRedirectURIs   = rOther.m_aRedirectURIs;
     174             : 
     175           0 :     return *this;
     176             : }
     177             : 
     178             : #if 0 // currently not used, but please don't remove code
     179             : 
     180             : void DAVResourceAccess::OPTIONS(
     181             :     DAVCapabilities & rCapabilities,
     182             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     183             :   throw( DAVException )
     184             : {
     185             :     initialize();
     186             : 
     187             :     bool bRetry;
     188             :     int errorCount = 0;
     189             :     do
     190             :     {
     191             :         bRetry = false;
     192             :         try
     193             :         {
     194             :             DAVRequestHeaders aHeaders;
     195             :             getUserRequestHeaders( xEnv,
     196             :                                    getRequestURI(),
     197             :                                    OUString( "OPTIONS" ),
     198             :                                    aHeaders );
     199             : 
     200             :             m_xSession->OPTIONS( getRequestURI(),
     201             :                                  rCapabilities,
     202             :                                  DAVRequestEnvironment(
     203             :                                      getRequestURI(),
     204             :                                      new DAVAuthListener_Impl( xEnv, m_aURL ),
     205             :                                      aHeaders, xEnv) );
     206             :         }
     207             :         catch ( const DAVException & e )
     208             :         {
     209             :             errorCount++;
     210             :             bRetry = handleException( e, errorCount );
     211             :             if ( !bRetry )
     212             :                 throw;
     213             :         }
     214             :     }
     215             :     while ( bRetry );
     216             : }
     217             : #endif
     218             : 
     219             : 
     220           0 : void DAVResourceAccess::PROPFIND(
     221             :     const Depth nDepth,
     222             :     const std::vector< OUString > & rPropertyNames,
     223             :     std::vector< DAVResource > & rResources,
     224             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     225             :   throw( DAVException )
     226             : {
     227           0 :     initialize();
     228             : 
     229           0 :     int errorCount = 0;
     230             :     bool bRetry;
     231           0 :     do
     232             :     {
     233           0 :         bRetry = false;
     234             :         try
     235             :         {
     236           0 :             DAVRequestHeaders aHeaders;
     237             : 
     238             :             getUserRequestHeaders( xEnv,
     239           0 :                                    getRequestURI(),
     240             :                                    ucb::WebDAVHTTPMethod_PROPFIND,
     241           0 :                                    aHeaders );
     242             : 
     243           0 :             m_xSession->PROPFIND( getRequestURI(),
     244             :                                   nDepth,
     245             :                                   rPropertyNames,
     246             :                                   rResources,
     247             :                                   DAVRequestEnvironment(
     248           0 :                                       getRequestURI(),
     249           0 :                                       new DAVAuthListener_Impl( xEnv, m_aURL ),
     250           0 :                                       aHeaders, xEnv ) );
     251             :         }
     252           0 :         catch ( const DAVException & e )
     253             :         {
     254           0 :             errorCount++;
     255           0 :             bRetry = handleException( e, errorCount );
     256           0 :             if ( !bRetry )
     257           0 :                 throw;
     258             :         }
     259             :     }
     260             :     while ( bRetry );
     261           0 : }
     262             : 
     263             : 
     264           0 : void DAVResourceAccess::PROPFIND(
     265             :     const Depth nDepth,
     266             :     std::vector< DAVResourceInfo > & rResInfo,
     267             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     268             :   throw( DAVException )
     269             : {
     270           0 :     initialize();
     271             : 
     272           0 :     int errorCount = 0;
     273             :     bool bRetry;
     274           0 :     do
     275             :     {
     276           0 :         bRetry = false;
     277             :         try
     278             :         {
     279           0 :             DAVRequestHeaders aHeaders;
     280             :             getUserRequestHeaders( xEnv,
     281           0 :                                    getRequestURI(),
     282             :                                    ucb::WebDAVHTTPMethod_PROPFIND,
     283           0 :                                    aHeaders );
     284             : 
     285           0 :             m_xSession->PROPFIND( getRequestURI(),
     286             :                                   nDepth,
     287             :                                   rResInfo,
     288             :                                   DAVRequestEnvironment(
     289           0 :                                       getRequestURI(),
     290           0 :                                       new DAVAuthListener_Impl( xEnv, m_aURL ),
     291           0 :                                       aHeaders, xEnv ) ) ;
     292             :         }
     293           0 :         catch ( const DAVException & e )
     294             :         {
     295           0 :             errorCount++;
     296           0 :             bRetry = handleException( e, errorCount );
     297           0 :             if ( !bRetry )
     298           0 :                 throw;
     299             :         }
     300             :     }
     301             :     while ( bRetry );
     302           0 : }
     303             : 
     304             : 
     305           0 : void DAVResourceAccess::PROPPATCH(
     306             :     const std::vector< ProppatchValue >& rValues,
     307             :     const uno::Reference< ucb::XCommandEnvironment >& xEnv )
     308             :   throw( DAVException )
     309             : {
     310           0 :     initialize();
     311             : 
     312           0 :     int errorCount = 0;
     313             :     bool bRetry;
     314           0 :     do
     315             :     {
     316           0 :         bRetry = false;
     317             :         try
     318             :         {
     319           0 :             DAVRequestHeaders aHeaders;
     320             :             getUserRequestHeaders( xEnv,
     321           0 :                                    getRequestURI(),
     322             :                                    ucb::WebDAVHTTPMethod_PROPPATCH,
     323           0 :                                    aHeaders );
     324             : 
     325           0 :             m_xSession->PROPPATCH( getRequestURI(),
     326             :                                    rValues,
     327             :                                    DAVRequestEnvironment(
     328           0 :                                        getRequestURI(),
     329           0 :                                        new DAVAuthListener_Impl( xEnv, m_aURL ),
     330           0 :                                        aHeaders, xEnv ) );
     331             :         }
     332           0 :         catch ( const DAVException & e )
     333             :         {
     334           0 :             errorCount++;
     335           0 :             bRetry = handleException( e, errorCount );
     336           0 :             if ( !bRetry )
     337           0 :                 throw;
     338             :         }
     339             :     }
     340             :     while ( bRetry );
     341           0 : }
     342             : 
     343             : 
     344           0 : void DAVResourceAccess::HEAD(
     345             :     const std::vector< OUString > & rHeaderNames,
     346             :     DAVResource & rResource,
     347             :     const uno::Reference< ucb::XCommandEnvironment >& xEnv )
     348             :   throw( DAVException )
     349             : {
     350           0 :     initialize();
     351             : 
     352           0 :     int errorCount = 0;
     353             :     bool bRetry;
     354           0 :     do
     355             :     {
     356           0 :         bRetry = false;
     357             :         try
     358             :         {
     359           0 :             DAVRequestHeaders aHeaders;
     360             :             getUserRequestHeaders( xEnv,
     361           0 :                                    getRequestURI(),
     362             :                                    ucb::WebDAVHTTPMethod_HEAD,
     363           0 :                                    aHeaders );
     364             : 
     365           0 :             m_xSession->HEAD( getRequestURI(),
     366             :                               rHeaderNames,
     367             :                               rResource,
     368             :                               DAVRequestEnvironment(
     369           0 :                                   getRequestURI(),
     370           0 :                                   new DAVAuthListener_Impl( xEnv, m_aURL ),
     371           0 :                                   aHeaders, xEnv ) );
     372             :         }
     373           0 :         catch ( const DAVException & e )
     374             :         {
     375           0 :             errorCount++;
     376           0 :             bRetry = handleException( e, errorCount );
     377           0 :             if ( !bRetry )
     378           0 :                 throw;
     379             :         }
     380             :     }
     381             :     while ( bRetry );
     382           0 : }
     383             : 
     384             : 
     385           0 : uno::Reference< io::XInputStream > DAVResourceAccess::GET(
     386             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     387             :   throw( DAVException )
     388             : {
     389           0 :     initialize();
     390             : 
     391           0 :     uno::Reference< io::XInputStream > xStream;
     392           0 :     int errorCount = 0;
     393             :     bool bRetry;
     394           0 :     do
     395             :     {
     396           0 :         bRetry = false;
     397             :         try
     398             :         {
     399           0 :             DAVRequestHeaders aHeaders;
     400             :             getUserRequestHeaders( xEnv,
     401           0 :                                    getRequestURI(),
     402             :                                    ucb::WebDAVHTTPMethod_GET,
     403           0 :                                    aHeaders );
     404             : 
     405           0 :             xStream = m_xSession->GET( getRequestURI(),
     406             :                                        DAVRequestEnvironment(
     407           0 :                                            getRequestURI(),
     408             :                                            new DAVAuthListener_Impl(
     409           0 :                                                xEnv, m_aURL ),
     410           0 :                                            aHeaders, xEnv ) );
     411             :         }
     412           0 :         catch ( const DAVException & e )
     413             :         {
     414           0 :             errorCount++;
     415           0 :             bRetry = handleException( e, errorCount );
     416           0 :             if ( !bRetry )
     417           0 :                 throw;
     418             :         }
     419             :     }
     420             :     while ( bRetry );
     421             : 
     422           0 :     return xStream;
     423             : }
     424             : 
     425             : 
     426           0 : void DAVResourceAccess::GET(
     427             :     uno::Reference< io::XOutputStream > & rStream,
     428             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     429             :   throw( DAVException )
     430             : {
     431           0 :     initialize();
     432             : 
     433           0 :     int errorCount = 0;
     434             :     bool bRetry;
     435           0 :     do
     436             :     {
     437           0 :         bRetry = false;
     438             :         try
     439             :         {
     440           0 :             DAVRequestHeaders aHeaders;
     441             :             getUserRequestHeaders( xEnv,
     442           0 :                                    getRequestURI(),
     443             :                                    ucb::WebDAVHTTPMethod_GET,
     444           0 :                                    aHeaders );
     445             : 
     446           0 :             m_xSession->GET( getRequestURI(),
     447             :                              rStream,
     448             :                              DAVRequestEnvironment(
     449           0 :                                  getRequestURI(),
     450           0 :                                  new DAVAuthListener_Impl( xEnv, m_aURL ),
     451           0 :                                  aHeaders, xEnv ) );
     452             :         }
     453           0 :         catch ( const DAVException & e )
     454             :         {
     455           0 :             errorCount++;
     456           0 :             bRetry = handleException( e, errorCount );
     457           0 :             if ( !bRetry )
     458           0 :                 throw;
     459             :         }
     460             :     }
     461             :     while ( bRetry );
     462           0 : }
     463             : 
     464             : 
     465           0 : uno::Reference< io::XInputStream > DAVResourceAccess::GET(
     466             :     const std::vector< OUString > & rHeaderNames,
     467             :     DAVResource & rResource,
     468             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     469             :   throw( DAVException )
     470             : {
     471           0 :     initialize();
     472             : 
     473           0 :     uno::Reference< io::XInputStream > xStream;
     474           0 :     int errorCount = 0;
     475             :     bool bRetry;
     476           0 :     do
     477             :     {
     478           0 :         bRetry = false;
     479             :         try
     480             :         {
     481           0 :             DAVRequestHeaders aHeaders;
     482             :             getUserRequestHeaders( xEnv,
     483           0 :                                    getRequestURI(),
     484             :                                    ucb::WebDAVHTTPMethod_GET,
     485           0 :                                    aHeaders );
     486             : 
     487           0 :             xStream = m_xSession->GET( getRequestURI(),
     488             :                                        rHeaderNames,
     489             :                                        rResource,
     490             :                                        DAVRequestEnvironment(
     491           0 :                                            getRequestURI(),
     492             :                                            new DAVAuthListener_Impl(
     493           0 :                                                xEnv, m_aURL ),
     494           0 :                                            aHeaders, xEnv ) );
     495             :         }
     496           0 :         catch ( const DAVException & e )
     497             :         {
     498           0 :             errorCount++;
     499           0 :             bRetry = handleException( e, errorCount );
     500           0 :             if ( !bRetry )
     501           0 :                 throw;
     502             :         }
     503             :     }
     504             :     while ( bRetry );
     505             : 
     506           0 :     return xStream;
     507             : }
     508             : 
     509             : 
     510           0 : void DAVResourceAccess::GET(
     511             :     uno::Reference< io::XOutputStream > & rStream,
     512             :     const std::vector< OUString > & rHeaderNames,
     513             :     DAVResource & rResource,
     514             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     515             :   throw( DAVException )
     516             : {
     517           0 :     initialize();
     518             : 
     519             :     bool bRetry;
     520           0 :     int errorCount = 0;
     521           0 :     do
     522             :     {
     523           0 :         bRetry = false;
     524             :         try
     525             :         {
     526           0 :             DAVRequestHeaders aHeaders;
     527             :             getUserRequestHeaders( xEnv,
     528           0 :                                    getRequestURI(),
     529             :                                    ucb::WebDAVHTTPMethod_GET,
     530           0 :                                    aHeaders );
     531             : 
     532           0 :             m_xSession->GET( getRequestURI(),
     533             :                              rStream,
     534             :                              rHeaderNames,
     535             :                              rResource,
     536             :                              DAVRequestEnvironment(
     537           0 :                                  getRequestURI(),
     538           0 :                                  new DAVAuthListener_Impl( xEnv, m_aURL ),
     539           0 :                                  aHeaders, xEnv ) );
     540             :         }
     541           0 :         catch ( const DAVException & e )
     542             :         {
     543           0 :             errorCount++;
     544           0 :             bRetry = handleException( e, errorCount );
     545           0 :             if ( !bRetry )
     546           0 :                 throw;
     547             :         }
     548             :     }
     549             :     while ( bRetry );
     550           0 : }
     551             : 
     552             : 
     553           0 : void DAVResourceAccess::abort()
     554             :   throw( DAVException )
     555             : {
     556           0 :     initialize();
     557           0 :     m_xSession->abort();
     558           0 : }
     559             : 
     560             : 
     561             : namespace {
     562             : 
     563           0 :     void resetInputStream( const uno::Reference< io::XInputStream > & rStream )
     564             :         throw( DAVException )
     565             :     {
     566             :         try
     567             :         {
     568             :             uno::Reference< io::XSeekable > xSeekable(
     569           0 :                 rStream, uno::UNO_QUERY );
     570           0 :             if ( xSeekable.is() )
     571             :             {
     572           0 :                 xSeekable->seek( 0 );
     573           0 :                 return;
     574           0 :             }
     575             :         }
     576           0 :         catch ( lang::IllegalArgumentException const & )
     577             :         {
     578             :         }
     579           0 :         catch ( io::IOException const & )
     580             :         {
     581             :         }
     582             : 
     583           0 :         throw DAVException( DAVException::DAV_INVALID_ARG );
     584             :     }
     585             : 
     586             : } // namespace
     587             : 
     588             : 
     589           0 : void DAVResourceAccess::PUT(
     590             :     const uno::Reference< io::XInputStream > & rStream,
     591             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     592             :   throw( DAVException )
     593             : {
     594           0 :     initialize();
     595             : 
     596             :     // Make stream seekable, if it not. Needed, if request must be retried.
     597             :     uno::Reference< io::XInputStream > xSeekableStream
     598             :         = comphelper::OSeekableInputWrapper::CheckSeekableCanWrap(
     599           0 :             rStream, m_xContext );
     600             : 
     601           0 :     int errorCount = 0;
     602           0 :     bool bRetry = false;
     603           0 :     do
     604             :     {
     605           0 :         if ( bRetry )
     606           0 :             resetInputStream( xSeekableStream );
     607             : 
     608           0 :         bRetry = false;
     609             :         try
     610             :         {
     611           0 :             DAVRequestHeaders aHeaders;
     612             :             getUserRequestHeaders( xEnv,
     613           0 :                                    getRequestURI(),
     614             :                                    ucb::WebDAVHTTPMethod_PUT,
     615           0 :                                    aHeaders );
     616             : 
     617           0 :             m_xSession->PUT( getRequestURI(),
     618             :                              xSeekableStream,
     619             :                              DAVRequestEnvironment(
     620           0 :                                  getRequestURI(),
     621           0 :                                  new DAVAuthListener_Impl( xEnv, m_aURL ),
     622           0 :                                  aHeaders, xEnv ) );
     623             :         }
     624           0 :         catch ( const DAVException & e )
     625             :         {
     626           0 :             errorCount++;
     627           0 :             bRetry = handleException( e, errorCount );
     628           0 :             if ( !bRetry )
     629           0 :                 throw;
     630             :         }
     631             :     }
     632           0 :     while ( bRetry );
     633           0 : }
     634             : 
     635             : 
     636           0 : uno::Reference< io::XInputStream > DAVResourceAccess::POST(
     637             :     const OUString & rContentType,
     638             :     const OUString & rReferer,
     639             :     const uno::Reference< io::XInputStream > & rInputStream,
     640             :     const uno::Reference< ucb::XCommandEnvironment >& xEnv )
     641             :   throw ( DAVException )
     642             : {
     643           0 :     initialize();
     644             : 
     645             :     // Make stream seekable, if it not. Needed, if request must be retried.
     646             :     uno::Reference< io::XInputStream > xSeekableStream
     647             :         = comphelper::OSeekableInputWrapper::CheckSeekableCanWrap(
     648           0 :             rInputStream, m_xContext );
     649             : 
     650           0 :     uno::Reference< io::XInputStream > xStream;
     651           0 :     int errorCount = 0;
     652           0 :     bool bRetry = false;
     653           0 :     do
     654             :     {
     655           0 :         if ( bRetry )
     656             :         {
     657           0 :             resetInputStream( xSeekableStream );
     658           0 :             bRetry = false;
     659             :         }
     660             : 
     661             :         try
     662             :         {
     663           0 :             DAVRequestHeaders aHeaders;
     664             :             getUserRequestHeaders( xEnv,
     665           0 :                                    getRequestURI(),
     666             :                                    ucb::WebDAVHTTPMethod_POST,
     667           0 :                                    aHeaders );
     668             : 
     669           0 :             xStream = m_xSession->POST( getRequestURI(),
     670             :                                         rContentType,
     671             :                                         rReferer,
     672             :                                         xSeekableStream,
     673             :                                         DAVRequestEnvironment(
     674           0 :                                             getRequestURI(),
     675             :                                             new DAVAuthListener_Impl(
     676           0 :                                                 xEnv, m_aURL ),
     677           0 :                                             aHeaders, xEnv ) );
     678             :         }
     679           0 :         catch ( const DAVException & e )
     680             :         {
     681           0 :             errorCount++;
     682           0 :             bRetry = handleException( e, errorCount );
     683           0 :             if ( !bRetry )
     684           0 :                 throw;
     685             : 
     686           0 :             if ( e.getError() == DAVException::DAV_HTTP_REDIRECT )
     687             :             {
     688             :                 // #i74980# - Upon POST redirect, do a GET.
     689           0 :                 return GET( xEnv );
     690             :             }
     691           0 :         }
     692             :     }
     693             :     while ( bRetry );
     694             : 
     695           0 :     return xStream;
     696             : }
     697             : 
     698             : 
     699           0 : void DAVResourceAccess::POST(
     700             :     const OUString & rContentType,
     701             :     const OUString & rReferer,
     702             :     const uno::Reference< io::XInputStream > & rInputStream,
     703             :     uno::Reference< io::XOutputStream > & rOutputStream,
     704             :     const uno::Reference< ucb::XCommandEnvironment >& xEnv )
     705             :   throw ( DAVException )
     706             : {
     707           0 :     initialize();
     708             : 
     709             :     // Make stream seekable, if it not. Needed, if request must be retried.
     710             :     uno::Reference< io::XInputStream > xSeekableStream
     711             :         = comphelper::OSeekableInputWrapper::CheckSeekableCanWrap(
     712           0 :             rInputStream, m_xContext );
     713             : 
     714           0 :     int errorCount = 0;
     715           0 :     bool bRetry  = false;
     716           0 :     do
     717             :     {
     718           0 :         if ( bRetry )
     719             :         {
     720           0 :             resetInputStream( xSeekableStream );
     721           0 :             bRetry = false;
     722             :         }
     723             : 
     724             :         try
     725             :         {
     726           0 :             DAVRequestHeaders aHeaders;
     727             :             getUserRequestHeaders( xEnv,
     728           0 :                                    getRequestURI(),
     729             :                                    ucb::WebDAVHTTPMethod_POST,
     730           0 :                                    aHeaders );
     731             : 
     732           0 :             m_xSession->POST( getRequestURI(),
     733             :                               rContentType,
     734             :                               rReferer,
     735             :                               xSeekableStream,
     736             :                               rOutputStream,
     737             :                               DAVRequestEnvironment(
     738           0 :                                   getRequestURI(),
     739           0 :                                   new DAVAuthListener_Impl( xEnv, m_aURL ),
     740           0 :                                   aHeaders, xEnv ) );
     741             :         }
     742           0 :         catch ( const DAVException & e )
     743             :         {
     744           0 :             errorCount++;
     745           0 :             bRetry = handleException( e, errorCount );
     746           0 :             if ( !bRetry )
     747           0 :                 throw;
     748             : 
     749           0 :             if ( e.getError() == DAVException::DAV_HTTP_REDIRECT )
     750             :             {
     751             :                 // #i74980# - Upon POST redirect, do a GET.
     752           0 :                 GET( rOutputStream, xEnv );
     753           0 :                 return;
     754             :             }
     755           0 :         }
     756             :     }
     757           0 :     while ( bRetry );
     758             : }
     759             : 
     760             : 
     761           0 : void DAVResourceAccess::MKCOL(
     762             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     763             :   throw( DAVException )
     764             : {
     765           0 :     initialize();
     766             : 
     767           0 :     int errorCount = 0;
     768             :     bool bRetry;
     769           0 :     do
     770             :     {
     771           0 :         bRetry = false;
     772             :         try
     773             :         {
     774           0 :             DAVRequestHeaders aHeaders;
     775             :             getUserRequestHeaders( xEnv,
     776           0 :                                    getRequestURI(),
     777             :                                    ucb::WebDAVHTTPMethod_MKCOL,
     778           0 :                                    aHeaders );
     779             : 
     780           0 :             m_xSession->MKCOL( getRequestURI(),
     781             :                                DAVRequestEnvironment(
     782           0 :                                    getRequestURI(),
     783           0 :                                    new DAVAuthListener_Impl( xEnv, m_aURL ),
     784           0 :                                    aHeaders, xEnv ) );
     785             :         }
     786           0 :         catch ( const DAVException & e )
     787             :         {
     788           0 :             errorCount++;
     789           0 :             bRetry = handleException( e, errorCount );
     790           0 :             if ( !bRetry )
     791           0 :                 throw;
     792             :         }
     793             :     }
     794             :     while ( bRetry );
     795           0 : }
     796             : 
     797             : 
     798           0 : void DAVResourceAccess::COPY(
     799             :     const OUString & rSourcePath,
     800             :     const OUString & rDestinationURI,
     801             :     sal_Bool bOverwrite,
     802             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     803             :   throw( DAVException )
     804             : {
     805           0 :     initialize();
     806             : 
     807           0 :     int errorCount = 0;
     808             :     bool bRetry;
     809           0 :     do
     810             :     {
     811           0 :         bRetry = false;
     812             :         try
     813             :         {
     814           0 :             DAVRequestHeaders aHeaders;
     815             :             getUserRequestHeaders( xEnv,
     816           0 :                                    getRequestURI(),
     817             :                                    ucb::WebDAVHTTPMethod_COPY,
     818           0 :                                    aHeaders );
     819             : 
     820           0 :             m_xSession->COPY( rSourcePath,
     821             :                               rDestinationURI,
     822             :                               DAVRequestEnvironment(
     823           0 :                                   getRequestURI(),
     824           0 :                                   new DAVAuthListener_Impl( xEnv, m_aURL ),
     825             :                                   aHeaders, xEnv ),
     826           0 :                               bOverwrite );
     827             :         }
     828           0 :         catch ( const DAVException & e )
     829             :         {
     830           0 :             errorCount++;
     831           0 :             bRetry = handleException( e, errorCount );
     832           0 :             if ( !bRetry )
     833           0 :                 throw;
     834             :         }
     835             :     }
     836             :     while ( bRetry );
     837           0 : }
     838             : 
     839             : 
     840           0 : void DAVResourceAccess::MOVE(
     841             :     const OUString & rSourcePath,
     842             :     const OUString & rDestinationURI,
     843             :     sal_Bool bOverwrite,
     844             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     845             :   throw( DAVException )
     846             : {
     847           0 :     initialize();
     848             : 
     849           0 :     int errorCount = 0;
     850             :     bool bRetry;
     851           0 :     do
     852             :     {
     853           0 :         bRetry = false;
     854             :         try
     855             :         {
     856           0 :             DAVRequestHeaders aHeaders;
     857             :             getUserRequestHeaders( xEnv,
     858           0 :                                    getRequestURI(),
     859             :                                    ucb::WebDAVHTTPMethod_MOVE,
     860           0 :                                    aHeaders );
     861             : 
     862           0 :             m_xSession->MOVE( rSourcePath,
     863             :                               rDestinationURI,
     864             :                               DAVRequestEnvironment(
     865           0 :                                   getRequestURI(),
     866           0 :                                   new DAVAuthListener_Impl( xEnv, m_aURL ),
     867             :                                   aHeaders, xEnv ),
     868           0 :                               bOverwrite );
     869             :         }
     870           0 :         catch ( const DAVException & e )
     871             :         {
     872           0 :             errorCount++;
     873           0 :             bRetry = handleException( e, errorCount );
     874           0 :             if ( !bRetry )
     875           0 :                 throw;
     876             :         }
     877             :     }
     878             :     while ( bRetry );
     879           0 : }
     880             : 
     881             : 
     882           0 : void DAVResourceAccess::DESTROY(
     883             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     884             :   throw( DAVException )
     885             : {
     886           0 :     initialize();
     887             : 
     888           0 :     int errorCount = 0;
     889             :     bool bRetry;
     890           0 :     do
     891             :     {
     892           0 :         bRetry = false;
     893             :         try
     894             :         {
     895           0 :             DAVRequestHeaders aHeaders;
     896             :             getUserRequestHeaders( xEnv,
     897           0 :                                    getRequestURI(),
     898             :                                    ucb::WebDAVHTTPMethod_DELETE,
     899           0 :                                    aHeaders );
     900             : 
     901           0 :             m_xSession->DESTROY( getRequestURI(),
     902             :                                  DAVRequestEnvironment(
     903           0 :                                      getRequestURI(),
     904           0 :                                      new DAVAuthListener_Impl( xEnv, m_aURL ),
     905           0 :                                      aHeaders, xEnv ) );
     906             :         }
     907           0 :         catch ( const DAVException & e )
     908             :         {
     909           0 :             errorCount++;
     910           0 :             bRetry = handleException( e, errorCount );
     911           0 :             if ( !bRetry )
     912           0 :                 throw;
     913             :         }
     914             :     }
     915             :     while ( bRetry );
     916           0 : }
     917             : 
     918             : 
     919             : // set new lock.
     920           0 : void DAVResourceAccess::LOCK(
     921             :     ucb::Lock & inLock,
     922             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     923             :   throw ( DAVException )
     924             : {
     925           0 :     initialize();
     926             : 
     927           0 :     int errorCount = 0;
     928             :     bool bRetry;
     929           0 :     do
     930             :     {
     931           0 :         bRetry = false;
     932             :         try
     933             :         {
     934           0 :             DAVRequestHeaders aHeaders;
     935             :             getUserRequestHeaders( xEnv,
     936           0 :                                    getRequestURI(),
     937             :                                    ucb::WebDAVHTTPMethod_LOCK,
     938           0 :                                    aHeaders );
     939             : 
     940           0 :             m_xSession->LOCK( getRequestURI(),
     941             :                               inLock,
     942             :                               DAVRequestEnvironment(
     943           0 :                                   getRequestURI(),
     944           0 :                                   new DAVAuthListener_Impl( xEnv, m_aURL ),
     945           0 :                                   aHeaders, xEnv ) );
     946             :         }
     947           0 :         catch ( const DAVException & e )
     948             :         {
     949           0 :             errorCount++;
     950           0 :             bRetry = handleException( e, errorCount );
     951           0 :             if ( !bRetry )
     952           0 :                 throw;
     953             :         }
     954             :     }
     955             :     while ( bRetry );
     956           0 : }
     957             : 
     958             : #if 0 // currently not used, but please don't remove code
     959             : 
     960             : // refresh existing lock.
     961             : sal_Int64 DAVResourceAccess::LOCK(
     962             :     sal_Int64 nTimeout,
     963             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
     964             :   throw ( DAVException )
     965             : {
     966             :     initialize();
     967             : 
     968             :     sal_Int64 nNewTimeout = 0;
     969             :     int errorCount = 0;
     970             :     bool bRetry;
     971             :     do
     972             :     {
     973             :         bRetry = false;
     974             :         try
     975             :         {
     976             :             DAVRequestHeaders aHeaders;
     977             :             getUserRequestHeaders( xEnv,
     978             :                                    getRequestURI(),
     979             :                                    ucb::WebDAVHTTPMethod_LOCK,
     980             :                                    aHeaders );
     981             : 
     982             :             nNewTimeout = m_xSession->LOCK( getRequestURI(),
     983             :                                             nTimeout,
     984             :                                             DAVRequestEnvironment(
     985             :                                                 getRequestURI(),
     986             :                                                 new DAVAuthListener_Impl(
     987             :                                                     xEnv, m_aURL ),
     988             :                                             aHeaders, xEnv ) );
     989             :         }
     990             :         catch ( const DAVException & e )
     991             :         {
     992             :             errorCount++;
     993             :             bRetry = handleException( e, errorCount );
     994             :             if ( !bRetry )
     995             :                 throw;
     996             :         }
     997             :     }
     998             :     while ( bRetry );
     999             : 
    1000             :     return nNewTimeout;
    1001             : }
    1002             : #endif
    1003             : 
    1004             : 
    1005           0 : void DAVResourceAccess::UNLOCK(
    1006             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv )
    1007             :   throw ( DAVException )
    1008             : {
    1009           0 :     initialize();
    1010             : 
    1011           0 :     int errorCount = 0;
    1012             :     bool bRetry;
    1013           0 :     do
    1014             :     {
    1015           0 :         bRetry = false;
    1016             :         try
    1017             :         {
    1018           0 :             DAVRequestHeaders aHeaders;
    1019             :             getUserRequestHeaders( xEnv,
    1020           0 :                                    getRequestURI(),
    1021             :                                    ucb::WebDAVHTTPMethod_UNLOCK,
    1022           0 :                                    aHeaders );
    1023             : 
    1024           0 :             m_xSession->UNLOCK( getRequestURI(),
    1025             :                                 DAVRequestEnvironment(
    1026           0 :                                     getRequestURI(),
    1027           0 :                                     new DAVAuthListener_Impl( xEnv, m_aURL ),
    1028           0 :                                     aHeaders, xEnv ) );
    1029             :         }
    1030           0 :         catch ( const DAVException & e )
    1031             :         {
    1032           0 :             errorCount++;
    1033           0 :             bRetry = handleException( e, errorCount );
    1034           0 :             if ( !bRetry )
    1035           0 :                 throw;
    1036             :         }
    1037             :     }
    1038             :     while ( bRetry );
    1039           0 : }
    1040             : 
    1041             : 
    1042           0 : void DAVResourceAccess::setFlags( const uno::Sequence< beans::NamedValue >& rFlags )
    1043             :     throw ( DAVException )
    1044             : {
    1045           0 :     osl::Guard< osl::Mutex > aGuard( m_aMutex );
    1046           0 :     m_aFlags = rFlags;
    1047           0 : }
    1048             : 
    1049             : 
    1050           0 : void DAVResourceAccess::setURL( const OUString & rNewURL )
    1051             :     throw( DAVException )
    1052             : {
    1053           0 :     osl::Guard< osl::Mutex > aGuard( m_aMutex );
    1054           0 :     m_aURL  = rNewURL;
    1055           0 :     m_aPath = OUString(); // Next initialize() will create new session.
    1056           0 : }
    1057             : 
    1058             : 
    1059             : // init dav session and path
    1060           0 : void DAVResourceAccess::initialize()
    1061             :     throw ( DAVException )
    1062             : {
    1063           0 :     osl::Guard< osl::Mutex > aGuard( m_aMutex );
    1064           0 :     if ( m_aPath.isEmpty() )
    1065             :     {
    1066           0 :         NeonUri aURI( m_aURL );
    1067           0 :         OUString aPath( aURI.GetPath() );
    1068             : 
    1069             :         /* #134089# - Check URI */
    1070           0 :         if ( aPath.isEmpty() )
    1071           0 :             throw DAVException( DAVException::DAV_INVALID_ARG );
    1072             : 
    1073             :         /* #134089# - Check URI */
    1074           0 :         if ( aURI.GetHost().isEmpty() )
    1075           0 :             throw DAVException( DAVException::DAV_INVALID_ARG );
    1076             : 
    1077           0 :         if ( !m_xSession.is() || !m_xSession->CanUse( m_aURL, m_aFlags ) )
    1078             :         {
    1079           0 :             m_xSession.clear();
    1080             : 
    1081             :             // create new webdav session
    1082             :             m_xSession
    1083           0 :                 = m_xSessionFactory->createDAVSession( m_aURL, m_aFlags, m_xContext );
    1084             : 
    1085           0 :             if ( !m_xSession.is() )
    1086           0 :                 return;
    1087             :         }
    1088             : 
    1089             :         // Own URI is needed for redirect cycle detection.
    1090           0 :         m_aRedirectURIs.push_back( aURI );
    1091             : 
    1092             :         // Success.
    1093           0 :         m_aPath = aPath;
    1094             : 
    1095             :         // Not only the path has to be encoded
    1096           0 :         m_aURL = aURI.GetURI();
    1097           0 :     }
    1098             : }
    1099             : 
    1100             : 
    1101           0 : const OUString & DAVResourceAccess::getRequestURI() const
    1102             : {
    1103             :     OSL_ENSURE( m_xSession.is(),
    1104             :                 "DAVResourceAccess::getRequestURI - Not initialized!" );
    1105             : 
    1106             :     // In case a proxy is used we have to use the absolute URI for a request.
    1107           0 :     if ( m_xSession->UsesProxy() )
    1108           0 :         return m_aURL;
    1109             : 
    1110           0 :     return m_aPath;
    1111             : }
    1112             : 
    1113             : 
    1114             : // static
    1115           0 : void DAVResourceAccess::getUserRequestHeaders(
    1116             :     const uno::Reference< ucb::XCommandEnvironment > & xEnv,
    1117             :     const OUString & rURI,
    1118             :     ucb::WebDAVHTTPMethod eMethod,
    1119             :     DAVRequestHeaders & rRequestHeaders )
    1120             : {
    1121           0 :     if ( xEnv.is() )
    1122             :     {
    1123             :         uno::Reference< ucb::XWebDAVCommandEnvironment > xDAVEnv(
    1124           0 :             xEnv, uno::UNO_QUERY );
    1125             : 
    1126           0 :         if ( xDAVEnv.is() )
    1127             :         {
    1128             :             uno::Sequence< beans::StringPair > aRequestHeaders
    1129           0 :                 = xDAVEnv->getUserRequestHeaders( rURI, eMethod );
    1130             : 
    1131           0 :             for ( sal_Int32 n = 0; n < aRequestHeaders.getLength(); ++n )
    1132             :             {
    1133             :                 rRequestHeaders.push_back(
    1134             :                     DAVRequestHeader(
    1135           0 :                         aRequestHeaders[ n ].First,
    1136           0 :                         aRequestHeaders[ n ].Second ) );
    1137           0 :             }
    1138           0 :         }
    1139             :     }
    1140             : 
    1141             :     // Make sure a User-Agent header is always included, as at least
    1142             :     // en.wikipedia.org:80 forces back 403 "Scripts should use an informative
    1143             :     // User-Agent string with contact information, or they may be IP-blocked
    1144             :     // without notice" otherwise:
    1145           0 :     for ( DAVRequestHeaders::iterator i(rRequestHeaders.begin());
    1146           0 :           i != rRequestHeaders.end(); ++i )
    1147             :     {
    1148           0 :         if ( i->first.equalsIgnoreAsciiCase( "User-Agent" ) )
    1149             :         {
    1150           0 :             return;
    1151             :         }
    1152             :     }
    1153             :     rRequestHeaders.push_back(
    1154           0 :         DAVRequestHeader( "User-Agent", "LibreOffice" ) );
    1155             : }
    1156             : 
    1157             : 
    1158           0 : sal_Bool DAVResourceAccess::detectRedirectCycle(
    1159             :                                 const OUString& rRedirectURL )
    1160             :     throw ( DAVException )
    1161             : {
    1162           0 :     osl::Guard< osl::Mutex > aGuard( m_aMutex );
    1163             : 
    1164           0 :     NeonUri aUri( rRedirectURL );
    1165             : 
    1166           0 :     std::vector< NeonUri >::const_iterator it  = m_aRedirectURIs.begin();
    1167           0 :     std::vector< NeonUri >::const_iterator end = m_aRedirectURIs.end();
    1168             : 
    1169           0 :     while ( it != end )
    1170             :     {
    1171           0 :         if ( aUri == (*it) )
    1172           0 :             return sal_True;
    1173             : 
    1174           0 :         ++it;
    1175             :     }
    1176             : 
    1177           0 :     return sal_False;
    1178             : }
    1179             : 
    1180             : 
    1181           0 : void DAVResourceAccess::resetUri()
    1182             : {
    1183           0 :     osl::Guard< osl::Mutex > aGuard( m_aMutex );
    1184           0 :     if ( !m_aRedirectURIs.empty() )
    1185             :     {
    1186           0 :         std::vector< NeonUri >::const_iterator it  = m_aRedirectURIs.begin();
    1187             : 
    1188           0 :         NeonUri aUri( (*it) );
    1189           0 :         m_aRedirectURIs.clear();
    1190           0 :         setURL ( aUri.GetURI() );
    1191           0 :         initialize();
    1192           0 :     }
    1193           0 : }
    1194             : 
    1195             : 
    1196           0 : sal_Bool DAVResourceAccess::handleException( const DAVException & e, int errorCount )
    1197             :     throw ( DAVException )
    1198             : {
    1199           0 :     switch ( e.getError() )
    1200             :     {
    1201             :     case DAVException::DAV_HTTP_REDIRECT:
    1202           0 :         if ( !detectRedirectCycle( e.getData() ) )
    1203             :         {
    1204             :             // set new URL and path.
    1205           0 :             setURL( e.getData() );
    1206           0 :             initialize();
    1207           0 :             return sal_True;
    1208             :         }
    1209           0 :         return sal_False;
    1210             :     // #67048# copy & paste images doesn't display.
    1211             :     // if we have a bad connection try again. Up to three times.
    1212             :     case DAVException::DAV_HTTP_ERROR:
    1213             :         // retry up to three times, if not a client-side error.
    1214           0 :         if ( ( e.getStatus() < 400 || e.getStatus() >= 500 ) &&
    1215             :              errorCount < 3 )
    1216             :         {
    1217           0 :             return sal_True;
    1218             :         }
    1219           0 :         return sal_False;
    1220             :     // if connection has said retry then retry!
    1221             :     case DAVException::DAV_HTTP_RETRY:
    1222           0 :         return sal_True;
    1223             :     default:
    1224           0 :         return sal_False; // Abort
    1225             :     }
    1226             : }
    1227             : 
    1228             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10