jsonfix3

CHANGELOG.md

@@ -1,3 +1,8 @@
+#### [0.4.13] - 2025-03-20
+- Fixed Topic objects serialization error in cache/memorycache.py
+- Improved CustomJSONEncoder to support SQLAlchemy models with dict() method
+- Enhanced error handling in cache_on_arguments decorator
+
 #### [0.4.12] - 2025-03-19
 - `delete_reaction` detects comments and uses `deleted_at` update
 - `check_to_unfeature` etc. update

cache/memorycache.py

@@ -99,10 +99,21 @@ class RedisCache:
                 try:
                     import asyncio
 
+                    # Попытка сериализовать результат в JSON
+                    try:
                         serialized = json.dumps(result, cls=CustomJSONEncoder)
+                    except (TypeError, ValueError) as e:
+                        logger.debug(f"JSON сериализация не удалась, используем pickle: {e}")
+                        # Если не удалось сериализовать как JSON, используем pickle
+                        serialized = pickle.dumps(result).decode()
+
                     asyncio.create_task(redis.set(key, serialized, ex=self.ttl))
                 except Exception as e:
                     logger.error(f"Ошибка при кешировании результата: {e}")
+                    # Для отладки добавляем информацию о типе объекта
+                    logger.debug(f"Тип результата: {type(result)}")
+                    if hasattr(result, "__class__"):
+                        logger.debug(f"Класс результата: {result.__class__.__name__}")
 
                 return result
 

utils/encoders.py

@@ -3,7 +3,26 @@ from json import JSONEncoder
 
 
 class CustomJSONEncoder(JSONEncoder):
+    """
+    Расширенный JSON энкодер с поддержкой сериализации объектов SQLAlchemy.
+
+    Примеры:
+    >>> import json
+    >>> from decimal import Decimal
+    >>> from orm.topic import Topic
+    >>> json.dumps(Decimal("10.50"), cls=CustomJSONEncoder)
+    '"10.50"'
+    >>> topic = Topic(id=1, slug="test")
+    >>> json.dumps(topic, cls=CustomJSONEncoder)
+    '{"id": 1, "slug": "test", ...}'
+    """
+
     def default(self, obj):
         if isinstance(obj, Decimal):
             return str(obj)
+
+        # Проверяем, есть ли у объекта метод dict() (как у моделей SQLAlchemy)
+        if hasattr(obj, "dict") and callable(obj.dict):
+            return obj.dict()
+
         return super().default(obj)