feat: make My Work refresh resumable (#119)

tests/test_context_polling.py

@@ -0,0 +1,65 @@
+import json
+import subprocess
+from pathlib import Path
+
+
+POLLER = Path(__file__).parents[1] / "frontend" / "context-poller.js"
+
+
+def run_node(script: str) -> dict:
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+    return json.loads(result.stdout)
+
+
+def test_context_poller_is_single_flight_and_pauses_until_visible():
+    script = f"""
+const createContextPoller = require({json.dumps(str(POLLER))});
+let calls = 0;
+let hidden = false;
+let resolveRequest;
+const timers = [];
+const poller = createContextPoller({{
+  fetchContext: () => {{
+    calls += 1;
+    if (calls > 1) return Promise.resolve({{ repos: [] }});
+    return new Promise((resolve) => {{ resolveRequest = resolve; }});
+  }},
+  onSnapshot: () => {{}},
+  onError: () => {{}},
+  isHidden: () => hidden,
+  setTimer: (callback) => {{ timers.push(callback); return timers.length; }},
+  clearTimer: () => {{}},
+  intervalMs: 8000,
+}});
+
+(async () => {{
+  const first = poller.start();
+  const joined = poller.refresh();
+  const callsWhilePending = calls;
+  resolveRequest({{ repos: [] }});
+  await Promise.all([first, joined]);
+
+  hidden = true;
+  poller.setVisible(false);
+  const scheduled = timers.shift();
+  if (scheduled) scheduled();
+  await Promise.resolve();
+  const callsWhileHidden = calls;
+
+  hidden = false;
+  await poller.setVisible(true);
+  process.stdout.write(JSON.stringify({{
+    callsWhilePending,
+    callsWhileHidden,
+    callsAfterResume: calls,
+  }}));
+}})();
+"""
+
+    assert run_node(script) == {
+        "callsWhilePending": 1,
+        "callsWhileHidden": 1,
+        "callsAfterResume": 2,
+    }

tests/test_event_stream.py

@@ -17,7 +17,8 @@ def test_dashboard_has_realtime_gitea_event_stream_widget():
     assert "Gitea event stream" in html
     assert "id=\"gitea-events\"" in html
     assert "function paintEventStream" in html
-    assert "setInterval(loadEventStream, 5000)" in html
+    assert "setInterval(() => { if (!document.hidden) loadEventStream(); }, 5000)" in html
+    assert "if (!document.hidden) loadEventStream();" in html
     assert "event.actor?.login" in html
     assert "event.repo?.full_name" in html
 

tests/test_my_work.py

@@ -97,6 +97,24 @@ process.stdout.write(JSON.stringify({{
     assert output["summary"] == "1 review · 2 assigned"
 
 
+def test_my_work_filter_counts_distinguish_prs_from_review_requests():
+    items = [
+        {"kind": "issue", "is_review": False},
+        {"kind": "pull", "is_review": False},
+        {"kind": "pull", "is_review": True},
+    ]
+    script = f"""
+const buildMyWork = require({json.dumps(str(MY_WORK))});
+process.stdout.write(JSON.stringify(buildMyWork.countMyWork({json.dumps(items)})));
+"""
+
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+
+    assert json.loads(result.stdout) == {"all": 3, "issue": 1, "pull": 1, "review": 1}
+
+
 @pytest.mark.anyio
 async def test_mobile_dashboard_puts_filterable_my_work_before_auxiliary_panels():
     html = await dashboard()
@@ -112,3 +130,16 @@ async def test_mobile_dashboard_puts_filterable_my_work_before_auxiliary_panels(
     assert "buildMyWork(data)" in html
     assert "markMyWorkStale()" in html
     assert "filterMyWork(lastMyWork, selectedWorkFilter)" in html
+
+
+@pytest.mark.anyio
+async def test_mobile_filters_wrap_show_counts_and_persist_for_the_session():
+    html = await dashboard()
+
+    assert '.work-filters { display:flex; gap:8px; flex-wrap:wrap; }' in html
+    assert 'data-work-count="all"' in html
+    assert 'data-work-count="issue"' in html
+    assert 'data-work-count="pull"' in html
+    assert 'data-work-count="review"' in html
+    assert 'sessionStorage.getItem(WORK_FILTER_KEY)' in html
+    assert 'sessionStorage.setItem(WORK_FILTER_KEY, selectedWorkFilter)' in html

tests/test_shared_context_snapshot.py

@@ -0,0 +1,17 @@
+import pytest
+
+from src.views import dashboard
+
+
+@pytest.mark.anyio
+async def test_one_context_snapshot_updates_every_context_backed_panel():
+    html = await dashboard()
+
+    assert '<script src="static/context-poller.js"></script>' in html
+    assert "createContextPoller({" in html
+    assert "renderContextSnapshot(data)" in html
+    assert "renderRepoMix(qs('#repo-mix'), data)" in html
+    assert "setInterval(tickWidgets, 2000)" not in html
+    assert "updateRepoMix(qs('#repo-mix'), fetch)" not in html
+    assert "setInterval(load, 8000)" not in html
+    assert "document.addEventListener('visibilitychange'" in html