chore: major reliability overhaul - added result_data storage, auto-migrations, and fixed JSON parsing

app/db/models/analysis_run.py

@@ -1,7 +1,7 @@
 """
 Database Models for Analysis Runs
 """
-from sqlalchemy import Column, DateTime, Text, ForeignKey, UUID
+from sqlalchemy import Column, DateTime, Text, ForeignKey, UUID, JSON
 from sqlalchemy.orm import relationship
 from datetime import datetime
 import uuid
@@ -18,6 +18,7 @@ class AnalysisRun(Base):
     status = Column(Text)
     started_at = Column(DateTime)
     completed_at = Column(DateTime)
+    result_data = Column(JSON) # JSON blob for frontend consumption
     
     # Relationships
     project = relationship("Project", back_populates="analysis_runs")

app/main.py

@@ -79,6 +79,14 @@ async def lifespan(app: FastAPI):
                 with engine.connect().execution_options(isolation_level="AUTOCOMMIT") as ddl_conn:
                     ddl_conn.execute(text("ALTER TABLE research_papers ADD COLUMN summary TEXT"))
                 logger.info("Added 'summary' column to research_papers table.")
+
+            # Check if 'result_data' column exists in analysis_runs
+            res_res = conn.execute(text("SELECT column_name FROM information_schema.columns WHERE table_name='analysis_runs' AND column_name='result_data'")).fetchone()
+            if not res_res:
+                with engine.connect().execution_options(isolation_level="AUTOCOMMIT") as ddl_conn:
+                    # On utilise JSON pour Postgres, ou TEXT comme fallback si besoin
+                    ddl_conn.execute(text("ALTER TABLE analysis_runs ADD COLUMN result_data JSON"))
+                logger.info("Added 'result_data' column to analysis_runs table.")
     except Exception as e:
         logger.warning(f"Auto-migration warning (non-fatal): {str(e)}")
 

app/services/analysis_service.py

@@ -43,7 +43,7 @@ class AnalysisService:
             analysis.status = status
             analysis.completed_at = datetime.utcnow()
             if result:
-                analysis.result_data = json.dumps(result)
+                analysis.result_data = result # SQLAlchemy handles JSON serialization
             self.analysis_repo.db.add(analysis)
             self.analysis_repo.db.commit()
             self.analysis_repo.db.refresh(analysis)