feat: surface Human Gates in mobile preparation (Closes #1417)

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-v139" in worker
+    assert "stackchain-dashboard-shell-v140" in worker

tests/test_following_frontend.py

@@ -593,7 +593,7 @@ process.stdout.write(JSON.stringify({{
     assert ".following-disposition-mode" in css
     assert "if (searchPreviewReturnKind === 'following')" in dashboard
     assert "e.key === 'Escape' && searchPreviewReturnKind === 'following'" in dashboard
-    assert "stackchain-dashboard-shell-v139" in service_worker
+    assert "stackchain-dashboard-shell-v140" in service_worker
 
 
 def test_prepare_today_lazily_refreshes_and_directly_reviews_following():

tests/test_human_gates_frontend.py

@@ -6,6 +6,7 @@ from pathlib import Path
 MODULE = Path(__file__).parents[1] / "frontend" / "human-gates.js"
 INDEX = Path(__file__).parents[1] / "frontend" / "index.html"
 DASHBOARD = Path(__file__).parents[1] / "frontend" / "dashboard.js"
+WORKER = Path(__file__).parents[1] / "frontend" / "service-worker.js"
 
 
 def run_node(body):
@@ -29,6 +30,42 @@ const gates=createHumanGates({storage,getLogin:()=> 'timmy',isOnline:()=>true,no
     assert "Inbox zero" in output["zero"]["html"]
 
 
+def test_queue_changes_publish_mobile_counts_and_authoritative_decision_completion():
+    output = run_node(r"""
+const changes=[];
+const item={id:'g1',title:'Candidate',candidate_hash:'abc123',revision:1,checks:[]};
+const gates=createHumanGates({
+  storage:{getItem:()=>null,setItem(){}}, getLogin:()=> 'timmy', isOnline:()=>true,
+  nodes:{count:{},list:{},status:{},panel:{},detail:{}}, location:{hash:''},
+  onChange:(snapshot, state)=>changes.push({count:snapshot.pending_count,...state}),
+  fetchJson:async(path, options={})=>options.method==='POST' ? {receipt_id:'r1'} : {pending_count:1,items:[item]},
+});
+(async()=>{await gates.load();gates.reviewNext();await gates.decideAndNext('release',{checklist:{exact_hash:true,artifacts_reviewed:true,provenance_reviewed:true}});process.stdout.write(JSON.stringify(changes));})();
+""")
+    assert output == [
+        {"count": 1, "available": True, "authoritative": True},
+        {"count": 0, "available": True, "authoritative": True, "decision": True},
+    ]
+
+
+def test_queue_load_failure_distinguishes_cached_read_only_data_from_unavailable():
+    output = run_node(r"""
+const cached={pending_count:1,items:[{id:'g1',title:'Cached',candidate_hash:'abc'}]};
+const changes=[];
+const make=(value,label)=>createHumanGates({
+  storage:{getItem:()=>value ? JSON.stringify(value) : null,setItem(){}},
+  getLogin:()=> 'timmy', isOnline:()=>false, nodes:{count:{},list:{},status:{},panel:{}}, location:{hash:''},
+  onChange:(snapshot,state)=>changes.push({label,count:snapshot.pending_count,...state}),
+  fetchJson:async()=>{throw new Error('network')},
+});
+(async()=>{await make(cached,'cached').load();try{await make(null,'empty').load()}catch(_){}process.stdout.write(JSON.stringify(changes));})();
+""")
+    assert output == [
+        {"label": "cached", "count": 1, "available": True, "authoritative": False, "cached": True},
+        {"label": "empty", "count": 0, "available": False, "authoritative": False},
+    ]
+
+
 def test_review_next_is_a_fixed_snapshot_and_decision_and_next_advances_without_new_arrivals():
     output = run_node(r"""
 const calls=[]; const nodes={count:{textContent:''},list:{innerHTML:''},status:{textContent:''},panel:{hidden:true},detail:{innerHTML:''}};
@@ -155,3 +192,13 @@ def test_human_gate_mobile_shell_and_deep_route_are_wired():
     assert "#/my-work/human-gates" in dashboard
     assert "createHumanGates" in dashboard
     assert "planningOwnerAccountKey = confirmedOwnerLogin && saved.user?.id" in dashboard
+    assert 'data-mobile-queue="gate"' in index
+    assert 'data-mobile-queue-count="gate"' in index
+    assert "openHumanGates: () => openHumanGates()" in dashboard
+    assert "onChange:(snapshot, state)=>" in dashboard
+    assert "queueCounts.gate = snapshot.pending_count" in dashboard
+    assert "preparationItems.gate = snapshot.items" in dashboard
+    assert "mobileStartDay.reconcile({authoritative:true, authoritativePhases:['gate']})" in dashboard
+    assert "counts.gate = queueCounts.gate" in dashboard
+    assert "gate:preparationItems.gate || []" in dashboard
+    assert "stackchain-dashboard-shell-v140" in WORKER.read_text()

tests/test_later_sync.py

@@ -435,5 +435,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-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/later-sync.js'" in source

tests/test_markdown_renderer.py

@@ -256,4 +256,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-v139" in worker
+    assert "stackchain-dashboard-shell-v140" in worker

tests/test_mobile_composer_integration.py

@@ -45,7 +45,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-v139" in worker
+    assert "stackchain-dashboard-shell-v140" in worker
 
 
 def test_all_conversation_composers_offer_accessible_mobile_mentions():

tests/test_mobile_device_setup.py

@@ -383,7 +383,7 @@ def test_mobile_dashboard_mounts_phone_safe_device_setup_flow():
     assert "controller.recoverPermission('deadline')" in dashboard
     assert "pushControllerReady.then(ensureDeviceSetup)" in dashboard
     assert "BASE + 'static/mobile-device-setup.js'" in worker
-    assert "stackchain-dashboard-shell-v139" in worker
+    assert "stackchain-dashboard-shell-v140" in worker
     assert ".device-setup-panel" in css
     assert ".device-readiness-card" in css
     assert "overflow-x:hidden" in css

tests/test_mobile_insights.py

@@ -274,5 +274,5 @@ async def test_mobile_home_progressively_discloses_secondary_panels_as_insights(
 def test_mobile_insights_rolls_into_the_offline_shell():
     worker = (CONTROLLER.parent / "service-worker.js").read_text()
 
-    assert "stackchain-dashboard-shell-v139" in worker
+    assert "stackchain-dashboard-shell-v140" in worker
     assert "BASE + 'static/mobile-insights.js'" in worker

tests/test_mobile_start_day.py

@@ -110,6 +110,61 @@ process.stdout.write(JSON.stringify({{blocked, handed, opened, handoffs}}));
     assert output["handoffs"] == ["agenda"]
 
 
+def test_prepare_today_reviews_human_gates_after_delivery_before_agenda():
+    script = f"""
+const createStartDay = require({json.dumps(str(START_DAY))});
+const opened = [];
+const controller = createStartDay({{
+  getCounts: () => ({{delivery:1, gate:2, agenda:1, today:4}}),
+  openQueue: name => opened.push(name),
+}});
+const briefing = controller.briefing();
+controller.startNext();
+process.stdout.write(JSON.stringify({{briefing, opened}}));
+"""
+
+    output = run_node(script)
+    assert output == {
+        "briefing": {
+            "total": 4,
+            "next": "delivery",
+            "label": "Review Delivery",
+            "summary": "1 delivery needs action before Today · 3 other items · 4 planned",
+            "phases": [
+                {"name": "delivery", "label": "Delivery recovery", "count": 1},
+                {"name": "gate", "label": "Human Gates", "count": 2},
+                {"name": "agenda", "label": "Agenda", "count": 1},
+            ],
+        },
+        "opened": ["delivery"],
+    }
+
+
+def test_prepare_today_keeps_unavailable_human_gates_retryable_before_today():
+    script = f"""
+const createStartDay = require({json.dumps(str(START_DAY))});
+const opened = [];
+const controller = createStartDay({{
+  getCounts: () => ({{gateUnavailable:true, today:2}}),
+  openQueue: name => opened.push(name),
+}});
+const briefing = controller.briefing();
+controller.startNext();
+process.stdout.write(JSON.stringify({{briefing, opened}}));
+"""
+
+    assert run_node(script) == {
+        "briefing": {
+            "total": 0,
+            "next": "gate",
+            "label": "Retry Human Gates",
+            "summary": "Human Gates need retry before Today · 2 planned",
+            "phases": [{"name": "gate", "label": "Human Gates unavailable · retry", "count": 0}],
+        },
+        "opened": ["gate"],
+    }
+
+
 def test_prepare_today_counts_each_work_identity_in_only_its_highest_priority_phase():
     script = f"""
 const createStartDay = require({json.dumps(str(START_DAY))});
@@ -414,7 +469,7 @@ async def test_dashboard_wires_thumb_safe_start_day_briefing_into_offline_mobile
     assert ".mobile-start-day-finish { min-height:44px;" in html
     assert "max-width:100%; overflow-wrap:anywhere;" in html
     assert "BASE + 'static/mobile-start-day.js'" in service_worker
-    assert "stackchain-dashboard-shell-v139" in service_worker
+    assert "stackchain-dashboard-shell-v140" in service_worker
 
 
 @pytest.mark.anyio

tests/test_mobile_task_dock.py

@@ -469,7 +469,7 @@ sheet.close = function () {{ this.open = false; this.listeners.close?.(); }};
 const close = new FakeElement();
 const badge = new FakeElement();
 const deadline = new FakeElement();
-const rows = Object.fromEntries(['today','agenda','delivery','attention','update','filed','later','draft','recaps'].map(name => [name, new FakeElement()]));
+const rows = Object.fromEntries(['today','agenda','delivery','gate','attention','update','filed','later','draft','recaps'].map(name => [name, new FakeElement()]));
 const counts = Object.fromEntries(Object.keys(rows).map(name => [name, new FakeElement()]));
 const selected = [];
 const utilities = [];
@@ -480,7 +480,7 @@ const dock = createDock({{
   observe() {{}},
 }});
 dock.start();
-dock.updateQueues({{today:2, agenda:5, delivery:1, attention:1, update:5, filed:2, later:3, draft:4}});
+dock.updateQueues({{today:2, agenda:5, delivery:1, gate:2, attention:1, update:5, filed:2, later:3, draft:4}});
 queues.click();
 const opened = sheet.open;
 rows.update.click();
@@ -525,9 +525,9 @@ process.stdout.write(JSON.stringify({{
         "utilities": ["recaps:trigger"],
         "badge": "0 active",
         "populated": {
-            "badge": "7 active",
+            "badge": "8 active",
             "badgeHidden": False,
-            "badgeLabel": "Queues: Today 2, Agenda 5 due, Delivery 1, Attention 1, Updates 5, Filed 2, Later 3, Drafts 4; 7 active queues",
+            "badgeLabel": "Queues: Today 2, Agenda 5 due, Delivery 1, Human Gates 2, Attention 1, Updates 5, Filed 2, Later 3, Drafts 4; 8 active queues",
             "deadline": "5 due",
             "deadlineHidden": False,
             "agendaDue": "true",
@@ -536,13 +536,13 @@ process.stdout.write(JSON.stringify({{
             "badge": "1 active",
             "badgeHidden": False,
             "deadlineHidden": True,
-            "badgeLabel": "Queues: Today 0, Agenda 0 due, Delivery 0, Attention 0, Updates 7, Filed 0, Later 0, Drafts 0; 1 active queue",
+            "badgeLabel": "Queues: Today 0, Agenda 0 due, Delivery 0, Human Gates 0, Attention 0, Updates 7, Filed 0, Later 0, Drafts 0; 1 active queue",
         },
         "clearedBadgeHidden": True,
         "clearedDeadlineHidden": True,
         "clearedAgendaDue": None,
         "clearedBadgeLabel": "Queues: no active queues; no upcoming deadlines",
-        "counts": {"today": "0", "agenda": "0", "delivery": "0", "attention": "0", "update": "0", "filed": "0", "later": "0", "draft": "0", "recaps": "0"},
+        "counts": {"today": "0", "agenda": "0", "delivery": "0", "gate": "0", "attention": "0", "update": "0", "filed": "0", "later": "0", "draft": "0", "recaps": "0"},
         "updateLabel": "Updates, 0 unread conversations",
         "queueFocuses": 3,
         "columnState": None,
@@ -599,6 +599,27 @@ process.stdout.write(JSON.stringify({{result, calls}}));
     }
 
 
+def test_mobile_queue_launcher_uses_existing_human_gate_review_flow():
+    script = f"""
+const createLauncher = require({json.dumps(str(QUEUE_LAUNCHER))});
+const calls = [];
+const launcher = createLauncher({{
+  openHumanGates: () => {{ calls.push('human-gates'); return 'opened-gates'; }},
+  selectFilter: name => calls.push('generic-filter:' + name),
+  firstAction: () => {{ throw new Error('generic card launch must not run'); }},
+  announce: message => calls.push('announce:' + message),
+}});
+process.stdout.write(JSON.stringify({{result:launcher.open('gate'), calls}}));
+"""
+    result = subprocess.run(["node", "-e", script], capture_output=True, text=True)
+
+    assert result.returncode == 0, result.stderr
+    assert json.loads(result.stdout) == {
+        "result": "opened-gates",
+        "calls": ["human-gates"],
+    }
+
+
 def test_mobile_queue_launcher_uses_dedicated_delivery_recovery_flow():
     script = f"""
 const createLauncher = require({json.dumps(str(QUEUE_LAUNCHER))});
@@ -621,7 +642,7 @@ def test_mobile_work_prioritizes_and_revalidates_actionable_delivery_recovery():
     script = f"""
 const createLauncher = require({json.dumps(str(QUEUE_LAUNCHER))});
 const calls = [];
-let counts = {{delivery:2, attention:3, today:1, update:4}};
+let counts = {{delivery:2, gate:1, attention:3, today:1, update:4}};
 const launcher = createLauncher({{
   getCounts: () => counts,
   openDelivery: () => {{ calls.push('delivery-recovery'); return 'opened-delivery'; }},
@@ -633,7 +654,7 @@ const launcher = createLauncher({{
 }});
 const delivery = launcher.recommend();
 const opened = launcher.continueWork();
-counts = {{delivery:0, attention:0, today:0, update:4}};
+counts = {{delivery:0, gate:1, attention:0, today:0, update:4}};
 const afterRecovery = launcher.recommend();
 process.stdout.write(JSON.stringify({{delivery, opened, afterRecovery, calls}}));
 """
@@ -643,7 +664,7 @@ process.stdout.write(JSON.stringify({{delivery, opened, afterRecovery, calls}}))
     assert json.loads(result.stdout) == {
         "delivery": {"name": "delivery", "count": 2, "label": "Recover Delivery (2)"},
         "opened": "opened-delivery",
-        "afterRecovery": {"name": "update", "count": 4, "label": "Resume Updates (4)"},
+        "afterRecovery": {"name": "gate", "count": 1, "label": "Review Human Gates (1)"},
         "calls": ["delivery-recovery"],
     }
 

tests/test_plan_today.py

@@ -418,7 +418,7 @@ async def test_starting_saved_today_work_closes_a_concurrent_rollover_planner():
 def test_plan_today_controller_is_available_in_the_offline_shell():
     source = SERVICE_WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/plan-today.js'" in source
     assert "BASE + 'static/plan-today-readiness.js'" in source
     assert "BASE + 'static/plan-today-preview.js'" in source

tests/test_service_worker.py

@@ -189,7 +189,7 @@ async function dispatchPush(payload) {{
 def test_week_unplan_undo_rolls_the_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/week-plan.js'" in source
     assert "BASE + 'static/dashboard.css'" in source
 
@@ -197,20 +197,20 @@ def test_week_unplan_undo_rolls_the_offline_shell():
 def test_private_today_action_mailbox_rolls_the_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
 
 
 def test_per_day_week_conflict_ui_rolls_the_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/week-plan.js'" in source
 
 
 def test_resumable_today_session_ships_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/my-work.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/dashboard.css'" in source
@@ -219,7 +219,7 @@ def test_resumable_today_session_ships_in_a_new_offline_shell():
 def test_mobile_conversation_photo_bundles_roll_the_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/authored-outbox.js'" in source
     assert "BASE + 'static/background-issue-sync.js'" in source
@@ -228,7 +228,7 @@ def test_mobile_conversation_photo_bundles_roll_the_offline_shell():
 def test_photo_metadata_sanitizer_rolls_the_cached_optimizer_atomically():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/issue-evidence-review.js'" in source
     assert "BASE + 'static/issue-attachment.js'" in source
 
@@ -236,14 +236,14 @@ def test_photo_metadata_sanitizer_rolls_the_cached_optimizer_atomically():
 def test_ownership_exit_runtime_rolls_the_offline_shell_cache():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" 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-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/today-completion.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
 
@@ -251,7 +251,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-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/create-issue-sheet.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
 
@@ -259,7 +259,7 @@ def test_duplicate_aware_capture_ships_in_a_new_offline_shell():
 def test_inline_checklist_step_flow_rolls_the_offline_shell_atomically():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/issue-sheet.js'" in source
     assert "BASE + 'static/checklist-conflict.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
@@ -269,14 +269,14 @@ def test_inline_checklist_step_flow_rolls_the_offline_shell_atomically():
 def test_exact_later_picker_ships_atomically_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v139" in source
+    assert "stackchain-dashboard-shell-v140" 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-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/dashboard.css'" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/install-app.js'" in source
@@ -285,21 +285,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-v139" in source
+    assert "stackchain-dashboard-shell-v140" 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-v139" in source
+    assert "stackchain-dashboard-shell-v140" 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-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/update-ownership.js'" in source
 
 
@@ -1354,7 +1354,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-v139" in source
+    assert "stackchain-dashboard-shell-v140" 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-v139';" in service_worker
+    assert "const CACHE = 'stackchain-dashboard-shell-v140';" in service_worker
     assert "BASE + 'static/today-readiness.js'" in service_worker
 
 

tests/test_today_sync.py

@@ -343,7 +343,7 @@ listeners['stackchain:first-task-complete']();
 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-v139" in source
+    assert "stackchain-dashboard-shell-v140" in source
     assert "BASE + 'static/today-sync.js'" in source