Fix: Use Supabase REST API instead of psycopg2 for HF compatibility

syscred/backend_app.py

@@ -421,8 +421,9 @@ def verify_endpoint():
             print(f"[SysCRED Backend] TREC metrics error: {e}")
             result['trec_metrics'] = {'error': str(e)}
         
-        # [NEW] Persist to Database
+        # [NEW] Persist to Database (SQLite + Supabase REST)
         try:
+            # Save to SQLite
             new_analysis = AnalysisResult(
                 url=input_data[:500],
                 credibility_score=result.get('scoreCredibilite', 0.5),
@@ -431,7 +432,23 @@ def verify_endpoint():
             )
             db.session.add(new_analysis)
             db.session.commit()
-            print(f"[SysCRED-DB] Result saved. ID: {new_analysis.id}")
+            print(f"[SysCRED-DB] Result saved to SQLite. ID: {new_analysis.id}")
+            
+            # Also save to Supabase via REST API
+            try:
+                from syscred.database import get_supabase
+                supabase = get_supabase()
+                if supabase:
+                    supabase.insert('analysis_results', {
+                        'url': input_data[:500],
+                        'credibility_score': result.get('scoreCredibilite', 0.5),
+                        'summary': result.get('resumeAnalyse', ''),
+                        'source_reputation': result.get('detailsScore', {}).get('factors', [{}])[0].get('value')
+                    })
+                    print(f"[SysCRED-DB] Result synced to Supabase")
+            except Exception as supabase_err:
+                print(f"[SysCRED-DB] Supabase sync failed: {supabase_err}")
+                
         except Exception as e:
             print(f"[SysCRED-DB] Save failed: {e}")
 

syscred/database.py

@@ -1,17 +1,95 @@
 # -*- coding: utf-8 -*-
 """
 Database Manager for SysCRED
-===========================
-Handles connection to Supabase (PostgreSQL) and defines models.
+=============================
+Handles connection to Supabase using REST API (PostgREST) for HF Spaces compatibility.
 """
 
 import os
+import requests
 from flask_sqlalchemy import SQLAlchemy
 from datetime import datetime
 
 # Initialize SQLAlchemy
 db = SQLAlchemy()
 
+# Supabase REST API configuration
+SUPABASE_URL = os.environ.get('SUPABASE_URL', 'https://zmluirvqfkmfazqitqgi.supabase.co')
+SUPABASE_KEY = os.environ.get('SUPABASE_KEY', os.environ.get('SUPABASE_SERVICE_ROLE_KEY', ''))
+
+class SupabaseClient:
+    """REST API client for Supabase (PostgREST)."""
+    
+    def __init__(self):
+        self.url = SUPABASE_URL
+        self.key = SUPABASE_KEY
+        self.headers = {
+            'apikey': self.key,
+            'Authorization': f'Bearer {self.key}',
+            'Content-Type': 'application/json',
+            'Prefer': 'return=representation'
+        }
+    
+    def insert(self, table, data):
+        """Insert a row into a table."""
+        try:
+            response = requests.post(
+                f"{self.url}/rest/v1/{table}",
+                json=data,
+                headers=self.headers
+            )
+            return response.status_code in [200, 201, 204]
+        except Exception as e:
+            print(f"[Supabase REST] Insert error: {e}")
+            return False
+    
+    def select(self, table, filters=None):
+        """Select rows from a table."""
+        try:
+            params = filters or {}
+            response = requests.get(
+                f"{self.url}/rest/v1/{table}",
+                params=params,
+                headers=self.headers
+            )
+            if response.status_code == 200:
+                return response.json()
+            return []
+        except Exception as e:
+            print(f"[Supabase REST] Select error: {e}")
+            return []
+    
+    def count(self, table):
+        """Count rows in a table."""
+        try:
+            response = requests.get(
+                f"{self.url}/rest/v1/{table}",
+                params={'select': 'count', 'count': 'exact'},
+                headers=self.headers
+            )
+            if response.status_code == 200:
+                return int(response.headers.get('Content-Range', '0-0').split('/')[-1])
+            return 0
+        except Exception as e:
+            print(f"[Supabase REST] Count error: {e}")
+            return 0
+
+
+# Global Supabase client
+supabase_client = None
+
+def get_supabase():
+    """Get or create Supabase client."""
+    global supabase_client
+    if supabase_client is None:
+        if SUPABASE_KEY:
+            supabase_client = SupabaseClient()
+            print("[SysCRED-DB] Supabase REST client initialized")
+        else:
+            print("[SysCRED-DB] Warning: No SUPABASE_KEY, Supabase disabled")
+    return supabase_client
+
+
 class AnalysisResult(db.Model):
     """Stores the result of a credibility analysis."""
     __tablename__ = 'analysis_results'
@@ -36,30 +114,27 @@ class AnalysisResult(db.Model):
             'source_reputation': self.source_reputation
         }
 
+
 def init_db(app):
     """Initialize the database with the Flask app."""
-    # Prefer DATABASE_URL (direct connection), then SYSCRED_DATABASE_URL (pooler)
-    # HF Spaces often can't resolve the pooler hostname
-    db_url = os.environ.get('DATABASE_URL') or os.environ.get('SYSCRED_DATABASE_URL')
-    if db_url and db_url.startswith("postgres://"):
-        db_url = db_url.replace("postgres://", "postgresql://", 1)
-    
-    # Fallback to SQLite in a writable directory
-    if not db_url:
-        import tempfile
-        db_path = os.path.join(tempfile.gettempdir(), 'syscred.db')
-        db_url = f'sqlite:///{db_path}'
-        print(f"[SysCRED-DB] No DATABASE_URL, using SQLite: {db_path}")
+    # Use SQLite fallback - Supabase operations use REST API separately
+    import tempfile
+    db_path = os.path.join(tempfile.gettempdir(), 'syscred.db')
+    db_url = f'sqlite:///{db_path}'
+    print(f"[SysCRED-DB] Using SQLite (Supabase uses REST API): {db_path}")
     
     app.config['SQLALCHEMY_DATABASE_URI'] = db_url
     app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
     
     db.init_app(app)
     
-    # Create tables if they don't exist (basic migration)
+    # Create tables
     with app.app_context():
         try:
             db.create_all()
             print("[SysCRED-DB] Database tables initialized.")
         except Exception as e:
             print(f"[SysCRED-DB] Warning: create_all failed: {e}")
+    
+    # Initialize Supabase REST client
+    get_supabase()