ucb/source/ucp/ftp/ftpcontentprovider.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 /**************************************************************************
  22                                 TODO
  23  **************************************************************************
  24
  25  *************************************************************************/
  26
  27 #include <com/sun/star/ucb/UniversalContentBroker.hpp>
  28 #include <comphelper/processfactory.hxx>
  29 #include <osl/socket.hxx>
  30 #include "ftpcontentprovider.hxx"
  31 #include "ftpcontent.hxx"
  32 #include "ftploaderthread.hxx"
  33
  34
  35 using namespace ftp;
  36 using namespace com::sun::star::lang;
  37 using namespace com::sun::star::container;
  38 using namespace com::sun::star::uno;
  39 using namespace com::sun::star::ucb;
  40 using namespace com::sun::star::beans;
  41
  42
  43
  44 //=========================================================================
  45 //=========================================================================
  46 //
  47 // ContentProvider Implementation.
  48 //
  49 //=========================================================================
  50 //=========================================================================
  51
  52 FTPContentProvider::FTPContentProvider(
  53     const Reference< XComponentContext >& rxContext)
  54 : ::ucbhelper::ContentProviderImplHelper(rxContext),
  55   m_ftpLoaderThread(0),
  56   m_pProxyDecider(0)
  57 {
  58 }
  59
  60 //=========================================================================
  61 // virtual
  62 FTPContentProvider::~FTPContentProvider()
  63 {
  64     delete m_ftpLoaderThread;
  65     delete m_pProxyDecider;
  66 }
  67
  68 //=========================================================================
  69 //
  70 // XInterface methods.
  71 //
  72 //=========================================================================
  73
  74 XINTERFACE_IMPL_3(FTPContentProvider,
  75                   XTypeProvider,
  76                   XServiceInfo,
  77                   XContentProvider)
  78
  79 //=========================================================================
  80 //
  81 // XTypeProvider methods.
  82 //
  83 //=========================================================================
  84
  85 XTYPEPROVIDER_IMPL_3(FTPContentProvider,
  86                      XTypeProvider,
  87                      XServiceInfo,
  88                      XContentProvider)
  89
  90 //=========================================================================
  91 //
  92 // XServiceInfo methods.
  93 //
  94 //=========================================================================
  95
  96 XSERVICEINFO_IMPL_1_CTX(
  97     FTPContentProvider,
  98     rtl::OUString("com.sun.star.comp.FTPContentProvider"),
  99     rtl::OUString(FTP_CONTENT_PROVIDER_SERVICE_NAME));
 100
 101 //=========================================================================
 102 //
 103 // Service factory implementation.
 104 //
 105 //=========================================================================
 106
 107 ONE_INSTANCE_SERVICE_FACTORY_IMPL(FTPContentProvider);
 108
 109
 110 //=========================================================================
 111 //
 112 // XContentProvider methods.
 113 //
 114 //=========================================================================
 115
 116 // virtual
 117 Reference<XContent> SAL_CALL
 118 FTPContentProvider::queryContent(
 119     const Reference< XContentIdentifier >& xCanonicId
 120 )
 121     throw(
 122         IllegalIdentifierException,
 123         RuntimeException
 124     )
 125 {
 126     // Check, if a content with given id already exists...
 127     Reference<XContent> xContent = queryExistingContent(xCanonicId).get();
 128     if(xContent.is())
 129         return xContent;
 130
 131     // A new content has to be returned:
 132     {
 133         // Initialize
 134         osl::MutexGuard aGuard( m_aMutex );
 135         if(!m_ftpLoaderThread || !m_pProxyDecider)
 136         {
 137             try {
 138                 init();
 139             } catch( ... ) {
 140                 throw RuntimeException();
 141             }
 142
 143             if(!m_ftpLoaderThread || !m_pProxyDecider)
 144                 throw RuntimeException();
 145         }
 146     }
 147
 148     try {
 149         FTPURL aURL(xCanonicId->getContentIdentifier(),
 150                     this);
 151
 152         if(!m_pProxyDecider->shouldUseProxy(
 153             rtl::OUString("ftp"),
 154             aURL.host(),
 155             aURL.port().toInt32()))
 156         {
 157             xContent = new FTPContent( m_xContext, this,xCanonicId,aURL);
 158             registerNewContent(xContent);
 159         }
 160         else {
 161             Reference<XContentProvider>
 162                 xProvider(getHttpProvider());
 163             if(xProvider.is())
 164                 return xProvider->queryContent(xCanonicId);
 165             else
 166                 throw RuntimeException();
 167         }
 168     } catch(const malformed_exception&) {
 169         throw IllegalIdentifierException();
 170     }
 171
 172     // may throw IllegalIdentifierException
 173     return xContent;
 174 }
 175
 176
 177
 178
 179 void FTPContentProvider::init() {
 180     m_ftpLoaderThread = new FTPLoaderThread();
 181     m_pProxyDecider = new ucbhelper::InternetProxyDecider( m_xContext );
 182 }
 183
 184
 185
 186 CURL* FTPContentProvider::handle() {
 187     // Cannot be zero if called from here;
 188     return m_ftpLoaderThread->handle();
 189 }
 190
 191
 192 bool FTPContentProvider::forHost(
 193     const rtl::OUString& host,
 194     const rtl::OUString& port,
 195     const rtl::OUString& username,
 196     rtl::OUString& password,
 197     rtl::OUString& account)
 198 {
 199     osl::MutexGuard aGuard(m_aMutex);
 200     for(unsigned int i = 0; i < m_ServerInfo.size(); ++i)
 201         if(host == m_ServerInfo[i].host &&
 202            port == m_ServerInfo[i].port &&
 203            username == m_ServerInfo[i].username )
 204         {
 205             password = m_ServerInfo[i].password;
 206             account = m_ServerInfo[i].account;
 207             return true;
 208         }
 209
 210     return false;
 211 }
 212
 213
 214 bool  FTPContentProvider::setHost(
 215     const rtl::OUString& host,
 216     const rtl::OUString& port,
 217     const rtl::OUString& username,
 218     const rtl::OUString& password,
 219     const rtl::OUString& account)
 220 {
 221     ServerInfo inf;
 222     inf.host = host;
 223     inf.port = port;
 224     inf.username = username;
 225     inf.password = password;
 226     inf.account = account;
 227
 228     bool present(false);
 229     osl::MutexGuard aGuard(m_aMutex);
 230     for(unsigned int i = 0; i < m_ServerInfo.size(); ++i)
 231         if(host == m_ServerInfo[i].host &&
 232            port == m_ServerInfo[i].port &&
 233            username == m_ServerInfo[i].username)
 234         {
 235             present = true;
 236             m_ServerInfo[i].password = password;
 237             m_ServerInfo[i].account = account;
 238         }
 239
 240     if(!present)
 241         m_ServerInfo.push_back(inf);
 242
 243     return !present;
 244 }
 245
 246
 247
 248 Reference<XContentProvider>
 249 FTPContentProvider::getHttpProvider()
 250     throw(RuntimeException)
 251 {
 252     // used for access to ftp-proxy
 253     return UniversalContentBroker::create( m_xContext )->queryContentProvider("http:");
 254 }
 255
 256 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */