(fix) validate pydantic model types

Author: trowinshade

aiocarrot/carrot.py

@@ -1,3 +1,5 @@
+from pydantic import BaseModel
+
 from loguru import logger
 
 from typing import Optional, TYPE_CHECKING
@@ -50,6 +52,11 @@ async def send(self, _cnm: str, **kwargs) -> 'ConfirmationFrameType':
             **kwargs,
         }
 
+        message_body = {
+            key: (value.model_dump() if isinstance(value, BaseModel) else value)
+            for key, value in message_body.items()
+        }
+
         payload = ujson.dumps(message_body).encode()
 
         return await channel.default_exchange.publish(

aiocarrot/consumer/types.py

@@ -31,9 +31,6 @@ def type(self) -> any:
     def __post_init__(self) -> None:
         self._type_adapter: TypeAdapter[any] = TypeAdapter(
             Annotated[self.field_info.annotation, self.field_info],
-            config=ConfigDict(
-                arbitrary_types_allowed=True,
-            ),
         )
 
     def validate(self, value: any) -> tuple[T | None, str | None]: