clear session on shutdown

reporting/server/SubscriptionManager.cpp

@@ -131,23 +131,3 @@ SubscriptionManager::unsubProposedTransactions(std::shared_ptr<session>& session
 {
     streamSubscribers_[TransactionsProposed].erase(session);
 }
-
-void
-SubscriptionManager::clearSession(std::shared_ptr<session> const& session)
-{
-    for(auto& stream : streamSubscribers_)
-        stream.erase(session);
-
-    for(auto& [account, subscribers] : accountSubscribers_)
-    {
-        if (subscribers.find(session) != subscribers.end())
-            accountSubscribers_[account].erase(session);
-    }
-
-    
-    for(auto& [account, subscribers] : accountProposedSubscribers_)
-    {
-        if (subscribers.find(session) != subscribers.end())
-            accountProposedSubscribers_[account].erase(session);
-    }
-}

reporting/server/SubscriptionManager.h

@@ -93,9 +93,6 @@ public:
 
     void
     unsubProposedTransactions(std::shared_ptr<session>& session);
-
-    void
-    clearSession(std::shared_ptr<session> const& session);
 };
 
 #endif //SUBSCRIPTION_MANAGER_H

reporting/server/session.h

@@ -220,6 +220,17 @@ public:
                 &session::on_write, shared_from_this()));
     }
 
+    void
+    close(boost::beast::websocket::close_reason const& cr)
+    {
+        boost::beast::error_code ec;
+
+        ws_.close(cr, ec);
+
+        if (ec)
+            return fail(ec, "close");
+    }
+
 private:
 
     // Get on the correct executor
@@ -287,7 +298,7 @@ private:
             return;
 
         if (ec)
-            return fail(ec, "read");
+            fail(ec, "read");
 
         std::string msg{
             static_cast<char const*>(buffer_.data().data()), buffer_.size()};