Changed mute function and added disable force mute functionality

- Changed mute_all function to reflect the active flag to always be True

- Added disable_force_mute function to disable the mute state with the active flag always set to False

Author: geekchick

opentok/opentok.py

@@ -1657,18 +1657,16 @@ def mute_all(self,
         This is an optional property. If you omit this property, all streams in the session will be muted.
 
         :param active Whether streams published after the call, in addition to the current streams
-        in the session, should be muted (True) or not (False).
+        in the session, should be muted (True).
         """
 
         options = {}
         url = self.endpoints.get_mute_all_url(session_id)
 
         try:
             if excludedStreamIds:
-                if active:
-                    options = {'active': active, 'excludedStreams': excludedStreamIds }
+                options = {'active': active, 'excludedStreams': excludedStreamIds }
             else:
-                active = False
                 options = {'active': active, 'excludedStreams': []}
 
             response = requests.post(url, headers=self.get_headers(), data=json.dumps(options))
@@ -1687,6 +1685,35 @@ def mute_all(self,
                     session_id, excludedStreamIds))
 
 
+    def disable_force_mute(self, session_id: str, active: bool= False) -> requests.Response:
+        """
+        Disables the mute all streams in an OpenTok session.
+
+        :param session_id The session ID.
+
+        :param active Whether streams published after the call, in addition to the current streams
+        in the session, should not be muted (False).
+        """
+
+        url = self.endpoints.get_mute_all_url(session_id)
+
+        response = requests.post(url, headers=self.get_headers())
+
+
+        try:
+            if response:
+                    return response
+            elif response.status_code == 400:
+                raise GetStreamError("Invalid request. This response may indicate that data in your request data is invalid JSON. Or it may indicate that you do not pass in a session ID or you passed in an invalid stream ID.")
+            elif response.status_code == 403:
+                raise AuthError("Failed to mute, invalid credentials.")
+            elif response.status_code == 404:
+                raise NotFoundError("The session or a stream is not found.")
+        except Exception as e:
+            raise OpenTokException(
+                ("There was an error thrown by the OpenTok SDK, please check that your session_id {0} is valid").format(
+                    session_id))
+
 
     def mute_stream(self, session_id: str, stream_id: str) -> requests.Response:
         """

tests/test_opentok.py

@@ -52,6 +52,28 @@ def test_mute_all_exclude_streams(self):
         response.headers["x-opentok-auth"].should.equal(self.jwt_token_string)
         response.headers["Content-Type"].should.equal("application/json")
 
+    @httpretty.activate
+    def test_disable_force_mute(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='{}',
+                                                                content_type="application/json",
+                                                                adding_headers= {"x-opentok-auth": self.jwt_token_string},
+                                                                status=201)
+                                        ])
+
+    
+        response = requests.post(self.url)
+
+        response.text.should.equal('{}')
+        response.headers["x-opentok-auth"].should.equal(self.jwt_token_string)
+        response.headers["Content-Type"].should.equal("application/json")
+
     @httpretty.activate
     def test_mute_single_stream(self):
         self.url = "https://api.opentok.com/v2/project/{0}/session/{1}/stream/{2}/mute".format(