From 4ac23bf3cf1fe05be527435efa33e91a30ef98d3 Mon Sep 17 00:00:00 2001
From: aitbc <aitbc@keisanki.net>
Date: Fri, 8 May 2026 19:30:42 +0200
Subject: [PATCH] fix: convert SQLAlchemy model objects to dictionaries for
 JSON serialization

- Update list_offers to return dict instead of SQLAlchemy model objects
- Fixes ValueError and TypeError in FastAPI jsonable_encoder
- Converts all offer fields to dictionaries with proper datetime serialization
- Added logging for conversion tracking
---
 .../services/marketplace_service.py           | 26 +++++++++++++++++--
 .../services/marketplace_service.py           | 26 +++++++++++++++++--
 2 files changed, 48 insertions(+), 4 deletions(-)

diff --git a/apps/marketplace-service-debug/src/marketplace_service/services/marketplace_service.py b/apps/marketplace-service-debug/src/marketplace_service/services/marketplace_service.py
index 4cd22d3f..e098575b 100644
--- a/apps/marketplace-service-debug/src/marketplace_service/services/marketplace_service.py
+++ b/apps/marketplace-service-debug/src/marketplace_service/services/marketplace_service.py
@@ -22,7 +22,7 @@ class MarketplaceService:
         status: str | None = None,
         region: str | None = None,
         gpu_model: str | None = None,
-    ) -> list[MarketplaceOffer]:
+    ) -> list[dict]:
         """List marketplace offers"""
         try:
             logger.info(f"list_offers called with filters: status={status}, region={region}, gpu_model={gpu_model}")
@@ -36,7 +36,29 @@ class MarketplaceService:
             logger.info("Executing database query for offers")
             result = list((await self.session.execute(stmt)).all())
             logger.info(f"Retrieved {len(result)} offers")
-            return result
+            # Convert SQLAlchemy model objects to dictionaries for JSON serialization
+            offers_list = []
+            for row in result:
+                offer = row[0] if row else None
+                if offer:
+                    offers_list.append({
+                        'id': offer.id,
+                        'provider': offer.provider,
+                        'capacity': offer.capacity,
+                        'price': offer.price,
+                        'sla': offer.sla,
+                        'status': offer.status,
+                        'created_at': offer.created_at.isoformat() if offer.created_at else None,
+                        'attributes': offer.attributes,
+                        'gpu_model': offer.gpu_model,
+                        'gpu_memory_gb': offer.gpu_memory_gb,
+                        'gpu_count': offer.gpu_count,
+                        'cuda_version': offer.cuda_version,
+                        'price_per_hour': offer.price_per_hour,
+                        'region': offer.region,
+                    })
+            logger.info(f"Converted {len(offers_list)} offers to dictionaries")
+            return offers_list
         except Exception as e:
             logger.error(f"Error in list_offers: {type(e).__name__}: {str(e)}")
             raise
diff --git a/apps/marketplace-service/src/marketplace_service/services/marketplace_service.py b/apps/marketplace-service/src/marketplace_service/services/marketplace_service.py
index 4cd22d3f..e098575b 100644
--- a/apps/marketplace-service/src/marketplace_service/services/marketplace_service.py
+++ b/apps/marketplace-service/src/marketplace_service/services/marketplace_service.py
@@ -22,7 +22,7 @@ class MarketplaceService:
         status: str | None = None,
         region: str | None = None,
         gpu_model: str | None = None,
-    ) -> list[MarketplaceOffer]:
+    ) -> list[dict]:
         """List marketplace offers"""
         try:
             logger.info(f"list_offers called with filters: status={status}, region={region}, gpu_model={gpu_model}")
@@ -36,7 +36,29 @@ class MarketplaceService:
             logger.info("Executing database query for offers")
             result = list((await self.session.execute(stmt)).all())
             logger.info(f"Retrieved {len(result)} offers")
-            return result
+            # Convert SQLAlchemy model objects to dictionaries for JSON serialization
+            offers_list = []
+            for row in result:
+                offer = row[0] if row else None
+                if offer:
+                    offers_list.append({
+                        'id': offer.id,
+                        'provider': offer.provider,
+                        'capacity': offer.capacity,
+                        'price': offer.price,
+                        'sla': offer.sla,
+                        'status': offer.status,
+                        'created_at': offer.created_at.isoformat() if offer.created_at else None,
+                        'attributes': offer.attributes,
+                        'gpu_model': offer.gpu_model,
+                        'gpu_memory_gb': offer.gpu_memory_gb,
+                        'gpu_count': offer.gpu_count,
+                        'cuda_version': offer.cuda_version,
+                        'price_per_hour': offer.price_per_hour,
+                        'region': offer.region,
+                    })
+            logger.info(f"Converted {len(offers_list)} offers to dictionaries")
+            return offers_list
         except Exception as e:
             logger.error(f"Error in list_offers: {type(e).__name__}: {str(e)}")
             raise