feat: add mobile task dock (#236)

Read complete unread-update conversations from mobile My Work (#220)

README.md

@@ -16,12 +16,15 @@ python3 -m pip install -r requirements.txt
 Point the dashboard at the Gitea server root (without `/api/v1`) and provide a
 token that can read dashboard data, update the authenticated user's notification
 threads, create and self-assign issues, discover, claim, and release issue assignments,
-set or clear due dates on assigned issues, create issue comments, close assigned issues,
+list repository labels and open milestones, set or clear due dates on assigned issues, create issue comments, close assigned issues,
 inspect/comment on assigned pull
 requests, merge assigned pull requests, and submit pull-request reviews.
 Pull-request replies and mobile My Work issue and PR comments use Gitea's
 issue-comment API; mobile issue capture requires issue
-creation and assignment permission. Issue capture and authored mobile actions (issue
+creation and assignment permission. The New issue sheet can optionally select an open
+repository milestone and due date; the dashboard validates both and sends them with
+self-assignment in the single create request, so planned work appears in its release
+lane immediately. Issue capture and authored mobile actions (issue
 comments, pull-request comments, notification replies, and reviews) persist per-draft
 idempotency keys, so retrying after a timeout, reload, process restart, or handoff to
 another worker replays a confirmed result instead of posting duplicate content. Results
@@ -65,6 +68,40 @@ API process is running and does not contact Gitea. GET `/readyz` is the
 readiness check: it validates the configured Gitea credentials and returns
 HTTP 503 with an error when Gitea is unavailable or authentication fails.
 
+## Offline mobile shell
+
+At phone widths, a persistent bottom task dock keeps **Work**, **Find**, **New**,
+**Search**, and **Drafts** thumb-reachable. It reuses the existing sheets and My Work
+filter, preserves the selected release lane, shows the current draft count, respects
+the device safe area, and moves out of the way while a full-screen task is open.
+Desktop layout is unchanged.
+
+After one successful online load, the installed dashboard precaches a versioned,
+subpath-scoped application shell. During a network outage or a dashboard HTTP
+`500`, `502`, `503`, or `504` response, navigation falls back to that shell when
+it is available so local issue and review drafts remain reachable. Authentication
+and other client-error responses are never hidden. A visible, accessible offline
+or server-outage notice distinguishes cached mode from live Gitea data, and the
+dashboard keeps polling until it can restore its live snapshot automatically.
+
+Users can explicitly enable **Keep My Work available offline**. Each healthy live
+refresh then stores a seven-day, versioned snapshot containing only the signed-in
+user identity and queue-card metadata for issues, pull requests, unread updates,
+and pagination totals. Bodies, comments, diffs, credentials, repository catalogs,
+events, and complete API responses are excluded. A cold offline launch labels the
+saved time and renders this snapshot read-only; opening live details, pagination,
+and server mutations remain disabled until reconnection. **Clear offline work
+data** deletes the snapshot, and opting out deletes it automatically.
+
+API responses and mutations are never cached by the service worker. New issue captures,
+issue comments, pull-request comments, and unread-update replies use bounded local
+outboxes when connectivity or a retryable server failure prevents delivery. Drafts
+shows queued and needs-attention messages with explicit send/discard controls; reconnect
+flushes messages sequentially with their original idempotency keys. State-sensitive
+actions such as reviews, merges, closures, labels, milestones, and assignments are never
+queued. Service-worker upgrades are atomic and remove only older
+`stackchain-dashboard-*` caches, preserving unrelated caches on the same origin.
+
 Run the test suite with:
 
 ```bash

frontend/authored-outbox.js

@@ -0,0 +1,133 @@
+function createAuthoredOutbox({ storage, fetchJson, createOperationId, now = () => Date.now(), maxItems = 50 }) {
+  const storageKey = 'stackchain.authored-outbox.v1';
+  const makeId = createOperationId || (() =>
+    globalThis.crypto?.randomUUID?.() || String(Date.now()) + '-' + Math.random().toString(16).slice(2)
+  );
+  const pending = new Map();
+  const supportedKinds = new Set(['issue-comment', 'pull-comment', 'update-reply']);
+
+  function read() {
+    try {
+      const record = JSON.parse(storage?.getItem(storageKey) || 'null');
+      if (record?.version !== 1 || !Array.isArray(record.items)) return [];
+      return record.items.filter(item => item && supportedKinds.has(item.kind));
+    } catch (_error) { return []; }
+  }
+
+  function write(items) {
+    storage?.setItem(storageKey, JSON.stringify({ version: 1, items }));
+  }
+
+  function enqueue(message) {
+    if (!supportedKinds.has(message?.kind)) throw new Error('This action cannot be queued.');
+    const items = read();
+    const requestedOperationId = String(message.operationId || '').slice(0, 128);
+    const existing = requestedOperationId && items.find(item => item.operationId === requestedOperationId);
+    if (existing) return { ...existing };
+    if (items.length >= maxItems) throw new Error('Message outbox is full. Send or discard a queued message first.');
+    const id = String(requestedOperationId || makeId()).slice(0, 128);
+    const item = {
+      id,
+      operationId: requestedOperationId || id,
+      kind: message.kind,
+      repository: String(message.repository || ''),
+      number: Number(message.number || 0),
+      notificationId: Number(message.notificationId || 0),
+      body: String(message.body || ''),
+      status: 'queued',
+      queuedAt: Number(now()),
+    };
+    items.push(item);
+    write(items);
+    return item;
+  }
+
+  function update(id, changes) {
+    let updated = null;
+    write(read().map(item => {
+      if (item.id !== id) return item;
+      const body = String(changes?.body ?? item.body);
+      updated = {
+        ...item,
+        body,
+        operationId: body === item.body ? item.operationId : String(makeId()).slice(0, 128),
+        status: 'queued',
+      };
+      delete updated.error;
+      return updated;
+    }));
+    return updated;
+  }
+
+  function discard(id) {
+    const items = read();
+    if (!items.some(item => item.id === id)) return false;
+    write(items.filter(item => item.id !== id));
+    return true;
+  }
+
+  function endpoint(item) {
+    if (item.kind === 'update-reply') {
+      return 'api/v1/notifications/' + encodeURIComponent(item.notificationId) + '/reply';
+    }
+    const repository = item.repository.split('/').map(encodeURIComponent).join('/');
+    const resource = item.kind === 'pull-comment' ? 'pulls' : 'issues';
+    return 'api/v1/repos/' + repository + '/' + resource + '/' + encodeURIComponent(item.number) + '/comments';
+  }
+
+  async function sendItem(item) {
+    if (pending.has(item.id)) return pending.get(item.id);
+    const request = (async () => {
+      try {
+        const result = await fetchJson(endpoint(item), {
+          method: 'POST',
+          headers: {
+            Accept: 'application/json',
+            'Content-Type': 'application/json',
+            'Idempotency-Key': item.operationId,
+          },
+          body: JSON.stringify({ body: item.body }),
+        });
+        discard(item.id);
+        return { result };
+      } catch (error) {
+        const status = Number(error?.status || 0);
+        const permanent = status >= 400 && status < 500;
+        if (permanent) {
+          write(read().map(candidate => candidate.id === item.id ? {
+            ...candidate,
+            status: 'attention',
+            error: String(error.message || 'Message needs attention').slice(0, 240),
+          } : candidate));
+        }
+        return { error, transient: !permanent };
+      }
+    })();
+    pending.set(item.id, request);
+    try { return await request; }
+    finally { if (pending.get(item.id) === request) pending.delete(item.id); }
+  }
+
+  async function flush() {
+    const confirmed = [];
+    for (const item of read()) {
+      if (item.status === 'attention') continue;
+      const outcome = await sendItem(item);
+      if (outcome.result) confirmed.push(outcome.result);
+      if (outcome.transient) break;
+    }
+    return { confirmed, remaining: read() };
+  }
+
+  async function retry(id) {
+    const item = read().find(candidate => candidate.id === id);
+    if (!item) return { confirmed: [], remaining: read() };
+    const queued = item.status === 'attention' ? update(id, item) : item;
+    const outcome = await sendItem(queued);
+    return { confirmed: outcome.result ? [outcome.result] : [], remaining: read() };
+  }
+
+  return { enqueue, update, discard, flush, retry, list: () => read().map(item => ({ ...item })) };
+}
+
+if (typeof module !== 'undefined' && module.exports) module.exports = createAuthoredOutbox;

frontend/create-issue-sheet.js

@@ -8,25 +8,44 @@ function newIssueOperationId() {
   return String(Date.now()) + '-' + Math.random().toString(16).slice(2);
 }
 
+function normalizeSharedContent(value = {}) {
+  const clean = input => String(input || '').replace(/\s+/g, ' ').trim();
+  const text = String(value.text || '').trim().slice(0, 9500);
+  const textSummary = clean(text);
+  const sentence = (textSummary.match(/^.{1,80}?[.!?](?:\s|$)/)?.[0] || textSummary.slice(0, 80)).trim();
+  const title = (clean(value.title) || sentence).slice(0, 240);
+  const url = clean(value.url).slice(0, 2000);
+  const body = text && url && text.includes(url) ? text : [text, url].filter(Boolean).join('\n\n');
+  return { title, body };
+}
+
 function createIssueCapture({ fetchJson, storage, createOperationId = newIssueOperationId }) {
   const storageKey = 'stackchain.issue-capture.v1';
+  const sharedStorageKey = 'stackchain.issue-share.v1';
   let pending = null;
   const safeLabelIds = value => Array.from(new Set(
     (Array.isArray(value) ? value : []).filter(id => Number.isInteger(id) && id > 0)
   )).slice(0, 20);
   const emptyDraft = () => ({ repository: '', title: '', body: '', labelIds: [] });
+  const safeMilestoneId = value => Number.isInteger(Number(value)) && Number(value) > 0 ? Number(value) : null;
+  const safeDueDate = value => /^\d{4}-\d{2}-\d{2}$/.test(String(value || '')) ? String(value) : '';
 
   function loadStored() {
     try {
       const parsed = JSON.parse(storage.getItem(storageKey) || 'null');
       if (!parsed || typeof parsed !== 'object') return {...emptyDraft(), operationId: ''};
-      return {
+      const draft = {
         repository: String(parsed.repository || ''),
         title: String(parsed.title || ''),
         body: String(parsed.body || ''),
         labelIds: safeLabelIds(parsed.labelIds),
         operationId: String(parsed.operationId || '').slice(0, 128),
       };
+      const milestoneId = safeMilestoneId(parsed.milestoneId);
+      const dueDate = safeDueDate(parsed.dueDate);
+      if (milestoneId !== null) draft.milestoneId = milestoneId;
+      if (dueDate) draft.dueDate = dueDate;
+      return draft;
     } catch (_error) {
       return {...emptyDraft(), operationId: ''};
     }
@@ -45,7 +64,12 @@ function createIssueCapture({ fetchJson, storage, createOperationId = newIssueOp
       body: String(draft?.body || ''),
       labelIds: safeLabelIds(draft?.labelIds),
     };
-    const unchanged = ['repository', 'title', 'body'].every(key => previous[key] === safe[key]) &&
+    const milestoneId = safeMilestoneId(draft?.milestoneId);
+    const dueDate = safeDueDate(draft?.dueDate);
+    if (milestoneId !== null) safe.milestoneId = milestoneId;
+    if (dueDate) safe.dueDate = dueDate;
+    const unchanged = ['repository', 'title', 'body', 'milestoneId', 'dueDate']
+      .every(key => (previous[key] || '') === (safe[key] || '')) &&
       JSON.stringify(previous.labelIds) === JSON.stringify(safe.labelIds);
     writeStored({...safe, operationId: unchanged ? previous.operationId : ''});
     return safe;
@@ -61,6 +85,42 @@ function createIssueCapture({ fetchJson, storage, createOperationId = newIssueOp
     catch (_error) { /* Confirmed creation remains authoritative. */ }
   }
 
+  function pendingSharedContent() {
+    try {
+      const parsed = JSON.parse(storage.getItem(sharedStorageKey) || 'null');
+      if (!parsed || typeof parsed !== 'object') return null;
+      const shared = normalizeSharedContent({title: parsed.title, text: parsed.body});
+      return shared.title || shared.body ? shared : null;
+    } catch (_error) {
+      return null;
+    }
+  }
+
+  function acceptSharedContent() {
+    const shared = pendingSharedContent();
+    if (!shared) return loadDraft();
+    const accepted = saveDraft({...loadDraft(), ...shared});
+    try { storage.removeItem(sharedStorageKey); }
+    catch (_error) { /* Accepted content is already persisted as the issue draft. */ }
+    return accepted;
+  }
+
+  function discardSharedContent() {
+    try { storage.removeItem(sharedStorageKey); }
+    catch (_error) { /* The existing issue draft remains authoritative. */ }
+  }
+
+  function stageSharedContent(value) {
+    const shared = normalizeSharedContent(value);
+    if (!shared.title && !shared.body) return {status: 'empty'};
+    try { storage.setItem(sharedStorageKey, JSON.stringify(shared)); }
+    catch (_error) { /* The caller can still use the in-page share payload. */ }
+    const existing = loadDraft();
+    if (existing.title || existing.body) return {status: 'conflict'};
+    acceptSharedContent();
+    return {status: 'ready'};
+  }
+
   function loadLabels(repository) {
     const encoded = String(repository || '').split('/').map(encodeURIComponent).join('/');
     const priorities = new Set(['p0', 'priority-high', 'critical']);
@@ -73,6 +133,13 @@ function createIssueCapture({ fetchJson, storage, createOperationId = newIssueOp
     );
   }
 
+  function loadMilestones(repository) {
+    const encoded = String(repository || '').split('/').map(encodeURIComponent).join('/');
+    return fetchJson('api/v1/repos/' + encoded + '/milestones').then(milestones =>
+      Array.isArray(milestones) ? milestones : []
+    );
+  }
+
   function submit(draft) {
     if (pending) return pending;
     const saved = saveDraft(draft);
@@ -88,6 +155,8 @@ function createIssueCapture({ fetchJson, storage, createOperationId = newIssueOp
       },
       body: JSON.stringify({
         title: saved.title, body: saved.body, label_ids: saved.labelIds,
+        ...(saved.milestoneId ? {milestone_id: saved.milestoneId} : {}),
+        ...(saved.dueDate ? {due_date: saved.dueDate + 'T23:59:59Z'} : {}),
       }),
     }).then(issue => {
       clearDraft();
@@ -96,7 +165,12 @@ function createIssueCapture({ fetchJson, storage, createOperationId = newIssueOp
     return pending;
   }
 
-  return { saveDraft, loadDraft, loadLabels, submit };
+  return {
+    saveDraft, loadDraft, clearDraft, loadLabels, loadMilestones, submit,
+    stageSharedContent, pendingSharedContent, acceptSharedContent, discardSharedContent,
+  };
 }
 
+createIssueCapture.normalizeSharedContent = normalizeSharedContent;
+
 if (typeof module !== 'undefined' && module.exports) module.exports = createIssueCapture;

frontend/drafts.js

@@ -98,6 +98,52 @@ function createDraftInbox({ storage, now = () => Date.now() }) {
     return null;
   }
 
+  function parseOutbox(raw) {
+    try {
+      const record = JSON.parse(raw);
+      if (record?.version !== 1 || !Array.isArray(record.items)) return [];
+      return record.items.filter(item =>
+        item && typeof item.id === 'string' && typeof item.repository === 'string' && typeof item.title === 'string'
+      ).map(item => ({
+        id: 'stackchain.issue-outbox.v1:' + item.id,
+        outbox_id: item.id,
+        kind: 'issue-outbox',
+        status: item.status === 'attention' ? 'attention' : 'queued',
+        label: item.status === 'attention' ? 'Needs attention' : 'Queued issue',
+        repository: item.repository,
+        title: textPreview(item.title) || 'Untitled queued issue',
+        preview: textPreview([item.title, item.error || item.body].filter(Boolean).join(' — ')),
+        updated_at: Number(item.queuedAt || 0),
+      }));
+    } catch (_error) { return []; }
+  }
+
+  function parseAuthoredOutbox(raw) {
+    try {
+      const record = JSON.parse(raw);
+      if (record?.version !== 1 || !Array.isArray(record.items)) return [];
+      return record.items.filter(item => item && typeof item.id === 'string' && typeof item.body === 'string')
+        .map(item => {
+          const isUpdate = item.kind === 'update-reply';
+          const routeKind = item.kind === 'pull-comment' ? 'pull' : 'issue';
+          const target = isUpdate ? 'Update #' + item.notificationId : item.repository + '#' + item.number;
+          return {
+            id: 'stackchain.authored-outbox.v1:' + item.id,
+            outbox_id: item.id,
+            kind: 'authored-outbox',
+            status: item.status === 'attention' ? 'attention' : 'queued',
+            label: item.status === 'attention' ? 'Needs attention' : 'Queued message',
+            repository: isUpdate ? '' : item.repository,
+            title: target,
+            preview: textPreview([item.error, item.body].filter(Boolean).join(' — ')),
+            updated_at: Number(item.queuedAt || 0),
+            route: isUpdate ? { kind:'update', notification_id:item.notificationId } :
+              { kind:routeKind, repository:item.repository, number:item.number },
+          };
+        });
+    } catch (_error) { return []; }
+  }
+
   function list() {
     const index = readIndex();
     const seen = new Set();
@@ -107,6 +153,16 @@ function createDraftInbox({ storage, now = () => Date.now() }) {
       let raw;
       try { raw = storage.getItem(key); }
       catch (_error) { return; }
+      if (key === 'stackchain.issue-outbox.v1') {
+        parseOutbox(raw).forEach(item => drafts.push(item));
+        seen.add(key);
+        return;
+      }
+      if (key === 'stackchain.authored-outbox.v1') {
+        parseAuthoredOutbox(raw).forEach(item => drafts.push(item));
+        seen.add(key);
+        return;
+      }
       const parsed = parse(key, raw);
       if (!parsed) return;
       seen.add(key);

frontend/index.html

@@ -3,6 +3,8 @@
 <head>
 <meta charset="utf-8" />
 <meta name="viewport" content="width=device-width, initial-scale=1" />
+<meta name="theme-color" content="#0b1220" />
+<link rel="manifest" href="manifest.webmanifest" />
 <title>Stackchain Dashboard</title>
 <style>
 :root { color-scheme: dark; --bg:#050c15; --panel:#0b1526; --line:#1b2d45; --text:#e5e7eb; --accent:#60a5fa; }
@@ -53,6 +55,12 @@ textarea { resize: vertical; min-height: 120px; }
 .small { font-size: 12px; color: #94a3b8; }
 .status { display:inline-flex; gap:6px; align-items:center; }
 .dot { width: 8px; height: 8px; border-radius: 50%; background: #22c55e; box-shadow: 0 0 8px #22c55e; }
+.offline-status { position:relative; z-index:19; padding:10px 16px; border-bottom:1px solid #f59e0b; background:#35210b; color:#fde68a; font-size:13px; text-align:center; }
+.offline-status[hidden] { display:none; }
+.offline-work-controls { display:flex; gap:10px; align-items:center; flex-wrap:wrap; width:100%; padding-top:2px; }
+.offline-work-controls label { display:flex; gap:8px; align-items:center; min-height:44px; }
+.offline-work-controls input { width:20px; height:20px; }
+.offline-work-controls button { min-height:44px; }
 .widget { border: 1px solid #1b2d45; border-radius: 12px; padding: 10px; background: linear-gradient(180deg,#0f1d33,#0b1526); }
 .widget h3 { margin: 4px 0 8px; font-size: 13px; color: #7aa1c9; }
 .event { padding: 8px 0; border-bottom: 1px solid #1b2d45; }
@@ -67,7 +75,7 @@ textarea { resize: vertical; min-height: 120px; }
 .my-work-list { display:grid; grid-template-columns:repeat(auto-fit,minmax(260px,1fr)); gap:10px; }
 .draft-card { display:flex; flex-direction:column; gap:8px; min-width:0; }
 .draft-preview { color:var(--muted); overflow-wrap:anywhere; }
-.draft-actions { display:grid; grid-template-columns:1fr 1fr; gap:8px; }
+.draft-actions { display:grid; grid-template-columns:repeat(auto-fit,minmax(120px,1fr)); gap:8px; }
 .draft-actions button { min-height:44px; width:100%; }
 .my-work-card { min-height: 44px; display:grid; gap:8px; padding:12px; border:1px solid #1f3a5f; border-radius:12px; background:#0f1d33; color:var(--text); }
 .my-work-card-main { display:block; width:100%; color:var(--text); text-align:left; font:inherit; background:transparent; border:0; padding:0; }
@@ -206,12 +214,15 @@ textarea { resize: vertical; min-height: 120px; }
 .create-issue-header button, .create-issue-actions button { min-height:44px; }
 .create-issue-form { display:grid; gap:12px; }
 .create-issue-form label { display:grid; gap:6px; }
-.create-issue-form select { min-height:44px; padding:8px; border-radius:8px; border:1px solid #1f3a5f; background:#0b1526; color:#e5e7eb; }
+.create-issue-form select, .create-issue-form input[type="date"] { min-height:44px; padding:8px; border-radius:8px; border:1px solid #1f3a5f; background:#0b1526; color:#e5e7eb; }
 .create-issue-labels { display:grid; gap:8px; margin:0; padding:0; border:0; }
 .create-issue-label-list { display:grid; grid-template-columns:repeat(auto-fit,minmax(140px,1fr)); gap:8px; }
 .create-issue-label-option { min-height:44px; display:flex !important; grid-template-columns:auto 1fr !important; align-items:center; gap:8px; padding:8px 10px; border:1px solid #2a496e; border-radius:10px; background:#10213a; }
 .create-issue-label-option input { width:20px; height:20px; margin:0; }
 .create-issue-actions { position:sticky; bottom:0; display:grid; gap:8px; padding:10px 0; padding-bottom:calc(10px + env(safe-area-inset-bottom)); background:#0b1526; }
+.shared-content-conflict { display:grid; gap:8px; padding:12px; border:1px solid #8b5cf6; border-radius:10px; background:#16142b; }
+.shared-content-actions { display:grid; grid-template-columns:1fr 1fr; gap:8px; }
+.shared-content-actions button { min-height:44px; }
 .pull-sheet { position:fixed; inset:0; z-index:58; display:none; justify-content:flex-end; background:rgba(5,12,21,.72); backdrop-filter:blur(4px); }
 .pull-sheet.open { display:flex; }
 .pull-sheet-panel { width:min(560px,100%); height:100dvh; overflow:auto; padding:18px; padding-bottom:calc(90px + env(safe-area-inset-bottom)); background:#0b1526; border-left:1px solid #2a496e; }
@@ -239,7 +250,13 @@ textarea { resize: vertical; min-height: 120px; }
 .pull-sheet-actions { position:sticky; bottom:0; display:grid; grid-template-columns:1fr 1fr; gap:8px; padding:10px 0; padding-bottom:calc(10px + env(safe-area-inset-bottom)); background:#0b1526; }
 .pull-sheet-actions a { display:grid; place-items:center; border:1px solid #60a5fa; border-radius:10px; font-weight:700; }
 .pull-retry { min-height:44px; width:100%; margin-top:10px; }
+.mobile-task-dock { display:none; }
+.mobile-task-dock[hidden] { display:none; }
+.mobile-task-action { min-width:0; min-height:44px; padding:6px 2px; border:0; border-radius:8px; background:transparent; display:grid; place-items:center; gap:2px; font-size:12px; }
+.mobile-task-action[aria-current="page"] { color:#bfdbfe; background:#17365a; outline:1px solid #31577f; }
+.mobile-task-count { min-width:18px; min-height:18px; padding:1px 5px; border-radius:999px; background:#31577f; font-size:11px; line-height:16px; }
 @media (max-width: 600px) {
+  body { padding-bottom:calc(66px + env(safe-area-inset-bottom)); }
   header { align-items:flex-start; }
   .my-work { margin:0; }
   .my-work-list { grid-template-columns:1fr; }
@@ -251,6 +268,7 @@ textarea { resize: vertical; min-height: 120px; }
   .search-preview-panel { width:100%; border-left:0; padding:14px; padding-bottom:calc(14px + env(safe-area-inset-bottom)); overflow-x:hidden; }
   .create-issue-panel { width:100%; border-left:0; padding:14px; }
   .pull-sheet-panel { width:100%; border-left:0; padding:14px; }
+  .mobile-task-dock { position:fixed; inset:auto 0 0; z-index:45; display:grid; grid-template-columns:repeat(5,minmax(0,1fr)); gap:2px; padding:6px 8px; padding-bottom:env(safe-area-inset-bottom); border-top:1px solid #2a496e; background:rgba(11,21,38,.98); backdrop-filter:blur(12px); }
 }
 .obi { width:14px; height:14px; background: url('data:image/svg+xml;utf8,<svg xmlns=%22http://www.w3.org/2000/svg%22 viewBox=%220 0 24 24%22><rect width=%2224%22 height=%2224%22 rx=%226%22 fill=%22%230b1526%22/><circle cx=%2212%22 cy=%2212%22 r=%226%22 fill=%22%2360a5fa%22/></svg>') center/contain no-repeat; display:inline-block; }
 .footer { padding: 12px; text-align: center; color:#4e6b8a; font-size:12px; }
@@ -268,9 +286,12 @@ textarea { resize: vertical; min-height: 120px; }
     <span class="small muted" id="clock"></span>
   </div>
 </header>
+<div class="offline-status" id="offline-status" role="status" aria-live="polite" hidden>
+  Offline · live Gitea data is unavailable. Saved drafts remain available on this device.
+</div>
 
 <main>
-  <section class="panel my-work" id="my-work">
+  <section class="panel my-work" id="my-work" tabindex="-1">
     <div class="my-work-header">
       <div>
         <h2>My Work</h2>
@@ -295,6 +316,11 @@ textarea { resize: vertical; min-height: 120px; }
           <option value="unplanned">Unplanned</option>
         </select>
       </label>
+      <div class="offline-work-controls">
+        <label for="keep-work-offline"><input id="keep-work-offline" type="checkbox" /> Keep My Work available offline</label>
+        <button id="clear-offline-work" type="button">Clear offline work data</button>
+        <span class="small" id="offline-work-status" role="status" aria-live="polite"></span>
+      </div>
     </div>
     <div class="my-work-list" id="my-work-list"></div>
     <div class="small" id="work-page-status" aria-live="polite"></div>
@@ -509,6 +535,14 @@ textarea { resize: vertical; min-height: 120px; }
       <h3 id="create-issue-heading">New issue</h3>
       <button id="cancel-new-issue" type="button">Cancel</button>
     </div>
+    <aside class="shared-content-conflict" id="shared-content-conflict" aria-live="assertive" hidden>
+      <strong>You already have an unfinished issue draft.</strong>
+      <span class="small">Resume it, or replace its title and description with the content shared to Stackchain.</span>
+      <div class="shared-content-actions">
+        <button id="resume-issue-draft" type="button">Resume existing draft</button>
+        <button id="use-shared-content" type="button">Use shared content</button>
+      </div>
+    </aside>
     <form class="create-issue-form" id="create-issue-form">
       <label for="create-issue-repository">Repository
         <select id="create-issue-repository" required></select>
@@ -519,6 +553,15 @@ textarea { resize: vertical; min-height: 120px; }
       <label for="create-issue-body">Description <span class="small">Optional</span>
         <textarea id="create-issue-body" maxlength="10000"></textarea>
       </label>
+      <label for="create-issue-milestone">Milestone <span class="small">Optional</span>
+        <select id="create-issue-milestone" aria-describedby="create-issue-milestone-status">
+          <option value="">No milestone</option>
+        </select>
+        <span class="small" id="create-issue-milestone-status" aria-live="polite">Choose a repository to load milestones.</span>
+      </label>
+      <label for="create-issue-due-date">Due date <span class="small">Optional</span>
+        <input id="create-issue-due-date" type="date" />
+      </label>
       <fieldset class="create-issue-labels" id="create-issue-labels" aria-describedby="create-issue-label-status">
         <legend>Labels <span class="small">Optional</span></legend>
         <div class="small" id="create-issue-label-status" aria-live="polite">Choose a repository to load labels.</div>
@@ -548,9 +591,10 @@ textarea { resize: vertical; min-height: 120px; }
       <span class="pill" id="update-subject-type">Update</span>
       <span class="pill" id="update-subject-state"></span>
     </div>
-    <h2>Latest comment</h2>
-    <div class="small" id="update-comment-meta"></div>
-    <p class="update-sheet-content" id="update-comment-body"></p>
+    <h2>Full conversation</h2>
+    <div id="update-comments"></div>
+    <button class="conversation-more" id="load-older-update-comments" type="button" hidden>Load older messages</button>
+    <div id="update-conversation-status" class="small" aria-live="assertive"></div>
     <details>
       <summary><h2>Subject context</h2></summary>
       <p class="update-sheet-content muted" id="update-subject-body"></p>
@@ -674,6 +718,14 @@ textarea { resize: vertical; min-height: 120px; }
   </section>
 </div>
 
+<nav class="mobile-task-dock" id="mobile-task-dock" aria-label="Primary tasks">
+  <button class="mobile-task-action" data-mobile-task="work" type="button" aria-current="page">Work</button>
+  <button class="mobile-task-action" data-mobile-task="find" type="button">Find</button>
+  <button class="mobile-task-action" data-mobile-task="new" type="button">New</button>
+  <button class="mobile-task-action" data-mobile-task="search" type="button">Search</button>
+  <button class="mobile-task-action" data-mobile-task="drafts" type="button">Drafts <span class="mobile-task-count" id="mobile-draft-count" aria-label="0 drafts">0</span></button>
+</nav>
+
 <div class="footer">Creative AI-imbued UI • stackchain-dashboard</div>
 
 <script src="static/markdown.js"></script>
@@ -681,6 +733,9 @@ textarea { resize: vertical; min-height: 120px; }
 <script src="static/search-preview.js"></script>
 <script src="static/widgets.js"></script>
 <script src="static/drafts.js"></script>
+<script src="static/issue-outbox.js"></script>
+<script src="static/authored-outbox.js"></script>
+<script src="static/offline-work.js"></script>
 <script src="static/my-work.js"></script>
 <script src="static/pick-work.js"></script>
 <script src="static/conversation.js"></script>
@@ -690,6 +745,7 @@ textarea { resize: vertical; min-height: 120px; }
 <script src="static/review-sheet.js"></script>
 <script src="static/work-route.js"></script>
 <script src="static/context-poller.js"></script>
+<script src="static/mobile-task-dock.js"></script>
 <script>
 (function(){
   const qs = (s, el=document) => el.querySelector(s);
@@ -715,7 +771,38 @@ textarea { resize: vertical; min-height: 120px; }
       }
     });
   });
+  const mobileTaskButtons = Object.fromEntries(
+    Array.from(document.querySelectorAll('[data-mobile-task]')).map(button => [button.dataset.mobileTask, button])
+  );
+  const mobileTaskOverlays = Array.from(document.querySelectorAll('[role="dialog"], #whiteboard-modal, #markdown-modal'));
+  const mobileTaskDock = createMobileTaskDock({
+    nav: qs('#mobile-task-dock'),
+    buttons: mobileTaskButtons,
+    overlays: mobileTaskOverlays,
+    actions: {
+      work: () => qs('#my-work').scrollIntoView({block:'start'}) || qs('#my-work').focus(),
+      find: () => qs('#find-work').click(),
+      new: () => qs('#new-issue').click(),
+      search: () => qs('#open-palette').click(),
+      drafts: () => qs('[data-work-filter="draft"]').click(),
+    },
+    observe(callback, overlays) {
+      const observer = new MutationObserver(callback);
+      overlays.forEach(overlay => observer.observe(overlay, {attributes:true, attributeFilter:['class']}));
+      return observer;
+    },
+  });
+  mobileTaskDock.start();
+  const sourceDraftCount = qs('[data-work-count="draft"]');
+  const draftCount = qs('#mobile-draft-count');
+  function syncMobileDraftCount() {
+    draftCount.textContent = sourceDraftCount.textContent;
+    draftCount.setAttribute('aria-label', sourceDraftCount.textContent + ' drafts');
+  }
+  new MutationObserver(syncMobileDraftCount).observe(sourceDraftCount, {childList:true, characterData:true, subtree:true});
+  syncMobileDraftCount();
   let liveMode = true;
+  let offlineWorkMode = false;
   const WORK_FILTER_KEY = 'stackchain.my-work-filter.v1';
   const WORK_MILESTONE_KEY = 'stackchain.my-work-milestone.v1';
   let selectedWorkFilter = 'all';
@@ -759,11 +846,16 @@ textarea { resize: vertical; min-height: 120px; }
   let bulkConfirmationPending = false;
   let bulkMarkPending = false;
   let reviewHandoffPending = false;
+  let editingOutboxId = null;
 
   async function fetchReviewJson(url, options) {
     const response = await fetch(url, options);
     const payload = await response.json().catch(() => ({}));
-    if (!response.ok) throw new Error(payload.error || 'Review request failed.');
+    if (!response.ok) {
+      const error = new Error(payload.error || payload.detail || 'Review request failed.');
+      error.status = response.status;
+      throw error;
+    }
     return payload;
   }
 
@@ -784,8 +876,19 @@ textarea { resize: vertical; min-height: 120px; }
     loadMilestones: item => issueController.loadMilestones(item),
   });
   const issueCapture = createIssueCapture({ fetchJson: fetchReviewJson, storage: localStorage });
+  const issueOutbox = createIssueOutbox({ storage: localStorage, fetchJson: fetchReviewJson });
+  const authoredOutbox = createAuthoredOutbox({ storage: localStorage, fetchJson: fetchReviewJson });
+  const shareParams = new URLSearchParams(location.search);
+  const sharedLaunch = {
+    title: shareParams.get('title') || '',
+    text: shareParams.get('text') || '',
+    url: shareParams.get('url') || '',
+  };
+  let sharedLaunchState = Object.values(sharedLaunch).some(Boolean) ?
+    issueCapture.stageSharedContent(sharedLaunch) : null;
   const pullController = createPullSheet({ fetchJson: fetchReviewJson, storage: localStorage });
   const draftInbox = createDraftInbox({ storage: localStorage });
+  const offlineWorkStore = createOfflineWorkStore({ storage: localStorage });
   const findWorkController = createFindWork({
     fetchJson: fetchReviewJson,
     onItems: renderAvailableIssues,
@@ -845,6 +948,16 @@ textarea { resize: vertical; min-height: 120px; }
     return payload;
   }
 
+  async function fetchNotificationConversation(notificationId, page) {
+    const response = await fetch('api/v1/notifications/' + encodeURIComponent(notificationId) +
+      '/conversation?page=' + encodeURIComponent(page) + '&limit=20', {
+        headers: { Accept: 'application/json' },
+      });
+    const payload = await response.json().catch(() => ({}));
+    if (!response.ok) throw new Error(payload.error || 'Loading older messages failed.');
+    return payload;
+  }
+
   async function fetchWorkPage(stream, page) {
     const response = await fetch('api/v1/work/' + encodeURIComponent(stream) + '?page=' + encodeURIComponent(page), {
       headers: { Accept: 'application/json' },
@@ -920,18 +1033,21 @@ textarea { resize: vertical; min-height: 120px; }
   const notificationReplier = createNotificationReplier({
     post: postNotificationReply,
     storage: localStorage,
+    authoredOutbox,
     onStatus: message => { qs('#update-reply-status').textContent = message; },
   });
   const notificationReader = createNotificationReader({
     load: fetchNotificationDetail,
+    loadConversation: fetchNotificationConversation,
     markRead: markNotificationRead,
     onOpen: item => {
       selectedUpdate = item;
       qs('#update-sheet').classList.add('open');
       qs('#update-sheet-key').textContent = item.key || '';
       qs('#update-sheet-title').textContent = item.title || 'Unread update';
-      qs('#update-comment-meta').textContent = '';
-      qs('#update-comment-body').textContent = '';
+      qs('#update-comments').textContent = '';
+      qs('#update-conversation-status').textContent = '';
+      qs('#load-older-update-comments').hidden = true;
       qs('#update-subject-body').textContent = '';
       qs('#update-subject-type').textContent = item.subject_type || 'Update';
       qs('#update-subject-state').textContent = item.state || '';
@@ -943,18 +1059,14 @@ textarea { resize: vertical; min-height: 120px; }
       qs('#keep-update-unread').focus();
     },
     onDetail: detail => {
-      const comment = detail.latest_comment || {};
       qs('#update-sheet-title').textContent = detail.title || 'Unread update';
       qs('#update-subject-type').textContent = detail.subject_type || 'Update';
       qs('#update-subject-state').textContent = detail.state || '';
-      qs('#update-comment-meta').textContent = comment.author ?
-        comment.author + (comment.created_at ? ' · ' + fmt(comment.created_at) : '') :
-        (comment.created_at ? fmt(comment.created_at) : 'No comment author reported');
-      qs('#update-comment-body').textContent = comment.body || 'No comment body was provided.';
       qs('#update-subject-body').textContent = detail.subject_body || 'No subject context was provided.';
       qs('#open-update-gitea').href = detail.url || selectedUpdate?.url || '#';
       qs('#retry-update-load').hidden = true;
     },
+    onConversation: renderUpdateConversation,
     onItems: items => {
       const readId = selectedUpdate?.notification_id;
       lastMyWork = items;
@@ -980,6 +1092,10 @@ textarea { resize: vertical; min-height: 120px; }
 
   function openRoutedWork(item, trigger, options = {}) {
     if (!item) return;
+    if (offlineWorkMode) {
+      qs('#my-work-action-status').textContent = 'This saved item is read-only. Reconnect to open live details.';
+      return;
+    }
     if (item.has_update && item.kind === 'update') updateTrigger = trigger;
     else if (item.is_review) reviewTrigger = trigger;
     else if (item.kind === 'issue') issueTrigger = trigger;
@@ -1099,6 +1215,7 @@ textarea { resize: vertical; min-height: 120px; }
     if (data.work_pagination) workPager.reset(data.work_pagination);
     if (data.error && lastMyWork.length) markMyWorkStale();
     else paintMyWork(data);
+    openStagedSharedContent();
     qs('#context').innerHTML = '<div class="kv"><div class="label">User</div><div class="value">' + escapeHtml(data.user?.full_name || data.user?.login || '—') + '</div>' +
       '<div class="label">Repos</div><div class="value">' + (data.repos?.length || 0) + '</div>' +
       '<div class="label">Issues</div><div class="value">' + (data.issues?.length || 0) + '</div>' +
@@ -1125,6 +1242,7 @@ textarea { resize: vertical; min-height: 120px; }
   function handleContextError(e) {
     console.error('context failed', e);
     liveMode = false;
+    if (!hasContextSnapshot && hydrateOfflineWork('outage')) return;
     setStatus(hasContextSnapshot ? 'Update failed · showing last snapshot' : 'Unavailable');
     if (!hasContextSnapshot) {
       qs('#context').innerHTML = '<div class="muted">Context unavailable.</div>';
@@ -1181,15 +1299,27 @@ textarea { resize: vertical; min-height: 120px; }
 
   function renderDrafts() {
     const list = qs('#my-work-list');
-    list.innerHTML = lastDrafts.length ? lastDrafts.map((item, index) =>
-      '<article class="my-work-card draft-card">' +
-      '<span class="small">' + escapeHtml(item.label) + (item.repository ? ' · ' + escapeHtml(item.repository) : '') + '</span>' +
-      '<span class="my-work-card-title">' + escapeHtml(item.title) + '</span>' +
-      '<span class="draft-preview">' + escapeHtml(item.preview || 'Unfinished draft') + '</span>' +
-      '<span class="small">Saved ' + escapeHtml(fmt(item.updated_at)) + '</span>' +
-      '<div class="draft-actions"><button class="draft-resume" data-draft-index="' + index + '" type="button">Resume draft</button>' +
-      '<button class="draft-discard" data-draft-id="' + escAttr(item.id) + '" type="button">Discard draft</button></div></article>'
-    ).join('') : '<div class="muted">No unfinished drafts.</div>';
+    list.innerHTML = lastDrafts.length ? lastDrafts.map((item, index) => {
+      const isOutbox = item.kind === 'issue-outbox' || item.kind === 'authored-outbox';
+      const outboxActions = item.kind === 'issue-outbox' ?
+        '<button class="draft-edit" data-draft-index="' + index + '" type="button">Edit</button>' +
+        '<button class="draft-send" data-draft-index="' + index + '" type="button">Send now</button>' +
+        '<button class="draft-discard" data-draft-index="' + index + '" type="button">Discard</button>' :
+        item.kind === 'authored-outbox' ?
+        '<button class="draft-resume" data-draft-index="' + index + '" type="button">Open message</button>' +
+        '<button class="draft-send" data-draft-index="' + index + '" type="button">Send now</button>' +
+        '<button class="draft-discard" data-draft-index="' + index + '" type="button">Discard</button>' :
+        '<button class="draft-resume" data-draft-index="' + index + '" type="button">Resume draft</button>' +
+        '<button class="draft-discard" data-draft-index="' + index + '" type="button">Discard draft</button>';
+      const state = isOutbox ?
+        '<span class="pill">' + (item.status === 'attention' ? 'Needs attention' : 'Queued for sync') + '</span>' : '';
+      return '<article class="my-work-card draft-card">' +
+        '<span class="small">' + escapeHtml(item.label) + (item.repository ? ' · ' + escapeHtml(item.repository) : '') + '</span>' +
+        '<span class="my-work-card-title">' + escapeHtml(item.title) + '</span>' +
+        '<span class="draft-preview">' + escapeHtml(item.preview || 'Unfinished draft') + '</span>' + state +
+        '<span class="small">Saved ' + escapeHtml(fmt(item.updated_at)) + '</span>' +
+        '<div class="draft-actions">' + outboxActions + '</div></article>';
+    }).join('') : '<div class="muted">No unfinished drafts.</div>';
     list.querySelectorAll('.draft-resume').forEach(button => {
       button.addEventListener('click', () => {
         const item = lastDrafts[Number(button.dataset.draftIndex)];
@@ -1198,10 +1328,33 @@ textarea { resize: vertical; min-height: 120px; }
         else if (item.route) workRoute.open(item.route);
       });
     });
+    list.querySelectorAll('.draft-edit').forEach(button => {
+      button.addEventListener('click', () => {
+        const item = lastDrafts[Number(button.dataset.draftIndex)];
+        const queued = issueOutbox.list().find(candidate => candidate.id === item?.outbox_id);
+        if (!queued) return;
+        editingOutboxId = queued.id;
+        issueCapture.saveDraft(queued);
+        openCreateIssueSheet();
+        qs('#create-issue-status').textContent = 'Edit this queued issue, then send again.';
+      });
+    });
+    list.querySelectorAll('.draft-send').forEach(button => {
+      button.addEventListener('click', async () => {
+        const item = lastDrafts[Number(button.dataset.draftIndex)];
+        if (!item?.outbox_id) return;
+        button.disabled = true;
+        if (item.kind === 'authored-outbox') applyAuthoredOutboxResult(await authoredOutbox.retry(item.outbox_id));
+        else applyOutboxResult(await issueOutbox.retry(item.outbox_id));
+      });
+    });
     list.querySelectorAll('.draft-discard').forEach(button => {
       button.addEventListener('click', () => {
         if (!window.confirm('Discard this unfinished draft?')) return;
-        draftInbox.discard(button.dataset.draftId);
+        const item = lastDrafts[Number(button.dataset.draftIndex)];
+        if (item?.kind === 'issue-outbox') issueOutbox.discard(item.outbox_id);
+        else if (item?.kind === 'authored-outbox') authoredOutbox.discard(item.outbox_id);
+        else if (item) draftInbox.discard(item.id);
         lastDrafts = draftInbox.list();
         const count = qs('[data-work-count="draft"]');
         if (count) count.textContent = lastDrafts.length;
@@ -1365,6 +1518,15 @@ textarea { resize: vertical; min-height: 120px; }
       comments.length + ' of ' + Math.max(state.total || 0, comments.length) + ' messages loaded.' : 'No comments yet.';
   }
 
+  function renderUpdateConversation(state) {
+    const comments = state?.comments || [];
+    qs('#update-comments').innerHTML = comments.length ?
+      comments.map(renderIssueComment).join('') : '<div class="muted">No comments yet.</div>';
+    qs('#load-older-update-comments').hidden = !Number.isInteger(state?.older_page);
+    qs('#update-conversation-status').textContent = comments.length ?
+      comments.length + ' of ' + Math.max(state.total || 0, comments.length) + ' messages loaded.' : 'No comments yet.';
+  }
+
   function renderPullConversation(state) {
     const comments = state?.comments || [];
     qs('#pull-comments').innerHTML = comments.length ? comments.map(comment =>
@@ -1739,6 +1901,8 @@ textarea { resize: vertical; min-height: 120px; }
       title: qs('#create-issue-title').value,
       body: qs('#create-issue-body').value,
       labelIds: selectedIssueLabelIds(),
+      milestoneId: Number(qs('#create-issue-milestone').value) || null,
+      dueDate: qs('#create-issue-due-date').value,
     });
   }
 
@@ -1765,6 +1929,49 @@ textarea { resize: vertical; min-height: 120px; }
     }
   }
 
+  async function loadIssueMilestones(repository, selectedId = null) {
+    const select = qs('#create-issue-milestone');
+    const status = qs('#create-issue-milestone-status');
+    select.innerHTML = '<option value="">No milestone</option>';
+    if (!repository) {
+      status.textContent = 'Choose a repository to load milestones.';
+      return;
+    }
+    status.textContent = 'Loading milestones…';
+    try {
+      const milestones = await issueCapture.loadMilestones(repository);
+      if (qs('#create-issue-repository').value !== repository) return;
+      select.innerHTML += milestones.map(milestone =>
+        '<option value="' + Number(milestone.id) + '">' + escapeHtml(milestone.title) + '</option>'
+      ).join('');
+      if (selectedId) select.value = String(selectedId);
+      status.textContent = milestones.length ?
+        'Choose the release lane for this issue.' : 'This repository has no open milestones.';
+    } catch (_error) {
+      if (qs('#create-issue-repository').value !== repository) return;
+      status.textContent = 'Milestones could not be loaded. You can still create an unplanned issue.';
+    }
+  }
+
+  function clearSharedLaunchUrl() {
+    const cleanUrl = location.pathname + location.hash;
+    history.replaceState({}, '', cleanUrl);
+  }
+
+  function openStagedSharedContent() {
+    if (!sharedLaunchState || sharedLaunchState.status === 'shown') return;
+    openCreateIssueSheet();
+    if (sharedLaunchState.status === 'conflict') {
+      qs('#shared-content-conflict').hidden = false;
+      qs('#create-issue-status').textContent = 'Choose which draft to continue.';
+      qs('#resume-issue-draft').focus();
+      sharedLaunchState = {status: 'shown'};
+      return;
+    }
+    clearSharedLaunchUrl();
+    sharedLaunchState = null;
+  }
+
   function openCreateIssueSheet() {
     const captureDraft = issueCapture.loadDraft();
     const repositories = (lastContextSnapshot?.repos || []).map(repository => repository.full_name).filter(Boolean);
@@ -1777,7 +1984,9 @@ textarea { resize: vertical; min-height: 120px; }
     if (captureDraft.repository) qs('#create-issue-repository').value = captureDraft.repository;
     qs('#create-issue-title').value = captureDraft.title;
     qs('#create-issue-body').value = captureDraft.body;
+    qs('#create-issue-due-date').value = captureDraft.dueDate || '';
     loadIssueLabels(qs('#create-issue-repository').value, captureDraft.labelIds);
+    loadIssueMilestones(qs('#create-issue-repository').value, captureDraft.milestoneId);
     qs('#create-issue-status').textContent = repositories.length ? '' : 'No accessible repositories are available.';
     qs('#submit-new-issue').disabled = !repositories.length;
     qs('#create-issue-sheet').classList.add('open');
@@ -1791,6 +2000,51 @@ textarea { resize: vertical; min-height: 120px; }
     qs('#new-issue').focus();
   }
 
+  function applyOutboxResult(result, openCreated = false) {
+    (result.confirmed || []).forEach(confirmed => {
+      if (lastContextSnapshot) lastContextSnapshot.issues = [confirmed].concat(lastContextSnapshot.issues || []);
+    });
+    if (lastContextSnapshot) lastMyWork = buildMyWork(lastContextSnapshot);
+    refreshMyWorkView();
+    if (result.confirmed?.length) {
+      const keys = result.confirmed.map(issue => issue.repository + '#' + issue.number).join(', ');
+      qs('#my-work-action-status').textContent = keys + ' created and assigned to you.';
+      const confirmed = result.confirmed[result.confirmed.length - 1];
+      const created = lastMyWork.find(item =>
+        item.kind === 'issue' && item.repository === confirmed.repository && item.number === confirmed.number
+      );
+      if (openCreated && created) openRoutedWork(created, qs('#new-issue'));
+    } else if ((result.remaining || []).some(item => item.status === 'attention')) {
+      qs('#my-work-action-status').textContent = 'Needs attention · edit the queued issue before sending again.';
+    } else {
+      qs('#my-work-action-status').textContent = 'Queued for sync when the connection returns.';
+    }
+  }
+
+  async function flushIssueOutbox() {
+    if (!navigator.onLine || !issueOutbox.list().length) return;
+    applyOutboxResult(await issueOutbox.flush());
+  }
+
+  function applyAuthoredOutboxResult(result) {
+    refreshMyWorkView();
+    const attention = (result.remaining || []).some(item => item.status === 'attention');
+    qs('#my-work-action-status').textContent = result.confirmed?.length ?
+      result.confirmed.length + ' queued message' + (result.confirmed.length === 1 ? '' : 's') + ' sent.' :
+      attention ? 'A queued message needs attention. Open Drafts to edit or discard it.' :
+      'Message queued for sync when the connection returns.';
+  }
+
+  async function flushAuthoredOutbox() {
+    if (!navigator.onLine || !authoredOutbox.list().length) return;
+    applyAuthoredOutboxResult(await authoredOutbox.flush());
+  }
+
+  function canQueueMessage(error) {
+    const status = Number(error?.status || 0);
+    return !status || status >= 500;
+  }
+
   function inlineAnchor(target) {
     return {
       path: target.dataset.reviewFilename,
@@ -1978,6 +2232,8 @@ textarea { resize: vertical; min-height: 120px; }
   }
 
   function renderLiveSnapshot(snapshot) {
+    setOfflineWorkMode(false);
+    offlineStatus.hidden = true;
     const contextFreshness = snapshot.freshness?.sections?.context;
     const eventsFreshness = snapshot.freshness?.sections?.events;
     const notificationFreshness = snapshot.freshness?.sections?.notifications;
@@ -2002,10 +2258,19 @@ textarea { resize: vertical; min-height: 120px; }
       }
     }
     if (snapshot.context) {
+      setOfflineWorkMode(false);
       snapshot.context.notifications = lastNotifications;
       renderContextSnapshot(snapshot.context);
       if (contextFreshness?.stale) markMyWorkStale();
       else if (!notificationsFresh) markNotificationsStale();
+      if (!contextFreshness?.stale && notificationsFresh) {
+        offlineWorkStore.save({
+          ...snapshot.context,
+          notifications: snapshot.notifications,
+          notification_pagination: snapshot.notification_pagination,
+        });
+        updateOfflineWorkControls();
+      }
     } else handleContextError(new Error('Context section unavailable'));
     if (Array.isArray(snapshot.events)) paintEventStream(snapshot.events);
     if (eventsFreshness?.revalidating) {
@@ -2345,18 +2610,39 @@ textarea { resize: vertical; min-height: 120px; }
     }
   });
   qs('#new-issue').addEventListener('click', openCreateIssueSheet);
+  qs('#use-shared-content').addEventListener('click', () => {
+    issueCapture.acceptSharedContent();
+    qs('#shared-content-conflict').hidden = true;
+    sharedLaunchState = null;
+    clearSharedLaunchUrl();
+    openCreateIssueSheet();
+    qs('#create-issue-status').textContent = 'Shared content added. Choose a repository and finish planning.';
+  });
+  qs('#resume-issue-draft').addEventListener('click', () => {
+    issueCapture.discardSharedContent();
+    qs('#shared-content-conflict').hidden = true;
+    sharedLaunchState = null;
+    clearSharedLaunchUrl();
+    qs('#create-issue-status').textContent = 'Existing draft restored.';
+    qs('#create-issue-title').focus();
+  });
   qs('#cancel-new-issue').addEventListener('click', () => {
-    saveIssueCaptureDraft();
+    if (editingOutboxId) {
+      issueCapture.clearDraft();
+      editingOutboxId = null;
+    } else saveIssueCaptureDraft();
     closeCreateIssueSheet();
   });
-  ['#create-issue-title', '#create-issue-body'].forEach(selector =>
+  ['#create-issue-title', '#create-issue-body', '#create-issue-due-date'].forEach(selector =>
     qs(selector).addEventListener('input', saveIssueCaptureDraft)
   );
   qs('#create-issue-repository').addEventListener('change', event => {
     loadIssueLabels(event.target.value);
+    loadIssueMilestones(event.target.value);
     saveIssueCaptureDraft();
   });
   qs('#create-issue-label-list').addEventListener('change', saveIssueCaptureDraft);
+  qs('#create-issue-milestone').addEventListener('change', saveIssueCaptureDraft);
   qs('#create-issue-form').addEventListener('submit', async event => {
     event.preventDefault();
     const captureDraft = {
@@ -2364,6 +2650,8 @@ textarea { resize: vertical; min-height: 120px; }
       title: qs('#create-issue-title').value.trim(),
       body: qs('#create-issue-body').value.trim(),
       labelIds: selectedIssueLabelIds(),
+      milestoneId: Number(qs('#create-issue-milestone').value) || null,
+      dueDate: qs('#create-issue-due-date').value,
     };
     if (!captureDraft.repository || !captureDraft.title) {
       qs('#create-issue-status').textContent = 'Choose a repository and add a title.';
@@ -2372,18 +2660,16 @@ textarea { resize: vertical; min-height: 120px; }
     }
     const button = qs('#submit-new-issue');
     button.disabled = true;
-    qs('#create-issue-status').textContent = 'Creating issue…';
+    qs('#create-issue-status').textContent = navigator.onLine ? 'Sending issue…' : 'Saving issue to outbox…';
     try {
-      const confirmed = await issueCapture.submit(captureDraft);
-      lastContextSnapshot.issues = [confirmed].concat(lastContextSnapshot.issues || []);
-      lastMyWork = buildMyWork(lastContextSnapshot);
-      const created = lastMyWork.find(item =>
-        item.kind === 'issue' && item.repository === confirmed.repository && item.number === confirmed.number
-      );
+      const queued = editingOutboxId ? issueOutbox.update(editingOutboxId, captureDraft) :
+        issueOutbox.enqueue(captureDraft);
+      editingOutboxId = null;
+      issueCapture.clearDraft();
       closeCreateIssueSheet();
       refreshMyWorkView();
-      qs('#my-work-action-status').textContent = created.key + ' created and assigned to you.';
-      openRoutedWork(created, qs('#new-issue'));
+      qs('#my-work-action-status').textContent = 'Queued for sync.';
+      if (navigator.onLine) applyOutboxResult(await issueOutbox.retry(queued.id), true);
     } catch (error) {
       qs('#create-issue-status').textContent = error.message + ' Your draft is safe; retry.';
       button.disabled = false;
@@ -2591,8 +2877,17 @@ textarea { resize: vertical; min-height: 120px; }
       qs('#issue-comment').value = '';
       qs('#issue-comment-status').textContent = 'Comment posted.';
     } catch (error) {
-      qs('#issue-comment-status').textContent = error.message + ' Your draft is safe; retry.';
-      qs('#issue-comment').focus();
+      if (canQueueMessage(error)) {
+        const operationId = localStorage.getItem('stackchain.issue-comment.v1:' + selectedIssue.repository + '#' + selectedIssue.number + ':operation');
+        authoredOutbox.enqueue({ kind:'issue-comment', repository:selectedIssue.repository,
+          number:selectedIssue.number, body, operationId });
+        qs('#issue-comment').value = '';
+        qs('#issue-comment-status').textContent = 'Queued for sync when the connection returns.';
+        refreshMyWorkView();
+      } else {
+        qs('#issue-comment-status').textContent = error.message + ' Your draft is safe; retry.';
+        qs('#issue-comment').focus();
+      }
     } finally {
       button.disabled = false;
     }
@@ -2683,8 +2978,17 @@ textarea { resize: vertical; min-height: 120px; }
       qs('#pull-comment').value = '';
       qs('#pull-comment-status').textContent = 'Comment posted.';
     } catch (error) {
-      qs('#pull-comment-status').textContent = error.message + ' Your draft is safe; retry.';
-      qs('#pull-comment').focus();
+      if (canQueueMessage(error)) {
+        const operationId = localStorage.getItem('stackchain.pull-comment.v1:' + selectedPull.repository + '#' + selectedPull.number + ':operation');
+        authoredOutbox.enqueue({ kind:'pull-comment', repository:selectedPull.repository,
+          number:selectedPull.number, body, operationId });
+        qs('#pull-comment').value = '';
+        qs('#pull-comment-status').textContent = 'Queued for sync when the connection returns.';
+        refreshMyWorkView();
+      } else {
+        qs('#pull-comment-status').textContent = error.message + ' Your draft is safe; retry.';
+        qs('#pull-comment').focus();
+      }
     } finally {
       button.disabled = false;
     }
@@ -2713,6 +3017,16 @@ textarea { resize: vertical; min-height: 120px; }
   qs('#retry-update-load').addEventListener('click', () => {
     if (selectedUpdate) notificationReader.open(selectedUpdate, lastMyWork);
   });
+  qs('#load-older-update-comments').addEventListener('click', async () => {
+    const button = qs('#load-older-update-comments');
+    const panel = qs('#update-sheet .update-sheet-panel');
+    const previousHeight = panel.scrollHeight;
+    const previousTop = panel.scrollTop;
+    button.disabled = true;
+    await notificationReader.loadOlder();
+    panel.scrollTop = previousTop + (panel.scrollHeight - previousHeight);
+    button.disabled = false;
+  });
   qs('#update-reply').addEventListener('input', event => {
     if (selectedUpdate) notificationReplier.saveDraft(selectedUpdate, event.target.value);
   });
@@ -2727,7 +3041,12 @@ textarea { resize: vertical; min-height: 120px; }
     qs('#send-update-reply').disabled = true;
     const result = await notificationReplier.submit(selectedUpdate, body);
     qs('#send-update-reply').disabled = false;
-    if (result) {
+    if (result?.queued) {
+      qs('#update-reply').value = '';
+      refreshMyWorkView();
+      qs('#my-work-action-status').textContent = 'Reply queued for sync.';
+    } else if (result) {
+      notificationReader.appendReply(result);
       qs('#update-reply').value = '';
       qs('#mark-update-read-next').focus();
     } else {
@@ -2862,6 +3181,76 @@ textarea { resize: vertical; min-height: 120px; }
   });
   function load() { return contextPoller.refresh(); }
 
+  const offlineStatus = qs('#offline-status');
+  const keepWorkOffline = qs('#keep-work-offline');
+  const offlineWorkStatus = qs('#offline-work-status');
+  function updateOfflineWorkControls(message) {
+    keepWorkOffline.checked = offlineWorkStore.enabled();
+    const saved = offlineWorkStore.load();
+    offlineWorkStatus.textContent = message || (saved ? 'Saved ' + fmt(saved.saved_at) + ' · expires after 7 days.' :
+      (keepWorkOffline.checked ? 'Waiting for a healthy live refresh.' : 'Off · no work data is stored.'));
+  }
+  function setOfflineWorkMode(value) {
+    offlineWorkMode = value;
+    ['#find-work', '#start-work-session', '#load-more-work', '#load-more-notifications', '#bulk-mark-read']
+      .forEach(selector => { const button = qs(selector); if (button) button.disabled = value; });
+  }
+  function hydrateOfflineWork(mode = 'offline') {
+    const saved = offlineWorkStore.load();
+    if (!saved) return false;
+    const outage = mode === 'outage';
+    lastNotifications = saved.notifications || [];
+    notificationPagination = saved.notification_pagination || { page:1, total:lastNotifications.length, has_more:false };
+    workPagination = saved.work_pagination || {};
+    lastContextSnapshot = saved;
+    hasContextSnapshot = true;
+    paintMyWork(saved);
+    setOfflineWorkMode(true);
+    const savedLabel = fmt(saved.saved_at);
+    if (outage) {
+      qs('#my-work-status').textContent = 'Outage · saved ' + savedLabel + ' · read-only';
+      offlineStatus.textContent = 'Server unavailable · showing private My Work saved ' + savedLabel + '. Live details and actions will return automatically.';
+      offlineWorkStatus.textContent = 'Outage · saved ' + savedLabel + ' · expires after 7 days.';
+      setStatus('Outage · saved snapshot');
+    } else {
+      qs('#my-work-status').textContent = 'Offline · saved ' + savedLabel + ' · read-only';
+      offlineStatus.textContent = 'Offline · showing private My Work saved ' + savedLabel + '. Live details and actions require reconnection.';
+      offlineWorkStatus.textContent = 'Offline · saved ' + savedLabel + ' · expires after 7 days.';
+      setStatus('Offline · saved snapshot');
+    }
+    offlineStatus.hidden = false;
+    return true;
+  }
+  function showOfflineStatus() {
+    offlineStatus.hidden = false;
+    setStatus('Offline');
+    if (!hasContextSnapshot) hydrateOfflineWork();
+  }
+  function reconnectLiveData() {
+    offlineStatus.hidden = true;
+    setOfflineWorkMode(false);
+    setStatus('Reconnecting…');
+    contextPoller.refresh();
+  }
+  keepWorkOffline.addEventListener('change', () => {
+    offlineWorkStore.setEnabled(keepWorkOffline.checked);
+    if (keepWorkOffline.checked && liveMode && lastContextSnapshot) {
+      offlineWorkStore.save({ ...lastContextSnapshot, notifications:lastNotifications,
+        notification_pagination:notificationPagination });
+    }
+    updateOfflineWorkControls(keepWorkOffline.checked ? 'Offline saving enabled.' : 'Offline work data cleared.');
+  });
+  qs('#clear-offline-work').addEventListener('click', () => {
+    offlineWorkStore.clear();
+    updateOfflineWorkControls('Offline work data cleared.');
+  });
+  updateOfflineWorkControls();
+  if (!navigator.onLine) showOfflineStatus();
+  window.addEventListener('offline', showOfflineStatus);
+  window.addEventListener('online', reconnectLiveData);
+  window.addEventListener('online', flushIssueOutbox);
+  window.addEventListener('online', flushAuthoredOutbox);
+
   qs('#refresh').addEventListener('click', load);
   qs('#start-work-session').addEventListener('click', () => {
     if (!filterMyWork(lastMyWork, selectedWorkFilter).length) {
@@ -2939,7 +3328,14 @@ textarea { resize: vertical; min-height: 120px; }
     renderMyWork();
     if (workSession.active()) workSession.reconcile();
   });
+  if ('serviceWorker' in navigator) {
+    navigator.serviceWorker.register('service-worker.js').catch(error =>
+      console.warn('Stackchain install support unavailable', error)
+    );
+  }
   contextPoller.start();
+  flushIssueOutbox();
+  flushAuthoredOutbox();
   document.addEventListener('visibilitychange', () => {
     contextPoller.setVisible(!document.hidden);
   });

frontend/issue-outbox.js

@@ -0,0 +1,123 @@
+function createIssueOutbox({ storage, fetchJson, createOperationId, now = () => Date.now(), maxItems = 20 }) {
+  const storageKey = 'stackchain.issue-outbox.v1';
+  const operationId = createOperationId || (() =>
+    globalThis.crypto?.randomUUID?.() || String(Date.now()) + '-' + Math.random().toString(16).slice(2)
+  );
+  const pending = new Map();
+
+  function read() {
+    try {
+      const record = JSON.parse(storage?.getItem(storageKey) || 'null');
+      if (record?.version !== 1 || !Array.isArray(record.items)) return [];
+      return record.items.filter(item => item && typeof item === 'object');
+    } catch (_error) { return []; }
+  }
+
+  function write(items) {
+    storage?.setItem(storageKey, JSON.stringify({ version: 1, items }));
+  }
+
+  function enqueue(draft) {
+    const items = read();
+    if (items.length >= maxItems) throw new Error('Issue outbox is full. Send or discard a queued issue first.');
+    const item = {
+      id: String(operationId()).slice(0, 128),
+      operationId: '',
+      repository: String(draft?.repository || ''),
+      title: String(draft?.title || ''),
+      body: String(draft?.body || ''),
+      labelIds: Array.isArray(draft?.labelIds) ? draft.labelIds.filter(Number.isInteger).slice(0, 20) : [],
+      status: 'queued',
+      queuedAt: Number(now()),
+    };
+    item.operationId = item.id;
+    if (Number.isInteger(Number(draft?.milestoneId)) && Number(draft.milestoneId) > 0) {
+      item.milestoneId = Number(draft.milestoneId);
+    }
+    if (/^\d{4}-\d{2}-\d{2}$/.test(String(draft?.dueDate || ''))) item.dueDate = String(draft.dueDate);
+    items.push(item);
+    write(items);
+    return item;
+  }
+
+  function update(id, draft) {
+    let updated = null;
+    write(read().map(item => {
+      if (item.id !== id) return item;
+      updated = {
+        ...item,
+        repository: String(draft?.repository || ''), title: String(draft?.title || ''),
+        body: String(draft?.body || ''),
+        labelIds: Array.isArray(draft?.labelIds) ? draft.labelIds.filter(Number.isInteger).slice(0, 20) : [],
+        status: 'queued',
+      };
+      delete updated.error;
+      return updated;
+    }));
+    return updated;
+  }
+
+  function discard(id) {
+    const items = read();
+    if (!items.some(item => item.id === id)) return false;
+    write(items.filter(item => item.id !== id));
+    return true;
+  }
+
+  async function sendItem(item) {
+    if (pending.has(item.id)) return pending.get(item.id);
+    const repository = item.repository.split('/').map(encodeURIComponent).join('/');
+    const request = (async () => {
+      try {
+        const issue = await fetchJson('api/v1/repos/' + repository + '/issues', {
+          method: 'POST',
+          headers: {
+            Accept: 'application/json', 'Content-Type': 'application/json',
+            'Idempotency-Key': item.operationId,
+          },
+          body: JSON.stringify({
+            title: item.title, body: item.body, label_ids: item.labelIds,
+            ...(item.milestoneId ? { milestone_id: item.milestoneId } : {}),
+            ...(item.dueDate ? { due_date: item.dueDate + 'T23:59:59Z' } : {}),
+          }),
+        });
+        discard(item.id);
+        return { issue };
+      } catch (error) {
+        const status = Number(error?.status || 0);
+        if (status >= 400 && status < 500) {
+          write(read().map(candidate => candidate.id === item.id ? {
+            ...candidate, status: 'attention', error: String(error.message || 'Issue needs attention').slice(0, 240),
+          } : candidate));
+        }
+        return { error, transient: !(status >= 400 && status < 500) };
+      }
+    })();
+    pending.set(item.id, request);
+    try { return await request; }
+    finally { if (pending.get(item.id) === request) pending.delete(item.id); }
+  }
+
+  async function flush() {
+    const confirmed = [];
+    for (const item of read()) {
+      if (item.status === 'attention') continue;
+      const result = await sendItem(item);
+      if (result.issue) confirmed.push(result.issue);
+      if (result.transient) break;
+    }
+    return { confirmed, remaining: read() };
+  }
+
+  async function retry(id) {
+    const item = read().find(candidate => candidate.id === id);
+    if (!item) return { confirmed: [], remaining: read() };
+    update(id, item);
+    const result = await sendItem({ ...item, status: 'queued' });
+    return { confirmed: result.issue ? [result.issue] : [], remaining: read() };
+  }
+
+  return { enqueue, update, discard, flush, retry, list: () => read().map(item => ({ ...item })) };
+}
+
+if (typeof module !== 'undefined' && module.exports) module.exports = createIssueOutbox;

frontend/manifest.webmanifest

@@ -0,0 +1,21 @@
+{
+  "name": "Stackchain Dashboard",
+  "short_name": "Stackchain",
+  "description": "Capture, plan, and complete Gitea work from mobile.",
+  "id": "./",
+  "start_url": "./",
+  "scope": "./",
+  "display": "standalone",
+  "background_color": "#07111f",
+  "theme_color": "#0b1220",
+  "icons": [
+    {"src": "static/icons/stackchain-192.png", "sizes": "192x192", "type": "image/png"},
+    {"src": "static/icons/stackchain-512.png", "sizes": "512x512", "type": "image/png"}
+  ],
+  "share_target": {
+    "action": "./",
+    "method": "GET",
+    "enctype": "application/x-www-form-urlencoded",
+    "params": {"title": "title", "text": "text", "url": "url"}
+  }
+}

frontend/mobile-task-dock.js

@@ -0,0 +1,38 @@
+(function (root, factory) {
+  if (typeof module === 'object' && module.exports) module.exports = factory;
+  else root.createMobileTaskDock = factory;
+})(typeof self !== 'undefined' ? self : this, function createMobileTaskDock(options) {
+  const nav = options.nav;
+  const buttons = options.buttons;
+  const overlays = options.overlays || [];
+  let launcher = null;
+  let wasHidden = false;
+
+  function select(name) {
+    Object.entries(buttons).forEach(([key, button]) => {
+      if (key === name) button.setAttribute('aria-current', 'page');
+      else button.removeAttribute('aria-current');
+    });
+  }
+
+  function refreshVisibility() {
+    const hidden = overlays.some(overlay => overlay.classList.contains('open'));
+    nav.hidden = hidden;
+    if (wasHidden && !hidden && launcher) launcher.focus();
+    wasHidden = hidden;
+  }
+
+  function start() {
+    Object.entries(buttons).forEach(([name, button]) => {
+      button.addEventListener('click', event => {
+        launcher = event.currentTarget;
+        select(name);
+        options.actions[name]();
+      });
+    });
+    options.observe(refreshVisibility, overlays);
+    refreshVisibility();
+  }
+
+  return {start, refreshVisibility};
+});

frontend/my-work.js

@@ -249,10 +249,16 @@ function createWorkPager({ load, onItems, onPagination, onStatus }) {
   };
 }
 
-function createNotificationReader({ load, markRead, onOpen, onDetail, onItems, onStatus, onClose }) {
+function createNotificationReader({
+  load, markRead, onOpen, onDetail, onItems, onStatus, onClose,
+  loadConversation = null,
+  onConversation = () => {},
+  createPager = typeof createConversationPager === 'function' ? createConversationPager : null,
+}) {
   let selected = null;
   let loadVersion = 0;
   let marking = false;
+  let conversationPager = null;
 
   async function open(item) {
     selected = item;
@@ -263,6 +269,14 @@ function createNotificationReader({ load, markRead, onOpen, onDetail, onItems, o
       const detail = await load(item.notification_id);
       if (selected !== item || version !== loadVersion) return false;
       onDetail(detail);
+      if (createPager && loadConversation && detail.conversation) {
+        conversationPager = createPager({
+          loadPage: page => loadConversation(item.notification_id, page),
+        });
+        onConversation(conversationPager.reset(detail.conversation));
+      } else {
+        conversationPager = null;
+      }
       onStatus('Update ready.');
       return true;
     } catch (_error) {
@@ -275,6 +289,29 @@ function createNotificationReader({ load, markRead, onOpen, onDetail, onItems, o
 
   return {
     open,
+    appendReply(comment) {
+      if (!conversationPager) return false;
+      onConversation(conversationPager.append(comment));
+      return true;
+    },
+    async loadOlder() {
+      if (!conversationPager || !selected) return false;
+      const pager = conversationPager;
+      const version = loadVersion;
+      onStatus('Loading older messages…');
+      try {
+        const state = await pager.loadOlder();
+        if (pager !== conversationPager || version !== loadVersion) return false;
+        onConversation(state);
+        onStatus(state.comments.length + ' of ' + state.total + ' messages loaded.');
+        return true;
+      } catch (_error) {
+        if (pager === conversationPager && version === loadVersion) {
+          onStatus('Could not load older messages. Retry.');
+        }
+        return false;
+      }
+    },
     async markReadAndNext(items) {
       if (!selected || marking) return false;
       const current = selected;
@@ -307,7 +344,7 @@ function createNotificationReader({ load, markRead, onOpen, onDetail, onItems, o
 }
 
 function createNotificationReplier({
-  post, storage, onStatus,
+  post, storage, onStatus, authoredOutbox,
   createOperationId = () => globalThis.crypto?.randomUUID?.() || String(Date.now()) + '-' + Math.random(),
 }) {
   let pending = false;
@@ -343,7 +380,15 @@ function createNotificationReplier({
         catch (_error) { /* A confirmed result no longer needs replay identity. */ }
         onStatus('Reply posted. You can mark this update read when ready.');
         return result;
-      } catch (_error) {
+      } catch (error) {
+        const status = Number(error?.status || 0);
+        if (authoredOutbox && (!status || status >= 500)) {
+          authoredOutbox.enqueue({
+            kind: 'update-reply', notificationId: item.notification_id, body, operationId,
+          });
+          onStatus('Queued for sync when the connection returns.');
+          return { queued: true };
+        }
         onStatus('Could not send reply. Your draft is safe; retry.');
         return false;
       } finally {

frontend/offline-work.js

@@ -0,0 +1,88 @@
+(function (root, factory) {
+  const api = factory();
+  if (typeof module !== 'undefined' && module.exports) module.exports = api;
+  else root.createOfflineWorkStore = api;
+})(typeof self !== 'undefined' ? self : this, function () {
+  'use strict';
+
+  const ENABLED_KEY = 'stackchain.offline-work.enabled.v1';
+  const SNAPSHOT_KEY = 'stackchain.offline-work.snapshot.v1';
+  const VERSION = 1;
+  const DEFAULT_MAX_AGE_MS = 7 * 24 * 60 * 60 * 1000;
+  const ITEM_FIELDS = [
+    'id', 'number', 'title', 'state', 'repository', 'labels', 'assignees',
+    'updated_at', 'due_date', 'milestone', 'url', 'work_reasons',
+  ];
+  const NOTIFICATION_FIELDS = [
+    'id', 'number', 'title', 'unread', 'repository', 'subject_type', 'updated_at', 'url',
+  ];
+
+  function pick(source, fields) {
+    const output = {};
+    fields.forEach(field => {
+      if (source && source[field] !== undefined) output[field] = source[field];
+    });
+    return output;
+  }
+
+  function createOfflineWorkStore({ storage, now = () => new Date(), maxAgeMs = DEFAULT_MAX_AGE_MS }) {
+    function enabled() {
+      try { return storage.getItem(ENABLED_KEY) === 'true'; }
+      catch (_) { return false; }
+    }
+
+    function clear() {
+      try { storage.removeItem(SNAPSHOT_KEY); }
+      catch (_) { return false; }
+      return true;
+    }
+
+    function setEnabled(value) {
+      try {
+        storage.setItem(ENABLED_KEY, value ? 'true' : 'false');
+        if (!value) clear();
+        return true;
+      } catch (_) { return false; }
+    }
+
+    function save(snapshot) {
+      if (!enabled() || !snapshot?.user?.login) return false;
+      const record = {
+        version: VERSION,
+        user_login: String(snapshot.user.login),
+        saved_at: now().toISOString(),
+        data: {
+          user: pick(snapshot.user, ['login', 'full_name']),
+          issues: (snapshot.issues || []).map(item => pick(item, ITEM_FIELDS)),
+          pull_requests: (snapshot.pull_requests || []).map(item => pick(item, ITEM_FIELDS)),
+          notifications: (snapshot.notifications || []).map(item => pick(item, NOTIFICATION_FIELDS)),
+          work_pagination: snapshot.work_pagination || {},
+          notification_pagination: snapshot.notification_pagination || {},
+        },
+      };
+      try { storage.setItem(SNAPSHOT_KEY, JSON.stringify(record)); }
+      catch (_) { return false; }
+      return true;
+    }
+
+    function load(expectedLogin) {
+      let record;
+      try { record = JSON.parse(storage.getItem(SNAPSHOT_KEY) || 'null'); }
+      catch (_) { clear(); return null; }
+      const savedAt = Date.parse(record?.saved_at || '');
+      const invalid = record?.version !== VERSION || !record?.user_login || !record?.data ||
+        !Number.isFinite(savedAt);
+      const expired = Number.isFinite(savedAt) && now().getTime() - savedAt > maxAgeMs;
+      if (invalid || expired) {
+        clear();
+        return null;
+      }
+      if (expectedLogin && record.user_login !== expectedLogin) return null;
+      return { ...record.data, saved_at: record.saved_at };
+    }
+
+    return { enabled, setEnabled, save, load, clear };
+  }
+
+  return createOfflineWorkStore;
+});

frontend/service-worker.js

@@ -0,0 +1,66 @@
+const CACHE = 'stackchain-dashboard-shell-v7';
+const OUTAGE_STATUSES = new Set([500, 502, 503, 504]);
+const BASE = new URL('./', self.location.href).pathname;
+const SHELL = [
+  BASE,
+  BASE + 'manifest.webmanifest',
+  BASE + 'static/icons/stackchain-192.png',
+  BASE + 'static/icons/stackchain-512.png',
+  BASE + 'static/markdown.js',
+  BASE + 'static/commands.js',
+  BASE + 'static/search-preview.js',
+  BASE + 'static/widgets.js',
+  BASE + 'static/drafts.js',
+  BASE + 'static/issue-outbox.js',
+  BASE + 'static/authored-outbox.js',
+  BASE + 'static/offline-work.js',
+  BASE + 'static/my-work.js',
+  BASE + 'static/pick-work.js',
+  BASE + 'static/conversation.js',
+  BASE + 'static/issue-sheet.js',
+  BASE + 'static/create-issue-sheet.js',
+  BASE + 'static/pull-sheet.js',
+  BASE + 'static/review-sheet.js',
+  BASE + 'static/work-route.js',
+  BASE + 'static/context-poller.js',
+  BASE + 'static/mobile-task-dock.js',
+];
+
+self.addEventListener('install', event => {
+  event.waitUntil(caches.open(CACHE).then(cache => cache.addAll(SHELL)).then(() => self.skipWaiting()));
+});
+
+self.addEventListener('activate', event => {
+  event.waitUntil(caches.keys().then(keys => Promise.all(
+    keys.filter(key => key.startsWith('stackchain-dashboard-') && key !== CACHE)
+      .map(key => caches.delete(key))
+  )).then(() => self.clients.claim()));
+});
+
+self.addEventListener('fetch', event => {
+  const request = event.request;
+  if (request.method !== 'GET' || request.url.includes('/api/')) return;
+  const url = new URL(request.url);
+  if (url.origin !== self.location.origin || !url.pathname.startsWith(BASE)) return;
+  if (request.mode === 'navigate') {
+    event.respondWith(
+      fetch(request).then(async response => {
+        const cache = await caches.open(CACHE);
+        if (response.ok) {
+          await cache.put(BASE, response.clone());
+        } else if (OUTAGE_STATUSES.has(response.status)) {
+          const cached = await cache.match(BASE);
+          if (cached) return cached;
+        }
+        return response;
+      }).catch(async () => {
+        const cache = await caches.open(CACHE);
+        return cache.match(BASE);
+      })
+    );
+    return;
+  }
+  if (url.origin === self.location.origin && SHELL.includes(url.pathname)) {
+    event.respondWith(caches.match(request).then(cached => cached || fetch(request)));
+  }
+});

src/gitea_proxy.py

@@ -533,8 +533,30 @@ async def notification_detail(thread_id: int) -> dict:
     subject = subject_value if isinstance(subject_value, dict) else {}
     subject_path = _gitea_api_path(subject.get("url"))
     comment_path = _gitea_api_path(subject.get("latest_comment_url"))
-    subject_detail = await fetch(subject_path) if subject_path else {}
-    comment = await fetch(comment_path) if comment_path else {}
+    conversation_match = re.fullmatch(
+        r"repos/([^/]+/[^/]+)/(issues|pulls)/(\d+)", subject_path
+    )
+    repository_name = repository.get("full_name")
+    supported_conversation = (
+        conversation_match
+        and conversation_match.group(1) == repository_name
+        and subject.get("type") in {"Issue", "Pull"}
+    )
+    if supported_conversation:
+        assert conversation_match is not None
+        subject_detail, comment, conversation = await asyncio.gather(
+            fetch(subject_path),
+            fetch(comment_path) if comment_path else asyncio.sleep(0, result={}),
+            issue_conversation_page(
+                conversation_match.group(1), int(conversation_match.group(3))
+            ),
+        )
+    else:
+        subject_detail, comment, conversation = await asyncio.gather(
+            fetch(subject_path) if subject_path else asyncio.sleep(0, result={}),
+            fetch(comment_path) if comment_path else asyncio.sleep(0, result={}),
+            asyncio.sleep(0, result={"comments": [], "page": 1, "older_page": None, "total": 0}),
+        )
     subject_detail = subject_detail if isinstance(subject_detail, dict) else {}
     comment = comment if isinstance(comment, dict) else {}
     user_value = comment.get("user")
@@ -573,9 +595,33 @@ async def notification_detail(thread_id: int) -> dict:
             else "",
             "url": latest_url,
         },
+        "conversation": conversation,
     }
 
 
+async def notification_conversation_page(
+    thread_id: int, page: int, limit: int = 20
+) -> dict:
+    thread = await fetch(f"notifications/threads/{thread_id}")
+    if not isinstance(thread, dict):
+        raise ValueError("Gitea notification thread response was not an object")
+    repository = thread.get("repository")
+    subject = thread.get("subject")
+    if not isinstance(repository, dict) or not isinstance(subject, dict):
+        raise ValueError("Notification does not identify a conversation")
+    subject_path = _gitea_api_path(subject.get("url"))
+    match = re.fullmatch(r"repos/([^/]+/[^/]+)/(issues|pulls)/(\d+)", subject_path)
+    if (
+        not match
+        or match.group(1) != repository.get("full_name")
+        or subject.get("type") not in {"Issue", "Pull"}
+    ):
+        raise ValueError("Notification subject is not a supported conversation")
+    return await issue_conversation_page(
+        match.group(1), int(match.group(3)), page=page, limit=limit
+    )
+
+
 async def reply_to_notification(thread_id: int, body: str) -> dict:
     thread = await fetch(f"notifications/threads/{thread_id}")
     if not isinstance(thread, dict):
@@ -604,10 +650,7 @@ async def reply_to_notification(thread_id: int, body: str) -> dict:
     comment = response.json()
     if not isinstance(comment, dict):
         raise ValueError("Gitea comment response was not an object")
-    return {
-        "id": comment.get("id"),
-        "url": _safe_web_url(comment.get("html_url")),
-    }
+    return _normalize_issue_comment(comment)
 
 
 async def close_issue(repository: str, number: int) -> dict:
@@ -708,10 +751,16 @@ async def create_issue(
     body: str,
     assignee: str,
     label_ids: list[int] | None = None,
+    milestone_id: int | None = None,
+    due_date: str | None = None,
 ) -> dict:
     payload: dict = {"title": title, "body": body, "assignee": assignee}
     if label_ids:
         payload["labels"] = label_ids
+    if milestone_id is not None:
+        payload["milestone"] = milestone_id
+    if due_date is not None:
+        payload["due_date"] = due_date
     response = await _get_client().post(
         f"/api/v1/repos/{repository}/issues",
         headers=_auth(),
@@ -732,6 +781,22 @@ async def create_issue(
         raise ValueError("Gitea did not confirm issue self-assignment")
     labels_value = issue.get("labels")
     labels = labels_value if isinstance(labels_value, list) else []
+    milestone_value = issue.get("milestone")
+    milestone = (
+        {"id": milestone_value["id"], "title": milestone_value["title"]}
+        if isinstance(milestone_value, dict)
+        and isinstance(milestone_value.get("id"), int)
+        and isinstance(milestone_value.get("title"), str)
+        else None
+    )
+    confirmed_due_date = (
+        issue.get("due_date") if isinstance(issue.get("due_date"), str) else None
+    )
+    if (
+        (milestone_id is not None and (milestone or {}).get("id") != milestone_id)
+        or (due_date is not None and confirmed_due_date != due_date)
+    ):
+        raise ValueError("Gitea did not confirm issue release plan")
     return {
         "id": issue.get("id"),
         "number": issue["number"],
@@ -748,6 +813,8 @@ async def create_issue(
             if isinstance(item, dict) and isinstance(item.get("name"), str)
         ],
         "assignees": confirmed_assignees,
+        "milestone": milestone,
+        "due_date": confirmed_due_date,
         "updated_at": issue.get("updated_at", "")
         if isinstance(issue.get("updated_at"), str)
         else "",

src/main.py

@@ -4,6 +4,7 @@ import os
 import time
 from collections.abc import Awaitable, Coroutine
 from contextlib import asynccontextmanager
+from datetime import datetime
 from pathlib import Path
 from typing import Any, Literal
 
@@ -151,6 +152,12 @@ class IssueCreation(BaseModel):
     title: str = Field(min_length=1, max_length=255)
     body: str = Field(default="", max_length=10_000)
     label_ids: list[int] = Field(default_factory=list, max_length=20)
+    milestone_id: PositiveInt | None = None
+    due_date: str | None = Field(
+        default=None,
+        pattern=r"^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}Z$",
+        max_length=20,
+    )
 
     @field_validator("title")
     @classmethod
@@ -165,6 +172,13 @@ class IssueCreation(BaseModel):
     def strip_issue_body(cls, value: str) -> str:
         return value.strip()
 
+    @field_validator("due_date")
+    @classmethod
+    def validate_due_date(cls, value: str | None) -> str | None:
+        if value is not None:
+            datetime.strptime(value, "%Y-%m-%dT%H:%M:%SZ")
+        return value
+
 
 class IssueContentUpdate(BaseModel):
     title: str = Field(min_length=1, max_length=255)
@@ -1095,6 +1109,32 @@ async def notification_thread_detail(
     return JSONResponse(result)
 
 
+@app.get("/api/v1/notifications/{thread_id}/conversation")
+async def notification_thread_conversation(
+    thread_id: int = PathParam(gt=0),
+    page: int = Query(ge=1),
+    limit: int = Query(default=20, ge=1, le=50),
+) -> JSONResponse:
+    try:
+        result = await asyncio.wait_for(
+            gitea_proxy.notification_conversation_page(thread_id, page, limit),
+            timeout=NOTIFICATION_DETAIL_TIMEOUT_SECONDS,
+        )
+    except TimeoutError:
+        return JSONResponse(
+            {"error": "Loading older messages timed out. Please retry."},
+            status_code=503,
+            headers={"Retry-After": "1"},
+        )
+    except Exception:
+        return JSONResponse(
+            {"error": "Older messages are temporarily unavailable. Please retry."},
+            status_code=503,
+            headers={"Retry-After": "1"},
+        )
+    return JSONResponse(result)
+
+
 @app.patch("/api/v1/notifications/{thread_id}/read")
 async def read_notification(thread_id: int = PathParam(gt=0)) -> JSONResponse:
     try:
@@ -1413,6 +1453,27 @@ async def create_assigned_issue(
             }
             if any(label_id not in valid_label_ids for label_id in creation.label_ids):
                 raise HTTPException(status_code=422, detail="Unknown repository label")
+        if creation.milestone_id is not None:
+            available_milestones = await gitea_proxy.repo_milestones(repository)
+            valid_milestone_ids = {
+                item.get("id")
+                for item in available_milestones
+                if isinstance(item, dict) and isinstance(item.get("id"), int)
+            }
+            if creation.milestone_id not in valid_milestone_ids:
+                raise HTTPException(
+                    status_code=422, detail="Unknown open repository milestone"
+                )
+        if creation.milestone_id is not None or creation.due_date is not None:
+            return await gitea_proxy.create_issue(
+                repository,
+                creation.title,
+                creation.body,
+                login,
+                creation.label_ids,
+                creation.milestone_id,
+                creation.due_date,
+            )
         return await gitea_proxy.create_issue(
             repository, creation.title, creation.body, login, creation.label_ids
         )
@@ -1427,6 +1488,8 @@ async def create_assigned_issue(
                 creation.title,
                 creation.body,
                 tuple(creation.label_ids),
+                creation.milestone_id,
+                creation.due_date,
             ),
             timeout=ISSUE_ACTION_TIMEOUT_SECONDS,
         )

src/views.py

@@ -1,12 +1,35 @@
 from pathlib import Path
 
 from fastapi import APIRouter
-from fastapi.responses import HTMLResponse
+from fastapi.responses import FileResponse, HTMLResponse
 
 router = APIRouter()
 DASHBOARD_FILE = Path(__file__).resolve().parent.parent / "frontend" / "index.html"
+MANIFEST_FILE = DASHBOARD_FILE.parent / "manifest.webmanifest"
+SERVICE_WORKER_FILE = DASHBOARD_FILE.parent / "service-worker.js"
 
 
-@router.get("/", response_class=HTMLResponse)
+class RevalidatingHTMLResponse(HTMLResponse):
+    def __init__(self, content, status_code=200, headers=None, media_type=None, background=None):
+        response_headers = dict(headers or {})
+        response_headers["Cache-Control"] = "no-cache"
+        super().__init__(content, status_code, response_headers, media_type, background)
+
+
+@router.get("/", response_class=RevalidatingHTMLResponse)
 async def dashboard() -> str:
     return DASHBOARD_FILE.read_text()
+
+
+@router.get("/manifest.webmanifest", response_class=FileResponse)
+async def web_app_manifest() -> FileResponse:
+    return FileResponse(MANIFEST_FILE, media_type="application/manifest+json")
+
+
+@router.get("/service-worker.js", response_class=FileResponse)
+async def service_worker() -> FileResponse:
+    return FileResponse(
+        SERVICE_WORKER_FILE,
+        media_type="application/javascript",
+        headers={"Service-Worker-Allowed": "/", "Cache-Control": "no-cache"},
+    )

tests/test_authored_outbox.py

@@ -0,0 +1,136 @@
+import json
+import subprocess
+from pathlib import Path
+
+import pytest
+
+from src.views import dashboard
+
+
+OUTBOX = Path(__file__).parents[1] / "frontend" / "authored-outbox.js"
+
+
+def run_node(script: str):
+    result = subprocess.run(["node", "-e", script], check=True, capture_output=True, text=True)
+    return json.loads(result.stdout)
+
+
+def test_authored_outbox_persists_each_message_kind_and_flushes_sequentially():
+    script = f"""
+const createAuthoredOutbox = require({json.dumps(str(OUTBOX))});
+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 calls = [];
+const outbox = createAuthoredOutbox({{
+  storage, now:() => 1234,
+  fetchJson:async (url, options) => {{
+    calls.push({{url,key:options.headers['Idempotency-Key'],body:JSON.parse(options.body)}});
+    return {{id:calls.length}};
+  }},
+}});
+outbox.enqueue({{kind:'issue-comment',repository:'stackchain/api',number:7,body:'Issue note',operationId:'issue-op'}});
+outbox.enqueue({{kind:'pull-comment',repository:'stackchain/web',number:8,body:'PR note',operationId:'pull-op'}});
+outbox.enqueue({{kind:'update-reply',notificationId:9,body:'Update note',operationId:'update-op'}});
+const persisted = createAuthoredOutbox({{storage,fetchJson:outbox.fetchJson}}).list();
+outbox.flush().then(result => process.stdout.write(JSON.stringify({{persisted,calls,result,remaining:outbox.list()}})));
+"""
+    output = run_node(script)
+
+    assert [item["kind"] for item in output["persisted"]] == [
+        "issue-comment", "pull-comment", "update-reply"
+    ]
+    assert [item["operationId"] for item in output["persisted"]] == ["issue-op", "pull-op", "update-op"]
+    assert output["calls"] == [
+        {"url": "api/v1/repos/stackchain/api/issues/7/comments", "key": "issue-op", "body": {"body": "Issue note"}},
+        {"url": "api/v1/repos/stackchain/web/pulls/8/comments", "key": "pull-op", "body": {"body": "PR note"}},
+        {"url": "api/v1/notifications/9/reply", "key": "update-op", "body": {"body": "Update note"}},
+    ]
+    assert len(output["result"]["confirmed"]) == 3
+    assert output["remaining"] == []
+
+
+def test_authored_outbox_classifies_failures_and_continues_past_attention_items():
+    script = f"""
+const createAuthoredOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+let phase = 'permanent';
+const calls = [];
+const outbox = createAuthoredOutbox({{
+  storage,
+  fetchJson:async (_url, options) => {{
+    const body = JSON.parse(options.body).body; calls.push(body);
+    if (body === 'Bad' && phase === 'permanent') {{ const e = new Error('Reply rejected'); e.status=422; throw e; }}
+    if (body === 'Later' && phase === 'transient') {{ const e = new Error('Offline'); e.status=503; throw e; }}
+    return {{id:calls.length}};
+  }},
+}});
+const bad=outbox.enqueue({{kind:'issue-comment',repository:'o/r',number:1,body:'Bad',operationId:'a'}});
+outbox.enqueue({{kind:'pull-comment',repository:'o/r',number:2,body:'Good',operationId:'b'}});
+outbox.flush().then(async first => {{
+  phase='transient';
+  outbox.enqueue({{kind:'update-reply',notificationId:3,body:'Later',operationId:'c'}});
+  const second=await outbox.flush();
+  process.stdout.write(JSON.stringify({{first,second,calls,remaining:outbox.list(),badId:bad.id}}));
+}});
+"""
+    output = run_node(script)
+
+    assert output["calls"] == ["Bad", "Good", "Later"]
+    assert len(output["first"]["confirmed"]) == 1
+    assert output["remaining"][0]["id"] == output["badId"]
+    assert output["remaining"][0]["status"] == "attention"
+    assert output["remaining"][0]["error"] == "Reply rejected"
+    assert output["remaining"][1]["status"] == "queued"
+
+
+def test_authored_outbox_retry_is_single_flight_and_edit_rotates_identity():
+    script = f"""
+const createAuthoredOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+let release; const gate=new Promise(resolve=>release=resolve); let calls=0; let sequence=0;
+const outbox=createAuthoredOutbox({{
+  storage, createOperationId:()=> 'new-' + (++sequence),
+  fetchJson:async()=>{{calls++; await gate; return {{id:1}};}},
+}});
+const item=outbox.enqueue({{kind:'issue-comment',repository:'o/r',number:1,body:'Old',operationId:'old'}});
+const edited=outbox.update(item.id,{{body:'New'}});
+const flush=outbox.flush(); const retry=outbox.retry(item.id); release();
+Promise.all([flush,retry]).then(results=>process.stdout.write(JSON.stringify({{edited,calls,results,remaining:outbox.list()}})));
+"""
+    output = run_node(script)
+
+    assert output["edited"]["body"] == "New"
+    assert output["edited"]["operationId"] == "new-1"
+    assert output["calls"] == 1
+    assert output["remaining"] == []
+
+
+def test_authored_outbox_deduplicates_repeated_queue_attempts_by_operation_id():
+    script = f"""
+const createAuthoredOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v)}};
+const outbox=createAuthoredOutbox({{storage}});
+const first=outbox.enqueue({{kind:'issue-comment',repository:'o/r',number:1,body:'Same',operationId:'stable'}});
+const second=outbox.enqueue({{kind:'issue-comment',repository:'o/r',number:1,body:'Same',operationId:'stable'}});
+process.stdout.write(JSON.stringify({{first,second,items:outbox.list()}}));
+"""
+    output = run_node(script)
+
+    assert output["first"] == output["second"]
+    assert len(output["items"]) == 1
+
+
+@pytest.mark.anyio
+async def test_mobile_dashboard_loads_and_operates_authored_message_outbox():
+    html = await dashboard()
+
+    assert '<script src="static/authored-outbox.js"></script>' in html
+    assert "createAuthoredOutbox({ storage: localStorage" in html
+    assert "window.addEventListener('online', flushAuthoredOutbox)" in html
+    assert "authoredOutbox.enqueue" in html
+    assert "authoredOutbox.retry(item.outbox_id)" in html
+    assert "authoredOutbox.discard(item.outbox_id)" in html
+    assert "if (result?.queued)" in html

tests/test_drafts.py

@@ -102,6 +102,25 @@ process.stdout.write(JSON.stringify(drafts));
     assert output[0]["route"] == {"kind": "issue", "repository": "stackchain/api", "number": 18}
 
 
+def test_draft_inbox_expands_issue_outbox_items_with_actionable_states():
+    script = f"""
+const createDraftInbox = require({json.dumps(str(DRAFTS))});
+const values = new Map([['stackchain.issue-outbox.v1', JSON.stringify({{version:1,items:[
+  {{id:'queued-1',repository:'stackchain/api',title:'Offline capture',body:'Context',status:'queued',queuedAt:100}},
+  {{id:'attention-2',repository:'stackchain/web',title:'Fix labels',body:'Details',status:'attention',error:'Unknown label',queuedAt:200}},
+]}})]]);
+const storage = {{get length(){{return values.size}},key:i=>Array.from(values.keys())[i]||null,getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+const drafts = createDraftInbox({{storage,now:()=>300}}).list();
+process.stdout.write(JSON.stringify(drafts));
+"""
+    output = run_node(script)
+
+    assert [item["outbox_id"] for item in output] == ["attention-2", "queued-1"]
+    assert [item["status"] for item in output] == ["attention", "queued"]
+    assert output[0]["label"] == "Needs attention"
+    assert output[1]["label"] == "Queued issue"
+
+
 @pytest.mark.anyio
 async def test_mobile_dashboard_exposes_touch_safe_draft_recovery_lane():
     html = await dashboard()

tests/test_gitea_notifications.py

@@ -136,11 +136,20 @@ async def test_notification_detail_loads_subject_and_latest_comment_for_inbox_re
             return httpx.Response(200, json={"body": "Deploy fails after **three** retries."})
         if request.url.path.endswith("/issues/comments/9"):
             return httpx.Response(200, json={
+                "id": 9,
                 "body": "Logs point to the worker timeout.",
                 "created_at": "2026-08-06T12:30:00Z",
                 "user": {"login": "alexander"},
                 "html_url": "https://forge.example/stackchain/api/issues/7#issuecomment-9",
             })
+        if request.url.path.endswith("/issues/7/comments"):
+            return httpx.Response(200, json=[{
+                "id": 9,
+                "body": "Logs point to the worker timeout.",
+                "created_at": "2026-08-06T12:30:00Z",
+                "user": {"login": "alexander"},
+                "html_url": "https://forge.example/stackchain/api/issues/7#issuecomment-9",
+            }], headers={"X-Total-Count": "1"})
         return httpx.Response(404)
 
     gitea_proxy.start_client(transport=httpx.MockTransport(upstream))
@@ -153,6 +162,7 @@ async def test_notification_detail_loads_subject_and_latest_comment_for_inbox_re
         "http://127.0.0.1:3000/api/v1/notifications/threads/42",
         "http://127.0.0.1:3000/api/v1/repos/stackchain/api/issues/7",
         "http://127.0.0.1:3000/api/v1/repos/stackchain/api/issues/comments/9",
+        "http://127.0.0.1:3000/api/v1/repos/stackchain/api/issues/7/comments?limit=20&page=1",
     ]
     assert result == {
         "id": 42,
@@ -168,6 +178,18 @@ async def test_notification_detail_loads_subject_and_latest_comment_for_inbox_re
             "created_at": "2026-08-06T12:30:00Z",
             "url": "https://forge.example/stackchain/api/issues/7#issuecomment-9",
         },
+        "conversation": {
+            "comments": [{
+                "id": 9,
+                "author": "alexander",
+                "body": "Logs point to the worker timeout.",
+                "created_at": "2026-08-06T12:30:00Z",
+                "url": "https://forge.example/stackchain/api/issues/7#issuecomment-9",
+            }],
+            "page": 1,
+            "older_page": None,
+            "total": 1,
+        },
     }
 
 
@@ -223,6 +245,9 @@ async def test_reply_to_notification_posts_to_its_issue_conversation(subject_kin
             })
         return httpx.Response(201, json={
             "id": 91,
+            "user": {"login": "timmy"},
+            "body": "Please retry the worker.",
+            "created_at": "2026-08-07T19:00:00Z",
             "html_url": "https://forge.example/stackchain/api/issues/7#issuecomment-91",
         })
 
@@ -246,5 +271,8 @@ async def test_reply_to_notification_posts_to_its_issue_conversation(subject_kin
     ]
     assert result == {
         "id": 91,
+        "author": "timmy",
+        "body": "Please retry the worker.",
+        "created_at": "2026-08-07T19:00:00Z",
         "url": "https://forge.example/stackchain/api/issues/7#issuecomment-91",
     }

tests/test_issue_api.py

@@ -373,6 +373,55 @@ async def test_create_issue_endpoint_derives_self_assignment_and_returns_confirm
     assert calls == [("stackchain/api", "Capture mobile work", "Context", "timmy", [3])]
 
 
+@pytest.mark.anyio
+async def test_create_issue_atomically_validates_and_sends_release_plan(monkeypatch):
+    calls = []
+
+    async def user():
+        return {"login": "timmy"}
+
+    async def available_repos():
+        return [{"full_name": "stackchain/api"}]
+
+    async def milestones(repository):
+        assert repository == "stackchain/api"
+        return [{"id": 9, "title": "August RC"}]
+
+    async def create(repository, title, body, assignee, label_ids, milestone_id, due_date):
+        calls.append((repository, title, body, assignee, label_ids, milestone_id, due_date))
+        return {
+            "id": 221, "number": 221, "title": title, "state": "open",
+            "repository": repository, "labels": [], "assignees": [assignee],
+            "milestone": {"id": 9, "title": "August RC"},
+            "due_date": "2026-08-31T23:59:59Z",
+            "updated_at": "2026-08-07T20:00:00Z",
+            "url": "https://forge.example/stackchain/api/issues/221",
+        }
+
+    monkeypatch.setattr(main.gitea_proxy, "current_user", user)
+    monkeypatch.setattr(main.gitea_proxy, "repos", available_repos)
+    monkeypatch.setattr(main.gitea_proxy, "repo_milestones", milestones)
+    monkeypatch.setattr(main.gitea_proxy, "create_issue", create)
+    transport = httpx.ASGITransport(app=main.app)
+    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
+        response = await client.post(
+            "/api/v1/repos/stackchain/api/issues",
+            json={
+                "title": "Ship mobile plan",
+                "milestone_id": 9,
+                "due_date": "2026-08-31T23:59:59Z",
+            },
+        )
+
+    assert response.status_code == 201
+    assert response.json()["milestone"] == {"id": 9, "title": "August RC"}
+    assert response.json()["due_date"] == "2026-08-31T23:59:59Z"
+    assert calls == [(
+        "stackchain/api", "Ship mobile plan", "", "timmy", [], 9,
+        "2026-08-31T23:59:59Z",
+    )]
+
+
 @pytest.mark.anyio
 async def test_create_issue_replays_one_upstream_result_for_concurrent_idempotent_requests(monkeypatch):
     calls = 0
@@ -630,6 +679,26 @@ async def test_gitea_create_issue_posts_self_assignment_and_normalizes_confirmat
     assert result["labels"] == ["P0"]
 
 
+@pytest.mark.anyio
+async def test_gitea_create_issue_requires_confirmed_release_plan():
+    async def handler(_request):
+        return httpx.Response(201, json={
+            "id": 221, "number": 221, "title": "Planned work", "state": "open",
+            "assignees": [{"login": "timmy"}], "labels": [],
+            "milestone": None, "due_date": "2026-09-01T23:59:59Z",
+        })
+
+    gitea_proxy.start_client(transport=httpx.MockTransport(handler))
+    try:
+        with pytest.raises(ValueError, match="release plan"):
+            await gitea_proxy.create_issue(
+                "stackchain/api", "Planned work", "", "timmy", [], 9,
+                "2026-08-31T23:59:59Z",
+            )
+    finally:
+        await gitea_proxy.stop_client()
+
+
 @pytest.mark.anyio
 async def test_gitea_repo_labels_returns_safe_touch_picker_options():
     requests = []
@@ -702,6 +771,27 @@ async def test_create_issue_rejects_blank_title_before_upstream(monkeypatch):
     assert called is False
 
 
+@pytest.mark.anyio
+async def test_create_issue_rejects_nonexistent_due_date_before_upstream(monkeypatch):
+    called = False
+
+    async def user():
+        nonlocal called
+        called = True
+        return {"login": "timmy"}
+
+    monkeypatch.setattr(main.gitea_proxy, "current_user", user)
+    transport = httpx.ASGITransport(app=main.app)
+    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
+        response = await client.post(
+            "/api/v1/repos/stackchain/api/issues",
+            json={"title": "Impossible plan", "due_date": "2026-02-31T23:59:59Z"},
+        )
+
+    assert response.status_code == 422
+    assert called is False
+
+
 @pytest.mark.anyio
 async def test_create_issue_rejects_label_not_in_target_repository(monkeypatch):
     created = False

tests/test_issue_outbox.py

@@ -0,0 +1,150 @@
+import json
+import subprocess
+from pathlib import Path
+
+import pytest
+
+from src.views import dashboard
+
+
+OUTBOX = Path(__file__).parents[1] / "frontend" / "issue-outbox.js"
+
+
+def run_node(script: str):
+    result = subprocess.run(["node", "-e", script], check=True, capture_output=True, text=True)
+    return json.loads(result.stdout)
+
+
+def test_issue_outbox_queues_multiple_planned_issues_with_stable_operation_ids():
+    script = f"""
+const createIssueOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{
+  getItem:key => values.has(key) ? values.get(key) : null,
+  setItem:(key,value) => values.set(key,value),
+  removeItem:key => values.delete(key),
+}};
+let sequence = 0;
+const outbox = createIssueOutbox({{storage, createOperationId:() => 'op-' + (++sequence), now:() => 1000 + sequence}});
+outbox.enqueue({{repository:'stackchain/api',title:'First',body:'One',labelIds:[3]}});
+outbox.enqueue({{repository:'stackchain/web',title:'Second',body:'Two',milestoneId:4,dueDate:'2026-08-09'}});
+const reloaded = createIssueOutbox({{storage}}).list();
+process.stdout.write(JSON.stringify({{items:reloaded, stored:JSON.parse(values.get('stackchain.issue-outbox.v1'))}}));
+"""
+    output = run_node(script)
+
+    assert [(item["repository"], item["title"]) for item in output["items"]] == [
+        ("stackchain/api", "First"),
+        ("stackchain/web", "Second"),
+    ]
+    assert [item["operationId"] for item in output["items"]] == ["op-1", "op-2"]
+    assert all(item["status"] == "queued" for item in output["items"])
+    assert output["stored"]["version"] == 1
+
+
+def test_issue_outbox_flushes_sequentially_and_keeps_transient_failures_queued():
+    script = f"""
+const createIssueOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+let sequence = 0;
+const calls = [];
+const outbox = createIssueOutbox({{
+  storage,
+  createOperationId:() => 'stable-' + (++sequence),
+  fetchJson:async (url, options) => {{
+    calls.push({{url, key:options.headers['Idempotency-Key']}});
+    if (calls.length === 2) {{ const error = new Error('upstream unavailable'); error.status = 503; throw error; }}
+    return {{repository:'stackchain/api',number:41,title:'First'}};
+  }},
+}});
+outbox.enqueue({{repository:'stackchain/api',title:'First',body:'One'}});
+outbox.enqueue({{repository:'stackchain/web',title:'Second',body:'Two'}});
+outbox.flush().then(result => process.stdout.write(JSON.stringify({{result,calls,remaining:outbox.list()}})));
+"""
+    output = run_node(script)
+
+    assert output["result"]["confirmed"][0]["number"] == 41
+    assert output["calls"] == [
+        {"url": "api/v1/repos/stackchain/api/issues", "key": "stable-1"},
+        {"url": "api/v1/repos/stackchain/web/issues", "key": "stable-2"},
+    ]
+    assert len(output["remaining"]) == 1
+    assert output["remaining"][0]["title"] == "Second"
+    assert output["remaining"][0]["status"] == "queued"
+
+
+def test_issue_outbox_preserves_permanent_failures_for_edit_and_retry():
+    script = f"""
+const createIssueOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+let invalid = true;
+const calls = [];
+const outbox = createIssueOutbox({{
+  storage, createOperationId:() => 'stable-edit',
+  fetchJson:async (_url, options) => {{
+    calls.push({{key:options.headers['Idempotency-Key'],body:JSON.parse(options.body)}});
+    if (invalid) {{ const error = new Error('Title is invalid'); error.status = 422; throw error; }}
+    return {{repository:'stackchain/api',number:42,title:'Fixed title'}};
+  }},
+}});
+const queued = outbox.enqueue({{repository:'stackchain/api',title:'Bad',body:'Context'}});
+outbox.flush().then(async () => {{
+  const attention = outbox.list()[0];
+  outbox.update(queued.id, {{...attention,title:'Fixed title'}});
+  invalid = false;
+  const result = await outbox.retry(queued.id);
+  process.stdout.write(JSON.stringify({{attention,result,calls,remaining:outbox.list()}}));
+}});
+"""
+    output = run_node(script)
+
+    assert output["attention"]["status"] == "attention"
+    assert output["attention"]["error"] == "Title is invalid"
+    assert [call["key"] for call in output["calls"]] == ["stable-edit", "stable-edit"]
+    assert output["calls"][1]["body"]["title"] == "Fixed title"
+    assert output["result"]["confirmed"][0]["number"] == 42
+    assert output["remaining"] == []
+
+
+def test_issue_outbox_is_single_flight_when_reconnect_and_send_now_overlap():
+    script = f"""
+const createIssueOutbox = require({json.dumps(str(OUTBOX))});
+const values = new Map();
+const storage = {{getItem:k=>values.get(k)||null,setItem:(k,v)=>values.set(k,v),removeItem:k=>values.delete(k)}};
+let calls = 0;
+let release;
+const gate = new Promise(resolve => {{ release = resolve; }});
+const outbox = createIssueOutbox({{
+  storage, createOperationId:() => 'single-flight',
+  fetchJson:async () => {{ calls += 1; await gate; return {{repository:'stackchain/api',number:43,title:'Once'}}; }},
+}});
+const queued = outbox.enqueue({{repository:'stackchain/api',title:'Once',body:'Context'}});
+const reconnect = outbox.flush();
+const sendNow = outbox.retry(queued.id);
+release();
+Promise.all([reconnect,sendNow]).then(results => process.stdout.write(JSON.stringify({{calls,results,remaining:outbox.list()}})));
+"""
+    output = run_node(script)
+
+    assert output["calls"] == 1
+    assert output["remaining"] == []
+    assert sum(len(result["confirmed"]) for result in output["results"]) >= 1
+
+
+@pytest.mark.anyio
+async def test_mobile_dashboard_queues_offline_captures_and_exposes_outbox_actions():
+    html = await dashboard()
+
+    assert '<script src="static/issue-outbox.js"></script>' in html
+    assert "createIssueOutbox({ storage: localStorage" in html
+    assert "issueOutbox.enqueue(captureDraft)" in html
+    assert "navigator.onLine" in html
+    assert "window.addEventListener('online', flushIssueOutbox)" in html
+    assert 'class="draft-send"' in html
+    assert 'class="draft-edit"' in html
+    assert 'Queued for sync' in html
+    assert 'Needs attention' in html
+    assert "issueOutbox.discard(item.outbox_id)" in html
+    assert '.draft-actions { display:grid; grid-template-columns:repeat(auto-fit,minmax(120px,1fr));' in html

tests/test_mobile_task_dock.py

@@ -0,0 +1,93 @@
+import json
+import subprocess
+from pathlib import Path
+
+import pytest
+
+from src.views import dashboard
+
+
+DOCK = Path(__file__).resolve().parents[1] / "frontend" / "mobile-task-dock.js"
+
+
+def test_mobile_task_dock_routes_actions_hides_for_overlays_and_restores_focus():
+    script = f"""
+const createDock = require({json.dumps(str(DOCK))});
+class FakeElement {{
+  constructor() {{
+    this.listeners = {{}};
+    this.attributes = {{}};
+    this.classList = {{ values:new Set(), contains:value => this.classList.values.has(value) }};
+    this.hidden = false;
+    this.focuses = 0;
+  }}
+  addEventListener(name, callback) {{ this.listeners[name] = callback; }}
+  click() {{ this.listeners.click({{currentTarget:this}}); }}
+  setAttribute(name, value) {{ this.attributes[name] = value; }}
+  removeAttribute(name) {{ delete this.attributes[name]; }}
+  focus() {{ this.focuses += 1; }}
+}}
+const nav = new FakeElement();
+const buttons = Object.fromEntries(['work','find','new','search','drafts'].map(name => [name, new FakeElement()]));
+const overlay = new FakeElement();
+const calls = [];
+let observerCallback;
+const dock = createDock({{
+  nav, buttons, overlays:[overlay],
+  actions: Object.fromEntries(Object.keys(buttons).map(name => [name, () => calls.push(name)])),
+  observe(callback) {{ observerCallback = callback; return {{disconnect() {{}}}}; }},
+}});
+dock.start();
+buttons.work.click();
+buttons.find.click();
+overlay.classList.values.add('open'); observerCallback();
+const hiddenWhileOpen = nav.hidden;
+overlay.classList.values.delete('open'); observerCallback();
+buttons.drafts.click();
+process.stdout.write(JSON.stringify({{
+  calls, hiddenWhileOpen, hiddenAfterClose:nav.hidden,
+  findFocuses:buttons.find.focuses,
+  current:Object.fromEntries(Object.entries(buttons).map(([name, button]) => [name, button.attributes['aria-current'] || null])),
+}}));
+"""
+    result = subprocess.run(
+        ["node", "-e", script], capture_output=True, text=True
+    )
+
+    assert result.returncode == 0, result.stderr
+    assert json.loads(result.stdout) == {
+        "calls": ["work", "find", "drafts"],
+        "hiddenWhileOpen": True,
+        "hiddenAfterClose": False,
+        "findFocuses": 1,
+        "current": {
+            "work": None,
+            "find": None,
+            "new": None,
+            "search": None,
+            "drafts": "page",
+        },
+    }
+
+
+@pytest.mark.anyio
+async def test_dashboard_renders_and_wires_phone_safe_task_dock():
+    html = await dashboard()
+
+    assert '<nav class="mobile-task-dock" id="mobile-task-dock" aria-label="Primary tasks">' in html
+    assert html.count('class="mobile-task-action" data-mobile-task=') == 5
+    for task in ("work", "find", "new", "search", "drafts"):
+        assert f'data-mobile-task="{task}"' in html
+    assert 'id="mobile-draft-count"' in html
+    assert '.mobile-task-dock { display:none;' in html
+    assert 'grid-template-columns:repeat(5,minmax(0,1fr))' in html
+    assert 'padding-bottom:env(safe-area-inset-bottom)' in html
+    assert '.mobile-task-action { min-width:0; min-height:44px;' in html
+    assert '<script src="static/mobile-task-dock.js"></script>' in html
+    assert "createMobileTaskDock({" in html
+    assert "work: () => qs('#my-work').scrollIntoView" in html
+    assert "find: () => qs('#find-work').click()" in html
+    assert "new: () => qs('#new-issue').click()" in html
+    assert "search: () => qs('#open-palette').click()" in html
+    assert "drafts: () => qs('[data-work-filter=\"draft\"]').click()" in html
+    assert "draftCount.textContent = sourceDraftCount.textContent" in html

tests/test_my_work.py

@@ -521,6 +521,33 @@ async def test_mobile_issue_sheet_exposes_touch_sized_due_date_editor_and_card_b
     assert 'padding-bottom:calc(10px + env(safe-area-inset-bottom))' in html
 
 
+@pytest.mark.anyio
+async def test_new_issue_sheet_exposes_touch_safe_release_planning_controls():
+    html = await dashboard()
+
+    assert 'id="create-issue-milestone"' in html
+    assert 'id="create-issue-due-date" type="date"' in html
+    assert 'id="create-issue-milestone-status" aria-live="polite"' in html
+    assert '.create-issue-form select, .create-issue-form input[type="date"] { min-height:44px;' in html
+    assert 'issueCapture.loadMilestones(repository)' in html
+    assert "milestoneId: Number(qs('#create-issue-milestone').value) || null" in html
+    assert "dueDate: qs('#create-issue-due-date').value" in html
+
+
+@pytest.mark.anyio
+async def test_dashboard_launches_share_capture_with_draft_conflict_choices():
+    html = await dashboard()
+
+    assert '<link rel="manifest" href="manifest.webmanifest"' in html
+    assert "issueCapture.stageSharedContent(sharedLaunch)" in html
+    assert 'id="use-shared-content"' in html
+    assert 'id="resume-issue-draft"' in html
+    assert 'id="shared-content-conflict"' in html
+    assert '.shared-content-actions button { min-height:44px;' in html
+    assert "history.replaceState({}, '', cleanUrl)" in html
+    assert "navigator.serviceWorker.register('service-worker.js')" in html
+
+
 @pytest.mark.anyio
 async def test_mobile_my_work_exposes_touch_safe_milestone_lane_and_issue_editor():
     html = await dashboard()
@@ -1219,6 +1246,105 @@ first.submit(draft).catch(() => {{
     assert output["number"] == 17
 
 
+def test_issue_capture_normalizes_shared_mobile_content_without_repeating_source_url():
+    script = f"""
+const createIssueCapture = require({json.dumps(str(CREATE_ISSUE_SHEET))});
+const normalized = createIssueCapture.normalizeSharedContent({{
+  title: '  Production alert  ',
+  text: 'Latency crossed the threshold https://status.example/incidents/42',
+  url: 'https://status.example/incidents/42',
+}});
+process.stdout.write(JSON.stringify(normalized));
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+
+    assert json.loads(result.stdout) == {
+        "title": "Production alert",
+        "body": "Latency crossed the threshold https://status.example/incidents/42",
+    }
+
+
+def test_issue_capture_suggests_a_title_when_mobile_share_only_contains_text():
+    script = f"""
+const createIssueCapture = require({json.dumps(str(CREATE_ISSUE_SHEET))});
+process.stdout.write(JSON.stringify(createIssueCapture.normalizeSharedContent({{
+  text: 'Investigate checkout latency before the release window opens. More diagnostic context follows.'
+}})));
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+
+    assert json.loads(result.stdout) == {
+        "title": "Investigate checkout latency before the release window opens.",
+        "body": "Investigate checkout latency before the release window opens. More diagnostic context follows.",
+    }
+
+
+def test_issue_capture_keeps_existing_draft_until_shared_content_is_accepted():
+    script = f"""
+const createIssueCapture = require({json.dumps(str(CREATE_ISSUE_SHEET))});
+const values = new Map();
+const storage = {{
+  getItem:key => values.get(key) || null,
+  setItem:(key,value) => values.set(key,value),
+  removeItem:key => values.delete(key),
+}};
+let capture = createIssueCapture({{storage, fetchJson:()=>Promise.resolve({{}})}});
+capture.saveDraft({{
+  repository:'stackchain/api', title:'Existing draft', body:'Keep me', labelIds:[3], milestoneId:9,
+}});
+const staged = capture.stageSharedContent({{title:'Shared alert', text:'Investigate', url:'https://status.example/42'}});
+const before = capture.loadDraft();
+capture = createIssueCapture({{storage, fetchJson:()=>Promise.resolve({{}})}});
+const pendingAfterReload = capture.pendingSharedContent();
+const accepted = capture.acceptSharedContent();
+process.stdout.write(JSON.stringify({{staged, before, pendingAfterReload, accepted, pending:capture.pendingSharedContent()}}));
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+
+    assert json.loads(result.stdout) == {
+        "staged": {"status": "conflict"},
+        "before": {
+            "repository": "stackchain/api", "title": "Existing draft", "body": "Keep me",
+            "labelIds": [3], "milestoneId": 9,
+        },
+        "pendingAfterReload": {
+            "title": "Shared alert", "body": "Investigate\n\nhttps://status.example/42",
+        },
+        "accepted": {
+            "repository": "stackchain/api", "title": "Shared alert",
+            "body": "Investigate\n\nhttps://status.example/42", "labelIds": [3], "milestoneId": 9,
+        },
+        "pending": None,
+    }
+
+
+def test_issue_capture_can_resume_existing_draft_and_discard_staged_share():
+    script = f"""
+const createIssueCapture = require({json.dumps(str(CREATE_ISSUE_SHEET))});
+const values = new Map();
+const storage = {{getItem:key=>values.get(key)||null, setItem:(key,value)=>values.set(key,value), removeItem:key=>values.delete(key)}};
+const capture = createIssueCapture({{storage, fetchJson:()=>Promise.resolve({{}})}});
+capture.saveDraft({{repository:'stackchain/api', title:'Existing', body:'Keep', labelIds:[]}});
+capture.stageSharedContent({{title:'Incoming', text:'Replace'}});
+capture.discardSharedContent();
+process.stdout.write(JSON.stringify({{draft:capture.loadDraft(), pending:capture.pendingSharedContent()}}));
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+
+    assert json.loads(result.stdout) == {
+        "draft": {"repository": "stackchain/api", "title": "Existing", "body": "Keep", "labelIds": []},
+        "pending": None,
+    }
+
+
 def test_issue_capture_loads_repository_labels_with_priorities_first():
     script = f"""
 const createIssueCapture = require({json.dumps(str(CREATE_ISSUE_SHEET))});
@@ -1245,6 +1371,50 @@ capture.loadLabels('stackchain/api').then(labels => process.stdout.write(JSON.st
     assert [label["name"] for label in output["labels"]] == ["P0", "critical", "frontend"]
 
 
+def test_issue_capture_persists_and_submits_milestone_and_due_date():
+    script = f"""
+const createIssueCapture = require({json.dumps(str(CREATE_ISSUE_SHEET))});
+const values = new Map();
+const calls = [];
+const storage = {{
+  getItem:key => values.get(key) || null,
+  setItem:(key,value) => values.set(key,value),
+  removeItem:key => values.delete(key),
+}};
+const capture = createIssueCapture({{
+  storage,
+  createOperationId: () => 'planned-operation',
+  fetchJson: (url, options) => {{
+    calls.push({{url, body:options?.body ? JSON.parse(options.body) : null}});
+    if (url.endsWith('/milestones')) return Promise.resolve([{{id:9,title:'August RC'}}]);
+    return Promise.resolve({{number:221, milestone:{{id:9,title:'August RC'}}, due_date:'2026-08-31T23:59:59Z'}});
+  }},
+}});
+const draft = {{repository:'stackchain/api', title:'Ship plan', body:'', labelIds:[], milestoneId:9, dueDate:'2026-08-31'}};
+capture.saveDraft(draft);
+Promise.all([capture.loadMilestones('stackchain/api'), capture.submit(capture.loadDraft())]).then(results =>
+  process.stdout.write(JSON.stringify({{calls, stored:results[1], milestones:results[0]}}))
+);
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+    output = json.loads(result.stdout)
+
+    assert output["calls"] == [
+        {"url": "api/v1/repos/stackchain/api/milestones", "body": None},
+        {
+            "url": "api/v1/repos/stackchain/api/issues",
+            "body": {
+                "title": "Ship plan", "body": "", "label_ids": [],
+                "milestone_id": 9, "due_date": "2026-08-31T23:59:59Z",
+            },
+        },
+    ]
+    assert output["milestones"] == [{"id": 9, "title": "August RC"}]
+    assert output["stored"]["number"] == 221
+
+
 def test_unread_updates_enrich_matching_work_and_keep_unassigned_mentions_actionable():
     payload = {
         "user": {"login": "timmy"},
@@ -1619,6 +1789,72 @@ reader.open(item, [item]).then(() =>
     }
 
 
+def test_notification_reader_pages_conversation_single_flight_and_ignores_stale_update():
+    script = f"""
+const build = require({json.dumps(str(MY_WORK))});
+const createPager = require({json.dumps(str(CONVERSATION))});
+const details = {{
+  42: {{id:42, conversation:{{comments:[{{id:41,created_at:'2026-08-07T12:41:00Z'}}],page:3,older_page:2,total:47}}}},
+  43: {{id:43, conversation:{{comments:[{{id:90,created_at:'2026-08-07T13:00:00Z'}}],page:1,older_page:null,total:1}}}},
+}};
+let release;
+const requested = [];
+const states = [];
+const reader = build.createNotificationReader({{
+  load: async id => details[id], createPager,
+  loadConversation: (id, page) => {{
+    requested.push([id, page]);
+    return new Promise(resolve => {{ release = () => resolve({{comments:[{{id:21,created_at:'2026-08-07T12:21:00Z'}}],page:2,older_page:1,total:47}}); }});
+  }},
+  markRead: async () => {{}}, onOpen: () => {{}}, onDetail: () => {{}},
+  onConversation: state => states.push(state.comments.map(item => item.id)),
+  onItems: () => {{}}, onStatus: () => {{}}, onClose: () => {{}},
+}});
+const firstItem = {{notification_id:42}};
+const secondItem = {{notification_id:43}};
+reader.open(firstItem).then(async () => {{
+  const first = reader.loadOlder();
+  const duplicate = reader.loadOlder();
+  await reader.open(secondItem);
+  release();
+  await Promise.all([first, duplicate]);
+  process.stdout.write(JSON.stringify({{requested, states}}));
+}});
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+    output = json.loads(result.stdout)
+
+    assert output["requested"] == [[42, 2]]
+    assert output["states"] == [[41], [90]]
+
+
+def test_notification_reader_appends_a_confirmed_reply_exactly_once():
+    script = f"""
+const build = require({json.dumps(str(MY_WORK))});
+const createPager = require({json.dumps(str(CONVERSATION))});
+const states = [];
+const reader = build.createNotificationReader({{
+  load: async () => ({{conversation:{{comments:[{{id:41}}],page:1,older_page:null,total:1}}}}),
+  loadConversation: async () => ({{}}), createPager,
+  markRead: async () => {{}}, onOpen: () => {{}}, onDetail: () => {{}},
+  onConversation: state => states.push(state.comments.map(item => item.id)),
+  onItems: () => {{}}, onStatus: () => {{}}, onClose: () => {{}},
+}});
+reader.open({{notification_id:42}}).then(() => {{
+  reader.appendReply({{id:91, author:'timmy', body:'Ship it'}});
+  reader.appendReply({{id:91, author:'timmy', body:'Ship it'}});
+  process.stdout.write(JSON.stringify(states));
+}});
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+
+    assert json.loads(result.stdout) == [[41], [41, 91], [41, 91]]
+
+
 def test_notification_reader_wraps_to_an_earlier_visible_unread_update():
     script = f"""
 const buildMyWork = require({json.dumps(str(MY_WORK))});
@@ -2283,7 +2519,7 @@ async def test_mobile_update_reader_is_in_app_safe_area_aware_and_actionable():
     assert 'id="keep-update-unread"' in html
     assert 'id="mark-update-read-next"' in html
     assert 'id="retry-update-load"' in html
-    assert 'id="update-comment-body"' in html
+    assert 'id="update-comments"' in html
     assert 'id="update-subject-body"' in html
     assert 'id="open-update-gitea"' in html
     assert '.update-sheet-panel { width:min(560px,100%);' in html
@@ -2882,6 +3118,23 @@ async def test_mobile_review_failure_offers_an_in_place_retry_for_the_same_item(
     assert "qs('#retry-review-load').focus()" in html
 
 
+@pytest.mark.anyio
+async def test_mobile_update_sheet_renders_and_pages_the_complete_conversation():
+    html = await dashboard()
+
+    update_sheet = html[html.index('id="update-sheet"'):html.index('id="pull-sheet"')]
+    assert '<h2>Full conversation</h2>' in update_sheet
+    assert 'id="update-comments"' in update_sheet
+    assert 'id="load-older-update-comments"' in update_sheet
+    assert 'id="update-conversation-status"' in update_sheet
+    assert '.conversation-more' in html and 'min-height:44px' in html
+    assert "'/conversation?page='" in html
+    assert "loadConversation: fetchNotificationConversation" in html
+    assert "onConversation: renderUpdateConversation" in html
+    assert "notificationReader.loadOlder()" in html
+    assert "notificationReader.appendReply(result)" in html
+
+
 def test_issue_comment_reuses_operation_key_after_reload_until_success():
     script = f"""
 const createIssueSheet = require({json.dumps(str(ISSUE_SHEET))});

tests/test_notification_detail.py

@@ -3,7 +3,59 @@ import asyncio
 import httpx
 import pytest
 
-from src import main
+from src import gitea_proxy, main
+
+
+@pytest.mark.anyio
+async def test_notification_detail_opens_the_newest_conversation_page_in_chronological_order(monkeypatch):
+    requested_pages = []
+
+    def comment(comment_id):
+        return {
+            "id": comment_id,
+            "user": {"login": f"user-{comment_id}"},
+            "body": f"message {comment_id}",
+            "created_at": f"2026-08-06T12:{comment_id:02d}:00Z",
+            "html_url": f"https://forge.example/stackchain/api/issues/7#issuecomment-{comment_id}",
+        }
+
+    def handler(request):
+        if request.url.path.endswith("/notifications/threads/42"):
+            return httpx.Response(200, json={
+                "repository": {"full_name": "stackchain/api"},
+                "subject": {
+                    "type": "Issue", "title": "Retry failed deploy", "state": "open",
+                    "url": "https://forge.example/api/v1/repos/stackchain/api/issues/7",
+                    "latest_comment_url": "https://forge.example/api/v1/repos/stackchain/api/issues/comments/47",
+                    "html_url": "https://forge.example/stackchain/api/issues/7",
+                },
+            })
+        if request.url.path.endswith("/repos/stackchain/api/issues/7/comments"):
+            page = int(request.url.params["page"])
+            requested_pages.append(page)
+            comments = [comment(i) for i in (range(1, 21) if page == 1 else range(41, 48))]
+            return httpx.Response(200, json=comments, headers={"X-Total-Count": "47"})
+        if request.url.path.endswith("/repos/stackchain/api/issues/7"):
+            return httpx.Response(200, json={"body": "Deploy fails after retries."})
+        if request.url.path.endswith("/repos/stackchain/api/issues/comments/47"):
+            return httpx.Response(200, json=comment(47))
+        raise AssertionError(f"unexpected request: {request.url}")
+
+    monkeypatch.setattr(gitea_proxy, "GITEA_URL", "https://forge.example")
+    gitea_proxy.start_client(transport=httpx.MockTransport(handler))
+    try:
+        result = await gitea_proxy.notification_detail(42)
+    finally:
+        await gitea_proxy.stop_client()
+
+    assert requested_pages == [1, 3]
+    assert [item["id"] for item in result["conversation"]["comments"]] == list(range(41, 48))
+    assert result["conversation"] == {
+        "comments": result["conversation"]["comments"],
+        "page": 3,
+        "older_page": 2,
+        "total": 47,
+    }
 
 
 @pytest.mark.anyio
@@ -41,6 +93,32 @@ async def test_notification_detail_api_is_bounded_and_never_cacheable(monkeypatc
     assert calls == [42]
 
 
+@pytest.mark.anyio
+async def test_notification_conversation_api_loads_one_bounded_older_page(monkeypatch):
+    calls = []
+
+    async def conversation(thread_id, page, limit):
+        calls.append((thread_id, page, limit))
+        return {
+            "comments": [{"id": 21, "author": "timmy", "body": "Earlier context"}],
+            "page": page,
+            "older_page": 1,
+            "total": 47,
+        }
+
+    monkeypatch.setattr(main.gitea_proxy, "notification_conversation_page", conversation, raising=False)
+    transport = httpx.ASGITransport(app=main.app)
+    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
+        response = await client.get("/api/v1/notifications/42/conversation?page=2&limit=20")
+        invalid = await client.get("/api/v1/notifications/42/conversation?page=0&limit=51")
+
+    assert response.status_code == 200
+    assert response.json()["comments"][0]["id"] == 21
+    assert response.headers["cache-control"] == "no-store"
+    assert invalid.status_code == 422
+    assert calls == [(42, 2, 20)]
+
+
 @pytest.mark.anyio
 async def test_notification_detail_timeout_is_sanitized_and_retryable(monkeypatch):
     async def detail(_thread_id):

tests/test_notification_reply.py

@@ -3,7 +3,42 @@ import asyncio
 import httpx
 import pytest
 
-from src import main
+from src import gitea_proxy, main
+
+
+@pytest.mark.anyio
+async def test_notification_reply_returns_the_confirmed_comment_for_exact_once_append(monkeypatch):
+    def handler(request):
+        if request.method == "GET":
+            return httpx.Response(200, json={
+                "repository": {"full_name": "stackchain/api"},
+                "subject": {
+                    "type": "Issue",
+                    "url": "https://forge.example/api/v1/repos/stackchain/api/issues/7",
+                },
+            })
+        return httpx.Response(201, json={
+            "id": 91,
+            "user": {"login": "timmy"},
+            "body": "Please retry the worker.",
+            "created_at": "2026-08-07T19:00:00Z",
+            "html_url": "https://forge.example/stackchain/api/issues/7#issuecomment-91",
+        })
+
+    monkeypatch.setattr(gitea_proxy, "GITEA_URL", "https://forge.example")
+    gitea_proxy.start_client(transport=httpx.MockTransport(handler))
+    try:
+        result = await gitea_proxy.reply_to_notification(42, "Please retry the worker.")
+    finally:
+        await gitea_proxy.stop_client()
+
+    assert result == {
+        "id": 91,
+        "author": "timmy",
+        "body": "Please retry the worker.",
+        "created_at": "2026-08-07T19:00:00Z",
+        "url": "https://forge.example/stackchain/api/issues/7#issuecomment-91",
+    }
 
 
 @pytest.mark.anyio

tests/test_offline_work.py

@@ -0,0 +1,115 @@
+import json
+import subprocess
+from pathlib import Path
+
+import pytest
+
+from src.views import dashboard
+
+
+OFFLINE_WORK = Path(__file__).parents[1] / "frontend" / "offline-work.js"
+
+
+def run_scenario(scenario: str) -> dict:
+    script = f"""
+const createOfflineWorkStore = require({json.dumps(str(OFFLINE_WORK))});
+const values = new Map();
+const storage = {{
+  getItem: key => values.has(key) ? values.get(key) : null,
+  setItem: (key, value) => values.set(key, value),
+  removeItem: key => values.delete(key),
+}};
+{scenario}
+"""
+    result = subprocess.run(
+        ["node", "-e", script], check=True, capture_output=True, text=True
+    )
+    return json.loads(result.stdout)
+
+
+def test_opted_in_snapshot_survives_restart_with_only_queue_card_fields():
+    result = run_scenario("""
+const store = createOfflineWorkStore({storage, now:() => new Date('2026-08-07T12:00:00Z')});
+store.setEnabled(true);
+store.save({
+  user:{login:'timmy', full_name:'Timmy', token:'secret'},
+  issues:[{id:1, number:8, title:'Ship offline work', body:'private body', state:'open',
+    repository:'stackchain/dashboard', labels:['P0'], assignees:['timmy'],
+    updated_at:'2026-08-07T11:00:00Z', url:'https://forge.example/issues/8'}],
+  pull_requests:[],
+  notifications:[{id:9, number:8, title:'Updated', unread:true, subject_body:'private comment',
+    repository:'stackchain/dashboard', subject_type:'Issue', updated_at:'2026-08-07T11:30:00Z',
+    url:'https://forge.example/issues/8'}],
+  work_pagination:{issue:{page:1,total:1,has_more:false}},
+  repos:[{private:true}], events:[{body:'private event'}],
+});
+const restarted = createOfflineWorkStore({storage, now:() => new Date('2026-08-07T12:01:00Z')});
+process.stdout.write(JSON.stringify({loaded:restarted.load('timmy'), raw:[...values.values()].join(' ')}));
+""")
+
+    assert result["loaded"]["user"] == {"login": "timmy", "full_name": "Timmy"}
+    assert result["loaded"]["issues"][0]["title"] == "Ship offline work"
+    assert result["loaded"]["notifications"][0]["unread"] is True
+    assert result["loaded"]["saved_at"] == "2026-08-07T12:00:00.000Z"
+    assert "private body" not in result["raw"]
+    assert "private comment" not in result["raw"]
+    assert "private event" not in result["raw"]
+    assert "secret" not in result["raw"]
+
+
+def test_expired_snapshot_is_deleted_and_wrong_user_cannot_load_it():
+    result = run_scenario("""
+const writer = createOfflineWorkStore({storage, now:() => new Date('2026-08-01T12:00:00Z'), maxAgeMs:1000});
+writer.setEnabled(true);
+writer.save({user:{login:'timmy'}, issues:[], pull_requests:[], notifications:[]});
+const wrongUser = writer.load('alexander');
+const expired = createOfflineWorkStore({storage, now:() => new Date('2026-08-01T12:00:02Z'), maxAgeMs:1000});
+const expiredValue = expired.load('timmy');
+process.stdout.write(JSON.stringify({wrongUser, expiredValue, snapshotStillStored:values.has('stackchain.offline-work.snapshot.v1')}));
+""")
+
+    assert result == {
+        "wrongUser": None,
+        "expiredValue": None,
+        "snapshotStillStored": False,
+    }
+
+
+def test_opting_out_deletes_the_persisted_snapshot():
+    result = run_scenario("""
+const store = createOfflineWorkStore({storage});
+store.setEnabled(true);
+store.save({user:{login:'timmy'}, issues:[], pull_requests:[], notifications:[]});
+store.setEnabled(false);
+process.stdout.write(JSON.stringify({enabled:store.enabled(), loaded:store.load()}));
+""")
+
+    assert result == {"enabled": False, "loaded": None}
+
+
+@pytest.mark.anyio
+async def test_dashboard_offers_private_offline_work_controls_and_read_only_hydration():
+    html = await dashboard()
+
+    assert '<script src="static/offline-work.js"></script>' in html
+    assert 'id="keep-work-offline"' in html
+    assert 'Keep My Work available offline' in html
+    assert 'id="clear-offline-work"' in html
+    assert 'id="offline-work-status"' in html
+    assert 'offlineWorkStore.save({' in html
+    assert 'offlineWorkStore.load()' in html
+    assert 'Offline · saved ' in html
+    assert "setOfflineWorkMode(true)" in html
+    assert "if (offlineWorkMode)" in html
+    assert '.offline-work-controls button { min-height:44px;' in html
+
+
+@pytest.mark.anyio
+async def test_initial_http_outage_hydrates_saved_work_and_recovers_on_live_snapshot():
+    html = await dashboard()
+
+    assert "if (!hasContextSnapshot && hydrateOfflineWork('outage')) return;" in html
+    assert "Outage · saved " in html
+    assert "Server unavailable · showing private My Work saved " in html
+    assert "Live details and actions will return automatically." in html
+    assert "function renderLiveSnapshot(snapshot) {\n    setOfflineWorkMode(false);\n    offlineStatus.hidden = true;" in html

tests/test_service_worker.py

@@ -0,0 +1,196 @@
+import json
+import subprocess
+from pathlib import Path
+
+import pytest
+
+
+WORKER = Path(__file__).resolve().parents[1] / "frontend" / "service-worker.js"
+
+
+def run_worker_scenario(scenario: str) -> dict:
+    harness = f"""
+const fs = require('fs');
+const vm = require('vm');
+const listeners = {{}};
+const state = {{ added: [], deleted: [], claimed: false, skipped: false, fetches: [], puts: [], failFetch: false, fetchStatus: 200, cachedBody: null }};
+const cache = {{
+  addAll: async urls => {{ state.added = urls; }},
+  match: async request => state.cachedBody === null ? null : new Response(state.cachedBody),
+  put: async (request, response) => {{ state.puts.push(String(request.url || request)); }},
+}};
+const context = {{
+  URL, Request, Response,
+  console,
+  self: {{
+    location: {{ href: 'https://forge.example/dashboard/service-worker.js', origin: 'https://forge.example' }},
+    addEventListener: (name, handler) => {{ listeners[name] = handler; }},
+    skipWaiting: async () => {{ state.skipped = true; }},
+    clients: {{ claim: async () => {{ state.claimed = true; }} }},
+  }},
+  caches: {{
+    open: async () => cache,
+    keys: async () => ['stackchain-dashboard-old', 'another-app-cache'],
+    delete: async key => {{ state.deleted.push(key); return true; }},
+    match: async request => cache.match(request),
+  }},
+  fetch: async request => {{
+    state.fetches.push(String(request.url || request));
+    if (state.failFetch) throw new Error('offline');
+    return new Response('network', {{ status: state.fetchStatus }});
+  }},
+}};
+vm.createContext(context);
+vm.runInContext(fs.readFileSync({json.dumps(str(WORKER))}, 'utf8'), context);
+async function dispatch(name, request) {{
+  let pending;
+  let response;
+  listeners[name]({{
+    request,
+    waitUntil: promise => {{ pending = promise; }},
+    respondWith: promise => {{ response = promise; }},
+  }});
+  if (pending) await pending;
+  return response ? await response : null;
+}}
+(async () => {{
+{scenario}
+}})().catch(error => {{ console.error(error); process.exit(1); }});
+"""
+    completed = subprocess.run(
+        ["node", "-e", harness], capture_output=True, check=True, text=True
+    )
+    return json.loads(completed.stdout)
+
+
+def test_install_precaches_complete_subpath_scoped_app_shell():
+    result = run_worker_scenario(
+        """
+  await dispatch('install');
+  process.stdout.write(JSON.stringify(state));
+"""
+    )
+
+    assert result["skipped"] is True
+    assert result["added"][0] == "/dashboard/"
+    assert set(result["added"]) == {
+        "/dashboard/",
+        "/dashboard/manifest.webmanifest",
+        "/dashboard/static/icons/stackchain-192.png",
+        "/dashboard/static/icons/stackchain-512.png",
+        "/dashboard/static/markdown.js",
+        "/dashboard/static/commands.js",
+        "/dashboard/static/search-preview.js",
+        "/dashboard/static/widgets.js",
+        "/dashboard/static/drafts.js",
+        "/dashboard/static/issue-outbox.js",
+        "/dashboard/static/authored-outbox.js",
+        "/dashboard/static/offline-work.js",
+        "/dashboard/static/my-work.js",
+        "/dashboard/static/pick-work.js",
+        "/dashboard/static/conversation.js",
+        "/dashboard/static/issue-sheet.js",
+        "/dashboard/static/create-issue-sheet.js",
+        "/dashboard/static/pull-sheet.js",
+        "/dashboard/static/review-sheet.js",
+        "/dashboard/static/work-route.js",
+        "/dashboard/static/context-poller.js",
+        "/dashboard/static/mobile-task-dock.js",
+    }
+
+
+def test_activate_deletes_only_stale_stackchain_caches():
+    result = run_worker_scenario(
+        """
+  await dispatch('activate');
+  process.stdout.write(JSON.stringify(state));
+"""
+    )
+
+    assert result["claimed"] is True
+    assert result["deleted"] == ["stackchain-dashboard-old"]
+
+
+def test_offline_navigation_returns_cached_shell_for_share_target_url():
+    result = run_worker_scenario(
+        """
+  state.failFetch = true;
+  state.cachedBody = 'cached dashboard';
+  const response = await dispatch('fetch', {
+    method: 'GET', mode: 'navigate',
+    url: 'https://forge.example/dashboard/?title=Shared&url=https%3A%2F%2Fexample.com',
+  });
+  process.stdout.write(JSON.stringify({ body: await response.text(), state }));
+"""
+    )
+
+    assert result["body"] == "cached dashboard"
+    assert result["state"]["fetches"] == [
+        "https://forge.example/dashboard/?title=Shared&url=https%3A%2F%2Fexample.com"
+    ]
+
+
+def test_cross_origin_navigation_is_not_intercepted_or_cached():
+    result = run_worker_scenario(
+        """
+  const response = await dispatch('fetch', {
+    method: 'GET', mode: 'navigate', url: 'https://outside.example/page',
+  });
+  process.stdout.write(JSON.stringify({ intercepted: response !== null, state }));
+"""
+    )
+
+    assert result["intercepted"] is False
+    assert result["state"]["fetches"] == []
+    assert result["state"]["puts"] == []
+
+
+@pytest.mark.parametrize("status", [500, 502, 503, 504])
+def test_server_outage_navigation_returns_working_cached_shell_without_replacing_it(status):
+    result = run_worker_scenario(
+        f"""
+  state.fetchStatus = {status};
+  state.cachedBody = 'cached dashboard';
+  const response = await dispatch('fetch', {{
+    method: 'GET', mode: 'navigate', url: 'https://forge.example/dashboard/',
+  }});
+  process.stdout.write(JSON.stringify({{ status: response.status, body: await response.text(), state }}));
+"""
+    )
+
+    assert result["status"] == 200
+    assert result["body"] == "cached dashboard"
+    assert result["state"]["puts"] == []
+
+
+def test_server_outage_without_cached_shell_preserves_network_error():
+    result = run_worker_scenario(
+        """
+  state.fetchStatus = 503;
+  const response = await dispatch('fetch', {
+    method: 'GET', mode: 'navigate', url: 'https://forge.example/dashboard/',
+  });
+  process.stdout.write(JSON.stringify({ status: response.status, body: await response.text(), state }));
+"""
+    )
+
+    assert result["status"] == 503
+    assert result["body"] == "network"
+    assert result["state"]["puts"] == []
+
+
+def test_client_error_navigation_is_not_hidden_by_cached_shell():
+    result = run_worker_scenario(
+        """
+  state.fetchStatus = 401;
+  state.cachedBody = 'cached dashboard';
+  const response = await dispatch('fetch', {
+    method: 'GET', mode: 'navigate', url: 'https://forge.example/dashboard/',
+  });
+  process.stdout.write(JSON.stringify({ status: response.status, body: await response.text(), state }));
+"""
+    )
+
+    assert result["status"] == 401
+    assert result["body"] == "network"
+    assert result["state"]["puts"] == []

tests/test_work_pages.py

@@ -61,4 +61,53 @@ async def test_work_page_endpoint_rejects_unknown_stream_before_upstream_io(monk
         response = await client.get("/api/v1/work/unknown?page=2")
 
     assert response.status_code == 422
-    assert called is False
+    assert called is False
+
+
+@pytest.mark.anyio
+async def test_pwa_assets_expose_root_scoped_share_target_without_caching_api_data():
+    transport = httpx.ASGITransport(app=main.app)
+    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
+        manifest = await client.get("/manifest.webmanifest")
+        worker = await client.get("/service-worker.js")
+
+    assert manifest.status_code == 200
+    assert manifest.headers["content-type"].startswith("application/manifest+json")
+    assert manifest.json()["id"] == "./"
+    assert manifest.json()["start_url"] == "./"
+    assert manifest.json()["scope"] == "./"
+    assert manifest.json()["share_target"] == {
+        "action": "./", "method": "GET", "enctype": "application/x-www-form-urlencoded",
+        "params": {"title": "title", "text": "text", "url": "url"},
+    }
+    assert worker.status_code == 200
+    assert worker.headers["content-type"].startswith("application/javascript")
+    assert worker.headers["service-worker-allowed"] == "/"
+    assert "request.url.includes('/api/')" in worker.text
+    assert "request.method !== 'GET'" in worker.text
+    assert "new URL('./', self.location.href).pathname" in worker.text
+
+
+@pytest.mark.anyio
+async def test_dashboard_announces_offline_mode_and_refreshes_after_reconnect():
+    transport = httpx.ASGITransport(app=main.app)
+    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
+        response = await client.get("/")
+
+    assert response.status_code == 200
+    assert 'id="offline-status"' in response.text
+    assert 'role="status"' in response.text
+    assert 'aria-live="polite"' in response.text
+    assert "window.addEventListener('offline'" in response.text
+    assert "window.addEventListener('online'" in response.text
+    assert "contextPoller.refresh()" in response.text
+
+
+@pytest.mark.anyio
+async def test_dashboard_shell_revalidates_instead_of_being_stored_as_fresh():
+    transport = httpx.ASGITransport(app=main.app)
+    async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
+        response = await client.get("/")
+
+    assert response.status_code == 200
+    assert response.headers["cache-control"] == "no-cache"