Spaces:

tfrere
/

leaderboard-parser-agent

Build error

App Files Files Community

tfrere commited on Mar 21

Commit

3bfd040

1 Parent(s): e300cb8

add minimal ui for agent state

Browse files

Files changed (3) hide show

main.py +1 -1
src/processor.py +7 -1
src/server.py +67 -10

main.py CHANGED Viewed

@@ -80,7 +80,7 @@ def run_server_mode(args):
         logger.info("Running in server mode with periodic processing")
         # Run the FastAPI server
-        uvicorn.run(app, host="0.0.0.0", port=8000)
     except KeyboardInterrupt:
         logger.info("Server stopped by user")
     except Exception as e:

         logger.info("Running in server mode with periodic processing")
         # Run the FastAPI server
+        uvicorn.run(app, host="0.0.0.0", port=5176)
     except KeyboardInterrupt:
         logger.info("Server stopped by user")
     except Exception as e:

src/processor.py CHANGED Viewed

@@ -32,7 +32,7 @@ def update_server_status(status, error=None):
         error: The error message in case of failure
     """
     try:
-        from src.server import processing_status, processing_error
         # Update global variables in server.py
         globals()['processing_status'] = status
@@ -42,6 +42,12 @@ def update_server_status(status, error=None):
         import src.server
         src.server.processing_status = status
         src.server.processing_error = error
     except ImportError:
         # In non-server mode, these variables don't exist
         pass

         error: The error message in case of failure
     """
     try:
+        from src.server import processing_status, processing_error, last_run_time
         # Update global variables in server.py
         globals()['processing_status'] = status
         import src.server
         src.server.processing_status = status
         src.server.processing_error = error
+        # Update last run time when processing completes
+        if status == "completed":
+            now = datetime.datetime.now()
+            src.server.last_run_time = now
+            logger.info(f"Updated last run time to {now.isoformat()}")
     except ImportError:
         # In non-server mode, these variables don't exist
         pass

src/server.py CHANGED Viewed

@@ -7,7 +7,7 @@ import threading
 import logging
 import os
 from fastapi import FastAPI, HTTPException
-from fastapi.responses import JSONResponse
 from src.file_utils import format_datetime
 # Initialiser le logger
@@ -32,19 +32,76 @@ def initialize_server(process_function):
     Args:
         process_function: Fonction qui traite les leaderboards
     """
-    global process_leaderboards
     process_leaderboards = process_function
-    logger.info("Serveur initialisé avec la fonction de traitement")
 # Endpoints API
-@app.get("/")
 async def root():
-    """Root endpoint returning basic info"""
-    return {
-        "name": "Leaderboard Parser API",
-        "status": "running",
-        "version": "1.0.0"
-    }
 @app.get("/status")
 async def get_status():

 import logging
 import os
 from fastapi import FastAPI, HTTPException
+from fastapi.responses import JSONResponse, HTMLResponse
 from src.file_utils import format_datetime
 # Initialiser le logger
     Args:
         process_function: Fonction qui traite les leaderboards
     """
+    global process_leaderboards, last_run_time
     process_leaderboards = process_function
+    # Initialiser last_run_time à la date actuelle
+    last_run_time = datetime.datetime.now()
+    logger.info(f"Serveur initialisé avec la fonction de traitement. last_run_time initialisé à {last_run_time.isoformat()}")
 # Endpoints API
+@app.get("/", response_class=HTMLResponse)
 async def root():
+    """Root endpoint serving a simple HTML page with status info"""
+    global processing_status, last_run_time, processing_error
+    next_run = format_datetime(last_run_time + datetime.timedelta(hours=int(os.environ.get("LEADERBOARD_REPROCESS_INTERVAL_HOURS", 24)))) if last_run_time else "Not yet scheduled"
+    last_run = format_datetime(last_run_time) if last_run_time else "Never"
+    html_content = f"""
+    <!DOCTYPE html>
+    <html>
+        <head>
+            <title>Leaderboard Parser Status</title>
+            <style>
+                body {{
+                    font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
+                    display: flex;
+                    justify-content: center;
+                    align-items: center;
+                    height: 100vh;
+                    margin: 0;
+                    background-color: #f7f7f7;
+                }}
+                .status-box {{
+                    padding: 30px;
+                    text-align: left;
+                    background-color: white;
+                    border-radius: 12px;
+                    box-shadow: 0 4px 8px rgba(0, 0, 0, 0.05);
+                    max-width: 500px;
+                }}
+                h1 {{
+                    margin-top: 0;
+                    color: #333;
+                    font-weight: 600;
+                }}
+                p {{
+                    margin: 12px 0;
+                    font-size: 16px;
+                    line-height: 1.5;
+                }}
+                .status-label {{
+                    font-weight: bold;
+                    display: inline-block;
+                    min-width: 80px;
+                }}
+                .status-running {{ color: #1a73e8; font-weight: bold; }}
+                .status-idle {{ color: #188038; font-weight: bold; }}
+                .status-failed {{ color: #d93025; font-weight: bold; }}
+            </style>
+        </head>
+        <body>
+            <div class="status-box">
+                <h1>Leaderboards parser agent</h1>
+                <p><span class="status-label">Status</span> <span class="status-{processing_status}">{processing_status}</span></p>
+                <p><span class="status-label">Last run</span> {last_run}</p>
+                {f'<p style="color: #d93025; margin-top: 20px;"><span class="status-label">Error:</span> {processing_error}</p>' if processing_error else ''}
+            </div>
+        </body>
+    </html>
+    """
+    return HTMLResponse(content=html_content)
 @app.get("/status")
 async def get_status():