replaced msgspec with pydantic and blacksheep with quart (#43)

* replaced msgspec with pydantic and blacksheep with quart

* updated type from BaseException -> Exception

* Revert "updated type from BaseException -> Exception"

This reverts commit d97c1b6.

* added arbitrary_types_allowed=True to pydantic model config

* updated test server response

* removed arg

pyproject.toml

@@ -9,7 +9,7 @@ dependencies = [
     "aiodns>=3.2.0",
     "aiohttp>=3.10.10",
     "loguru>=0.7.2",
-    "msgspec>=0.18.6",
+    "pydantic>=2.9.2",
 ]
 
 [project.optional-dependencies]
@@ -19,7 +19,6 @@ uvloop = [
 
 [dependency-groups]
 dev = [
-    "blacksheep==2.0.6",
     "httpx>=0.27.2",
     "mypy>=1.13.0",
     "pip-audit>=2.7.3",
@@ -28,6 +27,7 @@ dev = [
     "pytest-asyncio>=0.24.0",
     "ruff>=0.7.3",
     "uvicorn>=0.32.0",
+    "quart>=0.19.8",
 ]
 
 [build-system]

src/loamy/session.py

@@ -3,8 +3,8 @@
 from typing import Literal
 
 import aiohttp
-import msgspec
 from loguru import logger
+from pydantic import BaseModel, ConfigDict
 
 # Disable the logger. If a consuming app wishes to see loamy's logs, they can enable() it again.
 logger.disable("loamy")
@@ -19,7 +19,7 @@
     logger.debug("Using asyncio for async operations")
 
 
-class RequestMap(msgspec.Struct):
+class RequestMap(BaseModel):
     """
     Class containing information about a single HTTP request to be sent.
     """
@@ -31,11 +31,13 @@ class RequestMap(msgspec.Struct):
     headers: dict[str, str] | None = None
 
 
-class RequestResponse(msgspec.Struct):
+class RequestResponse(BaseModel):
     """
     Class containing information about the result of an HTTP request.
     """
 
+    model_config = ConfigDict(arbitrary_types_allowed=True)
+
     request_map: RequestMap
     status_code: int
     body: dict | None = None

tests/bin/test_server/server.py

@@ -1,21 +1,24 @@
-from blacksheep import Application, Request, Response, get, json, post
+from quart import Quart, jsonify, Response, Request
 
-app = Application()
+app = Quart(__name__)
 
 
-@get("/")
+@app.get("/")
 async def index() -> Response:
-    return json({"message": "Hello, world!"})
+    return jsonify({"message": "Hello, world!"})
 
 
-@post("/foo")
-async def post_foo(request: Request) -> Response:
-    data = await request.json()
-    resp: Response = json(data)
-    resp.add_header(b"X-Test", b"Test")
+@app.post("/foo")
+async def post_foo() -> Response:
+    resp = jsonify({"foo": "bar"})
+    resp.headers["X-Test"] = "Test"
     return resp
 
 
-@get("/exception")
+@app.get("/exception")
 async def mock_exception() -> Response:
     raise Exception("Mock exception")
+
+
+if __name__ == "__main__":
+    app.run()

tests/test_requests.py

@@ -49,6 +49,7 @@ def test_send_requests(request_map_collection: List[RequestMap]) -> None:
             assert "x-test" in response.headers
             assert "Test" == response.headers["x-test"]
 
+
 def test_send_requests_with_exceptions(
     request_map_collection: List[RequestMap],
     request_map_to_trigger_exception: RequestMap,