blob: f1ec307e32bc7b13a9338c0c8e557891598fd755 (
plain) (
blame)
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
|
#include "curldatareceiver.h"
namespace newsboat {
std::unique_ptr<newsboat::CurlDataReceiver> CurlDataReceiver::register_data_handler(
CurlHandle& curlHandle)
{
return std::unique_ptr<CurlDataReceiver>(new CurlDataReceiver(curlHandle));
}
const std::string& CurlDataReceiver::get_data() const
{
return accumulated_data;
}
CurlDataReceiver::CurlDataReceiver(CurlHandle& curlHandle)
: curl_handle(curlHandle)
{
curl_easy_setopt(curl_handle.ptr(), CURLOPT_WRITEDATA, this);
curl_easy_setopt(curl_handle.ptr(), CURLOPT_WRITEFUNCTION,
&CurlDataReceiver::write_callback);
}
CurlDataReceiver::~CurlDataReceiver()
{
curl_easy_setopt(curl_handle.ptr(), CURLOPT_WRITEDATA, nullptr);
curl_easy_setopt(curl_handle.ptr(), CURLOPT_WRITEFUNCTION, nullptr);
}
size_t CurlDataReceiver::write_callback(char* buffer, size_t size, size_t nmemb,
void* receiver)
{
auto data_receiver = static_cast<CurlDataReceiver*>(receiver);
const auto data = std::string(buffer, size * nmemb);
data_receiver->handle_data(data);
return size * nmemb;
}
void CurlDataReceiver::handle_data(const std::string& data)
{
accumulated_data += data;
}
} // namespace newsboat
|
