Update app.py

app.py

@@ -3,17 +3,15 @@ from fastapi.responses import HTMLResponse, FileResponse
 from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
 from simple_salesforce import Salesforce
-from dotenv import load_dotenv
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+import sqlite3
 import os
 import logging
-import sqlite3
-from apscheduler.schedulers.asyncio import AsyncIOScheduler
 
 # Set up logging
 logging.basicConfig(level=logging.DEBUG)
 logger = logging.getLogger(__name__)
 
-# FastAPI app setup
 app = FastAPI()
 
 # Mount static files
@@ -42,11 +40,12 @@ def init_db():
         logger.debug("SQLite database initialized successfully.")
     except Exception as e:
         logger.error(f"Error initializing SQLite database: {e}")
+        raise
 
 # Run database initialization on startup
 init_db()
 
-# Salesforce connection function
+# Salesforce connection (using Space Secrets)
 def get_salesforce_connection():
     try:
         username = os.getenv("SFDC_USERNAME")
@@ -101,14 +100,15 @@ async def sync_to_salesforce():
         conn.close()
     except Exception as e:
         logger.error(f"Error syncing to Salesforce: {str(e)}")
+        raise  # Raise the exception to see the error in the response
 
-# Set up scheduler to run the sync function every 4 hours
+# Set up scheduler
 scheduler = AsyncIOScheduler()
-scheduler.add_job(sync_to_salesforce, 'interval', hours=4)
-scheduler.start()
+scheduler.add_job(sync_to_salesforce, "interval", hours=4)
 
 @app.on_event("startup")
 async def startup_event():
+    scheduler.start()
     logger.debug("Scheduler started successfully.")
 
 @app.on_event("shutdown")
@@ -166,6 +166,19 @@ async def submit_case(request: Request):
         logger.error(f"Error processing request: {str(e)}")
         raise HTTPException(status_code=500, detail=str(e))
 
+@app.get("/debug-cases")
+async def debug_cases():
+    try:
+        conn = sqlite3.connect("cases.db")
+        cursor = conn.cursor()
+        cursor.execute("SELECT * FROM cases")
+        cases = cursor.fetchall()
+        conn.close()
+        return {"cases": cases}
+    except Exception as e:
+        logger.error(f"Error retrieving cases: {str(e)}")
+        raise HTTPException(status_code=500, detail=str(e))
+
 if __name__ == "__main__":
     import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+    uvicorn.run(app, host="0.0.0.0", port=7860)