reverting black to 88 lines

Author: maxkahan

opentok/opentok.py

@@ -220,36 +220,48 @@ def generate_token(
                     expire_time = int(expire_time)
                 except (ValueError, TypeError):
                     raise OpenTokException(
-                        u("Cannot generate token, invalid expire time {0}").format(expire_time)
+                        u("Cannot generate token, invalid expire time {0}").format(
+                            expire_time
+                        )
                     )
         else:
             expire_time = int(time.time()) + (60 * 60 * 24)  # 1 day
 
         # validations
         if not text_type(session_id):
             raise OpenTokException(
-                u("Cannot generate token, session_id was not valid {0}").format(session_id)
+                u("Cannot generate token, session_id was not valid {0}").format(
+                    session_id
+                )
             )
         if not isinstance(role, Roles):
-            raise OpenTokException(u("Cannot generate token, {0} is not a valid role").format(role))
+            raise OpenTokException(
+                u("Cannot generate token, {0} is not a valid role").format(role)
+            )
         now = int(time.time())
         if expire_time < now:
             raise OpenTokException(
-                u("Cannot generate token, expire_time is not in the future {0}").format(expire_time)
+                u("Cannot generate token, expire_time is not in the future {0}").format(
+                    expire_time
+                )
             )
         if expire_time > now + (60 * 60 * 24 * 30):  # 30 days
             raise OpenTokException(
-                u("Cannot generate token, expire_time is not in the next 30 days {0}").format(
-                    expire_time
-                )
+                u(
+                    "Cannot generate token, expire_time is not in the next 30 days {0}"
+                ).format(expire_time)
             )
         if data and len(data) > 1000:
             raise OpenTokException(
                 u("Cannot generate token, data must be less than 1000 characters")
             )
-        if initial_layout_class_list and not all(text_type(c) for c in initial_layout_class_list):
+        if initial_layout_class_list and not all(
+            text_type(c) for c in initial_layout_class_list
+        ):
             raise OpenTokException(
-                u("Cannot generate token, all items in initial_layout_class_list must be strings")
+                u(
+                    "Cannot generate token, all items in initial_layout_class_list must be strings"
+                )
             )
         initial_layout_class_list_serialized = u(" ").join(initial_layout_class_list)
         if len(initial_layout_class_list_serialized) > 1000:
@@ -270,7 +282,9 @@ def generate_token(
             parts = decoded_session_id.decode("utf-8").split(u("~"))
         except Exception as e:
             raise OpenTokException(
-                u("Cannot generate token, the session_id {0} was not valid").format(session_id)
+                u("Cannot generate token, the session_id {0} was not valid").format(
+                    session_id
+                )
             )
         if self.api_key not in parts:
             raise OpenTokException(
@@ -389,15 +403,21 @@ def create_session(
         options = {}
         if not isinstance(media_mode, MediaModes):
             raise OpenTokException(
-                u("Cannot create session, {0} is not a valid media mode").format(media_mode)
+                u("Cannot create session, {0} is not a valid media mode").format(
+                    media_mode
+                )
             )
         if not isinstance(archive_mode, ArchiveModes):
             raise OpenTokException(
-                u("Cannot create session, {0} is not a valid archive mode").format(archive_mode)
+                u("Cannot create session, {0} is not a valid archive mode").format(
+                    archive_mode
+                )
             )
         if archive_mode == ArchiveModes.always and media_mode != MediaModes.routed:
             raise OpenTokException(
-                u("A session with always archive mode must also have the routed media mode.")
+                u(
+                    "A session with always archive mode must also have the routed media mode."
+                )
             )
 
         if archive_name is not None:
@@ -478,7 +498,9 @@ def create_session(
                     )
                 )
 
-            session_id = dom.getElementsByTagName("session_id")[0].childNodes[0].nodeValue
+            session_id = (
+                dom.getElementsByTagName("session_id")[0].childNodes[0].nodeValue
+            )
             return Session(
                 self,
                 session_id,
@@ -596,12 +618,16 @@ def start_archive(
         """
         if not isinstance(output_mode, OutputModes):
             raise OpenTokException(
-                u("Cannot start archive, {0} is not a valid output mode").format(output_mode)
+                u("Cannot start archive, {0} is not a valid output mode").format(
+                    output_mode
+                )
             )
 
         if resolution and output_mode == OutputModes.individual:
             raise OpenTokException(
-                u("Invalid parameters: Resolution cannot be supplied for individual output mode.")
+                u(
+                    "Invalid parameters: Resolution cannot be supplied for individual output mode."
+                )
             )
 
         payload = {
@@ -863,7 +889,9 @@ def add_archive_stream(
         else:
             raise RequestError("An unexpected error occurred.", response.status_code)
 
-    def remove_archive_stream(self, archive_id: str, stream_id: str) -> requests.Response:
+    def remove_archive_stream(
+        self, archive_id: str, stream_id: str
+    ) -> requests.Response:
         """
         This method will remove streams from the archive with removeStream.
 
@@ -1086,7 +1114,9 @@ def force_disconnect(self, session_id, connection_id):
         else:
             raise RequestError("An unexpected error occurred", response.status_code)
 
-    def set_archive_layout(self, archive_id, layout_type, stylesheet=None, screenshare_type=None):
+    def set_archive_layout(
+        self, archive_id, layout_type, stylesheet=None, screenshare_type=None
+    ):
         """
         Use this method to change the layout of videos in an OpenTok archive
 
@@ -1308,7 +1338,9 @@ class names (Strings) to apply to the stream. For example:
         else:
             raise RequestError("OpenTok server error.", response.status_code)
 
-    def start_broadcast(self, session_id, options, stream_mode=BroadcastStreamModes.auto):
+    def start_broadcast(
+        self, session_id, options, stream_mode=BroadcastStreamModes.auto
+    ):
         """
         Use this method to start a live streaming broadcast for an OpenTok session. This broadcasts
         the session to an HLS (HTTP live streaming) or to RTMP streams. To successfully start
@@ -1391,7 +1423,10 @@ def start_broadcast(self, session_id, options, stream_mode=BroadcastStreamModes.
         """
 
         if "hls" in options["outputs"]:
-            if "lowLatency" in options["outputs"]["hls"] and "dvr" in options["outputs"]["hls"]:
+            if (
+                "lowLatency" in options["outputs"]["hls"]
+                and "dvr" in options["outputs"]["hls"]
+            ):
                 if (
                     options["outputs"]["hls"]["lowLatency"] == True
                     and options["outputs"]["hls"]["dvr"] == True
@@ -1485,7 +1520,8 @@ def stop_broadcast(self, broadcast_id):
             raise AuthError("Authentication error.")
         elif response.status_code == 409:
             raise BroadcastError(
-                "The broadcast (with the specified ID) was not found or it has already " "stopped."
+                "The broadcast (with the specified ID) was not found or it has already "
+                "stopped."
             )
         else:
             raise RequestError("OpenTok server error.", response.status_code)
@@ -1539,11 +1575,15 @@ def add_broadcast_stream(
                     "Your broadcast is configured with a streamMode that does not support stream manipulation."
                 )
             elif response.status_code == 409:
-                raise BroadcastError("The broadcast has already started for the session.")
+                raise BroadcastError(
+                    "The broadcast has already started for the session."
+                )
         else:
             raise RequestError("An unexpected error occurred.", response.status_code)
 
-    def remove_broadcast_stream(self, broadcast_id: str, stream_id: str) -> requests.Response:
+    def remove_broadcast_stream(
+        self, broadcast_id: str, stream_id: str
+    ) -> requests.Response:
         """
         This method will remove streams from the broadcast with removeStream.
 
@@ -1580,7 +1620,9 @@ def remove_broadcast_stream(self, broadcast_id: str, stream_id: str) -> requests
                     "Your broadcast is configured with a streamMode that does not support stream manipulation."
                 )
             elif response.status_code == 409:
-                raise BroadcastError("The broadcast has already started for the session.")
+                raise BroadcastError(
+                    "The broadcast has already started for the session."
+                )
         else:
             raise RequestError("OpenTok server error.", response.status_code)
 
@@ -1906,12 +1948,16 @@ def connect_audio_to_websocket(
 
     def validate_websocket_options(self, options):
         if type(options) is not dict:
-            raise InvalidWebSocketOptionsError("Must pass WebSocket options as a dictionary.")
+            raise InvalidWebSocketOptionsError(
+                "Must pass WebSocket options as a dictionary."
+            )
         if "uri" not in options:
             raise InvalidWebSocketOptionsError("Provide a WebSocket URI.")
 
     def _sign_string(self, string, secret):
-        return hmac.new(secret.encode("utf-8"), string.encode("utf-8"), hashlib.sha1).hexdigest()
+        return hmac.new(
+            secret.encode("utf-8"), string.encode("utf-8"), hashlib.sha1
+        ).hexdigest()
 
     def _create_jwt_auth_header(self):
         payload = {
@@ -1952,7 +1998,9 @@ def mute_all(
             else:
                 options = {"active": True, "excludedStreams": []}
 
-            response = requests.post(url, headers=self.get_headers(), data=json.dumps(options))
+            response = requests.post(
+                url, headers=self.get_headers(), data=json.dumps(options)
+            )
 
             if response:
                 return response
@@ -1987,7 +2035,9 @@ def disable_force_mute(self, session_id: str) -> requests.Response:
         options = {"active": False}
         url = self.endpoints.get_mute_all_url(session_id)
 
-        response = requests.post(url, headers=self.get_headers(), data=json.dumps(options))
+        response = requests.post(
+            url, headers=self.get_headers(), data=json.dumps(options)
+        )
 
         try:
             if response:
@@ -2065,7 +2115,9 @@ def play_dtmf(
                 url = self.endpoints.get_dtmf_specific_url(session_id, connection_id)
                 payload = {"digits": digits}
 
-            response = requests.post(url, headers=self.get_json_headers(), data=json.dumps(payload))
+            response = requests.post(
+                url, headers=self.get_json_headers(), data=json.dumps(payload)
+            )
 
             if response.status_code == 200:
                 return response
@@ -2134,7 +2186,9 @@ def mute_all(
             else:
                 options = {"active": True, "excludedStreams": []}
 
-            response = requests.post(url, headers=self.get_headers(), data=json.dumps(options))
+            response = requests.post(
+                url, headers=self.get_headers(), data=json.dumps(options)
+            )
 
             if response:
                 return response
@@ -2167,7 +2221,9 @@ def disable_force_mute(self, session_id: str) -> requests.Response:
         options = {"active": False}
         url = self.endpoints.get_mute_all_url(session_id)
 
-        response = requests.post(url, headers=self.get_headers(), data=json.dumps(options))
+        response = requests.post(
+            url, headers=self.get_headers(), data=json.dumps(options)
+        )
 
         try:
             if response:
@@ -2239,7 +2295,9 @@ def play_dtmf(
                 url = self.endpoints.get_dtmf_specific_url(session_id, connection_id)
                 payload = {"digits": digits}
 
-            response = requests.post(url, headers=self.get_json_headers(), data=json.dumps(payload))
+            response = requests.post(
+                url, headers=self.get_json_headers(), data=json.dumps(payload)
+            )
 
             if response.status_code == 200:
                 return response