| /************************************************************** |
| * |
| * 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_xmlhelp.hxx" |
| |
| /************************************************************************** |
| TODO |
| ************************************************************************** |
| |
| *************************************************************************/ |
| #include <com/sun/star/beans/PropertyAttribute.hpp> |
| #include <com/sun/star/beans/XPropertyAccess.hpp> |
| #include <com/sun/star/sdbc/XRow.hpp> |
| #include <com/sun/star/ucb/OpenCommandArgument2.hpp> |
| #include <com/sun/star/ucb/OpenMode.hpp> |
| #include <com/sun/star/ucb/XCommandInfo.hpp> |
| #include <com/sun/star/io/XActiveDataSink.hpp> |
| #include <com/sun/star/io/XOutputStream.hpp> |
| #include <com/sun/star/lang/IllegalAccessException.hpp> |
| #include <com/sun/star/ucb/UnsupportedDataSinkException.hpp> |
| #include <com/sun/star/io/XActiveDataStreamer.hpp> |
| #include <com/sun/star/ucb/XPersistentPropertySet.hpp> |
| #ifndef _VOS_DIAGNOSE_HXX_ |
| #include <vos/diagnose.hxx> |
| #endif |
| #include <ucbhelper/contentidentifier.hxx> |
| #include <ucbhelper/propertyvalueset.hxx> |
| #ifndef _UCBHELPER_CANCELCOMMANDEXECUTION_HXX |
| #include <ucbhelper/cancelcommandexecution.hxx> |
| #endif |
| #include "content.hxx" |
| #include "provider.hxx" |
| #include "resultset.hxx" |
| #include "databases.hxx" |
| #include "resultsetfactory.hxx" |
| #include "resultsetbase.hxx" |
| #include "resultsetforroot.hxx" |
| #include "resultsetforquery.hxx" |
| |
| using namespace com::sun::star; |
| using namespace chelp; |
| |
| //========================================================================= |
| //========================================================================= |
| // |
| // Content Implementation. |
| // |
| //========================================================================= |
| //========================================================================= |
| |
| Content::Content( const uno::Reference< lang::XMultiServiceFactory >& rxSMgr, |
| ::ucbhelper::ContentProviderImplHelper* pProvider, |
| const uno::Reference< ucb::XContentIdentifier >& |
| Identifier, |
| Databases* pDatabases ) |
| : ContentImplHelper( rxSMgr, pProvider, Identifier ), |
| m_aURLParameter( Identifier->getContentIdentifier(),pDatabases ), |
| m_pDatabases( pDatabases ) // not owner |
| { |
| } |
| |
| //========================================================================= |
| // virtual |
| Content::~Content() |
| { |
| } |
| |
| //========================================================================= |
| // |
| // XInterface methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| void SAL_CALL Content::acquire() |
| throw( ) |
| { |
| ContentImplHelper::acquire(); |
| } |
| |
| //========================================================================= |
| // virtual |
| void SAL_CALL Content::release() |
| throw( ) |
| { |
| ContentImplHelper::release(); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Any SAL_CALL Content::queryInterface( const uno::Type & rType ) |
| throw ( uno::RuntimeException ) |
| { |
| uno::Any aRet; |
| return aRet.hasValue() ? aRet : ContentImplHelper::queryInterface( rType ); |
| } |
| |
| //========================================================================= |
| // |
| // XTypeProvider methods. |
| // |
| //========================================================================= |
| |
| XTYPEPROVIDER_COMMON_IMPL( Content ); |
| |
| //========================================================================= |
| // virtual |
| uno::Sequence< uno::Type > SAL_CALL Content::getTypes() |
| throw( uno::RuntimeException ) |
| { |
| static cppu::OTypeCollection* pCollection = NULL; |
| |
| if ( !pCollection ) |
| { |
| osl::MutexGuard aGuard( osl::Mutex::getGlobalMutex() ); |
| if ( !pCollection ) |
| { |
| static cppu::OTypeCollection aCollection( |
| CPPU_TYPE_REF( lang::XTypeProvider ), |
| CPPU_TYPE_REF( lang::XServiceInfo ), |
| CPPU_TYPE_REF( lang::XComponent ), |
| CPPU_TYPE_REF( ucb::XContent ), |
| CPPU_TYPE_REF( ucb::XCommandProcessor ), |
| CPPU_TYPE_REF( beans::XPropertiesChangeNotifier ), |
| CPPU_TYPE_REF( ucb::XCommandInfoChangeNotifier ), |
| CPPU_TYPE_REF( beans::XPropertyContainer ), |
| CPPU_TYPE_REF( beans::XPropertySetInfoChangeNotifier ), |
| CPPU_TYPE_REF( container::XChild ) ); |
| pCollection = &aCollection; |
| } |
| } |
| |
| return (*pCollection).getTypes(); |
| } |
| |
| //========================================================================= |
| // |
| // XServiceInfo methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| rtl::OUString SAL_CALL Content::getImplementationName() |
| throw( uno::RuntimeException ) |
| { |
| return rtl::OUString::createFromAscii( "CHelpContent" ); |
| } |
| |
| //========================================================================= |
| // virtual |
| uno::Sequence< rtl::OUString > SAL_CALL Content::getSupportedServiceNames() |
| throw( uno::RuntimeException ) |
| { |
| uno::Sequence< rtl::OUString > aSNS( 1 ); |
| aSNS.getArray()[ 0 ] |
| = rtl::OUString::createFromAscii( MYUCP_CONTENT_SERVICE_NAME ); |
| return aSNS; |
| } |
| |
| //========================================================================= |
| // |
| // XContent methods. |
| // |
| //========================================================================= |
| |
| // virtual |
| rtl::OUString SAL_CALL Content::getContentType() |
| throw( uno::RuntimeException ) |
| { |
| return rtl::OUString::createFromAscii( MYUCP_CONTENT_TYPE ); |
| } |
| |
| //========================================================================= |
| // |
| // XCommandProcessor methods. |
| // |
| //========================================================================= |
| |
| //virtual |
| void SAL_CALL Content::abort( sal_Int32 /*CommandId*/ ) |
| throw( uno::RuntimeException ) |
| { |
| } |
| |
| |
| |
| class ResultSetForRootFactory |
| : public ResultSetFactory |
| { |
| private: |
| |
| uno::Reference< lang::XMultiServiceFactory > m_xSMgr; |
| uno::Reference< ucb::XContentProvider > m_xProvider; |
| sal_Int32 m_nOpenMode; |
| uno::Sequence< beans::Property > m_seq; |
| uno::Sequence< ucb::NumberedSortingInfo > m_seqSort; |
| URLParameter m_aURLParameter; |
| Databases* m_pDatabases; |
| |
| |
| public: |
| |
| ResultSetForRootFactory( |
| const uno::Reference< lang::XMultiServiceFactory >& xSMgr, |
| const uno::Reference< ucb::XContentProvider >& xProvider, |
| sal_Int32 nOpenMode, |
| const uno::Sequence< beans::Property >& seq, |
| const uno::Sequence< ucb::NumberedSortingInfo >& seqSort, |
| URLParameter aURLParameter, |
| Databases* pDatabases ) |
| : m_xSMgr( xSMgr ), |
| m_xProvider( xProvider ), |
| m_nOpenMode( nOpenMode ), |
| m_seq( seq ), |
| m_seqSort( seqSort ), |
| m_aURLParameter( aURLParameter ), |
| m_pDatabases( pDatabases ) |
| { |
| } |
| |
| ResultSetBase* createResultSet() |
| { |
| return new ResultSetForRoot( m_xSMgr, |
| m_xProvider, |
| m_nOpenMode, |
| m_seq, |
| m_seqSort, |
| m_aURLParameter, |
| m_pDatabases ); |
| } |
| }; |
| |
| |
| |
| class ResultSetForQueryFactory |
| : public ResultSetFactory |
| { |
| private: |
| |
| uno::Reference< lang::XMultiServiceFactory > m_xSMgr; |
| uno::Reference< ucb::XContentProvider > m_xProvider; |
| sal_Int32 m_nOpenMode; |
| uno::Sequence< beans::Property > m_seq; |
| uno::Sequence< ucb::NumberedSortingInfo > m_seqSort; |
| URLParameter m_aURLParameter; |
| Databases* m_pDatabases; |
| |
| |
| public: |
| |
| ResultSetForQueryFactory( |
| const uno::Reference< lang::XMultiServiceFactory >& xSMgr, |
| const uno::Reference< ucb::XContentProvider >& xProvider, |
| sal_Int32 nOpenMode, |
| const uno::Sequence< beans::Property >& seq, |
| const uno::Sequence< ucb::NumberedSortingInfo >& seqSort, |
| URLParameter aURLParameter, |
| Databases* pDatabases ) |
| : m_xSMgr( xSMgr ), |
| m_xProvider( xProvider ), |
| m_nOpenMode( nOpenMode ), |
| m_seq( seq ), |
| m_seqSort( seqSort ), |
| m_aURLParameter( aURLParameter ), |
| m_pDatabases( pDatabases ) |
| { |
| } |
| |
| ResultSetBase* createResultSet() |
| { |
| return new ResultSetForQuery( m_xSMgr, |
| m_xProvider, |
| m_nOpenMode, |
| m_seq, |
| m_seqSort, |
| m_aURLParameter, |
| m_pDatabases ); |
| } |
| }; |
| |
| |
| |
| // virtual |
| uno::Any SAL_CALL Content::execute( |
| const ucb::Command& aCommand, |
| sal_Int32 CommandId, |
| const uno::Reference< ucb::XCommandEnvironment >& Environment ) |
| throw( uno::Exception, |
| ucb::CommandAbortedException, |
| uno::RuntimeException ) |
| { |
| uno::Any aRet; |
| |
| if ( aCommand.Name.compareToAscii( "getPropertyValues" ) == 0 ) |
| { |
| uno::Sequence< beans::Property > Properties; |
| if ( !( aCommand.Argument >>= Properties ) ) |
| { |
| aRet <<= lang::IllegalArgumentException(); |
| ucbhelper::cancelCommandExecution(aRet,Environment); |
| } |
| |
| aRet <<= getPropertyValues( Properties ); |
| } |
| else if ( aCommand.Name.compareToAscii( "setPropertyValues" ) == 0 ) |
| { |
| uno::Sequence<beans::PropertyValue> propertyValues; |
| |
| if( ! ( aCommand.Argument >>= propertyValues ) ) { |
| aRet <<= lang::IllegalArgumentException(); |
| ucbhelper::cancelCommandExecution(aRet,Environment); |
| } |
| |
| uno::Sequence< uno::Any > ret(propertyValues.getLength()); |
| uno::Sequence< beans::Property > props(getProperties(Environment)); |
| // No properties can be set |
| for(sal_Int32 i = 0; i < ret.getLength(); ++i) { |
| ret[i] <<= beans::UnknownPropertyException(); |
| for(sal_Int32 j = 0; j < props.getLength(); ++j) |
| if(props[j].Name == propertyValues[i].Name) { |
| ret[i] <<= lang::IllegalAccessException(); |
| break; |
| } |
| } |
| |
| aRet <<= ret; |
| } |
| else if ( aCommand.Name.compareToAscii( "getPropertySetInfo" ) == 0 ) |
| { |
| // Note: Implemented by base class. |
| aRet <<= getPropertySetInfo( Environment ); |
| } |
| else if ( aCommand.Name.compareToAscii( "getCommandInfo" ) == 0 ) |
| { |
| // Note: Implemented by base class. |
| aRet <<= getCommandInfo( Environment ); |
| } |
| else if ( aCommand.Name.compareToAscii( "open" ) == 0 ) |
| { |
| ucb::OpenCommandArgument2 aOpenCommand; |
| if ( !( aCommand.Argument >>= aOpenCommand ) ) |
| { |
| aRet <<= lang::IllegalArgumentException(); |
| ucbhelper::cancelCommandExecution(aRet,Environment); |
| } |
| |
| uno::Reference< io::XActiveDataSink > xActiveDataSink( |
| aOpenCommand.Sink, uno::UNO_QUERY); |
| |
| if(xActiveDataSink.is()) |
| m_aURLParameter.open(m_xSMgr, |
| aCommand, |
| CommandId, |
| Environment, |
| xActiveDataSink); |
| |
| uno::Reference< io::XActiveDataStreamer > xActiveDataStreamer( |
| aOpenCommand.Sink, uno::UNO_QUERY); |
| |
| if(xActiveDataStreamer.is()) { |
| aRet <<= ucb::UnsupportedDataSinkException(); |
| ucbhelper::cancelCommandExecution(aRet,Environment); |
| } |
| |
| uno::Reference< io::XOutputStream > xOutputStream( |
| aOpenCommand.Sink, uno::UNO_QUERY); |
| |
| if(xOutputStream.is() ) |
| m_aURLParameter.open(m_xSMgr, |
| aCommand, |
| CommandId, |
| Environment, |
| xOutputStream); |
| |
| if( m_aURLParameter.isRoot() ) |
| { |
| uno::Reference< ucb::XDynamicResultSet > xSet |
| = new DynamicResultSet( |
| m_xSMgr, |
| this, |
| aOpenCommand, |
| Environment, |
| new ResultSetForRootFactory( |
| m_xSMgr, |
| m_xProvider.get(), |
| aOpenCommand.Mode, |
| aOpenCommand.Properties, |
| aOpenCommand.SortingInfo, |
| m_aURLParameter, |
| m_pDatabases)); |
| aRet <<= xSet; |
| } |
| else if( m_aURLParameter.isQuery() ) |
| { |
| uno::Reference< ucb::XDynamicResultSet > xSet |
| = new DynamicResultSet( |
| m_xSMgr, |
| this, |
| aOpenCommand, |
| Environment, |
| new ResultSetForQueryFactory( |
| m_xSMgr, |
| m_xProvider.get(), |
| aOpenCommand.Mode, |
| aOpenCommand.Properties, |
| aOpenCommand.SortingInfo, |
| m_aURLParameter, |
| m_pDatabases ) ); |
| aRet <<= xSet; |
| } |
| } |
| else |
| { |
| ////////////////////////////////////////////////////////////////// |
| // Unsupported command |
| ////////////////////////////////////////////////////////////////// |
| aRet <<= ucb::UnsupportedCommandException(); |
| ucbhelper::cancelCommandExecution(aRet,Environment); |
| } |
| |
| return aRet; |
| } |
| |
| |
| |
| |
| //========================================================================= |
| uno::Reference< sdbc::XRow > Content::getPropertyValues( |
| const uno::Sequence< beans::Property >& rProperties ) |
| { |
| osl::MutexGuard aGuard( m_aMutex ); |
| |
| rtl::Reference< ::ucbhelper::PropertyValueSet > xRow = |
| new ::ucbhelper::PropertyValueSet( m_xSMgr ); |
| |
| for ( sal_Int32 n = 0; n < rProperties.getLength(); ++n ) |
| { |
| const beans::Property& rProp = rProperties[n]; |
| |
| if ( rProp.Name.compareToAscii( "ContentType" ) == 0 ) |
| xRow->appendString( |
| rProp, |
| rtl::OUString::createFromAscii( |
| "application/vnd.sun.star.help" ) ); |
| else if( rProp.Name.compareToAscii( "Title" ) == 0 ) |
| xRow->appendString ( rProp,m_aURLParameter.get_title() ); |
| else if( rProp.Name.compareToAscii( "IsReadOnly" ) == 0 ) |
| xRow->appendBoolean( rProp,true ); |
| else if( rProp.Name.compareToAscii( "IsDocument" ) == 0 ) |
| xRow->appendBoolean( |
| rProp, |
| m_aURLParameter.isFile() || m_aURLParameter.isRoot() ); |
| else if( rProp.Name.compareToAscii( "IsFolder" ) == 0 ) |
| xRow->appendBoolean( |
| rProp, |
| ! m_aURLParameter.isFile() || m_aURLParameter.isRoot() ); |
| else if( rProp.Name.compareToAscii( "IsErrorDocument" ) == 0 ) |
| xRow->appendBoolean( rProp, m_aURLParameter.isErrorDocument() ); |
| else if( rProp.Name.compareToAscii( "MediaType" ) == 0 ) |
| if( m_aURLParameter.isPicture() ) |
| xRow->appendString( |
| rProp, |
| rtl::OUString::createFromAscii( "image/gif" ) ); |
| else if( m_aURLParameter.isActive() ) |
| xRow->appendString( |
| rProp, |
| rtl::OUString::createFromAscii( "text/plain" ) ); |
| else if( m_aURLParameter.isFile() ) |
| xRow->appendString( |
| rProp,rtl::OUString::createFromAscii( "text/html" ) ); |
| else if( m_aURLParameter.isRoot() ) |
| xRow->appendString( |
| rProp, |
| rtl::OUString::createFromAscii( "text/css" ) ); |
| else |
| xRow->appendVoid( rProp ); |
| else if( m_aURLParameter.isModule() ) |
| if( rProp.Name.compareToAscii( "KeywordList" ) == 0 ) |
| { |
| KeywordInfo *inf = |
| m_pDatabases->getKeyword( m_aURLParameter.get_module(), |
| m_aURLParameter.get_language() ); |
| |
| uno::Any aAny; |
| if( inf ) |
| aAny <<= inf->getKeywordList(); |
| xRow->appendObject( rProp,aAny ); |
| } |
| else if( rProp.Name.compareToAscii( "KeywordRef" ) == 0 ) |
| { |
| KeywordInfo *inf = |
| m_pDatabases->getKeyword( m_aURLParameter.get_module(), |
| m_aURLParameter.get_language() ); |
| |
| uno::Any aAny; |
| if( inf ) |
| aAny <<= inf->getIdList(); |
| xRow->appendObject( rProp,aAny ); |
| } |
| else if( rProp.Name.compareToAscii( "KeywordAnchorForRef" ) == 0 ) |
| { |
| KeywordInfo *inf = |
| m_pDatabases->getKeyword( m_aURLParameter.get_module(), |
| m_aURLParameter.get_language() ); |
| |
| uno::Any aAny; |
| if( inf ) |
| aAny <<= inf->getAnchorList(); |
| xRow->appendObject( rProp,aAny ); |
| } |
| else if( rProp.Name.compareToAscii( "KeywordTitleForRef" ) == 0 ) |
| { |
| KeywordInfo *inf = |
| m_pDatabases->getKeyword( m_aURLParameter.get_module(), |
| m_aURLParameter.get_language() ); |
| |
| uno::Any aAny; |
| if( inf ) |
| aAny <<= inf->getTitleList(); |
| xRow->appendObject( rProp,aAny ); |
| } |
| else if( rProp.Name.compareToAscii( "SearchScopes" ) == 0 ) |
| { |
| uno::Sequence< rtl::OUString > seq( 2 ); |
| seq[0] = rtl::OUString::createFromAscii( "Heading" ); |
| seq[1] = rtl::OUString::createFromAscii( "FullText" ); |
| uno::Any aAny; |
| aAny <<= seq; |
| xRow->appendObject( rProp,aAny ); |
| } |
| else if( rProp.Name.compareToAscii( "Order" ) == 0 ) |
| { |
| StaticModuleInformation *inf = |
| m_pDatabases->getStaticInformationForModule( |
| m_aURLParameter.get_module(), |
| m_aURLParameter.get_language() ); |
| |
| uno::Any aAny; |
| if( inf ) |
| aAny <<= sal_Int32( inf->get_order() ); |
| xRow->appendObject( rProp,aAny ); |
| } |
| else |
| xRow->appendVoid( rProp ); |
| else if( rProp.Name.compareToAscii( "AnchorName" ) == 0 && |
| m_aURLParameter.isFile() ) |
| xRow->appendString( rProp,m_aURLParameter.get_tag() ); |
| else |
| xRow->appendVoid( rProp ); |
| } |
| |
| return uno::Reference< sdbc::XRow >( xRow.get() ); |
| } |
