really drop python <=3.7 support

compliance/test_client.py

@@ -1,8 +1,8 @@
+import asyncio
 import json
 import logging
 import urllib.parse
 
-import asyncio
 import websockets
 
 

compliance/test_server.py

@@ -1,6 +1,6 @@
+import asyncio
 import logging
 
-import asyncio
 import websockets
 
 

docs/conf.py

@@ -8,9 +8,9 @@
 import importlib
 import inspect
 import os
-import subprocess
 import sys
 
+
 # -- Path setup --------------------------------------------------------------
 
 # If extensions (or modules to document with autodoc) are in another directory,
@@ -25,7 +25,6 @@
 copyright = f"2013-{datetime.date.today().year}, Aymeric Augustin and contributors"
 author = "Aymeric Augustin"
 
-from websockets.version import tag as version, version as release
 
 
 # -- General configuration ---------------------------------------------------
@@ -79,6 +78,7 @@
 # Workaround for https://github.com/sphinx-doc/sphinx/issues/9560
 from sphinx.domains.python import PythonDomain
 
+
 assert PythonDomain.object_types["data"].roles == ("data", "obj")
 PythonDomain.object_types["data"].roles = ("data", "class", "obj")
 
@@ -97,6 +97,7 @@
 # Configure viewcode extension.
 from websockets.version import commit
 
+
 code_url = f"https://github.com/python-websockets/websockets/blob/{commit}"
 
 def linkcode_resolve(domain, info):

example/deployment/heroku/app.py

@@ -1,8 +1,8 @@
 #!/usr/bin/env python
 
 import asyncio
-import signal
 import os
+import signal
 
 import websockets
 

example/deployment/kubernetes/benchmark.py

@@ -2,6 +2,7 @@
 
 import asyncio
 import sys
+
 import websockets
 
 

example/django/authentication.py

@@ -5,6 +5,7 @@
 import django
 import websockets
 
+
 django.setup()
 
 from sesame.utils import get_user

example/django/notifications.py

@@ -7,6 +7,7 @@
 import django
 import websockets
 
+
 django.setup()
 
 from django.contrib.contenttypes.models import ContentType

example/django/signals.py

@@ -3,7 +3,6 @@
 from django.contrib.admin.models import LogEntry
 from django.db.models.signals import post_save
 from django.dispatch import receiver
-
 from django_redis import get_redis_connection
 
 

example/echo.py

@@ -1,8 +1,10 @@
 #!/usr/bin/env python
 
 import asyncio
+
 from websockets.server import serve
 
+
 async def echo(websocket):
     async for message in websocket:
         await websocket.send(message)

example/faq/health_check_server.py

@@ -2,8 +2,10 @@
 
 import asyncio
 import http
+
 import websockets
 
+
 async def health_check(path, request_headers):
     if path == "/healthz":
         return http.HTTPStatus.OK, [], b"OK\n"

example/faq/shutdown_client.py

@@ -2,8 +2,10 @@
 
 import asyncio
 import signal
+
 import websockets
 
+
 async def client():
     uri = "ws://localhost:8765"
     async with websockets.connect(uri) as websocket:

example/faq/shutdown_server.py

@@ -2,8 +2,10 @@
 
 import asyncio
 import signal
+
 import websockets
 
+
 async def echo(websocket):
     async for message in websocket:
         await websocket.send(message)

example/hello.py

@@ -1,8 +1,8 @@
 #!/usr/bin/env python
 
-import asyncio
 from websockets.sync.client import connect
 
+
 def hello():
     with connect("ws://localhost:8765") as websocket:
         websocket.send("Hello world!")

example/legacy/basic_auth_client.py

@@ -3,8 +3,10 @@
 # WS client example with HTTP Basic Authentication
 
 import asyncio
+
 import websockets
 
+
 async def hello():
     uri = "ws://mary:p@ssw0rd@localhost:8765"
     async with websockets.connect(uri) as websocket:

example/legacy/basic_auth_server.py

@@ -3,8 +3,10 @@
 # Server example with HTTP Basic Authentication over TLS
 
 import asyncio
+
 import websockets
 
+
 async def hello(websocket):
     greeting = f"Hello {websocket.username}!"
     await websocket.send(greeting)

example/legacy/unix_client.py

@@ -4,8 +4,10 @@
 
 import asyncio
 import os.path
+
 import websockets
 
+
 async def hello():
     socket_path = os.path.join(os.path.dirname(__file__), "socket")
     async with websockets.unix_connect(socket_path) as websocket:

example/legacy/unix_server.py

@@ -4,8 +4,10 @@
 
 import asyncio
 import os.path
+
 import websockets
 
+
 async def hello(websocket):
     name = await websocket.recv()
     print(f"<<< {name}")

example/logging/json_log_formatter.py

@@ -1,6 +1,7 @@
+import datetime
 import json
 import logging
-import datetime
+
 
 class JSONFormatter(logging.Formatter):
     """

example/quickstart/client.py

@@ -1,8 +1,10 @@
 #!/usr/bin/env python
 
 import asyncio
+
 import websockets
 
+
 async def hello():
     uri = "ws://localhost:8765"
     async with websockets.connect(uri) as websocket:

example/quickstart/client_secure.py

@@ -3,8 +3,10 @@
 import asyncio
 import pathlib
 import ssl
+
 import websockets
 
+
 ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
 localhost_pem = pathlib.Path(__file__).with_name("localhost.pem")
 ssl_context.load_verify_locations(localhost_pem)

example/quickstart/counter.py

@@ -3,8 +3,10 @@
 import asyncio
 import json
 import logging
+
 import websockets
 
+
 logging.basicConfig()
 
 USERS = set()

example/quickstart/server.py

@@ -1,8 +1,10 @@
 #!/usr/bin/env python
 
 import asyncio
+
 import websockets
 
+
 async def hello(websocket):
     name = await websocket.recv()
     print(f"<<< {name}")

example/quickstart/server_secure.py

@@ -3,8 +3,10 @@
 import asyncio
 import pathlib
 import ssl
+
 import websockets
 
+
 async def hello(websocket):
     name = await websocket.recv()
     print(f"<<< {name}")

example/quickstart/show_time.py

@@ -3,8 +3,10 @@
 import asyncio
 import datetime
 import random
+
 import websockets
 
+
 async def show_time(websocket):
     while True:
         message = datetime.datetime.utcnow().isoformat() + "Z"

example/quickstart/show_time_2.py

@@ -3,8 +3,10 @@
 import asyncio
 import datetime
 import random
+
 import websockets
 
+
 CONNECTIONS = set()
 
 async def register(websocket):

example/tutorial/step1/app.py

@@ -5,7 +5,6 @@
 import json
 
 import websockets
-
 from connect4 import PLAYER1, PLAYER2, Connect4
 
 

example/tutorial/step2/app.py

@@ -5,7 +5,6 @@
 import secrets
 
 import websockets
-
 from connect4 import PLAYER1, PLAYER2, Connect4
 
 

example/tutorial/step3/app.py

@@ -7,7 +7,6 @@
 import signal
 
 import websockets
-
 from connect4 import PLAYER1, PLAYER2, Connect4
 
 

src/websockets/client.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import warnings
-from typing import Any, Generator, List, Optional, Sequence
+from typing import Any, Generator, Sequence
 
 from .datastructures import Headers, MultipleValuesError
 from .exceptions import (
@@ -73,12 +73,12 @@ def __init__(
         self,
         wsuri: WebSocketURI,
         *,
-        origin: Optional[Origin] = None,
-        extensions: Optional[Sequence[ClientExtensionFactory]] = None,
-        subprotocols: Optional[Sequence[Subprotocol]] = None,
+        origin: Origin | None = None,
+        extensions: Sequence[ClientExtensionFactory] | None = None,
+        subprotocols: Sequence[Subprotocol] | None = None,
         state: State = CONNECTING,
-        max_size: Optional[int] = 2**20,
-        logger: Optional[LoggerLike] = None,
+        max_size: int | None = 2**20,
+        logger: LoggerLike | None = None,
     ):
         super().__init__(
             side=CLIENT,
@@ -153,7 +153,7 @@ def process_response(self, response: Response) -> None:
 
         headers = response.headers
 
-        connection: List[ConnectionOption] = sum(
+        connection: list[ConnectionOption] = sum(
             [parse_connection(value) for value in headers.get_all("Connection")], []
         )
 
@@ -162,7 +162,7 @@ def process_response(self, response: Response) -> None:
                 "Connection", ", ".join(connection) if connection else None
             )
 
-        upgrade: List[UpgradeProtocol] = sum(
+        upgrade: list[UpgradeProtocol] = sum(
             [parse_upgrade(value) for value in headers.get_all("Upgrade")], []
         )
 
@@ -188,7 +188,7 @@ def process_response(self, response: Response) -> None:
 
         self.subprotocol = self.process_subprotocol(headers)
 
-    def process_extensions(self, headers: Headers) -> List[Extension]:
+    def process_extensions(self, headers: Headers) -> list[Extension]:
         """
         Handle the Sec-WebSocket-Extensions HTTP response header.
 
@@ -219,15 +219,15 @@ def process_extensions(self, headers: Headers) -> List[Extension]:
             InvalidHandshake: To abort the handshake.
 
         """
-        accepted_extensions: List[Extension] = []
+        accepted_extensions: list[Extension] = []
 
         extensions = headers.get_all("Sec-WebSocket-Extensions")
 
         if extensions:
             if self.available_extensions is None:
                 raise InvalidHandshake("no extensions supported")
 
-            parsed_extensions: List[ExtensionHeader] = sum(
+            parsed_extensions: list[ExtensionHeader] = sum(
                 [parse_extension(header_value) for header_value in extensions], []
             )
 
@@ -261,7 +261,7 @@ def process_extensions(self, headers: Headers) -> List[Extension]:
 
         return accepted_extensions
 
-    def process_subprotocol(self, headers: Headers) -> Optional[Subprotocol]:
+    def process_subprotocol(self, headers: Headers) -> Subprotocol | None:
         """
         Handle the Sec-WebSocket-Protocol HTTP response header.
 
@@ -274,7 +274,7 @@ def process_subprotocol(self, headers: Headers) -> Optional[Subprotocol]:
            Subprotocol, if one was selected.
 
         """
-        subprotocol: Optional[Subprotocol] = None
+        subprotocol: Subprotocol | None = None
 
         subprotocols = headers.get_all("Sec-WebSocket-Protocol")