diff --git a/electron/coding-runtime/pi/release-proof.ts b/electron/coding-runtime/pi/release-proof.ts
index 31476cd..a4716a7 100644
--- a/electron/coding-runtime/pi/release-proof.ts
+++ b/electron/coding-runtime/pi/release-proof.ts
@@ -405,8 +405,16 @@ function respondWithHoldingBashCall(response: ServerResponse, model: string): vo
   response.end('data: [DONE]\n\n');
 }
 
-function requestContains(body: Record<string, unknown>, marker: string): boolean {
-  return JSON.stringify(body.messages ?? []).includes(marker);
+function latestUserMessageContains(body: Record<string, unknown>, marker: string): boolean {
+  if (!Array.isArray(body.messages)) return false;
+  for (let index = body.messages.length - 1; index >= 0; index -= 1) {
+    const message = body.messages[index];
+    if (!message || typeof message !== 'object' || Array.isArray(message)) continue;
+    const record = message as { role?: unknown; content?: unknown };
+    if (record.role !== 'user') continue;
+    return JSON.stringify(record.content ?? '').includes(marker);
+  }
+  return false;
 }
 
 async function startLocalProofProvider(mode: ProofProviderMode): Promise<LocalProofProvider> {
@@ -434,18 +442,26 @@ async function startLocalProofProvider(mode: ProofProviderMode): Promise<LocalPr
           else respondWithHoldingBashCall(response, model);
           return;
         }
-        if (requestContains(body, 'RESILIENCE_TARGET_ACTIVE')) {
-          respondWithSubagentCall(response, model, 'coding');
-          return;
-        }
-        if (requestContains(body, 'RESILIENCE_RECOVERED_TURN')) {
+        if (latestUserMessageContains(body, 'RESILIENCE_RECOVERED_TURN')) {
           respondWithText(response, model, 'RESILIENCE_RECOVERED_COMPLETE');
           return;
         }
-        if (requestContains(body, 'RESILIENCE_SETTLED_BEFORE_CLOSE')) {
+        if (latestUserMessageContains(body, 'RESILIENCE_SETTLED_BEFORE_CLOSE')) {
           respondWithText(response, model, 'RESILIENCE_SETTLED_COMPLETE');
           return;
         }
+        if (latestUserMessageContains(body, 'RESILIENCE_PROTOCOL_ACTIVE')) {
+          response.writeHead(200, { 'content-type': 'text/event-stream' });
+          writeChunk(response, model, { role: 'assistant', content: 'RESILIENCE_ACTIVE' }, null);
+          const entry = { role, response };
+          held.add(entry);
+          response.once('close', () => held.delete(entry));
+          return;
+        }
+        if (latestUserMessageContains(body, 'RESILIENCE_TARGET_ACTIVE')) {
+          respondWithSubagentCall(response, model, 'coding');
+          return;
+        }
         response.writeHead(200, { 'content-type': 'text/event-stream' });
         writeChunk(response, model, { role: 'assistant', content: 'RESILIENCE_ACTIVE' }, null);
         const entry = { role, response };