feat(agent-manager): strip claude code tag

Author: codeaholicguy

packages/agent-manager/src/__tests__/utils/ClaudeSessionParser.test.ts

@@ -0,0 +1,195 @@
+/**
+ * Tests for utils/ClaudeSessionParser.ts — focused on stripping
+ * harness-injected XML tags from conversation content.
+ */
+
+import { describe, it, expect, beforeEach, afterEach } from '@jest/globals';
+import * as fs from 'fs';
+import * as os from 'os';
+import * as path from 'path';
+import { ClaudeSessionParser } from '../../utils/ClaudeSessionParser';
+
+interface JsonlEntry {
+    type: 'user' | 'assistant' | 'system';
+    message: { content: string | Array<{ type: string; text?: string; content?: string; name?: string; input?: unknown; is_error?: boolean }> };
+    timestamp?: string;
+}
+
+function writeSession(entries: JsonlEntry[]): string {
+    const dir = fs.mkdtempSync(path.join(os.tmpdir(), 'parser-test-'));
+    const filePath = path.join(dir, 'session.jsonl');
+    fs.writeFileSync(filePath, entries.map(e => JSON.stringify(e)).join('\n'));
+    return filePath;
+}
+
+describe('ClaudeSessionParser.getConversation — harness tag stripping', () => {
+    let parser: ClaudeSessionParser;
+    const tempFiles: string[] = [];
+
+    beforeEach(() => {
+        parser = new ClaudeSessionParser();
+    });
+
+    afterEach(() => {
+        for (const f of tempFiles) {
+            try {
+                fs.rmSync(path.dirname(f), { recursive: true, force: true });
+            } catch { /* best effort */ }
+        }
+        tempFiles.length = 0;
+    });
+
+    function makeSession(entries: JsonlEntry[]): string {
+        const f = writeSession(entries);
+        tempFiles.push(f);
+        return f;
+    }
+
+    it('strips <system-reminder> blocks from text content', () => {
+        const file = makeSession([
+            {
+                type: 'assistant',
+                message: {
+                    content: [{
+                        type: 'text',
+                        text: 'Real response here.\n<system-reminder>\nDo not mention this reminder.\n</system-reminder>\nMore response.',
+                    }],
+                },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv).toHaveLength(1);
+        expect(conv[0].content).toBe('Real response here.\n\nMore response.');
+    });
+
+    it('strips <local-command-stdout> blocks', () => {
+        const file = makeSession([
+            {
+                type: 'system',
+                message: { content: 'before <local-command-stdout>\nRunning...\nDone\n</local-command-stdout> after' },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('before  after');
+    });
+
+    it('strips <user-prompt-submit-hook> blocks', () => {
+        const file = makeSession([
+            {
+                type: 'user',
+                message: { content: '<user-prompt-submit-hook>hook output</user-prompt-submit-hook>\nactual question' },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('actual question');
+    });
+
+    it('strips bash and command stdout/stderr blocks', () => {
+        const file = makeSession([
+            {
+                type: 'assistant',
+                message: {
+                    content: [{
+                        type: 'text',
+                        text: 'Output:\n<bash-input>ls</bash-input>\n<bash-stdout>file.txt</bash-stdout>\n<bash-stderr></bash-stderr>\n<command-stdout>x</command-stdout>\n<command-stderr>y</command-stderr>\nEnd.',
+                    }],
+                },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('Output:\n\n\n\n\n\nEnd.'.replace(/\n{3,}/g, '\n\n'));
+        expect(conv[0].content).not.toMatch(/<bash-/);
+        expect(conv[0].content).not.toMatch(/<command-stdout>|<command-stderr>/);
+    });
+
+    it('collapses <command-name>/<command-args> into "/name args" shorthand', () => {
+        const file = makeSession([
+            {
+                type: 'user',
+                message: {
+                    content: '<command-message>debug</command-message>\n<command-name>/debug</command-name>\n<command-args>fix the bug</command-args>',
+                },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('/debug fix the bug');
+    });
+
+    it('handles <command-name> without <command-args>', () => {
+        const file = makeSession([
+            {
+                type: 'user',
+                message: {
+                    content: '<command-message>clear</command-message>\n<command-name>/clear</command-name>',
+                },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('/clear');
+    });
+
+    it('handles multiple harness tags mixed together', () => {
+        const file = makeSession([
+            {
+                type: 'user',
+                message: {
+                    content: [{
+                        type: 'text',
+                        text: '<system-reminder>ignore me</system-reminder>\n<command-message>build</command-message>\n<command-name>/build</command-name>\n<command-args>--watch</command-args>\n<local-command-stdout>build output here</local-command-stdout>',
+                    }],
+                },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('/build --watch');
+    });
+
+    it('leaves text without harness tags unchanged', () => {
+        const file = makeSession([
+            {
+                type: 'assistant',
+                message: { content: [{ type: 'text', text: 'Hello, world!' }] },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('Hello, world!');
+    });
+
+    it('drops a message that becomes empty after stripping', () => {
+        const file = makeSession([
+            {
+                type: 'system',
+                message: { content: '<system-reminder>only this</system-reminder>' },
+            },
+            {
+                type: 'assistant',
+                message: { content: [{ type: 'text', text: 'kept' }] },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv).toHaveLength(1);
+        expect(conv[0].content).toBe('kept');
+    });
+
+    it('strips tags spanning multiple lines', () => {
+        const multilineReminder = '<system-reminder>\nLine 1\nLine 2\nLine 3\n</system-reminder>';
+        const file = makeSession([
+            {
+                type: 'assistant',
+                message: { content: [{ type: 'text', text: `before\n${multilineReminder}\nafter` }] },
+            },
+        ]);
+
+        const conv = parser.getConversation(file);
+        expect(conv[0].content).toBe('before\n\nafter');
+    });
+});

packages/agent-manager/src/utils/ClaudeSessionParser.ts

@@ -347,9 +347,9 @@ export class ClaudeSessionParser {
         if (!content) return undefined;
 
         if (typeof content === 'string') {
-            const trimmed = content.trim();
-            if (role === 'user' && isNoiseMessage(trimmed)) return undefined;
-            return trimmed || undefined;
+            const cleaned = stripHarnessTags(content);
+            if (role === 'user' && isNoiseMessage(cleaned)) return undefined;
+            return cleaned || undefined;
         }
 
         if (!Array.isArray(content)) return undefined;
@@ -358,8 +358,10 @@ export class ClaudeSessionParser {
 
         for (const block of content) {
             if (block.type === 'text' && block.text?.trim()) {
-                if (role === 'user' && isNoiseMessage(block.text.trim())) continue;
-                parts.push(block.text.trim());
+                const cleaned = stripHarnessTags(block.text);
+                if (!cleaned) continue;
+                if (role === 'user' && isNoiseMessage(cleaned)) continue;
+                parts.push(cleaned);
             } else if (block.type === 'tool_use' && verbose) {
                 const inputSummary = block.input?.file_path || block.input?.pattern || block.input?.command || '';
                 parts.push(`[Tool: ${block.name}]${inputSummary ? ' ' + inputSummary : ''}`);
@@ -374,6 +376,51 @@ export class ClaudeSessionParser {
     }
 }
 
+/**
+ * Tags whose entire block (including content) should be dropped — they are
+ * harness-injected prompt context (system reminders, hook output, command
+ * stdout), not meaningful conversation content.
+ */
+const HARNESS_DROP_TAGS = [
+    'system-reminder',
+    'local-command-stdout',
+    'local-command-stderr',
+    'user-prompt-submit-hook',
+    'command-stdout',
+    'command-stderr',
+    'bash-input',
+    'bash-stdout',
+    'bash-stderr',
+    'command-message',
+] as const;
+
+const HARNESS_DROP_RE = new RegExp(
+    `<(${HARNESS_DROP_TAGS.join('|')})>[\\s\\S]*?</\\1>`,
+    'g',
+);
+
+const COMMAND_INVOCATION_RE =
+    /<command-name>([^<]+)<\/command-name>(?:\s*<command-args>([\s\S]*?)<\/command-args>)?/g;
+
+/**
+ * Remove harness-injected XML blocks from message text and collapse
+ * <command-name>/<command-args> pairs into a "/name args" shorthand.
+ *
+ * Returns the cleaned, trimmed text. Returns an empty string if nothing
+ * survives stripping.
+ */
+function stripHarnessTags(text: string): string {
+    let out = text.replace(HARNESS_DROP_RE, '');
+
+    out = out.replace(COMMAND_INVOCATION_RE, (_match, rawName: string, rawArgs?: string) => {
+        const name = rawName.trim();
+        const args = rawArgs?.trim();
+        return args ? `${name} ${args}` : name;
+    });
+
+    return out.replace(/\n{3,}/g, '\n\n').trim();
+}
+
 /** Check if a message is noise (not a meaningful user intent). */
 function isNoiseMessage(text: string): boolean {
     return (