/**************************************************************
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*************************************************************/
// MARKER(update_precomp.py): autogen include statement, do not remove
#include "precompiled_ucb.hxx"
#include "osl/diagnose.h"
#include "com/sun/star/task/XInteractionAbort.hpp"
#include "com/sun/star/ucb/XWebDAVCommandEnvironment.hpp"
#include "ucbhelper/simpleauthenticationrequest.hxx"
#include "comphelper/seekableinput.hxx"
#include "DAVAuthListenerImpl.hxx"
#include "DAVResourceAccess.hxx"
using namespace http_dav_ucp;
using namespace com::sun::star;
//=========================================================================
//=========================================================================
//
// DAVAuthListener_Impl Implementation.
//
//=========================================================================
//=========================================================================
//=========================================================================
// virtual
int DAVAuthListener_Impl::authenticate(
const ::rtl::OUString & inRealm,
const ::rtl::OUString & inHostName,
::rtl::OUString & inoutUserName,
::rtl::OUString & outPassWord,
sal_Bool bCanUseSystemCredentials,
sal_Bool bUsePreviousCredentials )
{
if ( m_xEnv.is() )
{
uno::Reference< task::XInteractionHandler > xIH
= m_xEnv->getInteractionHandler();
if ( xIH.is() )
{
// Providing previously retrieved credentials will cause the password
// container to reject these. Thus, the credential input dialog will be shown again.
// #102871# - Supply username and password from previous try.
// Password container service depends on this!
if ( inoutUserName.getLength() == 0 && bUsePreviousCredentials )
inoutUserName = m_aPrevUsername;
if ( outPassWord.getLength() == 0 && bUsePreviousCredentials )
outPassWord = m_aPrevPassword;
rtl::Reference< ucbhelper::SimpleAuthenticationRequest > xRequest
= new ucbhelper::SimpleAuthenticationRequest(
m_aURL, inHostName, inRealm, inoutUserName,
outPassWord, ::rtl::OUString(),
true /*bAllowPersistentStoring*/,
bCanUseSystemCredentials );
xIH->handle( xRequest.get() );
rtl::Reference< ucbhelper::InteractionContinuation > xSelection
= xRequest->getSelection();
if ( xSelection.is() )
{
// Handler handled the request.
uno::Reference< task::XInteractionAbort > xAbort(
xSelection.get(), uno::UNO_QUERY );
if ( !xAbort.is() )
{
const rtl::Reference<
ucbhelper::InteractionSupplyAuthentication > & xSupp
= xRequest->getAuthenticationSupplier();
sal_Bool bUseSystemCredentials = sal_False;
if ( bCanUseSystemCredentials )
bUseSystemCredentials
= xSupp->getUseSystemCredentials();
if ( bUseSystemCredentials )
{
// This is the (strange) way to tell neon to use
// system credentials.
inoutUserName = rtl::OUString();
outPassWord = rtl::OUString();
}
else
{
inoutUserName = xSupp->getUserName();
outPassWord = xSupp->getPassword();
}
// #102871# - Remember username and password.
m_aPrevUsername = inoutUserName;
m_aPrevPassword = outPassWord;
// go on.
return 0;
}
}
}
}
// Abort.
return -1;
}
//=========================================================================
//=========================================================================
//
// DAVResourceAccess Implementation.
//
//=========================================================================
//=========================================================================
//=========================================================================
DAVResourceAccess::DAVResourceAccess(
const uno::Reference< lang::XMultiServiceFactory > & rSMgr,
rtl::Reference< DAVSessionFactory > const & rSessionFactory,
const rtl::OUString & rURL )
: m_aURL( rURL ),
m_xSessionFactory( rSessionFactory ),
m_xSMgr( rSMgr )
{
}
//=========================================================================
DAVResourceAccess::DAVResourceAccess( const DAVResourceAccess & rOther )
: m_aURL( rOther.m_aURL ),
m_aPath( rOther.m_aPath ),
m_xSession( rOther.m_xSession ),
m_xSessionFactory( rOther.m_xSessionFactory ),
m_xSMgr( rOther.m_xSMgr ),
m_aRedirectURIs( rOther.m_aRedirectURIs )
{
}
//=========================================================================
DAVResourceAccess & DAVResourceAccess::operator=(
const DAVResourceAccess & rOther )
{
m_aURL = rOther.m_aURL;
m_aPath = rOther.m_aPath;
m_xSession = rOther.m_xSession;
m_xSessionFactory = rOther.m_xSessionFactory;
m_xSMgr = rOther.m_xSMgr;
m_aRedirectURIs = rOther.m_aRedirectURIs;
return *this;
}
//=========================================================================
void DAVResourceAccess::PROPFIND(
const Depth nDepth,
const std::vector< rtl::OUString > & rPropertyNames,
std::vector< DAVResource > & rResources,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii(
"PROPFIND" ),
aHeaders );
m_xSession->PROPFIND( getRequestURI(),
nDepth,
rPropertyNames,
rResources,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::PROPFIND(
const Depth nDepth,
std::vector< DAVResourceInfo > & rResInfo,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii(
"PROPFIND" ),
aHeaders );
m_xSession->PROPFIND( getRequestURI(),
nDepth,
rResInfo,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) ) ;
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::PROPPATCH(
const std::vector< ProppatchValue >& rValues,
const uno::Reference< ucb::XCommandEnvironment >& xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii(
"PROPPATCH" ),
aHeaders );
m_xSession->PROPPATCH( getRequestURI(),
rValues,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::HEAD(
const std::vector< rtl::OUString > & rHeaderNames,
DAVResource & rResource,
const uno::Reference< ucb::XCommandEnvironment >& xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "HEAD" ),
aHeaders );
m_xSession->HEAD( getRequestURI(),
rHeaderNames,
rResource,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
uno::Reference< io::XInputStream > DAVResourceAccess::GET(
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
uno::Reference< io::XInputStream > xStream;
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "GET" ),
aHeaders );
xStream = m_xSession->GET( getRequestURI(),
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl(
xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
return xStream;
}
//=========================================================================
void DAVResourceAccess::GET(
uno::Reference< io::XOutputStream > & rStream,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "GET" ),
aHeaders );
m_xSession->GET( getRequestURI(),
rStream,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
uno::Reference< io::XInputStream > DAVResourceAccess::GET(
const std::vector< rtl::OUString > & rHeaderNames,
DAVResource & rResource,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
uno::Reference< io::XInputStream > xStream;
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "GET" ),
aHeaders );
xStream = m_xSession->GET( getRequestURI(),
rHeaderNames,
rResource,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl(
xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
return xStream;
}
//=========================================================================
void DAVResourceAccess::GET(
uno::Reference< io::XOutputStream > & rStream,
const std::vector< rtl::OUString > & rHeaderNames,
DAVResource & rResource,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
bool bRetry;
int errorCount = 0;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "GET" ),
aHeaders );
m_xSession->GET( getRequestURI(),
rStream,
rHeaderNames,
rResource,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::abort()
throw( DAVException )
{
// 17.11.09 (tkr): abort currently disabled caused by issue i106766
// initialize();
// m_xSession->abort();
OSL_TRACE( "Not implemented. -> #i106766#" );
}
//=========================================================================
namespace {
void resetInputStream( const uno::Reference< io::XInputStream > & rStream )
throw( DAVException )
{
try
{
uno::Reference< io::XSeekable > xSeekable(
rStream, uno::UNO_QUERY );
if ( xSeekable.is() )
{
xSeekable->seek( 0 );
return;
}
}
catch ( lang::IllegalArgumentException const & )
{
}
catch ( io::IOException const & )
{
}
throw DAVException( DAVException::DAV_INVALID_ARG );
}
} // namespace
//=========================================================================
void DAVResourceAccess::PUT(
const uno::Reference< io::XInputStream > & rStream,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
// Make stream seekable, if it not. Needed, if request must be retried.
uno::Reference< io::XInputStream > xSeekableStream
= comphelper::OSeekableInputWrapper::CheckSeekableCanWrap(
rStream, m_xSMgr );
int errorCount = 0;
bool bRetry = false;
do
{
if ( bRetry )
resetInputStream( xSeekableStream );
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "PUT" ),
aHeaders );
m_xSession->PUT( getRequestURI(),
xSeekableStream,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
uno::Reference< io::XInputStream > DAVResourceAccess::POST(
const rtl::OUString & rContentType,
const rtl::OUString & rReferer,
const uno::Reference< io::XInputStream > & rInputStream,
const uno::Reference< ucb::XCommandEnvironment >& xEnv )
throw ( DAVException )
{
initialize();
// Make stream seekable, if it not. Needed, if request must be retried.
uno::Reference< io::XInputStream > xSeekableStream
= comphelper::OSeekableInputWrapper::CheckSeekableCanWrap(
rInputStream, m_xSMgr );
uno::Reference< io::XInputStream > xStream;
int errorCount = 0;
bool bRetry = false;
do
{
if ( bRetry )
{
resetInputStream( xSeekableStream );
bRetry = false;
}
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "POST" ),
aHeaders );
xStream = m_xSession->POST( getRequestURI(),
rContentType,
rReferer,
xSeekableStream,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl(
xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
if ( e.getError() == DAVException::DAV_HTTP_REDIRECT )
{
// #i74980# - Upon POST redirect, do a GET.
return GET( xEnv );
}
}
}
while ( bRetry );
return xStream;
}
//=========================================================================
void DAVResourceAccess::POST(
const rtl::OUString & rContentType,
const rtl::OUString & rReferer,
const uno::Reference< io::XInputStream > & rInputStream,
uno::Reference< io::XOutputStream > & rOutputStream,
const uno::Reference< ucb::XCommandEnvironment >& xEnv )
throw ( DAVException )
{
initialize();
// Make stream seekable, if it not. Needed, if request must be retried.
uno::Reference< io::XInputStream > xSeekableStream
= comphelper::OSeekableInputWrapper::CheckSeekableCanWrap(
rInputStream, m_xSMgr );
int errorCount = 0;
bool bRetry = false;
do
{
if ( bRetry )
{
resetInputStream( xSeekableStream );
bRetry = false;
}
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "POST" ),
aHeaders );
m_xSession->POST( getRequestURI(),
rContentType,
rReferer,
xSeekableStream,
rOutputStream,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
if ( e.getError() == DAVException::DAV_HTTP_REDIRECT )
{
// #i74980# - Upon POST redirect, do a GET.
GET( rOutputStream, xEnv );
return;
}
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::MKCOL(
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "MKCOL" ),
aHeaders );
m_xSession->MKCOL( getRequestURI(),
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::COPY(
const ::rtl::OUString & rSourcePath,
const ::rtl::OUString & rDestinationURI,
sal_Bool bOverwrite,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "COPY" ),
aHeaders );
m_xSession->COPY( rSourcePath,
rDestinationURI,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ),
bOverwrite );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::MOVE(
const ::rtl::OUString & rSourcePath,
const ::rtl::OUString & rDestinationURI,
sal_Bool bOverwrite,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "MOVE" ),
aHeaders );
m_xSession->MOVE( rSourcePath,
rDestinationURI,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ),
bOverwrite );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::DESTROY(
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii(
"DESTROY" ),
aHeaders );
m_xSession->DESTROY( getRequestURI(),
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
// set new lock.
void DAVResourceAccess::LOCK(
ucb::Lock & inLock,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw ( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "LOCK" ),
aHeaders );
m_xSession->LOCK( getRequestURI(),
inLock,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
#if 0 // currently not used, but please don't remove code
//=========================================================================
// refresh existing lock.
sal_Int64 DAVResourceAccess::LOCK(
sal_Int64 nTimeout,
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw ( DAVException )
{
initialize();
sal_Int64 nNewTimeout = 0;
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "LOCK" ),
aHeaders );
nNewTimeout = m_xSession->LOCK( getRequestURI(),
nTimeout,
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl(
xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
return nNewTimeout;
}
#endif
//=========================================================================
void DAVResourceAccess::UNLOCK(
const uno::Reference< ucb::XCommandEnvironment > & xEnv )
throw ( DAVException )
{
initialize();
int errorCount = 0;
bool bRetry;
do
{
bRetry = false;
try
{
DAVRequestHeaders aHeaders;
getUserRequestHeaders( xEnv,
getRequestURI(),
rtl::OUString::createFromAscii( "UNLOCK" ),
aHeaders );
m_xSession->UNLOCK( getRequestURI(),
DAVRequestEnvironment(
getRequestURI(),
new DAVAuthListener_Impl( xEnv, m_aURL ),
aHeaders, xEnv ) );
}
catch ( DAVException & e )
{
errorCount++;
bRetry = handleException( e, errorCount );
if ( !bRetry )
throw;
}
}
while ( bRetry );
}
//=========================================================================
void DAVResourceAccess::setURL( const rtl::OUString & rNewURL )
throw( DAVException )
{
osl::Guard< osl::Mutex > aGuard( m_aMutex );
m_aURL = rNewURL;
m_aPath = rtl::OUString(); // Next initialize() will create new session.
}
//=========================================================================
// init dav session and path
void DAVResourceAccess::initialize()
throw ( DAVException )
{
osl::Guard< osl::Mutex > aGuard( m_aMutex );
if ( m_aPath.getLength() == 0 )
{
SerfUri aURI( m_aURL );
rtl::OUString aPath( aURI.GetPath() );
/* #134089# - Check URI */
if ( !aPath.getLength() )
throw DAVException( DAVException::DAV_INVALID_ARG );
/* #134089# - Check URI */
if ( !aURI.GetHost().getLength() )
throw DAVException( DAVException::DAV_INVALID_ARG );
if ( !m_xSession.is() || !m_xSession->CanUse( m_aURL ) )
{
m_xSession.clear();
// create new webdav session
m_xSession
= m_xSessionFactory->createDAVSession( m_aURL, m_xSMgr );
if ( !m_xSession.is() )
return;
}
// Own URI is needed for redirect cycle detection.
m_aRedirectURIs.push_back( aURI );
// Success.
m_aPath = aPath;
// Not only the path has to be encoded
m_aURL = aURI.GetURI();
}
}
//=========================================================================
const rtl::OUString & DAVResourceAccess::getRequestURI() const
{
OSL_ENSURE( m_xSession.is(),
"DAVResourceAccess::getRequestURI - Not initialized!" );
// In case a proxy is used we have to use the absolute URI for a request.
if ( m_xSession->UsesProxy() )
return m_aURL;
return m_aPath;
}
//=========================================================================
// static
void DAVResourceAccess::getUserRequestHeaders(
const uno::Reference< ucb::XCommandEnvironment > & xEnv,
const rtl::OUString & rURI,
const rtl::OUString & rMethod,
DAVRequestHeaders & rRequestHeaders )
{
if ( xEnv.is() )
{
uno::Reference< ucb::XWebDAVCommandEnvironment > xDAVEnv(
xEnv, uno::UNO_QUERY );
if ( xDAVEnv.is() )
{
uno::Sequence< beans::NamedValue > aRequestHeaders
= xDAVEnv->getUserRequestHeaders( rURI, rMethod );
for ( sal_Int32 n = 0; n < aRequestHeaders.getLength(); ++n )
{
rtl::OUString aValue;
sal_Bool isString = aRequestHeaders[ n ].Value >>= aValue;
if ( !isString )
{
OSL_ENSURE( isString,
"DAVResourceAccess::getUserRequestHeaders :"
"Value is not a string! Ignoring..." );
}
rRequestHeaders.push_back(
DAVRequestHeader( aRequestHeaders[ n ].Name, aValue ) );
}
}
}
}
//=========================================================================
sal_Bool DAVResourceAccess::detectRedirectCycle(
const rtl::OUString& rRedirectURL )
throw ( DAVException )
{
osl::Guard< osl::Mutex > aGuard( m_aMutex );
SerfUri aUri( rRedirectURL );
std::vector< SerfUri >::const_iterator it = m_aRedirectURIs.begin();
std::vector< SerfUri >::const_iterator end = m_aRedirectURIs.end();
while ( it != end )
{
if ( aUri == (*it) )
return sal_True;
it++;
}
return sal_False;
}
//=========================================================================
void DAVResourceAccess::resetUri()
{
osl::Guard< osl::Mutex > aGuard( m_aMutex );
if ( m_aRedirectURIs.size() > 0 )
{
std::vector< SerfUri >::const_iterator it = m_aRedirectURIs.begin();
SerfUri aUri( (*it) );
m_aRedirectURIs.clear();
setURL ( aUri.GetURI() );
initialize();
}
}
//=========================================================================
sal_Bool DAVResourceAccess::handleException( DAVException & e, int errorCount )
throw ( DAVException )
{
switch ( e.getError() )
{
case DAVException::DAV_HTTP_REDIRECT:
if ( !detectRedirectCycle( e.getData() ) )
{
// set new URL and path.
setURL( e.getData() );
initialize();
return sal_True;
}
return sal_False;
// --> tkr #67048# copy & paste images doesn't display.
// if we have a bad connection try again. Up to three times.
case DAVException::DAV_HTTP_ERROR:
// retry up to three times, if not a client-side error.
if ( ( e.getStatus() < 400 || e.getStatus() >= 500 ||
e.getStatus() == 413 ) &&
errorCount < 3 )
{
return sal_True;
}
return sal_False;
// <--
// --> tkr: if connection has said retry then retry!
case DAVException::DAV_HTTP_RETRY:
return sal_True;
// <--
default:
return sal_False; // Abort
}
}