connectivity/source/drivers/mozab/mozillasrc/MNSMozabProxy.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: MNSMozabProxy.cxx,v $
  10  * $Revision: 1.10.66.1 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_connectivity.hxx"
  33 #include "MNSMozabProxy.hxx"
  34
  35 #include "resource/mozab_res.hrc"
  36 #include "MDatabaseMetaDataHelper.hxx"
  37 #include "MQuery.hxx"
  38 #include <osl/mutex.hxx>
  39 #include <osl/conditn.hxx>
  40
  41 #include "pre_include_mozilla.h"
  42 #include <nsIProxyObjectManager.h>
  43 // More Mozilla includes for LDAP Connection Test
  44 #include "prprf.h"
  45 #include "nsILDAPURL.h"
  46 #include "nsILDAPMessage.h"
  47 #include "nsILDAPMessageListener.h"
  48 #include "nsILDAPErrors.h"
  49 #include "nsILDAPConnection.h"
  50 #include "nsILDAPOperation.h"
  51 #include "post_include_mozilla.h"
  52 #include "MQuery.hxx"
  53 #include <MQueryHelper.hxx>
  54 #include <com/sun/star/uno/Reference.hxx>
  55 #include <unotools/processfactory.hxx>
  56 #include "com/sun/star/mozilla/XProxyRunner.hpp"
  57
  58 using namespace com::sun::star::uno;
  59 using namespace com::sun::star::lang;
  60 using namespace com::sun::star::mozilla;
  61
  62
  63 #define TYPEASSERT(value,type) if (value != type) return !NS_OK;
  64
  65 using namespace connectivity::mozab;
  66
  67 /* Implementation file */
  68
  69 static ::osl::Mutex     m_aThreadMutex;
  70 extern nsresult NewAddressBook(const ::rtl::OUString * aName);
  71
  72
  73 MNSMozabProxy::MNSMozabProxy()
  74 {
  75   m_Args = NULL;
  76 #if OSL_DEBUG_LEVEL > 0
  77   m_oThreadID = osl_getThreadIdentifier(NULL);
  78 #endif
  79   acquire();
  80 }
  81
  82 MNSMozabProxy::~MNSMozabProxy()
  83 {
  84 }
  85
  86 sal_Int32 MNSMozabProxy::StartProxy(RunArgs * args,::com::sun::star::mozilla::MozillaProductType aProduct,const ::rtl::OUString &aProfile)
  87 {
  88     OSL_TRACE( "IN : MNSMozabProxy::StartProxy() \n" );
  89     ::osl::MutexGuard aGuard(m_aThreadMutex);
  90     m_Product = aProduct;
  91     m_Profile = aProfile;
  92     m_Args = args;
  93     if (!xRunner.is())
  94     {
  95         Reference<XMultiServiceFactory> xFactory = ::comphelper::getProcessServiceFactory();
  96         OSL_ENSURE( xFactory.is(), "can't get service factory" );
  97         ::com::sun::star::uno::Reference<XInterface> xInstance = xFactory->createInstance(::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.mozilla.MozillaBootstrap")) );
  98         OSL_ENSURE( xInstance.is(), "failed to create instance" );
  99         xRunner = ::com::sun::star::uno::Reference< ::com::sun::star::mozilla::XProxyRunner >(xInstance,UNO_QUERY);
 100     }
 101     const ::com::sun::star::uno::Reference< ::com::sun::star::mozilla::XCodeProxy > aCode(this);
 102     return xRunner->Run(aCode);
 103 }
 104
 105 extern nsresult getTableStringsProxied(const sal_Char* sAbURI, sal_Int32 *nDirectoryType,MNameMapper *nmap,
 106                         ::std::vector< ::rtl::OUString >*   _rStrings,
 107                         ::std::vector< ::rtl::OUString >*   _rTypes,
 108                         sal_Int32* pErrorId );
 109
 110 ::com::sun::star::mozilla::MozillaProductType SAL_CALL MNSMozabProxy::getProductType(  ) throw (::com::sun::star::uno::RuntimeException)
 111 {
 112     return m_Product;
 113 }
 114 ::rtl::OUString SAL_CALL MNSMozabProxy::getProfileName(  ) throw (::com::sun::star::uno::RuntimeException)
 115 {
 116     return m_Profile;
 117 }
 118
 119 sal_Int32 SAL_CALL MNSMozabProxy::run(  ) throw (::com::sun::star::uno::RuntimeException)
 120 {
 121 #if OSL_DEBUG_LEVEL > 0
 122     OSL_TRACE( "IN : MNSMozabProxy::Run() Caller thread :%4d \n" , m_oThreadID );
 123 #else
 124     OSL_TRACE( "IN : MNSMozabProxy::Run() \n" );
 125 #endif
 126     nsresult rv = NS_ERROR_INVALID_ARG;
 127     if (m_Args == NULL)
 128         return NS_ERROR_INVALID_ARG;
 129     switch(m_Args->funcIndex)
 130     {
 131     case ProxiedFunc::FUNC_TESTLDAP_INIT_LDAP:
 132     case ProxiedFunc::FUNC_TESTLDAP_IS_LDAP_CONNECTED:
 133     case ProxiedFunc::FUNC_TESTLDAP_RELEASE_RESOURCE:
 134         rv = testLDAPConnection();
 135         break;
 136     case ProxiedFunc::FUNC_GET_TABLE_STRINGS:
 137         rv = getTableStringsProxied((const sal_Char*)m_Args->arg1,
 138                                 (sal_Int32 *)m_Args->arg2,
 139                                 (MNameMapper *)m_Args->arg3,
 140                                 (::std::vector< ::rtl::OUString >*)m_Args->arg4,
 141                                 (::std::vector< ::rtl::OUString >*)m_Args->arg5,
 142                                 (sal_Int32 *)m_Args->arg6);
 143         break;
 144     case ProxiedFunc::FUNC_EXECUTE_QUERY:
 145         if (m_Args->arg1 && m_Args->arg2)
 146         {
 147             rv = ((MQuery*)m_Args->arg1)->executeQueryProxied((OConnection*)m_Args->arg2);
 148         }
 149         break;
 150     case ProxiedFunc::FUNC_QUERYHELPER_CREATE_NEW_CARD:
 151     case ProxiedFunc::FUNC_QUERYHELPER_DELETE_CARD:
 152     case ProxiedFunc::FUNC_QUERYHELPER_COMMIT_CARD:
 153     case ProxiedFunc::FUNC_QUERYHELPER_RESYNC_CARD:
 154         if (m_Args->arg1)
 155         {
 156             rv = QueryHelperStub();
 157         }
 158         break;
 159     case ProxiedFunc::FUNC_NEW_ADDRESS_BOOK:
 160         if (m_Args->arg1)
 161         {
 162             rv = NewAddressBook((const ::rtl::OUString*)m_Args->arg1 );
 163         }
 164         break;
 165     default:
 166            return NS_ERROR_INVALID_ARG;
 167     }
 168     return rv;
 169 }
 170
 171 nsresult MNSMozabProxy::QueryHelperStub()
 172 {
 173     nsresult rv = NS_ERROR_INVALID_ARG;
 174     MQueryHelper * mHelper=(MQueryHelper*) m_Args->arg1;
 175     switch(m_Args->funcIndex)
 176     {
 177     case ProxiedFunc::FUNC_QUERYHELPER_CREATE_NEW_CARD:
 178         if (m_Args->arg2 )  //m_Args->arg2 used to return cord number
 179         {
 180             *((sal_Int32*)m_Args->arg2) = mHelper->createNewCard();
 181             rv = NS_OK;
 182         }
 183         break;
 184     case ProxiedFunc::FUNC_QUERYHELPER_DELETE_CARD:
 185         if (m_Args->arg2 && m_Args->arg3 )  //m_Args->arg2 used to get the cord number
 186         {
 187             rv = mHelper->deleteCard(*((sal_Int32*)m_Args->arg2),(nsIAbDirectory*)m_Args->arg3);
 188         }
 189         break;
 190     case ProxiedFunc::FUNC_QUERYHELPER_COMMIT_CARD:
 191         if (m_Args->arg2 && m_Args->arg3 )  //m_Args->arg2 used to get the cord number
 192         {
 193             rv = mHelper->commitCard(*((sal_Int32*)m_Args->arg2),(nsIAbDirectory*)m_Args->arg3);
 194         }
 195         break;
 196     case ProxiedFunc::FUNC_QUERYHELPER_RESYNC_CARD:
 197         if (m_Args->arg2)  //m_Args->arg2 used to get the cord number
 198         {
 199             rv = mHelper->resyncRow(*((sal_Int32*)m_Args->arg2));
 200         }
 201         break;
 202     default:
 203         break;
 204     }
 205     return rv;
 206 }
 207 //-------------------------------------------------------------------
 208
 209 #define NS_LDAPCONNECTION_CONTRACTID     "@mozilla.org/network/ldap-connection;1"
 210 #define NS_LDAPOPERATION_CONTRACTID      "@mozilla.org/network/ldap-operation;1"
 211 #define NS_LDAPMESSAGE_CONTRACTID      "@mozilla.org/network/ldap-message;1"
 212 #define NS_LDAPURL_CONTRACTID       "@mozilla.org/network/ldap-url;1"
 213
 214 namespace connectivity {
 215     namespace mozab {
 216         class MLDAPMessageListener : public nsILDAPMessageListener
 217         {
 218             NS_DECL_ISUPPORTS
 219             NS_DECL_NSILDAPMESSAGELISTENER
 220
 221             MLDAPMessageListener();
 222             virtual ~MLDAPMessageListener();
 223
 224             sal_Bool    initialized() const;
 225             sal_Bool    goodConnection() const { return initialized() && m_GoodConnection; }
 226
 227         protected:
 228
 229             ::osl::Mutex        m_aMutex;
 230             ::osl::Condition    m_aCondition;
 231
 232             sal_Bool    m_IsComplete;
 233             sal_Bool    m_GoodConnection;
 234
 235             void        setConnectionStatus( sal_Bool _good );
 236         };
 237     }
 238 }
 239
 240 NS_IMPL_THREADSAFE_ISUPPORTS1(MLDAPMessageListener, nsILDAPMessageListener)
 241
 242 MLDAPMessageListener::MLDAPMessageListener()
 243     : mRefCnt( 0 )
 244     , m_IsComplete( sal_False )
 245     , m_GoodConnection( sal_False )
 246 {
 247     m_aCondition.reset();
 248 }
 249
 250 MLDAPMessageListener::~MLDAPMessageListener()
 251 {
 252 }
 253
 254 sal_Bool MLDAPMessageListener::initialized() const
 255 {
 256     return const_cast< MLDAPMessageListener* >( this )->m_aCondition.check();
 257 }
 258
 259 void MLDAPMessageListener::setConnectionStatus( sal_Bool _good )
 260 {
 261     ::osl::MutexGuard aGuard( m_aMutex );
 262     m_IsComplete = sal_True;
 263     m_GoodConnection = _good;
 264
 265     m_aCondition.set();
 266 }
 267
 268 NS_IMETHODIMP MLDAPMessageListener::OnLDAPInit(nsILDAPConnection* /*aConn*/, nsresult aStatus )
 269 {
 270     setConnectionStatus( NS_SUCCEEDED( aStatus ) ? sal_True : sal_False );
 271     return aStatus;
 272 }
 273
 274 NS_IMETHODIMP MLDAPMessageListener::OnLDAPMessage( nsILDAPMessage* aMessage )
 275 {
 276     nsresult rv;
 277
 278     PRInt32 messageType;
 279     rv = aMessage->GetType(&messageType);
 280     NS_ENSURE_SUCCESS(rv, rv);
 281     PRInt32 errCode;
 282     switch (messageType)
 283     {
 284     case nsILDAPMessage::RES_BIND:
 285         rv = aMessage->GetErrorCode(&errCode);
 286         // if the login failed
 287         if (errCode != (PRInt32)nsILDAPErrors::SUCCESS) {
 288             setConnectionStatus( sal_False );
 289         }
 290         else
 291             setConnectionStatus( sal_True );
 292         break;
 293     case nsILDAPMessage::RES_SEARCH_RESULT:
 294         setConnectionStatus( sal_True );
 295         break;
 296     default:
 297         break;
 298     }
 299
 300     return NS_OK;
 301 }
 302
 303 //-------------------------------------------------------------------
 304
 305 nsresult
 306 MNSMozabProxy::testLDAPConnection( )
 307 {
 308     nsresult rv=NS_ERROR_INVALID_ARG;
 309     switch(m_Args->funcIndex)
 310     {
 311     case ProxiedFunc::FUNC_TESTLDAP_INIT_LDAP:
 312         if (m_Args->arg1 && m_Args->arg4 )
 313         {
 314             rv = InitLDAP((sal_Char*)m_Args->arg1,(sal_Unicode*)m_Args->arg2,(sal_Unicode*)m_Args->arg3,(sal_Bool*)m_Args->arg4);
 315         }
 316         break;
 317     case ProxiedFunc::FUNC_TESTLDAP_IS_LDAP_CONNECTED:
 318         if (m_Args->arg5)
 319         {
 320             const MLDAPMessageListener* pListener( static_cast< const MLDAPMessageListener* >( m_Args->arg5 ) );
 321             if ( pListener->initialized() )
 322                 rv = pListener->goodConnection() ? 0 : (nsresult)PR_NOT_CONNECTED_ERROR;
 323             else
 324                 rv = (nsresult)PR_CONNECT_TIMEOUT_ERROR;
 325         }
 326         break;
 327     case ProxiedFunc::FUNC_TESTLDAP_RELEASE_RESOURCE:
 328         if (m_Args->arg5)
 329         {
 330             ((MLDAPMessageListener*)m_Args->arg5)->Release();
 331             delete (MLDAPMessageListener*)m_Args->arg5;
 332             m_Args->arg5 = NULL;
 333             rv = 0;
 334         }
 335         break;
 336     default:
 337         return NS_ERROR_INVALID_ARG;
 338     }
 339     return rv;
 340 }
 341 nsresult
 342 MNSMozabProxy::InitLDAP(sal_Char* sUri, sal_Unicode* sBindDN, sal_Unicode* pPasswd,sal_Bool * nUseSSL)
 343 {
 344     sal_Bool      useSSL    = *nUseSSL;
 345     nsresult       rv;
 346
 347     nsCOMPtr<nsILDAPURL> url;
 348     url = do_CreateInstance(NS_LDAPURL_CONTRACTID, &rv);
 349     if ( NS_FAILED(rv) )
 350         return NS_ERROR_INVALID_ARG;
 351
 352     rv = url->SetSpec( nsDependentCString(sUri) );
 353     NS_ENSURE_SUCCESS(rv, rv);
 354
 355     nsCAutoString host;
 356     rv = url->GetAsciiHost(host);
 357     NS_ENSURE_SUCCESS(rv, rv);
 358
 359     PRInt32 port;
 360     rv = url->GetPort(&port);
 361     NS_ENSURE_SUCCESS(rv, rv);
 362
 363     nsCString dn;
 364     rv = url->GetDn(dn);
 365     NS_ENSURE_SUCCESS(rv, rv);
 366
 367
 368
 369     // Get the ldap connection
 370     nsCOMPtr<nsILDAPConnection> ldapConnection;
 371     ldapConnection = do_CreateInstance(NS_LDAPCONNECTION_CONTRACTID, &rv);
 372     NS_ENSURE_SUCCESS(rv, rv);
 373
 374     MLDAPMessageListener* messageListener =
 375         new MLDAPMessageListener ( );
 376     if (messageListener == NULL)
 377         return NS_ERROR_INVALID_ARG;
 378
 379     messageListener->AddRef();
 380
 381     nsCAutoString nsBind;
 382     // PRUnichar != sal_Unicode in mingw
 383     nsBind.AssignWithConversion(reinterpret_cast_mingw_only<const PRUnichar *>(sBindDN));
 384
 385     // Now lets initialize the LDAP connection properly.
 386     rv = ldapConnection->Init(host.get(), port, useSSL, nsBind,
 387                               messageListener,NULL,nsILDAPConnection::VERSION3);
 388     // Initiate the LDAP operation
 389     nsCOMPtr<nsILDAPOperation> ldapOperation =
 390     do_CreateInstance(NS_LDAPOPERATION_CONTRACTID, &rv);
 391
 392     rv = ldapOperation->Init(ldapConnection, messageListener, nsnull);
 393     if (NS_FAILED(rv))
 394     return NS_ERROR_UNEXPECTED; // this should never happen
 395
 396     if ( pPasswd && *pPasswd )
 397     {
 398         nsCAutoString nsPassword;
 399         // PRUnichar != sal_Unicode in mingw
 400         nsPassword.AssignWithConversion(reinterpret_cast_mingw_only<const PRUnichar *>(pPasswd));
 401         rv = ldapOperation->SimpleBind(nsPassword);
 402     }
 403
 404     if (NS_SUCCEEDED(rv))
 405         m_Args->arg5 = messageListener;
 406     return rv;
 407 }