@@ -141,13 +141,9 @@ <h2 id="args">Args</h2>
141141 self.proxy = proxy
142142 self.base_url = base_url
143143 self.default_headers = default_headers if default_headers else {}
144- self.default_headers["User-Agent"] = get_user_agent(
145- user_agent_prefix, user_agent_suffix
146- )
144+ self.default_headers["User-Agent"] = get_user_agent(user_agent_prefix, user_agent_suffix)
147145 self.logger = logger if logger is not None else logging.getLogger(__name__)
148- self.retry_handlers = (
149- retry_handlers if retry_handlers is not None else default_retry_handlers()
150- )
146+ self.retry_handlers = retry_handlers if retry_handlers is not None else default_retry_handlers()
151147
152148 if self.proxy is None or len(self.proxy.strip()) == 0:
153149 env_variable = load_http_proxy_from_env(self.logger)
@@ -293,13 +289,8 @@ <h2 id="args">Args</h2>
293289 headers["Content-Type"] = "application/json;charset=utf-8"
294290
295291 if self.logger.level <= logging.DEBUG:
296- headers_for_logging = {
297- k: "(redacted)" if k.lower() == "authorization" else v
298- for k, v in headers.items()
299- }
300- self.logger.debug(
301- f"Sending a request - url: {url}, body: {body}, headers: {headers_for_logging}"
302- )
292+ headers_for_logging = {k: "(redacted)" if k.lower() == "authorization" else v for k, v in headers.items()}
293+ self.logger.debug(f"Sending a request - url: {url}, body: {body}, headers: {headers_for_logging}")
303294
304295 # NOTE: Intentionally ignore the `http_verb` here
305296 # Slack APIs accepts any API method requests with POST methods
@@ -338,15 +329,9 @@ <h2 id="args">Args</h2>
338329 )
339330 if e.code == 429:
340331 # for backward-compatibility with WebClient (v.2.5.0 or older)
341- if (
342- "retry-after" not in resp.headers
343- and "Retry-After" in resp.headers
344- ):
332+ if "retry-after" not in resp.headers and "Retry-After" in resp.headers:
345333 resp.headers["retry-after"] = resp.headers["Retry-After"]
346- if (
347- "Retry-After" not in resp.headers
348- and "retry-after" in resp.headers
349- ):
334+ if "Retry-After" not in resp.headers and "retry-after" in resp.headers:
350335 resp.headers["Retry-After"] = resp.headers["retry-after"]
351336 _debug_log_response(self.logger, resp)
352337
@@ -355,9 +340,7 @@ <h2 id="args">Args</h2>
355340 retry_response = RetryHttpResponse(
356341 status_code=e.code,
357342 headers={k: [v] for k, v in e.headers.items()},
358- data=response_body.encode("utf-8")
359- if response_body is not None
360- else None,
343+ data=response_body.encode("utf-8") if response_body is not None else None,
361344 )
362345 for handler in self.retry_handlers:
363346 if handler.can_retry(
@@ -383,9 +366,7 @@ <h2 id="args">Args</h2>
383366
384367 except Exception as err:
385368 last_error = err
386- self.logger.error(
387- f"Failed to send a request to Slack API server: {err}"
388- )
369+ self.logger.error(f"Failed to send a request to Slack API server: {err}")
389370
390371 # Try to find a retry handler for this error
391372 retry_request = RetryHttpRequest.from_urllib_http_request(req)
@@ -406,9 +387,7 @@ <h2 id="args">Args</h2>
406387 response=None,
407388 error=err,
408389 )
409- self.logger.info(
410- f"Going to retry the same request: {req.method} {req.full_url}"
411- )
390+ self.logger.info(f"Going to retry the same request: {req.method} {req.full_url}")
412391 break
413392
414393 if retry_state.next_attempt_requested is False:
@@ -418,9 +397,7 @@ <h2 id="args">Args</h2>
418397 return resp
419398 raise last_error
420399
421- def _perform_http_request_internal(
422- self, url: str, req: Request
423- ) -> AuditLogsResponse:
400+ def _perform_http_request_internal(self, url: str, req: Request) -> AuditLogsResponse:
424401 opener: Optional[OpenerDirector] = None
425402 # for security (BAN-B310)
426403 if url.lower().startswith("http"):
@@ -431,9 +408,7 @@ <h2 id="args">Args</h2>
431408 HTTPSHandler(context=self.ssl),
432409 )
433410 else:
434- raise SlackRequestError(
435- f"Invalid proxy detected: {self.proxy} must be a str value"
436- )
411+ raise SlackRequestError(f"Invalid proxy detected: {self.proxy} must be a str value")
437412 else:
438413 raise SlackRequestError(f"Invalid URL detected: {url}")
439414
@@ -442,9 +417,7 @@ <h2 id="args">Args</h2>
442417 if opener:
443418 http_resp = opener.open(req, timeout=self.timeout) # skipcq: BAN-B310
444419 else:
445- http_resp = urlopen( # skipcq: BAN-B310
446- req, context=self.ssl, timeout=self.timeout
447- )
420+ http_resp = urlopen(req, context=self.ssl, timeout=self.timeout) # skipcq: BAN-B310
448421 charset: str = http_resp.headers.get_content_charset() or "utf-8"
449422 response_body: str = http_resp.read().decode(charset)
450423 resp = AuditLogsResponse(
@@ -753,11 +726,7 @@ <h2 id="returns">Returns</h2>
753726 self.status_code = status_code
754727 self.headers = headers
755728 self.raw_body = raw_body
756- self.body = (
757- json.loads(raw_body)
758- if raw_body is not None and raw_body.startswith("{")
759- else None
760- )</ code > </ pre >
729+ self.body = json.loads(raw_body) if raw_body is not None and raw_body.startswith("{") else None</ code > </ pre >
761730</ details >
762731< h3 > Class variables</ h3 >
763732< dl >
0 commit comments