⚡ migrate Buffer to Rust instead of pure Python (#30)

.github/workflows/CI.yml

@@ -40,7 +40,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        os: [ubuntu-latest, macos-latest, windows-latest]
+        os: [ubuntu-latest, macos-13, windows-latest]
         python_version: ['3.7', '3.8', '3.9', '3.10', '3.11', '3.12', 'pypy-3.9', 'pypy-3.10']
         exclude:
           # circumvent wierd issue with qh3.asyncio+windows+proactor loop...
@@ -342,11 +342,11 @@ jobs:
     needs:
       - test
       - lint
-    runs-on: macos-latest
+    runs-on: macos-13
     strategy:
       fail-fast: false
       matrix:
-        target: [ x86_64, aarch64 ]
+        target: [ x86_64, aarch64, universal2 ]
         python_version: [ '3.10', 'pypy-3.7', 'pypy-3.8', 'pypy-3.9', 'pypy-3.10' ]
     steps:
       - uses: actions/checkout@3df4ab11eba7bda6032a0b82a6bb43b11571feac

CHANGELOG.rst

@@ -1,3 +1,9 @@
+1.0.4 (2024-04-23)
+=====================
+
+**Changed**
+- Buffer management has been migrated over to Rust in order to improve the overall performance.
+
 1.0.3 (2024-04-20)
 =====================
 

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "qh3"
-version = "1.0.3"
+version = "1.0.4"
 edition = "2021"
 rust-version = "1.75"
 license = "BSD-3"

qh3/__init__.py

@@ -11,7 +11,7 @@
 from .quic.packet import QuicProtocolVersion
 from .tls import CipherSuite, SessionTicket
 
-__version__ = "1.0.3"
+__version__ = "1.0.4"
 
 __all__ = (
     "connect",

qh3/_hazmat.pyi

@@ -207,3 +207,29 @@ class OCSPResponse:
 class OCSPRequest:
     def __init__(self, peer_certificate: bytes, issuer_certificate: bytes) -> None: ...
     def public_bytes(self) -> bytes: ...
+
+class BufferReadError(ValueError): ...
+class BufferWriteError(ValueError): ...
+
+class Buffer:
+    def __init__(self, capacity: int = 0, data: bytes | None = None) -> None: ...
+    @property
+    def capacity(self) -> int: ...
+    @property
+    def data(self) -> bytes: ...
+    def data_slice(self, start: int, end: int) -> bytes: ...
+    def eof(self) -> bool: ...
+    def seek(self, pos: int) -> None: ...
+    def tell(self) -> int: ...
+    def pull_bytes(self, length: int) -> bytes: ...
+    def pull_uint8(self) -> int: ...
+    def pull_uint16(self) -> int: ...
+    def pull_uint32(self) -> int: ...
+    def pull_uint64(self) -> int: ...
+    def pull_uint_var(self) -> int: ...
+    def push_bytes(self, value: bytes) -> None: ...
+    def push_uint8(self, value: int) -> None: ...
+    def push_uint16(self, value: int) -> None: ...
+    def push_uint32(self, value: int) -> None: ...
+    def push_uint64(self, value: int) -> None: ...
+    def push_uint_var(self, value: int) -> None: ...

qh3/buffer.py

@@ -1,4 +1,4 @@
-from ._buffer import Buffer, BufferReadError, BufferWriteError  # noqa
+from ._hazmat import Buffer, BufferReadError, BufferWriteError  # noqa
 
 UINT_VAR_MAX = 0x3FFFFFFFFFFFFFFF
 UINT_VAR_MAX_SIZE = 8