Update backend with high-quality catalog and fixes

app/api/admin.py

@@ -826,13 +826,21 @@ def restore_flagged_product(
     catalog_data["metadata"]["total"] = len(catalog_data["products"])
     
     # 5. Save main catalog
-    with open(catalog_path, "w", encoding="utf-8") as f:
-        json.dump(catalog_data, f, ensure_ascii=False, indent=2)
+    try:
+        with open(catalog_path, "w", encoding="utf-8") as f:
+            json.dump(catalog_data, f, ensure_ascii=False, indent=2)
+    except Exception as e:
+        print(f"[ADMIN] Warning: Could not update local catalog JSON: {e}")
+
         
     # 6. Remove from pending
     pending = [p for p in pending if p["id"] != product_id]
-    with open(PENDING_DELETION_FILE, "w", encoding="utf-8") as f:
-        json.dump(pending, f, ensure_ascii=False, indent=2)
+    try:
+        with open(PENDING_DELETION_FILE, "w", encoding="utf-8") as f:
+            json.dump(pending, f, ensure_ascii=False, indent=2)
+    except Exception as e:
+        print(f"[ADMIN] Warning: Could not update pending_deletion.json: {e}")
+
         
     log_audit_event("RESTORED_FROM_QUARANTINE", f"Product {product_id} restored to main catalog", {"product_id": product_id})
         
@@ -861,8 +869,12 @@ async def delete_flagged_product(
     if len(flagged_data) == original_count:
         raise HTTPException(status_code=404, detail="Product not found in quarantine")
         
-    with open(PENDING_DELETION_FILE, "w", encoding="utf-8") as f:
-        json.dump(flagged_data, f, ensure_ascii=False, indent=2)
+    try:
+        with open(PENDING_DELETION_FILE, "w", encoding="utf-8") as f:
+            json.dump(flagged_data, f, ensure_ascii=False, indent=2)
+    except Exception as e:
+        print(f"[ADMIN] Warning: Could not update pending_deletion.json: {e}")
+
         
     # Log the permanent deletion with metadata
     log_audit_event("PERMANENTLY_DELETED", f"Deleted product ID: {product_id}", {"product_id": product_id, "source": "quarantine"})

app/api/product_quality_checker_lib.py

@@ -39,14 +39,21 @@ except ImportError:
         DB_AVAILABLE = False
 
 
-logging.basicConfig(
-    level=logging.INFO,
-    format='%(asctime)s - %(levelname)s - %(message)s',
-    handlers=[
-        logging.FileHandler(f'product_quality_{datetime.now().strftime("%Y%m%d_%H%M%S")}.log'),
-        logging.StreamHandler()
-    ]
-)
+try:
+    logging.basicConfig(
+        level=logging.INFO,
+        format='%(asctime)s - %(levelname)s - %(message)s',
+        handlers=[
+            logging.FileHandler(f'product_quality_{datetime.now().strftime("%Y%m%d_%H%M%S")}.log'),
+            logging.StreamHandler()
+        ]
+    )
+except Exception:
+    logging.basicConfig(
+        level=logging.INFO,
+        format='%(asctime)s - %(levelname)s - %(message)s',
+        handlers=[logging.StreamHandler()]
+    )
 logger = logging.getLogger(__name__)
 
 
@@ -385,11 +392,13 @@ class StandaloneQualityChecker:
         
         logger.info(f"Validation complete: {results['summary']['valid']} valid, {results['summary']['invalid']} invalid")
         
-        output_path = self.json_path.replace('.json', '_validation.json')
-        with open(output_path, 'w', encoding='utf-8') as f:
-            json.dump(results, f, ensure_ascii=False, indent=2)
-            
-        logger.info(f"Results saved to {output_path}")
+        try:
+            output_path = self.json_path.replace('.json', '_validation.json')
+            with open(output_path, 'w', encoding='utf-8') as f:
+                json.dump(results, f, ensure_ascii=False, indent=2)
+            logger.info(f"Results saved to {output_path}")
+        except Exception as e:
+            logger.warning(f"Could not save validation results to disk: {e}")
         
         return results
 
@@ -425,10 +434,12 @@ def create_backup(db_session) -> Optional[str]:
         backup_filename = f"products_backup_{datetime.now().strftime('%Y%m%d_%H%M%S')}.json"
         backup_path = os.path.join(backup_dir, backup_filename)
         
-        with open(backup_path, 'w', encoding='utf-8') as f:
-            json.dump(backup_data, f, ensure_ascii=False, indent=2)
-            
-        logger.info(f"Backup created: {backup_path}")
+        try:
+            with open(backup_path, 'w', encoding='utf-8') as f:
+                json.dump(backup_data, f, ensure_ascii=False, indent=2)
+            logger.info(f"Backup created: {backup_path}")
+        except Exception as e:
+            logger.warning(f"Could not write backup to disk: {e}")
         return backup_path
         
     except Exception as e:
@@ -480,11 +491,13 @@ def main():
         checker = ProductQualityChecker(db)
         report = checker.run_quality_check(args.batch_size)
         
-        report_path = os.path.join(os.path.dirname(__file__), f"quality_report_{datetime.now().strftime('%Y%m%d_%H%M%S')}.json")
-        with open(report_path, 'w', encoding='utf-8') as f:
-            json.dump(report.to_dict(), f, ensure_ascii=False, indent=2)
-            
-        logger.info(f"Quality report saved: {report_path}")
+        try:
+            report_path = os.path.join(os.path.dirname(__file__), f"quality_report_{datetime.now().strftime('%Y%m%d_%H%M%S')}.json")
+            with open(report_path, 'w', encoding='utf-8') as f:
+                json.dump(report.to_dict(), f, ensure_ascii=False, indent=2)
+            logger.info(f"Quality report saved: {report_path}")
+        except Exception as e:
+            logger.warning(f"Could not save quality report to disk: {e}")
         
     finally:
         db.close()

app/api/settings.py

@@ -1,7 +1,6 @@
 from fastapi import APIRouter, Depends, HTTPException, status, UploadFile, File
 from datetime import datetime
 import os
-import shutil
 from app.core.config import settings as app_settings
 from sqlalchemy.orm import Session
 from typing import Any

app/core/backup_manager.py

@@ -17,8 +17,11 @@ class BackupManager:
         self.catalog_path = os.path.join(base_dir, "backend", "real_products_200.json")
         self.retention_days = 30
         
-        if not os.path.exists(self.backup_dir):
-            os.makedirs(self.backup_dir, exist_ok=True)
+        try:
+            if not os.path.exists(self.backup_dir):
+                os.makedirs(self.backup_dir, exist_ok=True)
+        except Exception as e:
+            logger.warning(f"Could not create backup directory: {e}")
 
     def create_snapshot(self, reason: str = "automated"):
         """Creates a timestamped backup of the current catalog."""

app/core/logging.py

@@ -9,8 +9,11 @@ def log_audit_event(action: str, details: str, metadata: dict = None, severity:
     """Log an event to the formal JSON audit trail with rich metadata."""
     try:
         log_dir = os.path.dirname(AUDIT_LOG_FILE)
-        if not os.path.exists(log_dir):
-            os.makedirs(log_dir, exist_ok=True)
+        try:
+            if not os.path.exists(log_dir):
+                os.makedirs(log_dir, exist_ok=True)
+        except Exception as e:
+            print(f"[LOGGING] Warning: Could not create log directory: {e}")
             
         logs = []
         if os.path.exists(AUDIT_LOG_FILE):

app/main.py

@@ -85,19 +85,6 @@ def create_app() -> FastAPI:
     app.include_router(admin_router, prefix="/api")
     app.include_router(notifications_router, prefix="/api")
     
-    from fastapi.staticfiles import StaticFiles
-    import os
-    
-    # Mount uploads directory from DATA_DIR
-    uploads_base = os.path.join(settings.DATA_DIR, "uploads")
-    try:
-        os.makedirs(os.path.join(uploads_base, "receipts"), exist_ok=True)
-    except Exception as e:
-        print(f"[MAIN] Warning: Could not create upload directories: {e}")
-        
-    if os.path.exists(uploads_base):
-        app.mount("/uploads", StaticFiles(directory=uploads_base), name="uploads")
-
     app.include_router(settings_router, prefix="/api")
 
     VERSION = "2.0.0-FINAL-CATALOG"