fix: include user message in auto-capture when prePromptMessageCount excludes it (#1248)

Author: r266-tech

examples/openclaw-memory-plugin/index.ts

@@ -499,7 +499,7 @@ const memoryPlugin = {
         }
         try {
           const messages = event.messages;
-          const { texts: newTexts, newCount } = extractNewTurnTexts(messages, lastProcessedMsgCount);
+          const { texts: newTexts, newCount } = extractNewTurnTexts(messages, lastProcessedMsgCount, true);
           lastProcessedMsgCount = messages.length;
 
           if (newTexts.length === 0) {

examples/openclaw-memory-plugin/text-utils.ts

@@ -319,11 +319,17 @@ export function extractTextsFromUserMessages(messages: unknown[]): string[] {
 }
 
 /**
- * 提取从 startIndex 开始的新消息（user + assistant），返回格式化的文本。
+ * Extract new messages (user + assistant) starting from startIndex.
+ *
+ * Defensive fix (#1248): if ensureLastUserMessage is true and the last user
+ * message in the transcript falls before startIndex, prepend it to the result.
+ * This handles the case where prePromptMessageCount (OpenClaw's startIndex)
+ * excludes the current turn's user message.
  */
 export function extractNewTurnTexts(
   messages: unknown[],
   startIndex: number,
+  ensureLastUserMessage?: boolean,
 ): { texts: string[]; newCount: number } {
   const texts: string[] = [];
   let count = 0;
@@ -345,6 +351,36 @@ export function extractNewTurnTexts(
       }
     }
   }
+
+  // Defensive fix: ensure the last user message is included even if
+  // startIndex skipped it (OpenClaw prePromptMessageCount off-by-one)
+  if (ensureLastUserMessage && messages.length > 0) {
+    let lastUserText: string | null = null;
+    for (let i = messages.length - 1; i >= 0; i--) {
+      const msg = messages[i] as Record<string, unknown>;
+      if (!msg || typeof msg !== "object") continue;
+      if (msg.role === "user") {
+        const content = msg.content;
+        if (typeof content === "string" && content.trim()) {
+          lastUserText = `[user]: ${content.trim()}`;
+        } else if (Array.isArray(content)) {
+          for (const block of content) {
+            const b = block as Record<string, unknown>;
+            if (b?.type === "text" && typeof b.text === "string" && b.text.trim()) {
+              lastUserText = `[user]: ${b.text.trim()}`;
+              break;
+            }
+          }
+        }
+        break;
+      }
+    }
+    if (lastUserText && !texts.some((t) => t.startsWith("[user]:"))) {
+      texts.unshift(lastUserText);
+      count++;
+    }
+  }
+
   return { texts, newCount: count };
 }