fix: 保留 Langfuse OpenAI 数组消息角色

Author: XavierWangHX

src/services/langfuse/__tests__/langfuse.test.ts

@@ -208,6 +208,26 @@ describe('Langfuse integration', () => {
         },
       ])
     })
+
+    test('preserves roles for OpenAI-style array content messages', async () => {
+      const { convertMessagesToLangfuse } = await import('../convert.js')
+      const result = convertMessagesToLangfuse([
+        {
+          role: 'system',
+          content: [{ type: 'text', text: 'system reminder' }],
+        },
+        {
+          role: 'tool',
+          tool_call_id: 'call_1',
+          content: [{ type: 'text', text: 'tool output' }],
+        },
+      ])
+
+      expect(result).toEqual([
+        { role: 'system', content: 'system reminder' },
+        { role: 'tool', content: 'tool output', tool_call_id: 'call_1' },
+      ])
+    })
   })
 
   // ── client tests ────────────────────────────────────────────────────────────

src/services/langfuse/convert.ts

@@ -196,7 +196,16 @@ export function convertMessagesToLangfuse(
         .map(b => toContentPart(b))
         .filter((p): p is LangfuseContentPart => p !== null)
       if (parts.length > 0 || toolMessages.length === 0) {
-        result.push({ role: 'user', content: collapseContent(parts) })
+        result.push({
+          role,
+          content: collapseContent(parts),
+          ...('tool_call_id' in inner && typeof inner.tool_call_id === 'string'
+            ? { tool_call_id: inner.tool_call_id }
+            : {}),
+          ...('tool_calls' in inner && Array.isArray(inner.tool_calls)
+            ? { tool_calls: inner.tool_calls as LangfuseToolCall[] }
+            : {}),
+        })
       }
       result.push(...toolMessages)
     }