feat: reply to updates and continue Today (#451)

tests/test_comment_next.py

@@ -88,6 +88,61 @@ const controller = createCommentNext({{
     }
 
 
+def test_update_reply_and_next_preserves_notification_identity_online_and_offline():
+    script = f"""
+const createCommentNext = require({json.dumps(str(COMMENT_NEXT))});
+const calls = [];
+const retryable = Object.assign(new Error('offline'), {{status:503}});
+let offline = false;
+const controller = createCommentNext({{
+  queueKind: 'update-reply',
+  post: (item, body, operationId) => {{
+    calls.push({{post:[item.notification_id, body, operationId]}});
+    return offline ? Promise.reject(retryable) : Promise.resolve({{id:17}});
+  }},
+  canQueue: () => true,
+  queue: message => {{ calls.push({{queue:message}}); return Promise.resolve({{durable:true}}); }},
+  complete: item => {{ calls.push({{complete:item.notification_id}}); return true; }},
+}});
+(async () => {{
+  const item = {{kind:'issue', notification_id:91, repository:'stackchain/dashboard', number:8}};
+  const posted = await controller.submit(item, 'Online reply', 'reply-91-a');
+  offline = true;
+  const saved = await controller.submit(item, 'Offline reply', 'reply-91-b');
+  process.stdout.write(JSON.stringify({{posted, saved, calls}}));
+}})().catch(error => {{ console.error(error); process.exit(1); }});
+"""
+
+    assert json.loads(run_node(script)) == {
+        "posted": {
+            "accepted": True,
+            "delivery": "posted",
+            "comment": {"id": 17},
+            "completed": True,
+        },
+        "saved": {
+            "accepted": True,
+            "delivery": "saved",
+            "background": False,
+            "completed": True,
+        },
+        "calls": [
+            {"post": [91, "Online reply", "reply-91-a"]},
+            {"complete": 91},
+            {"post": [91, "Offline reply", "reply-91-b"]},
+            {
+                "queue": {
+                    "kind": "update-reply",
+                    "notificationId": 91,
+                    "body": "Offline reply",
+                    "operationId": "reply-91-b",
+                }
+            },
+            {"complete": 91},
+        ],
+    }
+
+
 def test_comment_and_next_reads_retry_identity_after_the_failed_post():
     script = f"""
 const createCommentNext = require({json.dumps(str(COMMENT_NEXT))});
@@ -210,3 +265,20 @@ async def test_mobile_composers_offer_comment_and_next_only_for_today_checkpoint
     assert "setCommentNextVisibility('pull')" in html
     assert '.comment-actions { display:grid; grid-template-columns:repeat(2,minmax(0,1fr));' in html
     assert '.comment-actions button { min-height:44px;' in html
+
+
+@pytest.mark.anyio
+async def test_current_today_update_offers_reply_and_next_without_marking_read():
+    html = await dashboard()
+
+    assert 'id="send-update-reply-next"' in html
+    assert '>Reply &amp; next</button>' in html
+    assert "setUpdateReplyNextVisibility();" in html
+    assert "const updateReplyNext = createCommentNext({" in html
+    assert "notificationReplier.saveDraft(item, '');" in html
+    assert "successMessage: 'Reply saved. Next Today item opened.'" in html
+    assert "qs('#mark-update-read-next').click()" not in html
+    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-v78" in worker

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-v77" in source
+    assert "stackchain-dashboard-shell-v78" 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-v77" in worker
+    assert "stackchain-dashboard-shell-v78" in worker

tests/test_mobile_composer_integration.py

@@ -35,7 +35,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-v77" in worker
+    assert "stackchain-dashboard-shell-v78" in worker
 
 
 def test_all_conversation_composers_offer_accessible_mobile_mentions():

tests/test_plan_today.py

@@ -232,6 +232,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-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/plan-today.js'" in source
     assert "BASE + 'static/plan-today-preview.js'" in source

tests/test_service_worker.py

@@ -122,7 +122,7 @@ async function dispatchNotificationClick(route) {{
 def test_resumable_today_session_ships_in_a_new_offline_shell():
     source = WORKER.read_text()
 
-    assert "stackchain-dashboard-shell-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/my-work.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/dashboard.css'" in source
@@ -131,14 +131,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-v77" in source
+    assert "stackchain-dashboard-shell-v78" 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-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/today-completion.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
 
@@ -146,7 +146,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-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/create-issue-sheet.js'" in source
     assert "BASE + 'static/dashboard.js'" in source
 
@@ -154,14 +154,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-v77" in source
+    assert "stackchain-dashboard-shell-v78" 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-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/dashboard.css'" in source
     assert "BASE + 'static/dashboard.js'" in source
     assert "BASE + 'static/install-app.js'" in source
@@ -170,21 +170,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-v77" in source
+    assert "stackchain-dashboard-shell-v78" 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-v77" in source
+    assert "stackchain-dashboard-shell-v78" 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-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/update-ownership.js'" in source
 
 
@@ -365,7 +365,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-v77" in source
+    assert "stackchain-dashboard-shell-v78" 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-v77';" in service_worker
+    assert "const CACHE = 'stackchain-dashboard-shell-v78';" in service_worker
     assert "BASE + 'static/today-readiness.js'" in service_worker
 
 

tests/test_today_sync.py

@@ -86,7 +86,7 @@ sync.enqueue('add', 'issue:r:1:');
 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-v77" in source
+    assert "stackchain-dashboard-shell-v78" in source
     assert "BASE + 'static/today-sync.js'" in source