feat: Add POST /flush-cache endpoint to clear all cached data and reset timers

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

app.py

@@ -7,7 +7,7 @@ import os
 import io
 import qrcode
 import logging
-from flask import Flask, render_template, g, send_file, request
+from flask import Flask, render_template, g, send_file, request, jsonify
 
 # Configure logging, allowing override via LOG_LEVEL environment variable
 log_level = os.environ.get("LOG_LEVEL", "INFO").upper()
@@ -23,7 +23,7 @@ from config import (
 )
 from attendance import get_members_with_fees, get_junior_members_with_fees, ADULT_MERGED_MONTHS, JUNIOR_MERGED_MONTHS
 from match_payments import reconcile, fetch_sheet_data, fetch_exceptions, normalize
-from cache_utils import get_sheet_modified_time, read_cache, write_cache, _LAST_CHECKED
+from cache_utils import get_sheet_modified_time, read_cache, write_cache, _LAST_CHECKED, flush_cache
 
 def get_cached_data(cache_key, sheet_id, fetch_func, *args, serialize=None, deserialize=None, **kwargs):
     mod_time = get_sheet_modified_time(cache_key)
@@ -105,8 +105,13 @@ def inject_render_time():
 
 @app.route("/")
 def index():
-    # Redirect root to /fees for convenience while there are no other apps
-    return '<meta http-equiv="refresh" content="0; url=/fees" />'
+    # Redirect root to /adults for convenience while there are no other apps
+    return '<meta http-equiv="refresh" content="0; url=/adults" />'
+
+@app.route("/flush-cache", methods=["POST"])
+def flush_cache_endpoint():
+    deleted = flush_cache()
+    return jsonify({"status": "ok", "deleted_files": deleted})
 
 @app.route("/fees")
 def fees():
@@ -582,7 +587,7 @@ def juniors_view():
             if expected == "?" or (isinstance(expected, int) and expected > 0):
                 if expected == "?":
                     status = "empty"
-                    cell_text = "?"
+                    cell_text = f"?{count_str}"
                 elif paid >= expected:
                     status = "ok"
                     cell_text = f"{paid}/{fee_display}"
@@ -705,6 +710,8 @@ def reconcile_juniors_view():
     # Filter to juniors for the main table
     junior_names = sorted([name for name, tier, _ in adapted_members])
     
+    junior_members_dict_rc = {name: fees_dict for name, _, fees_dict in junior_members}
+
     formatted_results = []
     for name in junior_names:
         data = result["members"][name]
@@ -714,15 +721,32 @@ def reconcile_juniors_view():
             mdata = data["months"].get(m, {"expected": 0, "original_expected": 0, "paid": 0})
             expected = mdata["expected"]
             paid = int(mdata["paid"])
-            
+
+            orig_fee_data = junior_members_dict_rc.get(name, {}).get(m)
+            adult_count = 0
+            junior_count = 0
+            att_count = 0
+            if orig_fee_data and len(orig_fee_data) == 4:
+                _, att_count, adult_count, junior_count = orig_fee_data
+
+            breakdown = ""
+            if adult_count > 0 and junior_count > 0:
+                breakdown = f":{junior_count}J,{adult_count}A"
+            elif junior_count > 0:
+                breakdown = f":{junior_count}J"
+            elif adult_count > 0:
+                breakdown = f":{adult_count}A"
+
+            count_str = f" ({att_count}{breakdown})" if att_count > 0 else ""
+
             status = "empty"
             cell_text = "-"
             amount_to_pay = 0
-            
+
             if expected == "?" or (isinstance(expected, int) and expected > 0):
                 if expected == "?":
                     status = "empty"
-                    cell_text = "?"
+                    cell_text = f"?{count_str}"
                 elif paid >= expected:
                     status = "ok"
                     cell_text = "OK"

scripts/cache_utils.py

@@ -155,3 +155,19 @@ def write_cache(sheet_id: str, modified_time: str, data: list | dict) -> None:
         logger.info(f"Wrote cache for {sheet_id}")
     except Exception as e:
         logger.error(f"Failed to write cache {sheet_id}: {e}")
+
+def flush_cache():
+    """Delete all cache files and reset in-memory state. Returns count of deleted files."""
+    global _DRIVE_SERVICE
+    _LAST_CHECKED.clear()
+    _DRIVE_SERVICE = None
+
+    deleted = 0
+    if CACHE_DIR.exists():
+        for f in CACHE_DIR.glob("*_cache.json"):
+            f.unlink()
+            deleted += 1
+            logger.info(f"Deleted cache file: {f.name}")
+
+    logger.info(f"Cache flushed: {deleted} files deleted, timers reset")
+    return deleted

tests/test_app.py

@@ -17,7 +17,7 @@ class TestWebApp(unittest.TestCase):
         """Test that / returns the refresh meta tag"""
         response = self.client.get('/')
         self.assertEqual(response.status_code, 200)
-        self.assertIn(b'url=/fees', response.data)
+        self.assertIn(b'url=/adults', response.data)
 
     @patch('app.get_cached_data', side_effect=_bypass_cache)
     @patch('app.get_members_with_fees')