fix(parser): carry promptSource through queued-command attachments

extractQueuedCommand dropped the top-level promptSource on
type=attachment queued_command entries, so queued prompts stored an
empty messages.prompt_source while standard user turns captured it.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: 2 people

internal/parser/claude.go

@@ -53,8 +53,9 @@ type dagEntry struct {
 // of band and splice them into the message stream by timestamp
 // after DAG processing completes.
 type claudeQueuedCommand struct {
-	prompt    string
-	timestamp time.Time
+	prompt       string
+	promptSource string
+	timestamp    time.Time
 }
 
 // claudeParseWithExclusions parses a Claude Code JSONL session file
@@ -1458,8 +1459,9 @@ func extractQueuedCommand(line string) (claudeQueuedCommand, bool) {
 		return claudeQueuedCommand{}, false
 	}
 	return claudeQueuedCommand{
-		prompt:    prompt,
-		timestamp: extractTimestamp(line),
+		prompt:       prompt,
+		promptSource: gjson.Get(line, "promptSource").Str,
+		timestamp:    extractTimestamp(line),
 	}, true
 }
 
@@ -1595,6 +1597,7 @@ func queuedCommandMessage(
 			ContentLength: len(q.prompt),
 			SourceType:    "system",
 			SourceSubtype: subtype,
+			PromptSource:  q.promptSource,
 		}
 	}
 	return ParsedMessage{
@@ -1604,6 +1607,7 @@ func queuedCommandMessage(
 		ContentLength: len(q.prompt),
 		SourceType:    "user",
 		SourceSubtype: "queued_command",
+		PromptSource:  q.promptSource,
 	}
 }
 

internal/parser/claude_parser_test.go

@@ -386,6 +386,23 @@ func TestParseClaudeSession_SkippedMessages(t *testing.T) {
 }
 
 func TestParseClaudeSession_QueuedCommand(t *testing.T) {
+	t.Run("carries top-level promptSource when present", func(t *testing.T) {
+		queued := `{"type":"attachment","timestamp":"` + tsZeroS2 + `",` +
+			`"promptSource":"queued","attachment":{"type":"queued_command",` +
+			`"commandMode":"prompt","prompt":"also do X"}}`
+		content := testjsonl.JoinJSONL(
+			testjsonl.ClaudeUserJSON("first request", tsZero),
+			testjsonl.ClaudeAssistantJSON([]map[string]any{
+				{"type": "text", "text": "starting work"},
+			}, tsZeroS1),
+			queued,
+		)
+		_, msgs := runClaudeParserTest(t, "test.jsonl", content)
+		require.Len(t, msgs, 3)
+		assert.Equal(t, "queued_command", msgs[2].SourceSubtype)
+		assert.Equal(t, "queued", msgs[2].PromptSource)
+	})
+
 	t.Run("surfaces as user message between turns", func(t *testing.T) {
 		content := testjsonl.JoinJSONL(
 			testjsonl.ClaudeUserJSON("first request", tsZero),