forked from dulikvor/cppKin
-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathHttpTransport.cpp
More file actions
68 lines (54 loc) · 2.42 KB
/
Copy pathHttpTransport.cpp
File metadata and controls
68 lines (54 loc) · 2.42 KB
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
#include "curl/curl.h"
#include "HttpTransport.h"
#include "ConfigParams.h"
#include "Encoder.h"
#include "EncodingContext.h"
using namespace std;
namespace cppkin
{
void HttpTransport::Submit(std::vector<std::unique_ptr<span_impl>>& spans) {
string buffer = EncoderContext(spans).ToString();
try {
CURL* curl = curl_easy_init();
if (!curl) {
// TODO
}
struct curl_slist *headers = nullptr;
if (ConfigParams::Instance().GetEncodingType() == EncodingType::Thrift)
headers = curl_slist_append(headers, "Content-Type: application/x-thrift");
else
headers = curl_slist_append(headers, "Content-Type: application/json");
if (ConfigParams::Instance().GetApiKey() != "") {
std::stringstream apikey;
apikey << "Api-Key: " << ConfigParams::Instance().GetApiKey();
headers = curl_slist_append(headers, apikey.str().c_str());
}
if (ConfigParams::Instance().GetDataFormat() != "") {
std::stringstream dataformat;
dataformat << "Data-Format: " << ConfigParams::Instance().GetDataFormat();
headers = curl_slist_append(headers, dataformat.str().c_str());
}
if (ConfigParams::Instance().GetDataFormatVersion() != 0) {
std::stringstream dataformatversion;
dataformatversion << "Data-Format-Version: " << ConfigParams::Instance().GetDataFormatVersion();
headers = curl_slist_append(headers, dataformatversion.str().c_str());
}
headers = curl_slist_append(headers, "Expect:");
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
std::stringstream url;
url << ConfigParams::Instance().GetEndpoint();
curl_easy_setopt(curl, CURLOPT_URL, url.str().c_str() );
curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, buffer.length());
curl_easy_setopt(curl, CURLOPT_POSTFIELDS, buffer.c_str());
CURLcode res = curl_easy_perform(curl);
/* Check for errors */
if(res != CURLE_OK)
fprintf(stderr, "curl_easy_perform() failed: %s\n",
curl_easy_strerror(res));
curl_slist_free_all(headers);
curl_easy_cleanup(curl);
}
catch(...){
}
}
}