kapitan/IXWebSocket
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add PATCH and add option to enforce a http request body write (#195)

Browse Source 
* add PATCH and add option to enforce a http request body write

* remove private bool prop
This commit is contained in:
Liz3 2020-05-05 16:38:55 +02:00 committed by GitHub
parent 2786631e3b
commit 8760c87635
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ixwebsocket/IXHttpClient.cpp
View File

@ -25,6 +25,7 @@ namespace ix
const std::string HttpClient::kHead = "HEAD"; const std::string HttpClient::kHead = "HEAD";
const std::string HttpClient::kDel = "DEL"; const std::string HttpClient::kDel = "DEL";
const std::string HttpClient::kPut = "PUT"; const std::string HttpClient::kPut = "PUT";
const std::string HttpClient::kPatch = "PATCH";
HttpClient::HttpClient(bool async) HttpClient::HttpClient(bool async)
: _async(async) : _async(async)
@ -49,6 +50,9 @@ namespace ix
_tlsOptions = tlsOptions; _tlsOptions = tlsOptions;
} }
void setForceBody(bool value) {
_forceBody = value;
}
HttpRequestArgsPtr HttpClient::createRequest(const std::string& url, const std::string& verb) HttpRequestArgsPtr HttpClient::createRequest(const std::string& url, const std::string& verb)
{ {
auto request = std::make_shared<HttpRequestArgs>(); auto request = std::make_shared<HttpRequestArgs>();
@ -192,7 +196,7 @@ namespace ix
ss << "User-Agent: " << userAgent() << "\r\n"; ss << "User-Agent: " << userAgent() << "\r\n";
} }
if (verb == kPost || verb == kPut) if (verb == kPost || verb == kPut || verb == kPatch || _forceBody)
{ {
ss << "Content-Length: " << body.size() << "\r\n"; ss << "Content-Length: " << body.size() << "\r\n";

5
ixwebsocket/IXHttpClient.h
View File

@ -51,7 +51,7 @@ namespace ix
const std::string& body, const std::string& body,
HttpRequestArgsPtr args, HttpRequestArgsPtr args,
int redirects = 0); int redirects = 0);
void setForceBody(bool value);
// Async API // Async API
HttpRequestArgsPtr createRequest(const std::string& url = std::string(), HttpRequestArgsPtr createRequest(const std::string& url = std::string(),
const std::string& verb = HttpClient::kGet); const std::string& verb = HttpClient::kGet);
@ -78,15 +78,16 @@ namespace ix
const static std::string kHead; const static std::string kHead;
const static std::string kDel; const static std::string kDel;
const static std::string kPut; const static std::string kPut;
const static std::string kPatch;
private: private:
void log(const std::string& msg, HttpRequestArgsPtr args); void log(const std::string& msg, HttpRequestArgsPtr args);
bool gzipInflate(const std::string& in, std::string& out); bool gzipInflate(const std::string& in, std::string& out);
bool _forceBody;
// Async API background thread runner // Async API background thread runner
void run(); void run();
// Async API // Async API
bool _async; bool _async;
std::queue<std::pair<HttpRequestArgsPtr, OnResponseCallback>> _queue; std::queue<std::pair<HttpRequestArgsPtr, OnResponseCallback>> _queue;