diff --git a/tests/runner-e2e/PRODUCT-JOURNEYS.md b/tests/runner-e2e/PRODUCT-JOURNEYS.md
index 1ceb361d639..7b6ce0f9708 100644
--- a/tests/runner-e2e/PRODUCT-JOURNEYS.md
+++ b/tests/runner-e2e/PRODUCT-JOURNEYS.md
@@ -105,7 +105,7 @@ The private provider supplies its exact execution identity through the `agent`
 capability and collects normalized run usage. The existing Cloud provider still
 owns authentication, conditional leases, fixture ownership, and cleanup.
 
-The Plan and Stop final-answer checks reload the owned task and bind its exact,
+The Plan, Stop and protected-action decline checks reload the owned task and bind its exact,
 unique visible reply to the final successful native run. A settled native turn
 can render its saved reply before the comments projection exists; that path also
 requires exactly one matching final assistant message in the complete durable
@@ -115,6 +115,9 @@ satisfy the check. A pending or suppressed comment can use the same proven nativ
 reply path. A finish summary by itself, an earlier turn, a progress
 bubble, or a cancelled run cannot satisfy it. Private receipts record the run,
 thread anchor and observed text; classic protocol comment matchers stay strict.
+The decline oracle accepts this explicit native receipt without inventing an
+issue comment. The final run must start after the saved decline, and the usual
+truthful explanation, zero service calls and no unread marker checks still apply.
 A model allowance is an accounting threshold; reused direct-provider routes do
 not acquire the onboarding gateway's request-level cash guarantee. The question
 observer allows one run and waits at most four minutes. Cleanup stops only
diff --git a/tests/runner-e2e/connection-guidance-evidence.ts b/tests/runner-e2e/connection-guidance-evidence.ts
index 5d2c651af05..13eb097668c 100644
--- a/tests/runner-e2e/connection-guidance-evidence.ts
+++ b/tests/runner-e2e/connection-guidance-evidence.ts
@@ -1,11 +1,12 @@
 import type { StoryComment } from "./everyday-observations.js";
+import type { BoundTaskFinalReply } from "./native-task-reply.js";
 
 type Decision = {
   id: string; kind: string; status: string; resolvedAt?: string | null;
   result?: { answers?: Array<{ questionId: string; optionIds?: string[] }> };
 };
 type Reply = Pick<StoryComment, "authorAgentId" | "createdByRunId" | "createdAt" | "body">;
-type Run = { id: string; nativeIssueId?: string | null; agentId?: string | null; status: string; finishedAt?: string | null };
+type Run = { id: string; nativeIssueId?: string | null; agentId?: string | null; status: string; runtimeMode?: string | null; startedAt?: string | null; finishedAt?: string | null };
 
 // Additional oracle for the new neutral-prompt suite only. Historical Everyday
 // grades remain intact. This proves attributed saved output, not cognition.
@@ -16,6 +17,8 @@ export type ConnectionGuidanceDeclineInput = {
   leadAgentId: string;
   issueId: string;
   replies: Reply[];
+  /** Only the shared reloaded task-thread observer produces this receipt. */
+  nativeFinalReply?: BoundTaskFinalReply;
   runs: Run[];
   calls?: number;
   marker: string;
@@ -45,7 +48,18 @@ function declineReplyEvidence(input: ConnectionGuidanceDeclineInput) {
     Boolean(reply.createdByRunId) && run.id === reply.createdByRunId && run.agentId === input.leadAgentId && run.nativeIssueId === input.issueId &&
     run.status === "succeeded" && Date.parse(run.finishedAt ?? "") >= resolvedAt &&
     Date.parse(run.finishedAt ?? "") === finalRunTime));
-  return { validDecision, afterDecision, attributed };
+  const native = input.nativeFinalReply;
+  const nativeAttributed = input.caseId === "service-decline" && validDecision && native?.source === "native-turn"
+    && native.agentId === input.leadAgentId && native.observedAfterReload && native.visible && native.settled && native.nativeFinal
+    && native.finalEvent?.body === native.body
+    && (native.anchor === `${native.runId}:turn` || native.anchor?.startsWith(`${native.runId}:turn:`) === true)
+    && input.runs.some(run => run.id === native.runId && run.agentId === input.leadAgentId && run.nativeIssueId === input.issueId
+      && run.runtimeMode === "native" && run.status === "succeeded" && Date.parse(run.startedAt ?? "") >= resolvedAt
+      && Date.parse(run.finishedAt ?? "") === finalRunTime && finalRunTime >= resolvedAt);
+  // Keep native evidence explicit. It is a saved final-message/DOM receipt,
+  // never a synthetic issue comment or a finish-summary fallback.
+  return { validDecision, afterDecision: [...afterDecision, ...(nativeAttributed ? [native!] : [])],
+    attributed: [...attributed, ...(nativeAttributed ? [native!] : [])] };
 }
 
 /** Readiness waits for storage, not a passing explanation. Wrong wording must still fail grading. */
@@ -66,7 +80,7 @@ export function gradeConnectionGuidanceDecline(input: ConnectionGuidanceDeclineI
       detail: "Exactly one correctly typed, resolved decline belongs to the selected decision." },
     { id: "guidance-decline-attributed-explanation",
       passed: attributed.some(reply => typeof reply.body === "string" && explainsConnectionUnavailable(reply.body)),
-      detail: "A saved explanation follows the decision and joins by run ID to the lead's final successful execution on this task." },
+      detail: "A saved explanation follows the decision and joins to the final successful task run; native task replies also require the reloaded final-message receipt." },
     { id: "guidance-decline-no-use", passed: (input.caseId === "connection-decline" || input.calls === 0) && input.sameConnections &&
         afterDecision.every(reply => (typeof reply.body !== "string" || !reply.body.includes(input.marker))),
       detail: "No connection changes or unread marker in replies. Installed-service/provider declines also require an observed zero fixture-call count; Notion setup does not execute a service." },
diff --git a/tests/runner-e2e/connection-guidance.test.ts b/tests/runner-e2e/connection-guidance.test.ts
index 6609569cc0c..3b1159636b8 100644
--- a/tests/runner-e2e/connection-guidance.test.ts
+++ b/tests/runner-e2e/connection-guidance.test.ts
@@ -49,6 +49,43 @@ const passes = (input: Parameters<typeof gradeConnectionGuidanceDecline>[0]) =>
   gradeConnectionGuidanceDecline(input).every(check => check.passed);
 
 describe("neutral decline evidence", () => {
+  const native = () => ({ ...structuredClone(valid), caseId: "service-decline" as const, replies: [],
+    decisions: [{ id: "decision", kind: "request_confirmation", status: "rejected", resolvedAt: "2026-10-06T22:00:00Z" }],
+    runs: [{ ...valid.runs[0], runtimeMode: "native", startedAt: "2026-10-06T22:00:01Z" }],
+    nativeFinalReply: { runId: "run", agentId: "lead", body: valid.replies[0].body, source: "native-turn", observedAfterReload: true,
+      visible: true, settled: true, nativeFinal: true, anchor: "run:turn", finalEvent: { seq: 10, sourceEventId: "final", sourceInstanceId: "runner",
+        sourceSeq: 10, protocolSchemaVersion: 1, body: valid.replies[0].body } },
+  });
+  it("accepts a proven reloaded native final after the decline without inventing a comment", () => {
+    const input = native();
+    expect(hasConnectionGuidanceDeclineReply(input)).toBe(true);
+    expect(passes(input)).toBe(true);
+    expect(input.replies).toEqual([]);
+  });
+  it("excludes an earlier successful native reply when a later successful run exists", () => {
+    const input = native();
+    input.runs.push({ ...input.runs[0], id: "latest", startedAt: "2026-10-06T22:00:04Z", finishedAt: "2026-10-06T22:00:06Z" });
+    expect(hasConnectionGuidanceDeclineReply(input)).toBe(false);
+    expect(passes(input)).toBe(false);
+    Object.assign(input.nativeFinalReply, { runId: "latest", anchor: "latest:turn" });
+    Object.assign(input.nativeFinalReply.finalEvent, { sourceEventId: "latest-final", sourceInstanceId: "latest-runner" });
+    expect(passes(input)).toBe(true);
+  });
+  it("rejects stale, unbound or untruthful native decline output and unread service data", () => {
+    for (const change of [{ runId: "other" }, { agentId: "other" }, { source: "summary" }, { observedAfterReload: false },
+      { settled: false }, { nativeFinal: false }, { visible: false }, { anchor: "other:turn" }, { finalEvent: null }]) {
+      const input = native(); Object.assign(input.nativeFinalReply, change); expect(passes(input)).toBe(false);
+    }
+    for (const change of [{ startedAt: "2026-10-06T21:59:00Z" }, { startedAt: "invalid" }, { runtimeMode: "legacy" },
+      { nativeIssueId: "other" }, { agentId: "other" }, { status: "cancelled" }]) {
+      const input = native(); Object.assign(input.runs[0], change); expect(passes(input)).toBe(false);
+    }
+    for (const body of ["Done.", "Unavailable but PRIVATE_MARKER"]) {
+      const input = native(); input.nativeFinalReply.body = input.nativeFinalReply.finalEvent.body = body;
+      expect(hasConnectionGuidanceDeclineReply(input)).toBe(true); expect(passes(input)).toBe(false);
+    }
+    for (const change of [{ calls: 1 }, { sameConnections: false }, { decisions: [] }]) expect(passes({ ...native(), ...change })).toBe(false);
+  });
   it("accepts an attributed explanation after each kind of saved decline", () => {
     expect(passes(valid)).toBe(true);
     for (const [caseId, kind] of [["service-decline", "request_confirmation"], ["connection-decline", "connection_intent"]] as const) {
diff --git a/tests/runner-e2e/everyday-cases.ts b/tests/runner-e2e/everyday-cases.ts
index 51bf0de2ee2..153ac13096c 100644
--- a/tests/runner-e2e/everyday-cases.ts
+++ b/tests/runner-e2e/everyday-cases.ts
@@ -63,13 +63,13 @@ const definitions = [
   [
     "service-approve",
     "Use a connection after approval",
-    `Use the connected page service to find recent pages and create a short Markdown briefing document on this task. Include the titles and verification code returned by the service.`,
+    `Use the connected page service to find recent pages and create a short Markdown briefing document on this task. Put the returned page titles and service receipt code in the document. When complete, give me the document link.`,
     2,
   ],
   [
     "service-decline",
     "Respect a declined tool action",
-    `Use the connected page service to find recent pages and create a short Markdown briefing document on this task. Include the titles and verification code returned by the service. If I decline the action, do not try again or request another connection. Instead, give me a brief explanation that you could not retrieve the data. That explanation is the complete allowed fallback; no briefing is required after a decline.`,
+    `Use the connected page service to find recent pages and create a short Markdown briefing document on this task. Put the returned page titles and service receipt code in the document. When complete, give me the document link. If I decline the action, do not try again or request another connection. Instead, give me a brief explanation that you could not retrieve the data. That explanation is the complete allowed fallback; no briefing is required after a decline.`,
     2,
   ],
   [
diff --git a/tests/runner-e2e/native-task-reply.ts b/tests/runner-e2e/native-task-reply.ts
index f67e347c449..afe678b4732 100644
--- a/tests/runner-e2e/native-task-reply.ts
+++ b/tests/runner-e2e/native-task-reply.ts
@@ -5,6 +5,7 @@ type Row = Record<string, any>;
 export interface TaskReplyObservation {
   body: string; anchor: string | null; settled: boolean; nativeFinal: boolean; visible: boolean;
 }
+export type BoundTaskFinalReply = Awaited<ReturnType<typeof readBoundTaskFinalReply>>;
 
 /** Native task replies can render from a saved turn before a completion comment
  * is projected. Respect an explicit presentation decision when one exists. */
diff --git a/tests/runner-e2e/product-journeys/agent-flows.ts b/tests/runner-e2e/product-journeys/agent-flows.ts
index 0492a2a15ad..d2daa20c5f9 100644
--- a/tests/runner-e2e/product-journeys/agent-flows.ts
+++ b/tests/runner-e2e/product-journeys/agent-flows.ts
@@ -93,7 +93,7 @@ export async function runAgentJourney(id: AgentJourney, context: JourneyContext,
   const settled = (issue: Row, count: number) => waitFor(options.deadlineAt, () => read(issue), state =>
     state.currentIssue.status === "done" && state.taskRuns.length === count && state.taskRuns.every(run => !active(run))
     && state.interactions.every(row => row.status !== "pending"), "agent_task_not_completed");
-  const finalReply = async (issue: Row, state: TaskState, marker: string) => {
+  const finalReply = async (issue: Row, state: TaskState, marker?: string) => {
     const runs = state.taskRuns.filter(run => run.status === "succeeded");
     if (!runs.length || runs.some(run => !Number.isFinite(Date.parse(run.finishedAt)))) throw new JourneyError("failed", "final_run_time_missing");
     const run = [...runs].sort((a, b) => Date.parse(a.finishedAt) - Date.parse(b.finishedAt)).at(-1)!;
@@ -189,12 +189,14 @@ export async function runAgentJourney(id: AgentJourney, context: JourneyContext,
       check(`${phase}-decision-persisted`, final.interactions.some(row => row.id === decision.id && row.status === (decline ? "rejected" : "accepted")));
       check(`${phase}-service-call-count`, service.invocationCount() === callsBefore + (decline ? 0 : 1));
       if (decline) {
+        const nativeFinalReply = await finalReply(issue, final);
+        const refreshed = await read(issue);
         const connectionAfter = await context.api.get<Row>(`/api/tool-connections/${service.connectionId}`);
         const unchanged = (row: Row) => JSON.stringify({ id: row.id, companyId: row.companyId, status: row.status, enabled: row.enabled,
           installs: row.installs?.filter((install: Row) => install.targetType === "agent" && install.targetId === agent.id) });
         const checks = gradeConnectionGuidanceDecline({ caseId: "service-decline", decisionId: decision.id,
-          decisions: final.interactions as any, leadAgentId: agent.id, issueId: issue.id, replies: final.comments,
-          runs: final.taskRuns as any, marker: service.marker, calls: service.invocationCount() - callsBefore, sameConnections: unchanged(connectionBefore) === unchanged(connectionAfter) });
+          decisions: refreshed.interactions as any, leadAgentId: agent.id, issueId: issue.id, replies: refreshed.comments, nativeFinalReply,
+          runs: refreshed.taskRuns as any, marker: service.marker, calls: service.invocationCount() - callsBefore, sameConnections: unchanged(connectionBefore) === unchanged(connectionAfter) });
         await retain("service-decline-grade.json", checks);
         check("decline-truthful-explanation", checks.every(row => row.passed));
       } else {