summaryrefslogtreecommitdiffstats
path: root/ucb/source/ucp/webdav-neon/NeonSession.hxx
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--ucb/source/ucp/webdav-neon/NeonSession.hxx288
1 files changed, 288 insertions, 0 deletions
diff --git a/ucb/source/ucp/webdav-neon/NeonSession.hxx b/ucb/source/ucp/webdav-neon/NeonSession.hxx
new file mode 100644
index 000000000..51b477373
--- /dev/null
+++ b/ucb/source/ucp/webdav-neon/NeonSession.hxx
@@ -0,0 +1,288 @@
+/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+/*************************************************************************
+ *
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+ *
+ * Copyright 2000, 2010 Oracle and/or its affiliates.
+ *
+ * OpenOffice.org - a multi-platform office productivity suite
+ *
+ * This file is part of OpenOffice.org.
+ *
+ * OpenOffice.org is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser General Public License version 3
+ * only, as published by the Free Software Foundation.
+ *
+ * OpenOffice.org is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Lesser General Public License version 3 for more details
+ * (a copy is included in the LICENSE file that accompanied this code).
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * version 3 along with OpenOffice.org. If not, see
+ * <http://www.openoffice.org/license.html>
+ * for a copy of the LGPLv3 License.
+ *
+ ************************************************************************/
+
+#ifndef INCLUDED_UCB_SOURCE_UCP_WEBDAV_NEON_NEONSESSION_HXX
+#define INCLUDED_UCB_SOURCE_UCP_WEBDAV_NEON_NEONSESSION_HXX
+
+#include <config_lgpl.h>
+#include <vector>
+#include <osl/mutex.hxx>
+#include "DAVSession.hxx"
+#include "NeonTypes.hxx"
+#include "NeonLockStore.hxx"
+#include <com/sun/star/lang/XMultiServiceFactory.hpp>
+
+namespace ucbhelper { class ProxyDecider; }
+
+namespace webdav_ucp
+{
+
+// A DAVSession implementation using the neon/expat library
+class NeonSession : public DAVSession
+{
+private:
+ osl::Mutex m_aMutex;
+ OUString m_aScheme;
+ OUString m_aHostName;
+ OUString m_aProxyName;
+ sal_Int32 m_nPort;
+ sal_Int32 m_nProxyPort;
+ css::uno::Sequence< css::beans::NamedValue > m_aFlags;
+ HttpSession * m_pHttpSession;
+ bool m_bNeedNewSession = false; // Something happened that could invalidate m_pHttpSession
+ void * m_pRequestData;
+ const ucbhelper::InternetProxyDecider & m_rProxyDecider;
+
+ // @@@ This should really be per-request data. But Neon currently
+ // (0.23.5) has no interface for passing per-request user data.
+ // Theoretically, a NeonSession instance could handle multiple requests
+ // at a time --currently it doesn't. Thus this is not an issue at the
+ // moment.
+ DAVRequestEnvironment m_aEnv;
+
+ static bool m_bGlobalsInited;
+ static NeonLockStore m_aNeonLockStore;
+
+protected:
+ virtual ~NeonSession() override;
+
+public:
+ /// @throws std::exception
+ NeonSession( const rtl::Reference< DAVSessionFactory > & rSessionFactory,
+ const OUString& inUri,
+ const css::uno::Sequence< css::beans::NamedValue >& rFlags,
+ const ucbhelper::InternetProxyDecider & rProxyDecider );
+
+ // DAVSession methods
+ virtual bool CanUse( const OUString & inPath,
+ const css::uno::Sequence< css::beans::NamedValue >& rFlags ) override;
+
+ virtual bool UsesProxy() override;
+
+ const DAVRequestEnvironment & getRequestEnvironment() const
+ { return m_aEnv; }
+
+ virtual void
+ OPTIONS( const OUString & inPath,
+ DAVOptions& rOptions, // contains the name+values
+ const DAVRequestEnvironment & rEnv ) override;
+
+ // allprop & named
+ virtual void
+ PROPFIND( const OUString & inPath,
+ const Depth inDepth,
+ const std::vector< OUString > & inPropNames,
+ std::vector< DAVResource > & ioResources,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ // propnames
+ virtual void
+ PROPFIND( const OUString & inPath,
+ const Depth inDepth,
+ std::vector< DAVResourceInfo >& ioResInfo,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ PROPPATCH( const OUString & inPath,
+ const std::vector< ProppatchValue > & inValues,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ HEAD( const OUString & inPath,
+ const std::vector< OUString > & inHeaderNames,
+ DAVResource & ioResource,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual css::uno::Reference< css::io::XInputStream >
+ GET( const OUString & inPath,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ GET( const OUString & inPath,
+ css::uno::Reference< css::io::XOutputStream > & ioOutputStream,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual css::uno::Reference< css::io::XInputStream >
+ GET( const OUString & inPath,
+ const std::vector< OUString > & inHeaderNames,
+ DAVResource & ioResource,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ GET0( const OUString & inPath,
+ const std::vector< OUString > & inHeaderNames,
+ DAVResource & ioResource,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ GET( const OUString & inPath,
+ css::uno::Reference< css::io::XOutputStream > & ioOutputStream,
+ const std::vector< OUString > & inHeaderNames,
+ DAVResource & ioResource,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ PUT( const OUString & inPath,
+ const css::uno::Reference< css::io::XInputStream > & inInputStream,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual css::uno::Reference< css::io::XInputStream >
+ POST( const OUString & inPath,
+ const OUString & rContentType,
+ const OUString & rReferer,
+ const css::uno::Reference< css::io::XInputStream > & inInputStream,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ POST( const OUString & inPath,
+ const OUString & rContentType,
+ const OUString & rReferer,
+ const css::uno::Reference< css::io::XInputStream > & inInputStream,
+ css::uno::Reference< css::io::XOutputStream > & oOutputStream,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ MKCOL( const OUString & inPath,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void
+ COPY( const OUString & inSourceURL,
+ const OUString & inDestinationURL,
+ const DAVRequestEnvironment & rEnv,
+ bool inOverWrite ) override;
+
+ virtual void
+ MOVE( const OUString & inSourceURL,
+ const OUString & inDestinationURL,
+ const DAVRequestEnvironment & rEnv,
+ bool inOverWrite ) override;
+
+ virtual void DESTROY( const OUString & inPath,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ // set new lock.
+ virtual void LOCK( const OUString & inURL,
+ css::ucb::Lock & inLock,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ virtual void UNLOCK( const OUString & inURL,
+ const DAVRequestEnvironment & rEnv ) override;
+
+ // helpers
+ virtual void abort() override;
+
+ const OUString & getHostName() const { return m_aHostName; }
+
+ ::uno::Reference< ::uno::XComponentContext > const & getComponentContext() const
+ { return m_xFactory->getComponentContext(); }
+
+ const void * getRequestData() const { return m_pRequestData; }
+
+ bool isDomainMatch( const OUString& certHostName );
+
+ int CertificationNotify(const ne_ssl_certificate *cert);
+
+ int NeonAuth(const char* inAuthProtocol, const char* inRealm,
+ int attempt, char* inoutUserName, char * inoutPassWord);
+
+ void PreSendRequest(ne_request* req, ne_buffer* headers);
+
+private:
+ friend class NeonLockStore;
+
+ /// @throws css::uno::RuntimeException
+ void Init();
+
+ /// @throws css::uno::RuntimeException
+ void Init( const DAVRequestEnvironment & rEnv );
+
+ // ret: true => retry request.
+ /// @throws std::exception
+ void HandleError( int nError,
+ const OUString & inPath,
+ const DAVRequestEnvironment & rEnv );
+
+ ucbhelper::InternetProxyServer getProxySettings() const;
+
+ bool removeExpiredLocktoken( const OUString & inURL,
+ const DAVRequestEnvironment & rEnv );
+
+ // refresh lock, called by NeonLockStore::refreshLocks
+ bool LOCK( NeonLock * pLock,
+ sal_Int32 & rlastChanceToSendRefreshRequest );
+
+ // unlock, called by NeonLockStore::~NeonLockStore
+ bool UNLOCK( NeonLock * pLock );
+
+ // low level GET implementation, used by public GET implementations
+ static int GET( ne_session * sess,
+ const char * uri,
+ ne_block_reader reader,
+ bool getheaders,
+ void * userdata );
+
+ // low level GET implementation, used by public GET implementations
+ // used as a HEAD substitute when head is not available
+ static int GET0( ne_session * sess,
+ const char * uri,
+ bool getheaders,
+ void * userdata );
+
+ // Buffer-based PUT implementation. Neon only has file descriptor-
+ // based API.
+ static int PUT( ne_session * sess,
+ const char * uri,
+ const char * buffer,
+ size_t size );
+
+ // Buffer-based POST implementation. Neon only has file descriptor-
+ // based API.
+ int POST( ne_session * sess,
+ const char * uri,
+ const char * buffer,
+ ne_block_reader reader,
+ void * userdata,
+ const OUString & rContentType,
+ const OUString & rReferer );
+
+ // Helper: XInputStream -> Sequence< sal_Int8 >
+ static bool getDataFromInputStream(
+ const css::uno::Reference< css::io::XInputStream > & xStream,
+ css::uno::Sequence< sal_Int8 > & rData,
+ bool bAppendTrailingZeroByte );
+
+ OUString makeAbsoluteURL( OUString const & rURL ) const;
+};
+
+osl::Mutex& getGlobalNeonMutex();
+
+} // namespace webdav_ucp
+
+#endif // INCLUDED_UCB_SOURCE_UCP_WEBDAV_NEON_NEONSESSION_HXX
+
+/* vim:set shiftwidth=4 softtabstop=4 expandtab: */