| /************************************************************** |
| * |
| * 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 <ucbhelper/contentidentifier.hxx> |
| #include "webdavprovider.hxx" |
| #include "webdavcontent.hxx" |
| #include "webdavuseragent.hxx" |
| |
| #include <osl/mutex.hxx> |
| #include <rtl/ustrbuf.hxx> |
| #include <comphelper/processfactory.hxx> |
| #include <com/sun/star/beans/NamedValue.hpp> |
| #include <com/sun/star/container/XNameAccess.hpp> |
| |
| 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: <scheme> + "://" |
| 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; |
| } |
| |
