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

send messages to subscribers w/ shared_ptr (#147)

Browse Source
This commit is contained in:
Nathan Nichols
2022-05-18 16:47:12 -05:00
committed by GitHub
parent 9939f6e6f4
commit ba6b764e38
4 changed files with 69 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/subscriptions/SubscriptionManager.cpp
View File

@@ -5,7 +5,7 @@
template <class T>
inline void
sendToSubscribers(
std::string const& message,
std::shared_ptr<Message>& message,
T& subscribers,
boost::asio::io_context::strand& strand)
{
@@ -63,7 +63,7 @@ Subscription::unsubscribe(std::shared_ptr<WsBase> const& session)
}
void
Subscription::publish(std::string const& message)
Subscription::publish(std::shared_ptr<Message>& message)
{
sendToSubscribers(message, subscribers_, strand_);
}
@@ -88,7 +88,9 @@ SubscriptionMap<Key>::unsubscribe(
template <class Key>
void
SubscriptionMap<Key>::publish(std::string const& message, Key const& account)
SubscriptionMap<Key>::publish(
std::shared_ptr<Message>& message,
Key const& account)
{
sendToSubscribers(message, subscribers_[account], strand_);
}
@@ -200,8 +202,10 @@ SubscriptionManager::pubLedger(
std::string const& ledgerRange,
std::uint32_t txnCount)
{
ledgerSubscribers_.publish(boost::json::serialize(
auto message = std::make_shared<Message>(boost::json::serialize(
getLedgerPubMessage(lgrInfo, fees, ledgerRange, txnCount)));
ledgerSubscribers_.publish(message);
}
void
@@ -250,7 +254,7 @@ SubscriptionManager::pubTransaction(
}
}
std::string pubMsg{boost::json::serialize(pubObj)};
auto pubMsg = std::make_shared<Message>(boost::json::serialize(pubObj));
txSubscribers_.publish(pubMsg);
auto accounts = meta->getAffectedAccounts();
@@ -304,7 +308,7 @@ void
SubscriptionManager::forwardProposedTransaction(
boost::json::object const& response)
{
std::string pubMsg{boost::json::serialize(response)};
auto pubMsg = std::make_shared<Message>(boost::json::serialize(response));
txProposedSubscribers_.publish(pubMsg);
auto transaction = response.at("transaction").as_object();
@@ -317,15 +321,15 @@ SubscriptionManager::forwardProposedTransaction(
void
SubscriptionManager::forwardManifest(boost::json::object const& response)
{
std::string pubMsg{boost::json::serialize(response)};
auto pubMsg = std::make_shared<Message>(boost::json::serialize(response));
manifestSubscribers_.publish(pubMsg);
}
void
SubscriptionManager::forwardValidation(boost::json::object const& response)
{
std::string pubMsg{boost::json::serialize(response)};
validationsSubscribers_.publish(std::move(pubMsg));
auto pubMsg = std::make_shared<Message>(boost::json::serialize(response));
validationsSubscribers_.publish(pubMsg);
}
void