Made changes to the mute function and added a test

- Updated the mute functionality with the active flag, excludedStream and excludedStreamIds

- Added a new test in test_opentok.py

Author: geekchick

opentok/opentok.py

@@ -1,4 +1,5 @@
 from datetime import datetime  # generate_token
+from typing import List, Optional # imports List, Optional type hint
 import calendar  # generate_token
 import base64  # generate_token
 import random  # generate_token
@@ -1423,30 +1424,45 @@ def __init__(
 
 
 
-    def mute(self, session_id: str, stream_id: str= "", options: dict = {}) -> requests.Response:
+    def mute(self, 
+            session_id: str,
+            excludedStreamIds: Optional[List[str]],
+            stream_id: str= "", 
+            active: bool= True,
+            data: dict = {}) -> requests.Response:
         """
         Use this method so the moderator can mute all streams or a specific stream for OpenTok.
         Please note that a client is able to unmute themselves.
         This function stays in the OpenTok class and inherits from the Client class.
 
         :param session_id gets the session id from another function called get_session()
 
+        :param excludedStreamIds is a list of The stream IDs for streams that should not be muted. 
+        This is an optional property. If you omit this property, all streams in the session will be muted.
+
         :param stream_id gets the stream id from another function called get_stream(). Note
         that this variable is set to an empty string in the function definition as a specific
         stream may not be chosen.
+
+        :param active is a required boolean that determines whether streams published after the 
+        call, in addition to the current streams in the session, should be muted (True) or not (False).
    
         """
-        
+    
         try:
             if not stream_id:
                 url = self.endpoints.get_mute_all_url(session_id)
-                data = {'excludedStream': stream_id}
+                if active:
+                    data = {'active': active, 'excludedStreams': excludedStreamIds }
+                else:
+                    active = False
+                    data = {'active': active, 'excludedStreams': []}
             else:
                 url = self.endpoints.get_stream_url(session_id, stream_id) + "/mute"
                 data = None
 
 
-            response = requests.post(url, headers=self.get_headers(), data=data)
+            response = requests.post(url, headers=self.get_headers(), data=json.dumps(data))
 
             if response:
                 return response

tests/test_opentok.py

@@ -50,6 +50,28 @@ def test_mute_all_response(self):
         response.headers["x-opentok-auth"].should.equal(self.jwt_token_string)
         response.headers["Content-Type"].should.equal("application/json")
 
+    @httpretty.activate
+    def test_mute_all_exclude_streams(self):
+        self.url = "https://api.opentok.com/v2/project/{0}/session/{1}/mute".format(
+                                                                                self.api_key, 
+                                                                                self.session_id)
+
+        httpretty.register_uri(httpretty.POST, 
+                                        self.url, 
+                                        responses=[
+                                            httpretty.Response(body='{"active": True, "excludedStreams": "excludedStreamIds1"}', 
+                                                               content_type="application/json",
+                                                               adding_headers= {"x-opentok-auth": self.jwt_token_string},
+                                                               status=201)
+                                        ])
+
+    
+        response = requests.post(self.url)
+
+        response.text.should.equal('{"active": True, "excludedStreams": "excludedStreamIds1"}')
+        response.headers["x-opentok-auth"].should.equal(self.jwt_token_string)
+        response.headers["Content-Type"].should.equal("application/json")
+
     @httpretty.activate
     def test_mute_stream_response(self):
         self.url = "https://api.opentok.com/v2/project/${0}/session/${1}/stream/${2}/mute".format(