Upload folder using huggingface_hub

docker-compose.monitoring.yml

@@ -42,6 +42,6 @@ services:
     networks:
       - customercore
     ports:
-      - "3000:3000"
+      - "3001:3000"
     depends_on:
       - prometheus

src/api/main.py

@@ -131,6 +131,13 @@ async def lifespan(app: FastAPI):
              env=os.getenv("APP_ENV", "development"),
              version="1.0.0")
 
+    # Run database migration checks
+    try:
+        from src.db.migrations import run_db_migrations
+        run_db_migrations()
+    except Exception as exc:
+        log.warning("Database migration checks failed (non-fatal)", error=str(exc))
+
     # Register Langfuse as LiteLLM callback (Phase 11 — LLM Observability)
     try:
         from src.monitoring.langfuse_tracer import setup_litellm_tracing

src/db/migrations.py

@@ -0,0 +1,50 @@
+import os
+import psycopg2
+import logging
+
+logger = logging.getLogger("customercore.db.migrations")
+
+def run_db_migrations():
+    """
+    Checks if tickets table has missing columns and updates it.
+    Also notifies PostgREST to reload its schema cache.
+    Fails gracefully if the database is unreachable (e.g., in IPv6-unsupported environments).
+    """
+    db_url = os.environ.get("SUPABASE_DB_URL")
+    if not db_url:
+        logger.warning("SUPABASE_DB_URL is not set. Skipping DDL migrations.")
+        return
+
+    logger.info("Running database migration checks...")
+    try:
+        # Connect to Postgres
+        conn = psycopg2.connect(db_url, connect_timeout=5)
+        conn.autocommit = True
+        cursor = conn.cursor()
+        
+        # Add columns if not present
+        cursor.execute("""
+            ALTER TABLE tickets 
+            ADD COLUMN IF NOT EXISTS customer_tier TEXT NOT NULL DEFAULT 'free' 
+            CHECK (customer_tier IN ('free','starter','growth','enterprise','vip'));
+        """)
+        
+        cursor.execute("""
+            ALTER TABLE tickets 
+            ADD COLUMN IF NOT EXISTS masked_text TEXT;
+        """)
+        
+        # Reload PostgREST schema cache
+        cursor.execute("SELECT pg_notify('pgrst', 'reload schema');")
+        logger.info("Database migration check completed successfully. PostgREST schema reloaded.")
+        
+        cursor.close()
+        conn.close()
+    except psycopg2.OperationalError as oe:
+        # Graceful fallback: log warning and continue so local app startup does not crash
+        logger.warning(
+            "Database connection timed out or unreachable (normal in local environments without IPv6 routing). "
+            f"Details: {oe}"
+        )
+    except Exception as e:
+        logger.error(f"Failed to execute database migrations: {e}")