Fix typing errors in examples, check with mypy

The examples we provide should also have correct type hints.

.github/workflows/tests.yml

@@ -30,7 +30,7 @@ jobs:
         run: |
           ruff check .
           ruff format --check --diff .
-          mypy src tests
+          mypy examples src tests
           check-manifest
 
   codespell:

examples/doq_client.py

@@ -17,11 +17,11 @@
 
 
 class DnsClientProtocol(QuicConnectionProtocol):
-    def __init__(self, *args, **kwargs):
+    def __init__(self, *args, **kwargs) -> None:
         super().__init__(*args, **kwargs)
         self._ack_waiter: Optional[asyncio.Future[DNSRecord]] = None
 
-    async def query(self, query_name: str, query_type: str) -> None:
+    async def query(self, query_name: str, query_type: str) -> DNSRecord:
         # serialize query
         query = DNSRecord(
             header=DNSHeader(id=0),

examples/http3_server.py

@@ -228,15 +228,15 @@ class WebTransportHandler:
     def __init__(
         self,
         *,
-        connection: HttpConnection,
+        connection: H3Connection,
         scope: Dict,
         stream_id: int,
         transmit: Callable[[], None],
     ) -> None:
         self.accepted = False
         self.closed = False
         self.connection = connection
-        self.http_event_queue: Deque[DataReceived] = deque()
+        self.http_event_queue: Deque[H3Event] = deque()
         self.queue: asyncio.Queue[Dict] = asyncio.Queue()
         self.scope = scope
         self.stream_id = stream_id
@@ -387,6 +387,9 @@ def http_event_received(self, event: H3Event) -> None:
                     transmit=self.transmit,
                 )
             elif method == "CONNECT" and protocol == "webtransport":
+                assert isinstance(
+                    self._http, H3Connection
+                ), "WebTransport is only supported over HTTP/3"
                 scope = {
                     "client": client,
                     "headers": headers,

examples/httpx_client.py

@@ -31,7 +31,7 @@ async def __aiter__(self) -> AsyncIterator[bytes]:
 
 
 class H3Transport(QuicConnectionProtocol, httpx.AsyncBaseTransport):
-    def __init__(self, *args, **kwargs):
+    def __init__(self, *args, **kwargs) -> None:
         super().__init__(*args, **kwargs)
 
         self._http = H3Connection(self._quic)

examples/siduck_client.py

@@ -14,7 +14,7 @@
 
 
 class SiduckClient(QuicConnectionProtocol):
-    def __init__(self, *args, **kwargs):
+    def __init__(self, *args, **kwargs) -> None:
         super().__init__(*args, **kwargs)
         self._ack_waiter: Optional[asyncio.Future[None]] = None