Import DEFAULT_MAX_TOTAL_ROWS / DEFAULT_MAX_CONTINUATION_FRAMES from dqlitewire

Replace inline 10_000_000 / 100_000 literals across the public
connect / create_pool / DqliteConnection / ConnectionPool /
ClusterClient.connect / DqliteProtocol entry points with the
canonical named constants from the wire layer.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: antoineleclair

src/dqliteclient/__init__.py

@@ -23,6 +23,12 @@
 )
 from dqliteclient.node_store import MemoryNodeStore, NodeInfo, NodeStore
 from dqliteclient.pool import ConnectionPool
+from dqlitewire import (
+    DEFAULT_MAX_CONTINUATION_FRAMES as _DEFAULT_MAX_CONTINUATION_FRAMES,
+)
+from dqlitewire import (
+    DEFAULT_MAX_TOTAL_ROWS as _DEFAULT_MAX_TOTAL_ROWS,
+)
 
 __version__ = "0.1.3"
 
@@ -54,8 +60,8 @@ async def connect(
     *,
     database: str = "default",
     timeout: float = 10.0,
-    max_total_rows: int | None = 10_000_000,
-    max_continuation_frames: int | None = 100_000,
+    max_total_rows: int | None = _DEFAULT_MAX_TOTAL_ROWS,
+    max_continuation_frames: int | None = _DEFAULT_MAX_CONTINUATION_FRAMES,
     trust_server_heartbeat: bool = False,
     close_timeout: float = 0.5,
 ) -> DqliteConnection:
@@ -105,8 +111,8 @@ async def create_pool(
     timeout: float = 10.0,
     cluster: ClusterClient | None = None,
     node_store: NodeStore | None = None,
-    max_total_rows: int | None = 10_000_000,
-    max_continuation_frames: int | None = 100_000,
+    max_total_rows: int | None = _DEFAULT_MAX_TOTAL_ROWS,
+    max_continuation_frames: int | None = _DEFAULT_MAX_CONTINUATION_FRAMES,
     trust_server_heartbeat: bool = False,
     close_timeout: float = 0.5,
 ) -> ConnectionPool:

src/dqliteclient/cluster.py

@@ -17,6 +17,12 @@
 from dqliteclient.node_store import MemoryNodeStore, NodeStore
 from dqliteclient.protocol import DqliteProtocol
 from dqliteclient.retry import retry_with_backoff
+from dqlitewire import (
+    DEFAULT_MAX_CONTINUATION_FRAMES as _DEFAULT_MAX_CONTINUATION_FRAMES,
+)
+from dqlitewire import (
+    DEFAULT_MAX_TOTAL_ROWS as _DEFAULT_MAX_TOTAL_ROWS,
+)
 from dqlitewire import NodeRole
 from dqlitewire.messages.responses import _sanitize_server_text as _sanitize_display_text
 
@@ -386,8 +392,8 @@ async def connect(
         self,
         database: str = "default",
         *,
-        max_total_rows: int | None = 10_000_000,
-        max_continuation_frames: int | None = 100_000,
+        max_total_rows: int | None = _DEFAULT_MAX_TOTAL_ROWS,
+        max_continuation_frames: int | None = _DEFAULT_MAX_CONTINUATION_FRAMES,
         trust_server_heartbeat: bool = False,
         close_timeout: float = 0.5,
         max_attempts: int | None = None,

src/dqliteclient/connection.py

@@ -23,6 +23,8 @@
     DqliteProtocol,
     _validate_positive_int_or_none,
 )
+from dqlitewire import DEFAULT_MAX_CONTINUATION_FRAMES as _DEFAULT_MAX_CONTINUATION_FRAMES
+from dqlitewire import DEFAULT_MAX_TOTAL_ROWS as _DEFAULT_MAX_TOTAL_ROWS
 from dqlitewire import LEADER_ERROR_CODES as _LEADER_ERROR_CODES
 from dqlitewire import TX_AUTO_ROLLBACK_PRIMARY_CODES as _TX_AUTO_ROLLBACK_PRIMARY_CODES
 from dqlitewire import primary_sqlite_code as _primary_sqlite_code
@@ -324,8 +326,8 @@ def __init__(
         *,
         database: str = "default",
         timeout: float = 10.0,
-        max_total_rows: int | None = 10_000_000,
-        max_continuation_frames: int | None = 100_000,
+        max_total_rows: int | None = _DEFAULT_MAX_TOTAL_ROWS,
+        max_continuation_frames: int | None = _DEFAULT_MAX_CONTINUATION_FRAMES,
         trust_server_heartbeat: bool = False,
         close_timeout: float = 0.5,
     ) -> None:

src/dqliteclient/pool.py

@@ -23,6 +23,12 @@
 )
 from dqliteclient.node_store import NodeStore
 from dqliteclient.protocol import _validate_positive_int_or_none
+from dqlitewire import (
+    DEFAULT_MAX_CONTINUATION_FRAMES as _DEFAULT_MAX_CONTINUATION_FRAMES,
+)
+from dqlitewire import (
+    DEFAULT_MAX_TOTAL_ROWS as _DEFAULT_MAX_TOTAL_ROWS,
+)
 
 __all__ = ["ConnectionPool"]
 
@@ -107,8 +113,8 @@ def __init__(
         timeout: float = 10.0,
         cluster: ClusterClient | None = None,
         node_store: NodeStore | None = None,
-        max_total_rows: int | None = 10_000_000,
-        max_continuation_frames: int | None = 100_000,
+        max_total_rows: int | None = _DEFAULT_MAX_TOTAL_ROWS,
+        max_continuation_frames: int | None = _DEFAULT_MAX_CONTINUATION_FRAMES,
         trust_server_heartbeat: bool = False,
         close_timeout: float = 0.5,
     ) -> None:

src/dqliteclient/protocol.py

@@ -7,6 +7,12 @@
 from typing import Any
 
 from dqliteclient.exceptions import DqliteConnectionError, OperationalError, ProtocolError
+from dqlitewire import (
+    DEFAULT_MAX_CONTINUATION_FRAMES as _DEFAULT_MAX_CONTINUATION_FRAMES,
+)
+from dqlitewire import (
+    DEFAULT_MAX_TOTAL_ROWS as _DEFAULT_MAX_TOTAL_ROWS,
+)
 from dqlitewire import MessageDecoder, MessageEncoder
 from dqlitewire.exceptions import (
     ProtocolError as _WireProtocolError,
@@ -94,8 +100,8 @@ def __init__(
         reader: asyncio.StreamReader,
         writer: asyncio.StreamWriter,
         timeout: float = 10.0,
-        max_total_rows: int | None = 10_000_000,
-        max_continuation_frames: int | None = 100_000,
+        max_total_rows: int | None = _DEFAULT_MAX_TOTAL_ROWS,
+        max_continuation_frames: int | None = _DEFAULT_MAX_CONTINUATION_FRAMES,
         trust_server_heartbeat: bool = False,
         address: str | None = None,
     ) -> None: