backend/main.py

@@ -94,7 +94,7 @@ gate_status = GateStatus()
 # Configure logging
 def setup_logging(settings: Settings):
     """Configure logging based on settings"""
-    log_level = getattr(logging, settings.logging.level.upper(), logging.INFO)
+    log_level = getattr(logging, settings.logging.level.upper(), logging.WARNING)
     logger.setLevel(log_level)
     
     # Remove existing handlers
@@ -197,36 +197,30 @@ async def get_settings():
         return settings
 
 async def get_events(limit: int = 10, offset: int = 0):
-    """Get events from database with pagination"""
+    """Get recent gate events with pagination"""
-    try:
+    async with get_db() as db:
-        async with aiosqlite.connect(DB_PATH) as db:
+        db.row_factory = aiosqlite.Row
-            # Get total count
+        
-            async with db.execute("SELECT COUNT(*) FROM events") as cursor:
+        # Get total count
-                total = (await cursor.fetchone())[0]
+        cursor = await db.execute("SELECT COUNT(*) as count FROM events")
-            
+        row = await cursor.fetchone()
-            # Get paginated events
+        total_count = row['count']
-            async with db.execute(
+        
-                "SELECT timestamp, action, source, success FROM events ORDER BY timestamp DESC LIMIT ? OFFSET ?",
+        # Get paginated events
-                (limit, offset)
+        cursor = await db.execute(
-            ) as cursor:
+            """
-                events = [
+            SELECT * FROM events 
-                    {
+            ORDER BY timestamp DESC 
-                        "timestamp": row[0],
+            LIMIT ? OFFSET ?
-                        "action": row[1],
+            """,
-                        "source": row[2],
+            (limit, offset)
-                        "success": bool(row[3])
+        )
-                    }
+        events = await cursor.fetchall()
-                    for row in await cursor.fetchall()
+        return {
-                ]
+            "events": [dict(event) for event in events],
-            
+            "total": total_count,
-            return {
+            "hasMore": (offset + limit) < total_count
-                "events": events,
+        }
-                "total": total,
-                "hasMore": total > (offset + limit)
-            }
-    except Exception as e:
-        logger.error(f"Failed to get events: {e}", exc_info=True)
-        raise HTTPException(status_code=500, detail="Failed to get events")
 
 # Set up MQTT event logging
 async def log_mqtt_event(action: str, success: bool = True):
@@ -447,7 +441,7 @@ async def get_status():
         raise HTTPException(status_code=500, detail="Failed to get gate status")
 
 @app.get("/api/events")
-async def get_events_route(limit: int = 10, offset: int = 0):
+async def get_events(limit: int = 10, offset: int = 0):
     """Get recent gate events with pagination"""
     return await get_events(limit, offset)