Add sources table sync to Supabase

syscred/backend_app.py

@@ -424,12 +424,23 @@ def verify_endpoint():
         
         # [NEW] Persist to Database (SQLite + Supabase REST)
         try:
+            # Extract domain for sources table
+            domain = None
+            if credibility_system and credibility_system.is_url(input_data):
+                try:
+                    from urllib.parse import urlparse
+                    domain = urlparse(input_data).netloc
+                except:
+                    pass
+            
+            source_reputation = result.get('detailsScore', {}).get('factors', [{}])[0].get('value')
+            
             # Save to SQLite
             new_analysis = AnalysisResult(
                 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')
+                source_reputation=source_reputation
             )
             db.session.add(new_analysis)
             db.session.commit()
@@ -444,9 +455,22 @@ def verify_endpoint():
                         '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')
+                        'source_reputation': source_reputation
                     })
                     print(f"[SysCRED-DB] Result synced to Supabase")
+                    
+                    # Sync source (domain)
+                    if domain and source_reputation:
+                        # Convert reputation to numeric score
+                        rep_score = 0.5
+                        if source_reputation in ['High', 'high', '5 found']:
+                            rep_score = 0.8
+                        elif source_reputation in ['Medium', 'medium']:
+                            rep_score = 0.5
+                        elif source_reputation in ['Low', 'low', 'Unknown']:
+                            rep_score = 0.2
+                        
+                        supabase.upsert_source(domain, rep_score)
             except Exception as supabase_err:
                 print(f"[SysCRED-DB] Supabase sync failed: {supabase_err}")
                 

syscred/database.py

@@ -78,6 +78,50 @@ class SupabaseClient:
         except Exception as e:
             print(f"[Supabase REST] Count error: {e}")
             return 0
+    
+    def upsert_source(self, domain, reputation_score, analysis_count=1):
+        """Insert or update a source (domain) in sources table."""
+        try:
+            # First check if source exists
+            existing = self.select('sources', {'domain': f'eq.{domain}'})
+            
+            if existing:
+                # Update existing source
+                current = existing[0]
+                new_count = current.get('analysis_count', 0) + analysis_count
+                
+                # Use PATCH to update
+                response = requests.patch(
+                    f"{self.url}/rest/v1/sources?domain=eq.{domain}",
+                    json={
+                        'reputation_score': reputation_score,
+                        'analysis_count': new_count
+                    },
+                    headers=self.headers
+                )
+                if response.status_code in [200, 204]:
+                    print(f"[Supabase] Updated source: {domain} (count: {new_count})")
+                    return True
+            else:
+                # Insert new source
+                response = requests.post(
+                    f"{self.url}/rest/v1/sources",
+                    json={
+                        'domain': domain,
+                        'reputation_score': reputation_score,
+                        'analysis_count': analysis_count
+                    },
+                    headers=self.headers
+                )
+                if response.status_code in [200, 201]:
+                    print(f"[Supabase] Inserted new source: {domain}")
+                    return True
+            
+            print(f"[Supabase] Source upsert failed: {response.status_code} - {response.text[:100]}")
+            return False
+        except Exception as e:
+            print(f"[Supabase REST] Upsert source error: {e}")
+            return False
 
 
 # Global Supabase client