/************************************************************** * * 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" /************************************************************************** TODO ************************************************************************** *************************************************************************/ #include #include "webdavprovider.hxx" #include "webdavcontent.hxx" #include "webdavuseragent.hxx" #include #include #include #include #include using namespace com::sun::star; using namespace http_dav_ucp; rtl::OUString &WebDAVUserAgent::operator()() const { rtl::OUStringBuffer aBuffer; aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "$ooName/$ooSetupVersion" )); #if OSL_DEBUG_LEVEL > 0 #ifdef APR_VERSION aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( " apr/" APR_VERSION )); #endif #ifdef APR_UTIL_VERSION aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( " apr-util/" APR_UTIL_VERSION )); #endif #ifdef SERF_VERSION aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( " serf/" SERF_VERSION )); #endif #endif static rtl::OUString aUserAgent( aBuffer.makeStringAndClear() ); return aUserAgent; } //========================================================================= //========================================================================= // // ContentProvider Implementation. // //========================================================================= //========================================================================= ContentProvider::ContentProvider( const uno::Reference< lang::XMultiServiceFactory >& rSMgr ) : ::ucbhelper::ContentProviderImplHelper( rSMgr ), m_xDAVSessionFactory( new DAVSessionFactory() ), m_pProps( 0 ) { static bool bInit = false; if ( bInit ) return; bInit = true; try { uno::Reference< uno::XComponentContext > xContext( ::comphelper::getProcessComponentContext() ); uno::Reference< lang::XMultiServiceFactory > xConfigProvider( xContext->getServiceManager()->createInstanceWithContext( rtl::OUString(RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.configuration.ConfigurationProvider")), xContext), uno::UNO_QUERY_THROW ); beans::NamedValue aNodePath; aNodePath.Name = rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "nodepath" ) ); aNodePath.Value <<= rtl::OUString( RTL_CONSTASCII_USTRINGPARAM("/org.openoffice.Setup/Product")); uno::Sequence< uno::Any > aArgs( 1 ); aArgs[0] <<= aNodePath; uno::Reference< container::XNameAccess > xConfigAccess( xConfigProvider->createInstanceWithArguments( rtl::OUString(RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.configuration.ConfigurationAccess")), aArgs), uno::UNO_QUERY_THROW ); rtl::OUString aVal; xConfigAccess->getByName(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("ooName"))) >>= aVal; rtl::OUString &aUserAgent = WebDAVUserAgent::get(); sal_Int32 nIndex = aUserAgent.indexOfAsciiL( RTL_CONSTASCII_STRINGPARAM( "$ooName" ) ); if ( !aVal.getLength() || nIndex == -1 ) return; aUserAgent = aUserAgent.replaceAt( nIndex, RTL_CONSTASCII_LENGTH( "$ooName" ), aVal ); xConfigAccess->getByName(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("ooSetupVersion"))) >>= aVal; nIndex = aUserAgent.indexOfAsciiL( RTL_CONSTASCII_STRINGPARAM( "$ooSetupVersion" ) ); if ( !aVal.getLength() || nIndex == -1 ) return; aUserAgent = aUserAgent.replaceAt( nIndex, RTL_CONSTASCII_LENGTH( "$ooSetupVersion" ), aVal ); } catch ( const uno::Exception &e ) { OSL_TRACE( "ContentProvider -caught exception! %s", rtl::OUStringToOString( e.Message, RTL_TEXTENCODING_UTF8 ).getStr() ); (void) e; } } //========================================================================= // virtual ContentProvider::~ContentProvider() { delete m_pProps; } //========================================================================= // // XInterface methods. // //========================================================================= XINTERFACE_IMPL_3( ContentProvider, lang::XTypeProvider, lang::XServiceInfo, ucb::XContentProvider ); //========================================================================= // // XTypeProvider methods. // //========================================================================= XTYPEPROVIDER_IMPL_3( ContentProvider, lang::XTypeProvider, lang::XServiceInfo, ucb::XContentProvider ); //========================================================================= // // XServiceInfo methods. // //========================================================================= XSERVICEINFO_IMPL_1( ContentProvider, rtl::OUString::createFromAscii( "com.sun.star.comp.WebDAVContentProvider" ), rtl::OUString::createFromAscii( WEBDAV_CONTENT_PROVIDER_SERVICE_NAME ) ); //========================================================================= // // Service factory implementation. // //========================================================================= ONE_INSTANCE_SERVICE_FACTORY_IMPL( ContentProvider ); //========================================================================= // // XContentProvider methods. // //========================================================================= // virtual uno::Reference< ucb::XContent > SAL_CALL ContentProvider::queryContent( const uno::Reference< ucb::XContentIdentifier >& Identifier ) throw( ucb::IllegalIdentifierException, uno::RuntimeException ) { // Check URL scheme... const rtl::OUString aScheme = Identifier->getContentProviderScheme().toAsciiLowerCase(); if ( !aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( HTTP_URL_SCHEME ) ) && !aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( HTTPS_URL_SCHEME ) ) && !aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( WEBDAV_URL_SCHEME ) ) && !aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( DAV_URL_SCHEME ) ) && !aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( DAVS_URL_SCHEME ) ) ) throw ucb::IllegalIdentifierException(); // Normalize URL and create new Id, if nessacary. rtl::OUString aURL = Identifier->getContentIdentifier(); // At least: + "://" if ( aURL.getLength() < ( aScheme.getLength() + 3 ) ) throw ucb::IllegalIdentifierException(); if ( ( aURL.getStr()[ aScheme.getLength() ] != sal_Unicode( ':' ) ) || ( aURL.getStr()[ aScheme.getLength() + 1 ] != sal_Unicode( '/' ) ) || ( aURL.getStr()[ aScheme.getLength() + 2 ] != sal_Unicode( '/' ) ) ) throw ucb::IllegalIdentifierException(); uno::Reference< ucb::XContentIdentifier > xCanonicId; bool bNewId = false; if ( aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( WEBDAV_URL_SCHEME ) ) ) { aURL = aURL.replaceAt( 0, WEBDAV_URL_SCHEME_LENGTH, rtl::OUString::createFromAscii( HTTP_URL_SCHEME ) ); bNewId = true; } else if ( aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( DAV_URL_SCHEME ) ) ) { aURL = aURL.replaceAt( 0, DAV_URL_SCHEME_LENGTH, rtl::OUString::createFromAscii( HTTP_URL_SCHEME ) ); bNewId = true; } else if ( aScheme.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM( DAVS_URL_SCHEME ) ) ) { aURL = aURL.replaceAt( 0, DAVS_URL_SCHEME_LENGTH, rtl::OUString::createFromAscii( HTTPS_URL_SCHEME ) ); bNewId = true; } sal_Int32 nPos = aURL.lastIndexOf( '/' ); if ( nPos != aURL.getLength() - 1 ) { // Find second slash in URL. nPos = aURL.indexOf( '/', aURL.indexOf( '/' ) + 1 ); if ( nPos == -1 ) throw ucb::IllegalIdentifierException(); nPos = aURL.indexOf( '/', nPos + 1 ); if ( nPos == -1 ) { aURL += rtl::OUString::createFromAscii( "/" ); bNewId = true; } } if ( bNewId ) xCanonicId = new ::ucbhelper::ContentIdentifier( m_xSMgr, aURL ); else xCanonicId = Identifier; osl::MutexGuard aGuard( m_aMutex ); // Check, if a content with given id already exists... uno::Reference< ucb::XContent > xContent = queryExistingContent( xCanonicId ).get(); if ( xContent.is() ) return xContent; // Create a new content. try { xContent = new ::http_dav_ucp::Content( m_xSMgr, this, xCanonicId, m_xDAVSessionFactory ); registerNewContent( xContent ); } catch ( ucb::ContentCreationException const & ) { throw ucb::IllegalIdentifierException(); } if ( !xContent->getIdentifier().is() ) throw ucb::IllegalIdentifierException(); return xContent; }