ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2026-04-29 15:37:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set X-User header where clio is a websocket client

Browse Source
This commit is contained in:
natenichols
2022-01-11 19:27:38 -06:00
committed by CJ Cobb
parent be1d1a13be
commit d9741c7c80
1 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/etl/ETLSource.cpp
View File

@@ -247,7 +247,9 @@ PlainETLSource::onConnect(
req.set(
boost::beast::http::field::user_agent,
std::string(BOOST_BEAST_VERSION_STRING) +
" websocket-client-async");
" coro-client");
req.set("X-User", "coro-client");
}));
// Update the host_ string. This will provide the value of the
@@ -291,7 +293,9 @@ SslETLSource::onConnect(
req.set(
boost::beast::http::field::user_agent,
std::string(BOOST_BEAST_VERSION_STRING) +
" websocket-client-async");
" clio-client");
req.set("X-User", "coro-client");
}));
// Update the host_ string. This will provide the value of the
@@ -342,6 +346,18 @@ ETLSourceImpl<Derived>::onHandshake(boost::beast::error_code ec)
{"ledger", "manifests", "validations", "transactions_proposed"}}};
std::string s = boost::json::serialize(jv);
BOOST_LOG_TRIVIAL(trace) << "Sending subscribe stream message";
derived().ws().set_option(
boost::beast::websocket::stream_base::decorator(
[](boost::beast::websocket::request_type& req) {
req.set(
boost::beast::http::field::user_agent,
std::string(BOOST_BEAST_VERSION_STRING) +
"clio-client");
req.set("X-User", "coro-client");
}));
// Send the message
derived().ws().async_write(
boost::asio::buffer(s),