[Update] formatting

Author: sebastien

examples/client.py

@@ -22,6 +22,7 @@
 Default: https://google.com/
 """
 
+
 async def make_requests(url_str: str, num_requests: int = 3):
 	"""Make multiple HTTP requests to demonstrate connection pooling."""
 	uri = URI.Parse(url_str)

examples/htmx.py

@@ -34,11 +34,13 @@ def html_page(self, *body_content: Node) -> str:
 			H.head(
 				H.title("HTMX Example"),
 				H.script(src="https://unpkg.com/htmx.org@1.9.12"),
-				H.style("""
+				H.style(
+					"""
 					body { font-family: Arial, sans-serif; padding: 20px; }
 					.counter { font-size: 24px; margin: 10px 0; }
 					button { padding: 10px 20px; margin: 5px; cursor: pointer; }
-				"""),
+				"""
+				),
 			),
 			H.body(*body_content),
 		)

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "extra-http"
-version = "1.0.2"
+version = "1.0.3"
 description = "A fast, async HTTP framework"
 readme = "README.md"
 requires-python = ">=3.10"
@@ -45,10 +45,15 @@ where = ["src/py"]
 [tool.ruff]
 line-length = 88
 target-version = "py38"
+indent-width = 4
+
+[tool.ruff.format]
+quote-style = "double"
+indent-style = "tab"
 
 [tool.ruff.lint]
 select = ["E", "F", "W", "I"]
-ignore = ["E203", "E501", "W503"]
+ignore = ["E203", "E501"]
 
 [tool.mypy]
 python_version = "3.10"
@@ -59,4 +64,4 @@ disallow_untyped_defs = true
 [tool.bandit]
 exclude_dirs = ["tests", "build"]
 skips = ["B101"]
-# EOF
+# EOF

src/py/extra/client.py

@@ -25,8 +25,8 @@
 from .http.parser import HTTPParser
 
 # For Python 3.8 compatibility
-ConnectionT = TypeVar('ConnectionT', bound='Connection')
-ConnectionPoolT = TypeVar('ConnectionPoolT', bound='ConnectionPool')
+ConnectionT = TypeVar("ConnectionT", bound="Connection")
+ConnectionPoolT = TypeVar("ConnectionPoolT", bound="ConnectionPool")
 
 
 # --

src/py/extra/decorators.py

@@ -129,7 +129,9 @@ def decorator(function: T) -> T:
 		meta.setdefault(Extra.ON_PRIORITY, int(priority))
 		json_data: Union[Any, None] = None
 		for http_method, url in list(methods.items()):
-			urls: Union[list[str], tuple[str, ...]] = (url,) if isinstance(url, str) else url
+			urls: Union[list[str], tuple[str, ...]] = (
+				(url,) if isinstance(url, str) else url
+			)
 			for method in http_method.upper().split("_"):
 				for _ in urls:
 					if method == "JSON":

src/py/extra/handler.py

@@ -76,7 +76,9 @@
 # - `authorizer`: (If applicable) Information from a custom authorizer (e.g., Lambda authorizer) that you've configured for your API Gateway API.
 
 
-TAWSRequestContext = dict[str, Union[str, bytes, int, float, bool, dict[str, str], None]]
+TAWSRequestContext = dict[
+	str, Union[str, bytes, int, float, bool, dict[str, str], None]
+]
 TAWSEvent = dict[
 	str, Union[str, bytes, int, float, bool, dict[str, str], TAWSRequestContext, None]
 ]
@@ -195,7 +197,9 @@ async def handle(
 		self, event: dict[str, Any], context: Union[dict[str, Any], None] = None
 	) -> dict[str, Any]:
 		req: HTTPRequest = AWSLambdaEvent.AsRequest(event)
-		r: Union[HTTPResponse, Coroutine[Any, HTTPResponse, Any]] = self.app.process(req)
+		r: Union[HTTPResponse, Coroutine[Any, HTTPResponse, Any]] = self.app.process(
+			req
+		)
 		if isinstance(r, HTTPResponse):
 			res: HTTPResponse = r
 		else:
@@ -241,7 +245,9 @@ def event(
 
 
 def awslambda(
-	handler: Callable[[HTTPRequest], Union[HTTPResponse, Coroutine[Any, HTTPResponse, Any]]],
+	handler: Callable[
+		[HTTPRequest], Union[HTTPResponse, Coroutine[Any, HTTPResponse, Any]]
+	],
 ) -> Callable[[dict[str, Any], Union[dict[str, Any], None]], dict[str, Any]]:
 	def wrapper(
 		event: dict[str, Any], context: Union[dict[str, Any], None] = None

src/py/extra/http/api.py

@@ -33,7 +33,8 @@ def respond(
 		status: int = 200,
 		headers: dict[str, str] | None = None,
 		message: str | None = None,
-	) -> T: ...
+	) -> T:
+		...
 
 	def error(
 		self,

src/py/extra/http/model.py

@@ -313,7 +313,8 @@ async def read(
 	@abstractmethod
 	async def _read(
 		self, timeout: float = BODY_READER_TIMEOUT, size: int | None = None
-	) -> bytes | None: ...
+	) -> bytes | None:
+		...
 
 	# NOTE: This is a dangerous operation, as this way bloat the whole memory.
 	# Instead, loading should spool the file.
@@ -425,7 +426,8 @@ async def _write(self, chunk: bytes, more: bool = False) -> bool:
 	@abstractmethod
 	async def _writeBytes(
 		self, chunk: bytes | None | Literal[False], more: bool = False
-	) -> bool: ...
+	) -> bool:
+		...
 
 
 # -----------------------------------------------------------------------------
@@ -534,7 +536,7 @@ def onClose(
 		self._onClose = callback
 		return self
 
-	async def read(self) -> AsyncGenerator[bytes | None]:
+	async def read(self) -> AsyncGenerator[bytes | None, None]:
 		body = self.body
 		if isinstance(body, HTTPBodyBlob):
 			yield body.raw

src/py/extra/http/processors.py

@@ -15,13 +15,16 @@
 
 class Processor(ABC, Generic[T]):
 	@abstractmethod
-	def accepts(self, headers: dict[str, str]) -> bool: ...
+	def accepts(self, headers: dict[str, str]) -> bool:
+		...
 
 	@abstractmethod
-	def start(self, headers: dict[str, str]) -> int: ...
+	def start(self, headers: dict[str, str]) -> int:
+		...
 
 	@abstractmethod
-	def feed(self, chunk: bytes) -> T | Control: ...
+	def feed(self, chunk: bytes) -> T | Control:
+		...
 
 
 # -----------------------------------------------------------------------------

src/py/extra/model.py

@@ -34,7 +34,9 @@ def ReloadFrom(cls, service: "Service") -> "Service":
 		# TODO: What about the prefix?
 		return res
 
-	def __init__(self, name: Union[str, None] = None, *, prefix: Union[str, None] = None) -> None:
+	def __init__(
+		self, name: Union[str, None] = None, *, prefix: Union[str, None] = None
+	) -> None:
 		self.name: str = name or self.__class__.__name__
 		self.app: Union[Application, None] = None
 		self.prefix = prefix or self.PREFIX