1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4; fill-column: 100 -*- */
/*
* This file is part of the LibreOffice project.
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#pragma once
#include "DAVSession.hxx"
#include "CurlUri.hxx"
#include <curl/curl.h>
#include <atomic>
#include <mutex>
namespace http_dav_ucp
{
/// implementation of libcurl HTTP/DAV back-end
class CurlSession : public DAVSession
{
private:
/// mutex required to access all other non-const members
::std::mutex m_Mutex;
css::uno::Reference<css::uno::XComponentContext> const m_xContext;
/// flags may be passed to constructor, e.g. "KeepAlive"
css::uno::Sequence<css::beans::NamedValue> const m_Flags;
CurlUri const m_URI;
/// buffer for libcurl detailed error messages
char m_ErrorBuffer[CURL_ERROR_SIZE];
/// proxy is used if non-empty
OUString const m_Proxy;
/// once authentication was successful, rely on m_pCurl's data
bool m_isAuthenticated = false;
bool m_isAuthenticatedProxy = false;
/// read timeout in milliseconds (connection timeout is stored in m_pCurl)
int m_nReadTimeout = 0;
/// flag to signal abort to transferring thread
::std::atomic<bool> m_AbortFlag = false;
/// libcurl multi handle
::std::unique_ptr<CURLM, deleter_from_fn<CURLM, curl_multi_cleanup>> m_pCurlMulti;
/// libcurl easy handle
::std::unique_ptr<CURL, deleter_from_fn<CURL, curl_easy_cleanup>> m_pCurl;
// this class exists just to hide the implementation details in cxx file
friend struct CurlProcessor;
public:
explicit CurlSession(css::uno::Reference<css::uno::XComponentContext> xContext,
::rtl::Reference<DAVSessionFactory> const& rpFactory, OUString const& rURI,
css::uno::Sequence<css::beans::NamedValue> const& rFlags,
::ucbhelper::InternetProxyDecider const& rProxyDecider);
virtual ~CurlSession() override;
virtual auto CanUse(OUString const& rURI,
css::uno::Sequence<css::beans::NamedValue> const& rFlags) -> bool override;
virtual auto UsesProxy() -> bool override;
// DAV methods
virtual auto OPTIONS(OUString const& rURIReference, DAVOptions& rOptions,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto PROPFIND(OUString const& rURIReference, Depth depth,
::std::vector<OUString> const& rPropertyNames,
::std::vector<DAVResource>& o_rResources,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto PROPFIND(OUString const& rURIReference, Depth depth,
::std::vector<DAVResourceInfo>& o_rResourceInfos,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto PROPPATCH(OUString const& rURIReference,
::std::vector<ProppatchValue> const& rValues,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto HEAD(OUString const& rURIReference, ::std::vector<OUString> const& rHeaderNames,
DAVResource& io_rResource, DAVRequestEnvironment const& rEnv)
-> void override;
virtual auto GET(OUString const& rURIReference, DAVRequestEnvironment const& rEnv)
-> css::uno::Reference<css::io::XInputStream> override;
virtual auto GET(OUString const& rURIReference,
css::uno::Reference<css::io::XOutputStream>& rxOutStream,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto GET(OUString const& rURIReference, ::std::vector<OUString> const& rHeaderNames,
DAVResource& io_rResource, DAVRequestEnvironment const& rEnv)
-> css::uno::Reference<css::io::XInputStream> override;
virtual auto GET(OUString const& rURIReference,
css::uno::Reference<css::io::XOutputStream>& rxOutStream,
::std::vector<OUString> const& rHeaderNames, DAVResource& io_rResource,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto PUT(OUString const& rURIReference,
css::uno::Reference<css::io::XInputStream> const& rxInStream,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto POST(OUString const& rURIReference, OUString const& rContentType,
OUString const& rReferer,
css::uno::Reference<css::io::XInputStream> const& rxInStream,
DAVRequestEnvironment const& rEnv)
-> css::uno::Reference<css::io::XInputStream> override;
virtual auto POST(OUString const& rURIReference, OUString const& rContentType,
OUString const& rReferer,
css::uno::Reference<css::io::XInputStream> const& rxInStream,
css::uno::Reference<css::io::XOutputStream>& rxOutStream,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto MKCOL(OUString const& rURIReference, DAVRequestEnvironment const& rEnv)
-> void override;
virtual auto COPY(OUString const& rSourceURIReference, OUString const& rDestinationURI,
DAVRequestEnvironment const& rEnv, bool isOverwrite = false) -> void override;
virtual auto MOVE(OUString const& rSourceURIReference, OUString const& rDestinationURI,
DAVRequestEnvironment const& rEnv, bool isOverwrite = false) -> void override;
virtual auto DESTROY(OUString const& rURIReference, DAVRequestEnvironment const& rEnv)
-> void override;
virtual auto LOCK(OUString const& rURIReference, css::ucb::Lock /*const*/& rLock,
DAVRequestEnvironment const& rEnv) -> void override;
virtual auto UNLOCK(OUString const& rURIReference, DAVRequestEnvironment const& rEnv)
-> void override;
virtual auto abort() -> void override;
auto NonInteractive_LOCK(OUString const& rURI, ::std::u16string_view rLockToken,
sal_Int32& o_rLastChanceToSendRefreshRequest, bool& o_rIsAuthFailed)
-> bool;
auto NonInteractive_UNLOCK(OUString const& rURI) -> void;
};
} // namespace http_dav_ucp
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
