thebestvibedev/tromcho.net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Implement HTTP server support O_o

Browse Source
This commit is contained in:
Vitaliy Filippov
2026-05-19 17:19:16 +03:00
parent 792efa673e
commit b72cfbad66
3 changed files with 191 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/etcd_state_client.cpp
+4 -4
View File
@@ -82,7 +82,7 @@ http_context_t *etcd_state_client_t::get_http_ctx()
if (!http_ctx)
{
std::string error;
http_ctx = http_context_init(etcd_client_cert, etcd_client_key, etcd_ca, error);
http_ctx = http_context_init(etcd_client_cert, etcd_client_key, etcd_ca, true, error);
if (!http_ctx)
{
fprintf(stderr, "Failed to initialize HTTP context: %s\n", error.c_str());
@@ -112,7 +112,7 @@ void etcd_state_client_t::etcd_call_oneshot(std::string etcd_address, std::strin
"Connection: close\r\n"
"\r\n"+req;
auto http_cli = http_init(tfd, get_http_ctx());
auto cb = [http_cli, callback](const http_message_t *response)
auto cb = [http_cli, callback](http_message_t *response)
{
std::string err;
json11::Json data;
@@ -152,7 +152,7 @@ void etcd_state_client_t::etcd_call(std::string api, json11::Json payload, int t
"\r\n"+req;
retries--;
auto cb = [this, api, payload, timeout, retries, interval, callback,
cur_addr = selected_etcd_address](const http_message_t *response)
cur_addr = selected_etcd_address](http_message_t *response)
{
std::string err;
json11::Json data;
@@ -386,7 +386,7 @@ void etcd_state_client_t::start_etcd_watcher()
else
http_close(etcd_watch_ws);
open_websocket(etcd_watch_ws, etcd_address, etcd_api_path+"/watch", { .timeout = etcd_slow_timeout, .ssl = ssl },
[this, cur_addr = selected_etcd_address](const http_message_t *msg)
[this, cur_addr = selected_etcd_address](http_message_t *msg)
{
if (msg->body.length())
{