sw/source/ui/uno/unodispatch.cxx

   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 <vcl/svapp.hxx>
  22 #include <sfx2/viewfrm.hxx>
  23 #include <sfx2/dispatch.hxx>
  24 #include <svx/dataaccessdescriptor.hxx>
  25 #include <comphelper/servicehelper.hxx>
  26 #include <unodispatch.hxx>
  27 #include <unobaseclass.hxx>
  28 #include <view.hxx>
  29 #include <cmdid.h>
  30 #include "wrtsh.hxx"
  31 #include "dbmgr.hxx"
  32
  33
  34 using namespace ::com::sun::star;
  35
  36
  37 static const char* cURLFormLetter      = ".uno:DataSourceBrowser/FormLetter";
  38 static const char* cURLInsertContent   = ".uno:DataSourceBrowser/InsertContent";//data into fields
  39 static const char* cURLInsertColumns   = ".uno:DataSourceBrowser/InsertColumns";//data into text
  40 static const char* cURLDocumentDataSource  = ".uno:DataSourceBrowser/DocumentDataSource";//current data source of the document
  41 static const sal_Char* cInternalDBChangeNotification = ".uno::Writer/DataSourceChanged";
  42
  43 SwXDispatchProviderInterceptor::SwXDispatchProviderInterceptor(SwView& rVw) :
  44     m_pView(&rVw)
  45 {
  46     uno::Reference< frame::XFrame> xUnoFrame = m_pView->GetViewFrame()->GetFrame().GetFrameInterface();
  47     m_xIntercepted = uno::Reference< frame::XDispatchProviderInterception>(xUnoFrame, uno::UNO_QUERY);
  48     if(m_xIntercepted.is())
  49     {
  50         m_refCount++;
  51         m_xIntercepted->registerDispatchProviderInterceptor((frame::XDispatchProviderInterceptor*)this);
  52         // this should make us the top-level dispatch-provider for the component, via a call to our
  53         // setDispatchProvider we should have got an fallback for requests we (i.e. our master) cannot fullfill
  54         uno::Reference< lang::XComponent> xInterceptedComponent(m_xIntercepted, uno::UNO_QUERY);
  55         if (xInterceptedComponent.is())
  56             xInterceptedComponent->addEventListener((lang::XEventListener*)this);
  57         m_refCount--;
  58     }
  59 }
  60
  61 SwXDispatchProviderInterceptor::~SwXDispatchProviderInterceptor()
  62 {
  63 }
  64
  65 uno::Reference< frame::XDispatch > SwXDispatchProviderInterceptor::queryDispatch(
  66     const util::URL& aURL, const OUString& aTargetFrameName, sal_Int32 nSearchFlags )
  67         throw(uno::RuntimeException)
  68 {
  69     DispatchMutexLock_Impl aLock(*this);
  70     uno::Reference< frame::XDispatch> xResult;
  71     // create some dispatch ...
  72     if(m_pView && aURL.Complete.startsWith(".uno:DataSourceBrowser/"))
  73     {
  74         if(!aURL.Complete.compareToAscii(cURLFormLetter) ||
  75             !aURL.Complete.compareToAscii(cURLInsertContent) ||
  76                 !aURL.Complete.compareToAscii(cURLInsertColumns)||
  77                     !aURL.Complete.compareToAscii(cURLDocumentDataSource))
  78         {
  79             if(!m_xDispatch.is())
  80                 m_xDispatch = new SwXDispatch(*m_pView);
  81             xResult = m_xDispatch;
  82         }
  83     }
  84
  85     // ask our slave provider
  86     if (!xResult.is() && m_xSlaveDispatcher.is())
  87         xResult = m_xSlaveDispatcher->queryDispatch(aURL, aTargetFrameName, nSearchFlags);
  88
  89     return xResult;
  90 }
  91
  92 uno::Sequence< uno::Reference< frame::XDispatch > > SwXDispatchProviderInterceptor::queryDispatches(
  93     const uno::Sequence< frame::DispatchDescriptor >& aDescripts ) throw(uno::RuntimeException)
  94 {
  95     DispatchMutexLock_Impl aLock(*this);
  96     uno::Sequence< uno::Reference< frame::XDispatch> > aReturn(aDescripts.getLength());
  97     uno::Reference< frame::XDispatch>* pReturn = aReturn.getArray();
  98     const frame::DispatchDescriptor* pDescripts = aDescripts.getConstArray();
  99     for (sal_Int16 i=0; i<aDescripts.getLength(); ++i, ++pReturn, ++pDescripts)
 100     {
 101         *pReturn = queryDispatch(pDescripts->FeatureURL,
 102                 pDescripts->FrameName, pDescripts->SearchFlags);
 103     }
 104     return aReturn;
 105 }
 106
 107 uno::Reference< frame::XDispatchProvider > SwXDispatchProviderInterceptor::getSlaveDispatchProvider(  )
 108         throw(uno::RuntimeException)
 109 {
 110     DispatchMutexLock_Impl aLock(*this);
 111     return m_xSlaveDispatcher;
 112 }
 113
 114 void SwXDispatchProviderInterceptor::setSlaveDispatchProvider(
 115     const uno::Reference< frame::XDispatchProvider >& xNewDispatchProvider ) throw(uno::RuntimeException)
 116 {
 117     DispatchMutexLock_Impl aLock(*this);
 118     m_xSlaveDispatcher = xNewDispatchProvider;
 119 }
 120
 121 uno::Reference< frame::XDispatchProvider > SwXDispatchProviderInterceptor::getMasterDispatchProvider(  )
 122         throw(uno::RuntimeException)
 123 {
 124     DispatchMutexLock_Impl aLock(*this);
 125     return m_xMasterDispatcher;
 126 }
 127
 128 void SwXDispatchProviderInterceptor::setMasterDispatchProvider(
 129     const uno::Reference< frame::XDispatchProvider >& xNewSupplier ) throw(uno::RuntimeException)
 130 {
 131     DispatchMutexLock_Impl aLock(*this);
 132     m_xMasterDispatcher = xNewSupplier;
 133 }
 134
 135 void SwXDispatchProviderInterceptor::disposing( const lang::EventObject& )
 136     throw(uno::RuntimeException)
 137 {
 138     DispatchMutexLock_Impl aLock(*this);
 139     if (m_xIntercepted.is())
 140     {
 141         m_xIntercepted->releaseDispatchProviderInterceptor((frame::XDispatchProviderInterceptor*)this);
 142         uno::Reference< lang::XComponent> xInterceptedComponent(m_xIntercepted, uno::UNO_QUERY);
 143         if (xInterceptedComponent.is())
 144             xInterceptedComponent->removeEventListener((lang::XEventListener*)this);
 145         m_xDispatch       = 0;
 146     }
 147     m_xIntercepted = NULL;
 148 }
 149
 150 namespace
 151 {
 152     class theSwXDispatchProviderInterceptorUnoTunnelId : public rtl::Static< UnoTunnelIdInit, theSwXDispatchProviderInterceptorUnoTunnelId > {};
 153 }
 154
 155 const uno::Sequence< sal_Int8 > & SwXDispatchProviderInterceptor::getUnoTunnelId()
 156 {
 157     return theSwXDispatchProviderInterceptorUnoTunnelId::get().getSeq();
 158 }
 159
 160 sal_Int64 SwXDispatchProviderInterceptor::getSomething(
 161     const uno::Sequence< sal_Int8 >& aIdentifier )
 162         throw(uno::RuntimeException)
 163 {
 164     if( aIdentifier.getLength() == 16
 165         && 0 == memcmp( getUnoTunnelId().getConstArray(),
 166                                         aIdentifier.getConstArray(), 16 ) )
 167     {
 168             return sal::static_int_cast< sal_Int64 >( reinterpret_cast< sal_IntPtr >( this ));
 169     }
 170     return 0;
 171 }
 172
 173 void    SwXDispatchProviderInterceptor::Invalidate()
 174 {
 175     DispatchMutexLock_Impl aLock(*this);
 176     if (m_xIntercepted.is())
 177     {
 178         m_xIntercepted->releaseDispatchProviderInterceptor((frame::XDispatchProviderInterceptor*)this);
 179         uno::Reference< lang::XComponent> xInterceptedComponent(m_xIntercepted, uno::UNO_QUERY);
 180         if (xInterceptedComponent.is())
 181             xInterceptedComponent->removeEventListener((lang::XEventListener*)this);
 182         m_xDispatch       = 0;
 183     }
 184     m_xIntercepted = NULL;
 185     m_pView = 0;
 186 }
 187
 188 SwXDispatch::SwXDispatch(SwView& rVw) :
 189     m_pView(&rVw),
 190     m_bOldEnable(sal_False),
 191     m_bListenerAdded(sal_False)
 192 {
 193 }
 194
 195 SwXDispatch::~SwXDispatch()
 196 {
 197     if(m_bListenerAdded && m_pView)
 198     {
 199         uno::Reference<view::XSelectionSupplier> xSupplier = m_pView->GetUNOObject();
 200         uno::Reference<view::XSelectionChangeListener> xThis = this;
 201         xSupplier->removeSelectionChangeListener(xThis);
 202     }
 203 }
 204
 205 void SwXDispatch::dispatch(
 206     const util::URL& aURL, const uno::Sequence< beans::PropertyValue >& aArgs ) throw(uno::RuntimeException)
 207 {
 208     if(!m_pView)
 209         throw uno::RuntimeException();
 210     SwWrtShell& rSh = m_pView->GetWrtShell();
 211     SwNewDBMgr* pNewDBMgr = rSh.GetNewDBMgr();
 212     if(!aURL.Complete.compareToAscii(cURLInsertContent))
 213     {
 214         ::svx::ODataAccessDescriptor aDescriptor(aArgs);
 215         SwMergeDescriptor aMergeDesc( DBMGR_MERGE, rSh, aDescriptor );
 216         pNewDBMgr->MergeNew(aMergeDesc);
 217     }
 218     else if(!aURL.Complete.compareToAscii(cURLInsertColumns))
 219     {
 220         pNewDBMgr->InsertText(rSh, aArgs);
 221     }
 222     else if(!aURL.Complete.compareToAscii(cURLFormLetter))
 223     {
 224         SfxUsrAnyItem aDBProperties(FN_PARAM_DATABASE_PROPERTIES, uno::makeAny(aArgs));
 225         m_pView->GetViewFrame()->GetDispatcher()->Execute(
 226             FN_MAILMERGE_WIZARD,
 227             SFX_CALLMODE_ASYNCHRON,
 228             &aDBProperties, 0L);
 229     }
 230     else if(!aURL.Complete.compareToAscii(cURLDocumentDataSource))
 231     {
 232         OSL_FAIL("SwXDispatch::dispatch: this URL is not to be dispatched!");
 233     }
 234     else if(!aURL.Complete.compareToAscii(cInternalDBChangeNotification))
 235     {
 236         frame::FeatureStateEvent aEvent;
 237         aEvent.IsEnabled = sal_True;
 238         aEvent.Source = *(cppu::OWeakObject*)this;
 239
 240         const SwDBData& rData = m_pView->GetWrtShell().GetDBDesc();
 241         ::svx::ODataAccessDescriptor aDescriptor;
 242         aDescriptor.setDataSource(rData.sDataSource);
 243         aDescriptor[::svx::daCommand]       <<= rData.sCommand;
 244         aDescriptor[::svx::daCommandType]   <<= rData.nCommandType;
 245
 246         aEvent.State <<= aDescriptor.createPropertyValueSequence();
 247         aEvent.IsEnabled = !rData.sDataSource.isEmpty();
 248
 249         StatusListenerList::iterator aListIter = m_aListenerList.begin();
 250         for(aListIter = m_aListenerList.begin(); aListIter != m_aListenerList.end(); ++aListIter)
 251         {
 252             StatusStruct_Impl aStatus = *aListIter;
 253             if(!aStatus.aURL.Complete.compareToAscii(cURLDocumentDataSource))
 254             {
 255                 aEvent.FeatureURL = aStatus.aURL;
 256                 aStatus.xListener->statusChanged( aEvent );
 257             }
 258         }
 259     }
 260     else
 261         throw uno::RuntimeException();
 262
 263 }
 264
 265 void SwXDispatch::addStatusListener(
 266     const uno::Reference< frame::XStatusListener >& xControl, const util::URL& aURL ) throw(uno::RuntimeException)
 267 {
 268     if(!m_pView)
 269         throw uno::RuntimeException();
 270     ShellModes eMode = m_pView->GetShellMode();
 271     sal_Bool bEnable = SHELL_MODE_TEXT == eMode  ||
 272                        SHELL_MODE_LIST_TEXT == eMode  ||
 273                        SHELL_MODE_TABLE_TEXT == eMode  ||
 274                        SHELL_MODE_TABLE_LIST_TEXT == eMode;
 275
 276     m_bOldEnable = bEnable;
 277     frame::FeatureStateEvent aEvent;
 278     aEvent.IsEnabled = bEnable;
 279     aEvent.Source = *(cppu::OWeakObject*)this;
 280     aEvent.FeatureURL = aURL;
 281
 282     // one of the URLs requires a special state ....
 283     if (!aURL.Complete.compareToAscii(cURLDocumentDataSource))
 284     {
 285         const SwDBData& rData = m_pView->GetWrtShell().GetDBDesc();
 286
 287         ::svx::ODataAccessDescriptor aDescriptor;
 288         aDescriptor.setDataSource(rData.sDataSource);
 289         aDescriptor[::svx::daCommand]       <<= rData.sCommand;
 290         aDescriptor[::svx::daCommandType]   <<= rData.nCommandType;
 291
 292         aEvent.State <<= aDescriptor.createPropertyValueSequence();
 293         aEvent.IsEnabled = !rData.sDataSource.isEmpty();
 294     }
 295
 296
 297     xControl->statusChanged( aEvent );
 298
 299     StatusListenerList::iterator aListIter = m_aListenerList.begin();
 300     StatusStruct_Impl aStatus;
 301     aStatus.xListener = xControl;
 302     aStatus.aURL = aURL;
 303     m_aListenerList.insert(aListIter, aStatus);
 304
 305     if(!m_bListenerAdded)
 306     {
 307         uno::Reference<view::XSelectionSupplier> xSupplier = m_pView->GetUNOObject();
 308         uno::Reference<view::XSelectionChangeListener> xThis = this;
 309         xSupplier->addSelectionChangeListener(xThis);
 310         m_bListenerAdded = sal_True;
 311     }
 312 }
 313
 314 void SwXDispatch::removeStatusListener(
 315     const uno::Reference< frame::XStatusListener >& xControl, const util::URL&  ) throw(uno::RuntimeException)
 316 {
 317     StatusListenerList::iterator aListIter = m_aListenerList.begin();
 318     for(aListIter = m_aListenerList.begin(); aListIter != m_aListenerList.end(); ++aListIter)
 319     {
 320         StatusStruct_Impl aStatus = *aListIter;
 321         if(aStatus.xListener.get() == xControl.get())
 322         {
 323             m_aListenerList.erase(aListIter);
 324             break;
 325         }
 326     }
 327     if(m_aListenerList.empty() && m_pView)
 328     {
 329         uno::Reference<view::XSelectionSupplier> xSupplier = m_pView->GetUNOObject();
 330         uno::Reference<view::XSelectionChangeListener> xThis = this;
 331         xSupplier->removeSelectionChangeListener(xThis);
 332         m_bListenerAdded = sal_False;
 333     }
 334 }
 335
 336 void SwXDispatch::selectionChanged( const lang::EventObject&  ) throw(uno::RuntimeException)
 337 {
 338     ShellModes eMode = m_pView->GetShellMode();
 339     sal_Bool bEnable = SHELL_MODE_TEXT == eMode  ||
 340                        SHELL_MODE_LIST_TEXT == eMode  ||
 341                        SHELL_MODE_TABLE_TEXT == eMode  ||
 342                        SHELL_MODE_TABLE_LIST_TEXT == eMode;
 343     if(bEnable != m_bOldEnable)
 344     {
 345         m_bOldEnable = bEnable;
 346         frame::FeatureStateEvent aEvent;
 347         aEvent.IsEnabled = bEnable;
 348         aEvent.Source = *(cppu::OWeakObject*)this;
 349
 350         StatusListenerList::iterator aListIter = m_aListenerList.begin();
 351         for(aListIter = m_aListenerList.begin(); aListIter != m_aListenerList.end(); ++aListIter)
 352         {
 353             StatusStruct_Impl aStatus = *aListIter;
 354             aEvent.FeatureURL = aStatus.aURL;
 355             if (0 != aStatus.aURL.Complete.compareToAscii(cURLDocumentDataSource))
 356                 // the document's data source does not depend on the selection, so it's state does not change here
 357                 aStatus.xListener->statusChanged( aEvent );
 358         }
 359     }
 360 }
 361
 362 void SwXDispatch::disposing( const lang::EventObject& rSource ) throw(uno::RuntimeException)
 363 {
 364     uno::Reference<view::XSelectionSupplier> xSupplier(rSource.Source, uno::UNO_QUERY);
 365     uno::Reference<view::XSelectionChangeListener> xThis = this;
 366     xSupplier->removeSelectionChangeListener(xThis);
 367     m_bListenerAdded = sal_False;
 368
 369     lang::EventObject aObject;
 370     aObject.Source = (cppu::OWeakObject*)this;
 371     StatusListenerList::iterator aListIter = m_aListenerList.begin();
 372     for(; aListIter != m_aListenerList.end(); ++aListIter)
 373     {
 374         StatusStruct_Impl aStatus = *aListIter;
 375         aStatus.xListener->disposing(aObject);
 376     }
 377     m_pView = 0;
 378 }
 379
 380 const sal_Char* SwXDispatch::GetDBChangeURL()
 381 {
 382     return cInternalDBChangeNotification;
 383 }
 384
 385 SwXDispatchProviderInterceptor::DispatchMutexLock_Impl::DispatchMutexLock_Impl(
 386                                                  SwXDispatchProviderInterceptor& ) :
 387     aGuard(Application::GetSolarMutex())
 388 {
 389 }
 390
 391 SwXDispatchProviderInterceptor::DispatchMutexLock_Impl::~DispatchMutexLock_Impl()
 392 {
 393 }
 394
 395 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */