Merge pull request #5 from clevertech/fix/lingering-participants

Add janus:destroy message to client disconnect
clevertech · Oct 26, 2018 · e427d3b · e427d3b
2 parents c8cdef7 + 6fc3028
commit e427d3b
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/plugins/websocket-client/JanusWebsocketClientImpl.cpp b/plugins/websocket-client/JanusWebsocketClientImpl.cpp
@@ -318,11 +318,33 @@ void JanusWebsocketClientImpl::keepConnectionAlive()
   }
 };
 
+void JanusWebsocketClientImpl::destroy()
+{
+    if (connection)
+    {
+      json destroyMsg = {
+        { "janus"    , "destroy" },
+        { "session_id" , session_id },
+        { "transaction" , std::to_string(rand()) },
+      };
+      try
+      {
+        connection->send(destroyMsg.dump());
+      }
+      catch (websocketpp::exception const & e)
+      {
+        std::cout << e.what() << std::endl;
+//        return;
+      }
+    }
+}
+
 bool JanusWebsocketClientImpl::disconnect(bool wait)
 {
 
   try
   {
+    destroy();
     // Stop keepAlive
     if (thread_keepAlive.joinable()){
       is_running.store(false);

diff --git a/plugins/websocket-client/JanusWebsocketClientImpl.h b/plugins/websocket-client/JanusWebsocketClientImpl.h
@@ -24,6 +24,7 @@ class JanusWebsocketClientImpl : public WebsocketClient
     virtual bool trickle(const std::string &mid, int index, const std::string &candidate, bool last);
     virtual bool disconnect(bool wait);
     void keepConnectionAlive();
+    void destroy();
 
 private:
     bool logged;