feat: replan Today from live budget risk (Closes #597)

tests/test_comment_next.py

@@ -303,4 +303,4 @@ async def test_unread_update_offers_reply_mark_read_and_next_independent_of_toda
     assert '.update-reply-actions { display:grid; grid-template-columns:repeat(2,minmax(0,1fr));' in html
     assert '.update-reply-actions button { min-height:44px;' in html
     worker = (Path(__file__).parents[1] / "frontend" / "service-worker.js").read_text()
-    assert "stackchain-dashboard-shell-v91" in worker
+    assert "stackchain-dashboard-shell-v92" in worker

tests/test_frontend_bundle.py

@@ -162,7 +162,7 @@ def test_legacy_cache_marker_is_normalized_out_of_build_identity(tmp_path):
     worker = changed_frontend / "service-worker.js"
     worker.write_text(
         worker.read_text().replace(
-            "const CACHE = 'stackchain-dashboard-shell-v91';",
+            "const CACHE = 'stackchain-dashboard-shell-v92';",
             "const CACHE = 'stackchain-dashboard-shell-v999';",
         )
     )

tests/test_later_sync.py

@@ -347,5 +347,5 @@ async def test_dashboard_syncs_every_later_change_and_exposes_account_status():
 def test_later_sync_ships_atomically_in_the_offline_shell():
     source = (Path(__file__).parents[1] / "frontend" / "service-worker.js").read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/later-sync.js'" in source

tests/test_markdown_renderer.py

@@ -137,4 +137,4 @@ def test_markdown_work_bodies_are_mobile_safe_block_containers():
     assert ".markdown-content { min-width:0; max-width:100%; overflow-wrap:anywhere;" in css
     assert ".markdown-content pre { max-width:100%; overflow-x:auto;" in css
     assert ".markdown-content a { min-height:44px;" in css
-    assert "stackchain-dashboard-shell-v91" in worker
+    assert "stackchain-dashboard-shell-v92" in worker

tests/test_mobile_composer_integration.py

@@ -41,7 +41,7 @@ def test_offline_shell_contains_every_local_dashboard_runtime_asset():
     shell_assets = set(re.findall(r"BASE \+ '([^']+)'", worker.split("async function sessionCsrf", 1)[0]))
 
     assert local_assets <= shell_assets, f"Offline shell is missing: {sorted(local_assets - shell_assets)}"
-    assert "stackchain-dashboard-shell-v91" in worker
+    assert "stackchain-dashboard-shell-v92" in worker
 
 
 def test_all_conversation_composers_offer_accessible_mobile_mentions():

tests/test_mobile_device_setup.py

@@ -186,7 +186,7 @@ def test_mobile_dashboard_mounts_phone_safe_device_setup_flow():
     assert "promptStorage:localStorage" in dashboard
     assert "pushControllerReady.then(ensureDeviceSetup)" in dashboard
     assert "BASE + 'static/mobile-device-setup.js'" in worker
-    assert "stackchain-dashboard-shell-v91" in worker
+    assert "stackchain-dashboard-shell-v92" in worker
     assert ".device-setup-panel" in css
     assert ".device-readiness-card" in css
     assert "overflow-x:hidden" in css

tests/test_my_work.py

@@ -2214,6 +2214,83 @@ process.stdout.write(JSON.stringify({{first,second,stopped,other}}));
     }
 
 
+def test_today_timer_totals_elapsed_work_for_live_capacity_without_cross_account_leakage():
+    script = f"""
+const createTodayTimer = require({json.dumps(str(TODAY_TIMER))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v)}};
+let login = 'timmy';
+let now = 0;
+const timer = createTodayTimer({{storage,getLogin:()=>login,now:()=>now}});
+timer.activate('issue:r:1:');
+now = 10 * 60000;
+timer.activate('issue:r:2:');
+now = 25 * 60000;
+const timmy = timer.totalElapsed();
+login = 'alexander';
+const isolated = timer.totalElapsed();
+process.stdout.write(JSON.stringify({{timmy,isolated}}));
+"""
+    result = subprocess.run(["node", "-e", script], capture_output=True, text=True)
+    assert result.returncode == 0, result.stderr
+    assert json.loads(result.stdout) == {"timmy": 25 * 60000, "isolated": 0}
+
+
+def test_today_timer_view_renders_live_budget_risk_and_replan_action():
+    script = f"""
+const createTodayTimer = require({json.dumps(str(TODAY_TIMER))});
+const progress = {{textContent:''}};
+const adjust = {{hidden:true}};
+const toggle = {{hidden:false,textContent:'',setAttribute(){{}}}};
+const snapshot = {{identity:'issue:r:1:',elapsed_ms:45*60000,running:true}};
+const view = createTodayTimer.createView({{
+  timer:{{snapshot:()=>snapshot,totalElapsed:()=>45*60000}}, isActive:()=>true,
+  queryAll:selector => selector.includes('progress') ? [progress] : selector.includes('adjust-plan') ? [adjust] : [toggle],
+  formatEstimate:minutes => minutes + 'm',
+  getRunway:() => ({{current_minutes:30,remaining_minutes:90,future_minutes:60,capacity_minutes:100}}),
+}});
+view.update({{index:1,total:2}});
+process.stdout.write(JSON.stringify({{text:progress.textContent,adjustHidden:adjust.hidden}}));
+"""
+    result = subprocess.run(["node", "-e", script], capture_output=True, text=True)
+    assert result.returncode == 0, result.stderr
+    assert json.loads(result.stdout) == {
+        "text": "Item 1 of 2 · 45:00 / 30m · 15m over estimate · Today projected 5m over capacity",
+        "adjustHidden": False,
+    }
+
+
+def test_today_budget_replan_pauses_once_and_restores_the_prior_timer_state():
+    script = f"""
+const createTodayTimer = require({json.dumps(str(TODAY_TIMER))});
+const calls = [];
+let running = true;
+const timer = {{
+  snapshot:()=>({{identity:'issue:r:1:',elapsed_ms:45*60000,running}}),
+  pause:()=>{{calls.push('pause');running=false;return true;}},
+  resume:()=>{{calls.push('resume');running=true;return true;}},
+}};
+const handoff = createTodayTimer.createBudgetReplan({{timer,openPlan:state=>calls.push('open:' + state.identity + ':' + Math.ceil(state.elapsed_ms/60000))}});
+const opened = handoff.open();
+const duplicate = handoff.open();
+const restored = handoff.restore();
+running = false;
+const pausedOpen = handoff.open();
+const pausedRestore = handoff.restore();
+process.stdout.write(JSON.stringify({{opened,duplicate,restored,pausedOpen,pausedRestore,calls}}));
+"""
+    result = subprocess.run(["node", "-e", script], capture_output=True, text=True)
+    assert result.returncode == 0, result.stderr
+    assert json.loads(result.stdout) == {
+        "opened": True,
+        "duplicate": False,
+        "restored": True,
+        "pausedOpen": True,
+        "pausedRestore": True,
+        "calls": ["pause", "open:issue:r:1::45", "resume", "open:issue:r:1::45"],
+    }
+
+
 def test_today_timer_can_be_initialized_before_operator_identity_is_restored():
     script = f"""
 const createTodayTimer = require({json.dumps(str(TODAY_TIMER))});
@@ -2240,6 +2317,23 @@ process.stdout.write(JSON.stringify({{activated,snapshot:timer.snapshot()}}));
     }
 
 
+@pytest.mark.anyio
+async def test_today_live_budget_replan_is_wired_into_every_mobile_session_control():
+    html = await dashboard()
+    dashboard_source = TODAY_TIMER.with_name("dashboard.js").read_text()
+
+    assert html.count('<nav class="work-session-nav" aria-label="Work session" hidden>') == 4
+    timer_source = TODAY_TIMER.read_text()
+    assert "document.createElement('button')" in timer_source
+    assert "button.textContent = 'Adjust remaining plan'" in timer_source
+    assert "todayWork.runway(todayMyWork, state.index - 1)" in dashboard_source
+    assert 'timer.totalElapsed()' in timer_source
+    assert 'createTodayBudgetReplan({' in timer_source
+    assert "button.addEventListener('click', () => replan.open())" in timer_source
+    assert 'if (sheet.hidden && replan.restore()) render();' in timer_source
+    assert '.work-session-nav button { min-height:44px;' in html
+
+
 @pytest.mark.anyio
 async def test_today_timer_is_wired_into_every_mobile_session_control():
     html = await dashboard()
@@ -2255,7 +2349,7 @@ async def test_today_timer_is_wired_into_every_mobile_session_control():
     assert 'timer.pause()' in timer_source
     assert 'timer.resume()' in timer_source
     assert "elapsed(snapshot.elapsed_ms)" in timer_source
-    assert "' / ' + formatEstimate(runway.current_minutes)" in timer_source
+    assert "' / ' + formatEstimate(liveRunway.current_minutes)" in timer_source
     assert '.work-session-nav [data-work-session-timer-toggle] { min-height:44px;' in html
 
 

tests/test_plan_today.py

@@ -288,7 +288,8 @@ async def test_mobile_dashboard_wires_focused_plan_today_sheet():
     assert "planToday.applyRecommendation" in html
     assert "Use " in html and " as new estimate" in html
     assert "todaySync.enqueueConfiguration" in html
-    assert "todayWork.runway(todayMyWork, state.index - 1)" in html
+    assert "todayWork.runway(todayMyWork, state.index - 1)" in (Path(__file__).parents[1] / "frontend" / "dashboard.js").read_text()
+    assert "timer.totalElapsed()" in (Path(__file__).parents[1] / "frontend" / "today-timer.js").read_text()
     assert "resetPlanTodayConfirmation()" in html
     assert "result === 'confirm-over-capacity'" in html
     assert 'id="save-and-start-today"' in html
@@ -332,6 +333,6 @@ async def test_plan_today_wires_cancel_back_and_success_through_overlay_history(
 def test_plan_today_controller_is_available_in_the_offline_shell():
     source = SERVICE_WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/plan-today.js'" in source
     assert "BASE + 'static/plan-today-preview.js'" in source

tests/test_service_worker.py

@@ -135,7 +135,7 @@ async function dispatchPush(payload) {{
 def test_resumable_today_session_ships_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/my-work.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/dashboard.css'" in source
@@ -144,14 +144,14 @@ def test_resumable_today_session_ships_in_a_new_offline_shell():
 def test_ownership_exit_runtime_rolls_the_offline_shell_cache():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/dashboard.js'" in source
 
 
 def test_offline_review_next_ships_today_completion_atomically():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/today-completion.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
 
@@ -159,7 +159,7 @@ def test_offline_review_next_ships_today_completion_atomically():
 def test_duplicate_aware_capture_ships_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/create-issue-sheet.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
 
@@ -167,14 +167,14 @@ def test_duplicate_aware_capture_ships_in_a_new_offline_shell():
 def test_exact_later_picker_ships_atomically_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/later-picker.js'" in source
 
 
 def test_navigation_deadline_ships_in_a_new_shell_cache():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/dashboard.css'" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/install-app.js'" in source
@@ -183,21 +183,21 @@ def test_navigation_deadline_ships_in_a_new_shell_cache():
 def test_today_convergence_ships_in_a_new_shell_cache():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/today-sync.js'" in source
 
 
 def test_mobile_search_viewport_ships_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/mobile-search-viewport.js'" in source
 
 
 def test_update_ownership_flow_ships_atomically_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/update-ownership.js'" in source
 
 
@@ -638,7 +638,7 @@ def test_one_session_bound_csrf_proof_is_reused_for_a_background_drain():
 def test_queue_today_ships_atomically_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/queue-today.js'" in source
 
 

tests/test_today_readiness.py

@@ -221,7 +221,7 @@ async def test_today_blocker_opens_existing_preview_and_preserves_readiness_gate
 def test_readiness_runtime_is_available_in_offline_shell():
     service_worker = SERVICE_WORKER.read_text()
 
-    assert "const CACHE = 'stackchain-dashboard-shell-v91';" in service_worker
+    assert "const CACHE = 'stackchain-dashboard-shell-v92';" in service_worker
     assert "BASE + 'static/today-readiness.js'" in service_worker
 
 

tests/test_today_sync.py

@@ -127,7 +127,7 @@ sync.enqueueConfiguration(120, {{'issue:r:1:':60}});
 def test_inflight_today_drain_ships_in_a_new_offline_shell():
     source = (Path(__file__).parents[1] / "frontend" / "service-worker.js").read_text()
 
-    assert "stackchain-dashboard-shell-v91" in source
+    assert "stackchain-dashboard-shell-v92" in source
     assert "BASE + 'static/today-sync.js'" in source
 
 

tests/test_today_work.py

@@ -98,8 +98,52 @@ queue.replacePlanning({{capacity_minutes:180,estimates:{{'issue:r:1:':30,'issue:
 process.stdout.write(JSON.stringify({{first:queue.runway([item(1),item(2),item(3)],0),second:queue.runway([item(1),item(2),item(3)],1)}}));
 """
     assert json.loads(run_node(script)) == {
-        "first": {"current_minutes": 30, "remaining_minutes": 135},
-        "second": {"current_minutes": 60, "remaining_minutes": 105},
+        "first": {
+            "current_minutes": 30, "remaining_minutes": 135,
+            "future_minutes": 105, "capacity_minutes": 180,
+        },
+        "second": {
+            "current_minutes": 60, "remaining_minutes": 105,
+            "future_minutes": 45, "capacity_minutes": 180,
+        },
+    }
+
+
+def test_today_live_runway_uses_elapsed_work_and_reports_capacity_risk():
+    script = f"""
+const createTodayWork = require({json.dumps(str(TODAY_WORK))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+const queue = createTodayWork({{storage, getLogin:()=> 'timmy'}});
+const item = number => ({{kind:'issue',repository:'r',number}});
+queue.replace(['issue:r:1:','issue:r:2:']);
+queue.replacePlanning({{capacity_minutes:100,estimates:{{'issue:r:1:':30,'issue:r:2:':60}}}});
+const healthy = queue.runway([item(1),item(2)],0,{{current_elapsed_ms:10*60000,total_elapsed_ms:10*60000}});
+const over = queue.runway([item(1),item(2)],0,{{current_elapsed_ms:45*60000,total_elapsed_ms:45*60000}});
+process.stdout.write(JSON.stringify({{healthy,over}}));
+"""
+    assert json.loads(run_node(script)) == {
+        "healthy": {"current_minutes": 30, "remaining_minutes": 90, "future_minutes": 60, "capacity_minutes": 100},
+        "over": {"current_minutes": 30, "remaining_minutes": 90, "future_minutes": 60, "capacity_minutes": 100},
+    }
+
+
+def test_today_live_runway_stays_truthful_when_estimates_or_capacity_are_missing():
+    script = f"""
+const createTodayWork = require({json.dumps(str(TODAY_WORK))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+const queue = createTodayWork({{storage, getLogin:()=> 'timmy'}});
+const item = number => ({{kind:'issue',repository:'r',number}});
+queue.replace(['issue:r:1:','issue:r:2:']);
+queue.replacePlanning({{capacity_minutes:null,estimates:{{'issue:r:1:':30}}}});
+process.stdout.write(JSON.stringify(queue.runway([item(1),item(2)],0,{{current_elapsed_ms:40*60000,total_elapsed_ms:40*60000}})));
+"""
+    assert json.loads(run_node(script)) == {
+        "current_minutes": 30,
+        "remaining_minutes": None,
+        "future_minutes": None,
+        "capacity_minutes": None,
     }