Switch Space to Gradio interface

Dockerfile

@@ -1,14 +0,0 @@
-FROM python:3.8-slim
-
-# Set the working directory
-WORKDIR /app
-
-# Copy the requirements file and install dependencies
-COPY requirements.txt /app/
-RUN pip install --no-cache-dir -r requirements.txt
-
-# Copy the rest of the code
-COPY . /app
-
-# Command to run the app
-CMD ["python", "app.py"]

README.md

@@ -3,17 +3,17 @@ title: GFES Wave 0 Downloader
 emoji: 🌍
 colorFrom: pink
 colorTo: gray
-sdk: docker
+sdk: gradio
 pinned: false
 license: cc-by-4.0
 ---
 
 ## GEFS Wave Control Member Downloader
 
-This Space runs a Flask service that automatically fetches the latest GEFS Wave control member (`c00`, “wave 0”) global 0.25° GRIB2 dataset from NOAA NOMADS. When a new cycle is published, the data is downloaded, archived into a tarball, and exposed through simple endpoints:
+This Space now provides a Gradio dashboard that keeps a local cache of the latest GEFS Wave control member (`c00`, “wave 0”) global 0.25° GRIB2 dataset from NOAA NOMADS. Use the interface to:
 
-- `/` and `/status` – View downloader status, including the most recent cycle timestamp and tarball path.
-- `/refresh` (POST) – Request a background refresh to capture a newer cycle if available.
-- `/wave/download` – Download the tarball containing every `global.0p25` GRIB2 file for the latest cycle.
+- Inspect the current downloader status and metadata for the newest available cycle.
+- Trigger a refresh to fetch a more recent cycle if one has been published.
+- Download a `.tar.gz` archive containing every `global.0p25` GRIB2 file for that cycle.
 
 Data is stored under `data/gefswave` inside the Space. Override this path with the `GEFS_WAVE_DATA_DIR` environment variable if needed. The downloader searches up to five days back to locate the newest complete cycle.

app.py

@@ -1,78 +1,98 @@
 import os
 from pathlib import Path
 from threading import Event
+from typing import Dict, Tuple
 
-from flask import Flask, jsonify, send_file
-from twilio.twiml.voice_response import VoiceResponse
+import gradio as gr
 
 from gefs_wave import WaveDownloadManager
 
-app = Flask(__name__)
 DATA_ROOT = Path(os.environ.get("GEFS_WAVE_DATA_DIR", "data/gefswave"))
 manager = WaveDownloadManager(DATA_ROOT)
 _refresh_started = Event()
 
 
-def ensure_refresh():
-    """Start the background refresh thread once."""
+def ensure_refresh() -> None:
+    """Kick off the downloader thread once per process."""
     if not _refresh_started.is_set():
         _refresh_started.set()
         manager.trigger_refresh()
 
 
-@app.route("/", methods=["GET"])
-def index():
+def format_status(status: Dict) -> Tuple[Dict, str]:
+    """Return status JSON and a markdown summary."""
+    latest = status.get("latest_state", {})
+    lines = [
+        f"**Downloader status:** `{status.get('status', 'unknown')}`",
+    ]
+    if "message" in status:
+        lines.append(f"- Message: {status['message']}")
+    if latest:
+        lines.extend(
+            [
+                f"- Latest cycle: `{latest.get('cycle', 'N/A')}`",
+                f"- Updated at: `{latest.get('updated_at', 'N/A')}`",
+                f"- Files cached: {len(latest.get('files', []))}",
+            ]
+        )
+        if tarball := latest.get("tarball"):
+            lines.append(f"- Tarball path: `{tarball}`")
+    else:
+        lines.append("- No cycle downloaded yet.")
+    lines.append("\nUse **Trigger Refresh** to fetch a newer cycle when available.")
+    return status, "\n".join(lines)
+
+
+def get_status() -> Tuple[Dict, str]:
     ensure_refresh()
-    return jsonify(manager.status())
+    status = manager.status()
+    return format_status(status)
 
 
-@app.route("/status", methods=["GET"])
-def status():
-    ensure_refresh()
-    return jsonify(manager.status())
-
-
-@app.route("/refresh", methods=["POST"])
-def refresh():
+def trigger_refresh() -> Tuple[Dict, str]:
     ensure_refresh()
     manager.trigger_refresh()
-    return jsonify({"message": "Refresh started."})
+    status = manager.status()
+    return format_status(status)
 
 
-@app.route("/wave/download", methods=["GET"])
-def download_wave():
+def download_tarball() -> str:
     ensure_refresh()
     state = manager.downloader.current_state()
     if not state or "tarball" not in state:
-        return jsonify({"error": "Wave dataset not available yet."}), 503
+        raise gr.Error("Wave dataset not available yet. Try triggering a refresh.")
 
     tarball_path = DATA_ROOT / state["tarball"]
     if not tarball_path.exists():
-        return jsonify({"error": "Tarball missing on disk."}), 404
-
-    filename = tarball_path.name
-    if cycle := state.get("cycle"):
-        filename = f"gefswave_wave0_{cycle.replace(' ', '_')}.tar.gz"
-    return send_file(
-        tarball_path,
-        as_attachment=True,
-        download_name=filename,
-        mimetype="application/gzip",
-        max_age=0,
+        raise gr.Error("Tarball missing on disk. Trigger a refresh and try again.")
+    return str(tarball_path)
+
+
+with gr.Blocks(title="GFES Wave 0 Downloader") as demo:
+    gr.Markdown(
+        """
+        ## GFES Wave 0 Downloader
+        Fetch the latest NOAA GEFS Wave control member (`c00`) global 0.25° dataset.
+
+        1. Check the status panel to confirm the current cycle.
+        2. Press **Trigger Refresh** to request a newer cycle if one is available.
+        3. Use **Download Latest Tarball** to grab a `.tar.gz` of every GRIB2 file for that cycle.
+        """
     )
+    status_json = gr.JSON(label="Downloader Status")
+    status_md = gr.Markdown()
 
+    with gr.Row():
+        refresh_button = gr.Button("Trigger Refresh", variant="secondary")
+        download_button = gr.DownloadButton("Download Latest Tarball", value=download_tarball, variant="primary")
 
-@app.route("/voice", methods=["GET", "POST"])
-def voice():
-    """Responds to incoming calls with a simple text-to-speech message."""
-    resp = VoiceResponse()
-    resp.say("The GEFS wave zero dataset downloader is online.", voice="alice")
+    demo.load(get_status, outputs=[status_json, status_md])
+    refresh_button.click(trigger_refresh, outputs=[status_json, status_md])
 
-    return str(resp)
+demo.queue(default_concurrency_count=2, max_size=8)
 
 
 if __name__ == "__main__":
     ensure_refresh()
     port = int(os.environ.get("PORT", 7860))
-    debug_mode = os.environ.get("FLASK_DEBUG", "").lower() in {"1", "true", "yes"}
-    app.run(host="0.0.0.0", port=port, debug=debug_mode)
+    demo.launch(server_name="0.0.0.0", server_port=port, show_api=False)

requirements.txt

@@ -1,3 +1,2 @@
-flask
-requests
-twilio
+gradio>=5.0.0
+requests>=2.31.0