LCOV - code coverage report
Current view: top level - ucb/source/ucp/ext - ucpext_datasupplier.cxx (source / functions) Hit Total Coverage
Test: commit e02a6cb2c3e2b23b203b422e4e0680877f232636 Lines: 0 124 0.0 %
Date: 2014-04-14 Functions: 0 21 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             :  * This file is part of the LibreOffice project.
       4             :  *
       5             :  * This Source Code Form is subject to the terms of the Mozilla Public
       6             :  * License, v. 2.0. If a copy of the MPL was not distributed with this
       7             :  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
       8             :  *
       9             :  * This file incorporates work covered by the following license notice:
      10             :  *
      11             :  *   Licensed to the Apache Software Foundation (ASF) under one or more
      12             :  *   contributor license agreements. See the NOTICE file distributed
      13             :  *   with this work for additional information regarding copyright
      14             :  *   ownership. The ASF licenses this file to you under the Apache
      15             :  *   License, Version 2.0 (the "License"); you may not use this file
      16             :  *   except in compliance with the License. You may obtain a copy of
      17             :  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
      18             :  */
      19             : 
      20             : 
      21             : #include "ucpext_datasupplier.hxx"
      22             : #include "ucpext_content.hxx"
      23             : #include "ucpext_provider.hxx"
      24             : 
      25             : #include <com/sun/star/deployment/PackageInformationProvider.hpp>
      26             : 
      27             : #include <ucbhelper/contentidentifier.hxx>
      28             : #include <comphelper/processfactory.hxx>
      29             : #include <ucbhelper/providerhelper.hxx>
      30             : #include <ucbhelper/content.hxx>
      31             : #include <ucbhelper/propertyvalueset.hxx>
      32             : #include <tools/diagnose_ex.h>
      33             : #include <rtl/ustrbuf.hxx>
      34             : 
      35             : #include <vector>
      36             : #include <boost/shared_ptr.hpp>
      37             : 
      38             : 
      39             : namespace ucb { namespace ucp { namespace ext
      40             : {
      41             : 
      42             : 
      43             :     using ::com::sun::star::uno::Reference;
      44             :     using ::com::sun::star::uno::XInterface;
      45             :     using ::com::sun::star::uno::UNO_QUERY;
      46             :     using ::com::sun::star::uno::UNO_QUERY_THROW;
      47             :     using ::com::sun::star::uno::UNO_SET_THROW;
      48             :     using ::com::sun::star::uno::Exception;
      49             :     using ::com::sun::star::uno::RuntimeException;
      50             :     using ::com::sun::star::uno::Any;
      51             :     using ::com::sun::star::uno::makeAny;
      52             :     using ::com::sun::star::uno::Sequence;
      53             :     using ::com::sun::star::uno::Type;
      54             :     using ::com::sun::star::uno::XComponentContext;
      55             :     using ::com::sun::star::ucb::XContent;
      56             :     using ::com::sun::star::ucb::XContentIdentifier;
      57             :     using ::com::sun::star::sdbc::XRow;
      58             :     using ::com::sun::star::lang::XMultiServiceFactory;
      59             :     using ::com::sun::star::ucb::IllegalIdentifierException;
      60             :     using ::com::sun::star::ucb::ResultSetException;
      61             :     using ::com::sun::star::deployment::PackageInformationProvider;
      62             :     using ::com::sun::star::deployment::XPackageInformationProvider;
      63             :     using ::com::sun::star::beans::Property;
      64             :     using ::com::sun::star::sdbc::XResultSet;
      65             :     using ::com::sun::star::ucb::XCommandEnvironment;
      66             : 
      67             : 
      68             :     //= ResultListEntry
      69             : 
      70           0 :     struct ResultListEntry
      71             :     {
      72             :         OUString                 sId;
      73             :         Reference< XContentIdentifier > xId;
      74             :         ::rtl::Reference< Content >     pContent;
      75             :         Reference< XRow >               xRow;
      76             :     };
      77             : 
      78             :     typedef ::std::vector< ResultListEntry >    ResultList;
      79             : 
      80             : 
      81             :     //= DataSupplier_Impl
      82             : 
      83             :     struct DataSupplier_Impl
      84             :     {
      85             :         ::osl::Mutex                                m_aMutex;
      86             :         ResultList                                  m_aResults;
      87             :         ::rtl::Reference< Content >                 m_xContent;
      88             :         Reference< XComponentContext >              m_xContext;
      89             :         sal_Int32                                   m_nOpenMode;
      90             : 
      91           0 :         DataSupplier_Impl( const Reference< XComponentContext >& rxContext, const ::rtl::Reference< Content >& i_rContent,
      92             :                            const sal_Int32 i_nOpenMode )
      93             :             :m_xContent( i_rContent )
      94             :             ,m_xContext( rxContext )
      95           0 :             ,m_nOpenMode( i_nOpenMode )
      96             :         {
      97           0 :         }
      98             :         ~DataSupplier_Impl();
      99             :     };
     100             : 
     101             : 
     102           0 :     DataSupplier_Impl::~DataSupplier_Impl()
     103             :     {
     104           0 :     }
     105             : 
     106             : 
     107             :     //= helper
     108             : 
     109             :     namespace
     110             :     {
     111           0 :         OUString lcl_compose( const OUString& i_rBaseURL, const OUString& i_rRelativeURL )
     112             :         {
     113           0 :             ENSURE_OR_RETURN( !i_rBaseURL.isEmpty(), "illegal base URL", i_rRelativeURL );
     114             : 
     115           0 :             OUStringBuffer aComposer( i_rBaseURL );
     116           0 :             if ( !i_rBaseURL.endsWith("/") )
     117           0 :                 aComposer.append( '/' );
     118           0 :             aComposer.append( i_rRelativeURL );
     119           0 :             return aComposer.makeStringAndClear();
     120             :         }
     121             :     }
     122             : 
     123             : 
     124             : 
     125             :     //= DataSupplier
     126             : 
     127             : 
     128           0 :     DataSupplier::DataSupplier( const Reference< XComponentContext >& rxContext,
     129             :                                 const ::rtl::Reference< Content >& i_rContent,
     130             :                                 const sal_Int32 i_nOpenMode )
     131           0 :         :m_pImpl( new DataSupplier_Impl( rxContext, i_rContent, i_nOpenMode ) )
     132             :     {
     133           0 :     }
     134             : 
     135             : 
     136           0 :     void DataSupplier::fetchData()
     137             :     {
     138             :         try
     139             :         {
     140           0 :             const Reference< XPackageInformationProvider > xPackageInfo = PackageInformationProvider::get( m_pImpl->m_xContext );
     141             : 
     142           0 :             const OUString sContentIdentifier( m_pImpl->m_xContent->getIdentifier()->getContentIdentifier() );
     143             : 
     144           0 :             switch ( m_pImpl->m_xContent->getExtensionContentType() )
     145             :             {
     146             :             case E_ROOT:
     147             :             {
     148           0 :                 Sequence< Sequence< OUString > > aExtensionInfo( xPackageInfo->getExtensionList() );
     149           0 :                 for (   const Sequence< OUString >* pExtInfo = aExtensionInfo.getConstArray();
     150           0 :                         pExtInfo != aExtensionInfo.getConstArray() + aExtensionInfo.getLength();
     151             :                         ++pExtInfo
     152             :                     )
     153             :                 {
     154           0 :                     if ( pExtInfo->getLength() <= 0 )
     155             :                     {
     156             :                         SAL_WARN( "ucb.ucp.ext", "illegal extension info" );
     157           0 :                         continue;
     158             :                     }
     159             : 
     160           0 :                     const OUString& rLocalId = (*pExtInfo)[0];
     161           0 :                     ResultListEntry aEntry;
     162           0 :                     aEntry.sId = ContentProvider::getRootURL() + Content::encodeIdentifier( rLocalId ) + OUString( '/' );
     163           0 :                     m_pImpl->m_aResults.push_back( aEntry );
     164           0 :                 }
     165             :             }
     166           0 :             break;
     167             :             case E_EXTENSION_ROOT:
     168             :             case E_EXTENSION_CONTENT:
     169             :             {
     170           0 :                 const OUString sPackageLocation( m_pImpl->m_xContent->getPhysicalURL() );
     171           0 :                 ::ucbhelper::Content aWrappedContent( sPackageLocation, getResultSet()->getEnvironment(), m_pImpl->m_xContext );
     172             : 
     173             :                 // obtain the properties which our result set is set up for from the wrapped content
     174           0 :                 Sequence< OUString > aPropertyNames(1);
     175           0 :                 aPropertyNames[0] = "Title";
     176             : 
     177           0 :                 const Reference< XResultSet > xFolderContent( aWrappedContent.createCursor( aPropertyNames ), UNO_SET_THROW );
     178           0 :                 const Reference< XRow > xContentRow( xFolderContent, UNO_QUERY_THROW );
     179           0 :                 while ( xFolderContent->next() )
     180             :                 {
     181           0 :                     ResultListEntry aEntry;
     182           0 :                     aEntry.sId = lcl_compose( sContentIdentifier, xContentRow->getString( 1 ) );
     183           0 :                     m_pImpl->m_aResults.push_back( aEntry );
     184           0 :                 }
     185             :             }
     186           0 :             break;
     187             :             default:
     188             :                 OSL_FAIL( "DataSupplier::fetchData: unimplemented content type!" );
     189           0 :                 break;
     190           0 :             }
     191             :         }
     192           0 :         catch( const Exception& )
     193             :         {
     194             :             DBG_UNHANDLED_EXCEPTION();
     195             :         }
     196           0 :     }
     197             : 
     198             : 
     199           0 :     DataSupplier::~DataSupplier()
     200             :     {
     201           0 :     }
     202             : 
     203             : 
     204           0 :     OUString DataSupplier::queryContentIdentifierString( sal_uInt32 i_nIndex )
     205             :     {
     206           0 :         ::osl::Guard< ::osl::Mutex > aGuard( m_pImpl->m_aMutex );
     207             : 
     208           0 :         if ( i_nIndex < m_pImpl->m_aResults.size() )
     209             :         {
     210           0 :             const OUString sId = m_pImpl->m_aResults[ i_nIndex ].sId;
     211           0 :             if ( !sId.isEmpty() )
     212           0 :                 return sId;
     213             :         }
     214             : 
     215             :         OSL_FAIL( "DataSupplier::queryContentIdentifierString: illegal index, or illegal result entry id!" );
     216           0 :         return OUString();
     217             :     }
     218             : 
     219             : 
     220           0 :     Reference< XContentIdentifier > DataSupplier::queryContentIdentifier( sal_uInt32 i_nIndex )
     221             :     {
     222           0 :         ::osl::Guard< ::osl::Mutex > aGuard( m_pImpl->m_aMutex );
     223             : 
     224           0 :         if ( i_nIndex < m_pImpl->m_aResults.size() )
     225             :         {
     226           0 :             Reference< XContentIdentifier > xId( m_pImpl->m_aResults[ i_nIndex ].xId );
     227           0 :             if ( xId.is() )
     228           0 :                 return xId;
     229             :         }
     230             : 
     231           0 :         OUString sId = queryContentIdentifierString( i_nIndex );
     232           0 :         if ( !sId.isEmpty() )
     233             :         {
     234           0 :             Reference< XContentIdentifier > xId = new ::ucbhelper::ContentIdentifier( sId );
     235           0 :             m_pImpl->m_aResults[ i_nIndex ].xId = xId;
     236           0 :             return xId;
     237             :         }
     238             : 
     239           0 :         return Reference< XContentIdentifier >();
     240             :     }
     241             : 
     242             : 
     243           0 :     Reference< XContent > DataSupplier::queryContent( sal_uInt32 i_nIndex )
     244             :     {
     245           0 :         ::osl::Guard< ::osl::Mutex > aGuard( m_pImpl->m_aMutex );
     246           0 :         ENSURE_OR_RETURN( i_nIndex < m_pImpl->m_aResults.size(), "illegal index!", NULL );
     247             : 
     248             : 
     249           0 :         ::rtl::Reference< Content > pContent( m_pImpl->m_aResults[ i_nIndex ].pContent );
     250           0 :         if ( pContent.is() )
     251           0 :             return pContent.get();
     252             : 
     253           0 :         Reference< XContentIdentifier > xId( queryContentIdentifier( i_nIndex ) );
     254           0 :         if ( xId.is() )
     255             :         {
     256             :             try
     257             :             {
     258           0 :                 Reference< XContent > xContent( m_pImpl->m_xContent->getProvider()->queryContent( xId ) );
     259           0 :                 pContent.set( dynamic_cast< Content* >( xContent.get() ) );
     260             :                 OSL_ENSURE( pContent.is() || !xContent.is(), "DataSupplier::queryContent: invalid content implementation!" );
     261           0 :                 m_pImpl->m_aResults[ i_nIndex ].pContent = pContent;
     262           0 :                 return pContent.get();
     263             : 
     264             :             }
     265           0 :             catch ( const IllegalIdentifierException& )
     266             :             {
     267             :                 DBG_UNHANDLED_EXCEPTION();
     268             :             }
     269             :         }
     270             : 
     271           0 :         return Reference< XContent >();
     272             :     }
     273             : 
     274             : 
     275           0 :     bool DataSupplier::getResult( sal_uInt32 i_nIndex )
     276             :     {
     277           0 :         ::osl::ClearableGuard< ::osl::Mutex > aGuard( m_pImpl->m_aMutex );
     278             : 
     279           0 :         if ( m_pImpl->m_aResults.size() > i_nIndex )
     280             :             // result already present.
     281           0 :             return true;
     282             : 
     283           0 :         return false;
     284             :     }
     285             : 
     286             : 
     287           0 :     sal_uInt32 DataSupplier::totalCount()
     288             :     {
     289           0 :         ::osl::ClearableGuard< ::osl::Mutex > aGuard( m_pImpl->m_aMutex );
     290           0 :         return m_pImpl->m_aResults.size();
     291             :     }
     292             : 
     293             : 
     294           0 :     sal_uInt32 DataSupplier::currentCount()
     295             :     {
     296           0 :         return m_pImpl->m_aResults.size();
     297             :     }
     298             : 
     299             : 
     300           0 :     bool DataSupplier::isCountFinal()
     301             :     {
     302           0 :         return true;
     303             :     }
     304             : 
     305             : 
     306           0 :     Reference< XRow > DataSupplier::queryPropertyValues( sal_uInt32 i_nIndex  )
     307             :     {
     308           0 :         ::osl::MutexGuard aGuard( m_pImpl->m_aMutex );
     309           0 :         ENSURE_OR_RETURN( i_nIndex < m_pImpl->m_aResults.size(), "DataSupplier::queryPropertyValues: illegal index!", NULL );
     310             : 
     311           0 :         Reference< XRow > xRow = m_pImpl->m_aResults[ i_nIndex ].xRow;
     312           0 :         if ( xRow.is() )
     313           0 :             return xRow;
     314             : 
     315           0 :         ENSURE_OR_RETURN( queryContent( i_nIndex ).is(), "could not retrieve the content", NULL );
     316             : 
     317           0 :         switch ( m_pImpl->m_xContent->getExtensionContentType() )
     318             :         {
     319             :         case E_ROOT:
     320             :         {
     321           0 :             const OUString& rId( m_pImpl->m_aResults[ i_nIndex ].sId );
     322           0 :             const OUString sRootURL( ContentProvider::getRootURL() );
     323           0 :             OUString sTitle = Content::decodeIdentifier( rId.copy( sRootURL.getLength() ) );
     324           0 :             if ( sTitle.endsWith("/") )
     325           0 :                 sTitle = sTitle.copy( 0, sTitle.getLength() - 1 );
     326           0 :             xRow = Content::getArtificialNodePropertyValues( m_pImpl->m_xContext, getResultSet()->getProperties(), sTitle );
     327             :         }
     328           0 :         break;
     329             : 
     330             :         case E_EXTENSION_ROOT:
     331             :         case E_EXTENSION_CONTENT:
     332             :         {
     333           0 :             xRow = m_pImpl->m_aResults[ i_nIndex ].pContent->getPropertyValues(
     334           0 :                 getResultSet()->getProperties(), getResultSet()->getEnvironment() );
     335             :         }
     336           0 :         break;
     337             :         default:
     338             :             OSL_FAIL( "DataSupplier::queryPropertyValues: unhandled case!" );
     339           0 :             break;
     340             :         }
     341             : 
     342           0 :         m_pImpl->m_aResults[ i_nIndex ].xRow = xRow;
     343           0 :         return xRow;
     344             :     }
     345             : 
     346             : 
     347           0 :     void DataSupplier::releasePropertyValues( sal_uInt32 i_nIndex )
     348             :     {
     349           0 :         ::osl::Guard< ::osl::Mutex > aGuard( m_pImpl->m_aMutex );
     350             : 
     351           0 :         if ( i_nIndex < m_pImpl->m_aResults.size() )
     352           0 :             m_pImpl->m_aResults[ i_nIndex ].xRow.clear();
     353           0 :     }
     354             : 
     355             : 
     356           0 :     void DataSupplier::close()
     357             :     {
     358           0 :     }
     359             : 
     360             : 
     361           0 :     void DataSupplier::validate() throw( ResultSetException )
     362             :     {
     363           0 :     }
     364             : 
     365             : 
     366             : } } }   // namespace ucp::ext
     367             : 
     368             : 
     369             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10