Compare commits

...

9 Commits

Author SHA1 Message Date
claude-code-best
0a90b218c3 fix: 同步 permissionModeTitle 测试断言与 bypassPermissions 的新 title 值
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
2026-04-26 15:07:50 +08:00
claude-code-best
de9494c0a3 feat: 添加 RSS 内存指示器并解绑 auto 权限模式与 TRANSCRIPT_CLASSIFIER
- 在 REPL 底栏添加 RSS 内存使用显示,512MB 以下 dimColor,512MB-1GB warning 色,1GB 以上 error 色
- auto 权限模式不再依赖 TRANSCRIPT_CLASSIFIER feature flag,classifier 不可用时 fallback 到 prompting
- Config 面板 defaultPermissionMode 使用类型安全的 permissionModeFromString,显示改用 shortTitle
- bypassPermissions title 缩短为 Bypass 与 shortTitle 一致

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
2026-04-26 15:01:57 +08:00
claude-code-best
e7e1f7a34d fix: 修复 PowerShellTool.isSearchOrReadCommand 在 input 为 undefined 时崩溃的问题
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
2026-04-26 15:01:57 +08:00
claude-code-best
9a5998eaef fix: 修复 Config 面板第二次进入时左右键无反应的问题
将左右键枚举值切换从依赖 DOM 焦点的 onKeyDown 改为 useKeybindings 系统,
确保按键在任何焦点状态下都能正确响应。同时修复 isSearchMode 初始值和布局问题。

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
2026-04-26 15:01:57 +08:00
claude-code-best
dff678924e refactor: 将 convertMessagesToLangfuse 参数类型从 unknown 收窄为联合类型
将 readonly unknown[] 改为 readonly LangfuseInputMessage[],
其中 LangfuseInputMessage = UserMessage | AssistantMessage | ChatCompletionMessageParam,
让调用方获得编译期类型检查。
2026-04-26 15:01:57 +08:00
Eric Guo
4591432a1d Fix mintlify validate errors (#367) 2026-04-26 11:07:20 +08:00
WANG HONGXIANG
901628b4d9 fix: 修复 OpenAI provider (gpt-5.4/gpt-5.3-codex等模型)下 内建mcp__plugin_weixin_weixin__reply 微信工具不可见的问题 (#359)
* fix: 修复 OpenAI provider 下 MCP 工具不可见

* docs: 补充 OpenAI MCP 工具列表注释

* fix: 修正 OpenAI Langfuse 输入记录

* refactor: 使用类型守卫收窄 Langfuse role

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

* fix: 合并 Langfuse OpenAI tool_calls

* fix: 修复 OpenAI Langfuse 类型检查
2026-04-26 09:17:09 +08:00
HitMargin
cf33c06021 添加deepseek-v4-pro支持选择max思考深度 (#365)
Co-authored-by: HitMargin <hitmargin@qq.com>
Co-authored-by: Copilot <copilot@github.com>
2026-04-26 09:00:43 +08:00
claude-code-best
e0ca1d054c chore: 1.10.2 2026-04-25 20:37:40 +08:00
22 changed files with 454 additions and 67 deletions

View File

@@ -188,7 +188,7 @@ The TUI (REPL) mode requires a real terminal and cannot be launched directly via
## Documentation & Links
- **Online docs (Mintlify)**: [ccb.agent-aura.top](https://ccb.agent-aura.top/) — source in [`docs/`](docs/), PR contributions welcome
- **DeepWiki**: <https://deepwiki.com/claude-code-best/claude-code>
- **DeepWiki**: https://deepwiki.com/claude-code-best/claude-code
## Contributors

View File

@@ -145,8 +145,8 @@ M 键(或 ← / →)用于在两种路由模式之间切换,**无需展开
```
/pipes — 显示所有实例 + 切换选择面板
/pipes select <name> — 选中某实例(消息会广播到它)
/pipes deselect <name> — 取消选中
/pipes select &lt;name&gt; — 选中某实例(消息会广播到它)
/pipes deselect &lt;name&gt; — 取消选中
/pipes all — 全选
/pipes none — 全部取消
```
@@ -169,7 +169,7 @@ LAN Peers:
Selected: cli-da029538
```
### /attach <name>
### /attach &lt;name&gt;
手动 attach 到一个实例,使其成为你的 slave。
@@ -179,7 +179,7 @@ Selected: cli-da029538
attach 后,对方变为 slave你变为 master。可以向它发送 prompt。通常不需要手动 attach——heartbeat 会自动发现并连接。
### /detach <name>
### /detach &lt;name&gt;
断开与某个 slave 的连接。
@@ -187,7 +187,7 @@ attach 后,对方变为 slave你变为 master。可以向它发送 prompt
/detach cli-04d67950
```
### /send <name> <message>
### /send &lt;name&gt; &lt;message&gt;
向指定 pipe 发送消息(不依赖选择状态,直接指定目标)。

View File

@@ -200,9 +200,9 @@ LSP 服务器通过插件提供。插件的 `manifest.json` 中可以声明 LSP
|------|------|------|------|
| `command` | string | 是 | LSP 服务器可执行命令(不含空格) |
| `args` | string[] | 否 | 命令行参数 |
| `extensionToLanguage` | Record<string, string> | 是 | 文件扩展名到语言 ID 的映射(至少一个) |
| `extensionToLanguage` | `Record<string, string>` | 是 | 文件扩展名到语言 ID 的映射(至少一个) |
| `transport` | `"stdio"` \| `"socket"` | 否 | 通信方式,默认 `stdio` |
| `env` | Record<string, string> | 否 | 启动服务器时设置的环境变量 |
| `env` | `Record<string, string>` | 否 | 启动服务器时设置的环境变量 |
| `initializationOptions` | unknown | 否 | 传给服务器的初始化选项 |
| `settings` | unknown | 否 | 通过 `workspace/didChangeConfiguration` 传递的设置 |
| `workspaceFolder` | string | 否 | 工作区目录路径 |

View File

@@ -175,7 +175,7 @@ F. getCompletedResults() → 空
---
#### #8 stream_event (input_json_delta: '{"file_path":')
#### #8 stream_event (input_json_delta: `'{"file_path":'`)
```
D. yield message ✅ → REPL 追加工具输入 JSON 碎片

View File

@@ -1,6 +1,6 @@
{
"name": "claude-code-best",
"version": "1.10.0",
"version": "1.10.2",
"description": "Reverse-engineered Anthropic Claude Code CLI — interactive AI coding assistant in the terminal",
"type": "module",
"author": "claude-code-best <claude-code-best@proton.me>",

View File

@@ -421,7 +421,7 @@ export const PowerShellTool = buildTool({
isSearch: boolean
isRead: boolean
} {
if (!input.command) {
if (!input?.command) {
return { isSearch: false, isRead: false }
}
return isSearchOrReadPowerShellCommand(input.command)

View File

@@ -169,7 +169,7 @@ export async function call(
if (COMMON_HELP_ARGS.includes(args)) {
onDone(
'Usage: /effort [low|medium|high|max|auto]\n\nEffort levels:\n- low: Quick, straightforward implementation\n- medium: Balanced approach with standard testing\n- high: Comprehensive implementation with extensive testing\n- max: Maximum capability with deepest reasoning (Opus 4.6 only)\n- auto: Use the default effort level for your model',
'Usage: /effort [low|medium|high|max|auto]\n\nEffort levels:\n- low: Quick, straightforward implementation\n- medium: Balanced approach with standard testing\n- high: Comprehensive implementation with extensive testing\n- max: Maximum capability with deepest reasoning (Opus 4.6/4.7, DeepSeek V4 Pro)\n- auto: Use the default effort level for your model',
)
return
}

View File

@@ -42,7 +42,7 @@ import { usePrStatus } from '../../hooks/usePrStatus.js'
import { Byline, KeyboardShortcutHint } from '@anthropic/ink'
import { useTerminalSize } from '../../hooks/useTerminalSize.js'
import { useTasksV2 } from '../../hooks/useTasksV2.js'
import { formatDuration } from '../../utils/format.js'
import { formatDuration, formatFileSize } from '../../utils/format.js'
import { VoiceWarmupHint } from './VoiceIndicator.js'
import { useVoiceEnabled } from '../../hooks/useVoiceEnabled.js'
import { useVoiceState } from '../../context/voice.js'
@@ -63,6 +63,26 @@ const NO_OP_SUBSCRIBE = (_cb: () => void) => () => {}
const NULL = () => null
const MAX_VOICE_HINT_SHOWS = 3
const RSS_UPDATE_INTERVAL_MS = 5_000
type RssState = { text: string; level: 'normal' | 'warning' | 'error' }
function useRssDisplay(): RssState | null {
const [state, setState] = useState<RssState | null>(null)
useEffect(() => {
function update(): void {
const mb = process.memoryUsage().rss / (1024 * 1024)
const level = mb >= 1024 ? 'error' : mb >= 512 ? 'warning' : 'normal'
const text = formatFileSize(mb * 1024 * 1024)
setState(prev => (prev?.text === text ? prev : { text, level }))
}
update()
const timer = setInterval(update, RSS_UPDATE_INTERVAL_MS)
return () => clearInterval(timer)
}, [])
return state
}
type Props = {
exitMessage: {
show: boolean
@@ -315,6 +335,7 @@ function ModeIndicator({
const isKillAgentsConfirmShowing = useAppState(
s => s.notifications.current?.key === 'kill-agents-confirm',
)
const rssState = useRssDisplay()
// Derive team info from teamContext (no filesystem I/O needed)
// Match the same logic as TeamStatus to avoid trailing separator
@@ -428,6 +449,18 @@ function ModeIndicator({
/>,
]
: []),
// RSS memory indicator — always visible
...(rssState
? [
<Text
key="rss"
dimColor={rssState.level === 'normal'}
color={rssState.level === 'error' ? 'error' : rssState.level === 'warning' ? 'warning' : undefined}
>
{rssState.text}
</Text>,
]
: []),
]
// Check if any in-process teammates exist (for hint text cycling)

View File

@@ -16,6 +16,7 @@ import {
import chalk from 'chalk';
import {
permissionModeTitle,
permissionModeShortTitle,
permissionModeFromString,
toExternalPermissionMode,
isExternalPermissionMode,
@@ -153,7 +154,7 @@ export function Config({
const initialLanguage = React.useRef(currentLanguage);
const [selectedIndex, setSelectedIndex] = useState(0);
const [scrollOffset, setScrollOffset] = useState(0);
const [isSearchMode, setIsSearchMode] = useState(true);
const [isSearchMode, setIsSearchMode] = useState(false);
const isTerminalFocused = useTerminalFocus();
const { rows } = useTerminalSize();
// contentHeight is set by Settings.tsx (same value passed to Tabs to fix
@@ -167,6 +168,9 @@ export function Config({
const thinkingEnabled = useAppState(s => s.thinkingEnabled);
const isFastMode = useAppState(s => (isFastModeEnabled() ? s.fastMode : false));
const promptSuggestionEnabled = useAppState(s => s.promptSuggestionEnabled);
const currentDefaultPermissionMode = permissionModeFromString(
settingsData?.permissions?.defaultMode ?? 'default',
);
// Show auto in the default-mode dropdown when the user has opted in OR the
// config is fully 'enabled' — even if currently circuit-broken ('disabled'),
// an opted-in user should still see it in settings (it's a temporary state).
@@ -558,27 +562,23 @@ export function Config({
{
id: 'defaultPermissionMode',
label: 'Default permission mode',
value: settingsData?.permissions?.defaultMode || 'default',
value: currentDefaultPermissionMode,
options: (() => {
const priorityOrder: PermissionMode[] = ['default', 'plan'];
const allModes: readonly PermissionMode[] = feature('TRANSCRIPT_CLASSIFIER')
? PERMISSION_MODES
: EXTERNAL_PERMISSION_MODES;
const excluded: PermissionMode[] = ['bypassPermissions'];
if (feature('TRANSCRIPT_CLASSIFIER') && !showAutoInDefaultModePicker) {
excluded.push('auto');
}
return [...priorityOrder, ...allModes.filter(m => !priorityOrder.includes(m) && !excluded.includes(m))];
return [...priorityOrder, ...PERMISSION_MODES.filter(m => !priorityOrder.includes(m))];
})(),
type: 'enum' as const,
onChange(mode: string) {
const parsedMode = permissionModeFromString(mode);
// Internal modes (e.g. auto) are stored directly
const validatedMode = isExternalPermissionMode(parsedMode) ? toExternalPermissionMode(parsedMode) : parsedMode;
// auto is an internal-only mode — store it directly, don't convert
// to its external mapping ('default') which would make it invisible.
const validatedMode = parsedMode === 'auto'
? parsedMode
: (isExternalPermissionMode(parsedMode) ? toExternalPermissionMode(parsedMode) : parsedMode);
const result = updateSettingsForSource('userSettings', {
permissions: {
...settingsData?.permissions,
defaultMode: validatedMode as ExternalPermissionMode,
defaultMode: validatedMode as (typeof PERMISSION_MODES)[number],
},
});
@@ -1548,6 +1548,8 @@ export function Config({
'scroll:lineUp': () => moveSelection(-1),
'scroll:lineDown': () => moveSelection(1),
'select:accept': toggleSetting,
'select:previousValue': () => toggleSetting(),
'select:nextValue': () => toggleSetting(),
'settings:search': () => {
setIsSearchMode(true);
setSearchQuery('');
@@ -1936,13 +1938,13 @@ export function Config({
return (
<React.Fragment key={setting.id}>
<Box>
<Box width="100%">
<Box width={44}>
<Text color={isSelected ? 'suggestion' : undefined}>
{isSelected ? figures.pointer : ' '} {setting.label}
</Text>
</Box>
<Box key={isSelected ? 'selected' : 'unselected'}>
<Box flexGrow={1}>
{setting.type === 'boolean' ? (
<>
<Text color={isSelected ? 'suggestion' : undefined}>{setting.value.toString()}</Text>
@@ -1963,7 +1965,7 @@ export function Config({
</Text>
) : setting.id === 'defaultPermissionMode' ? (
<Text color={isSelected ? 'suggestion' : undefined}>
{permissionModeTitle(setting.value as PermissionMode)}
{permissionModeShortTitle(setting.value as PermissionMode)}
</Text>
) : setting.id === 'autoUpdatesChannel' && autoUpdaterDisabledReason ? (
<Box flexDirection="column">

View File

@@ -117,6 +117,9 @@ export const DEFAULT_BINDINGS: KeybindingBlock[] = [
j: 'select:next',
'ctrl+p': 'select:previous',
'ctrl+n': 'select:next',
// Cycle enum values left/right (same as left/right arrow in handleKeyDown)
left: 'select:previousValue',
right: 'select:nextValue',
// Toggle/activate the selected setting (space only — enter saves & closes)
space: 'select:accept',
// Save and close the config panel

View File

@@ -168,6 +168,8 @@ export const KEYBINDING_ACTIONS = [
'settings:search',
'settings:retry',
'settings:close',
'select:previousValue',
'select:nextValue',
// Voice actions
'voice:pushToTalk',
] as const

View File

@@ -1340,7 +1340,10 @@ async function* queryModel(
// media stripping) but before Anthropic-specific logic (betas, thinking, caching).
if (getAPIProvider() === 'openai') {
const { queryModelOpenAI } = await import('./openai/index.js')
yield* queryModelOpenAI(messagesForAPI, systemPrompt, filteredTools, signal, options)
// OpenAI emulates Anthropic's dynamic tool loading client-side. It needs
// the full tool pool so ToolSearchTool can search deferred MCP tools that
// were intentionally filtered out of the initial API tool list above.
yield* queryModelOpenAI(messagesForAPI, systemPrompt, tools, signal, options)
return
}

View File

@@ -196,10 +196,52 @@ async function runQueryModel(
// We mock at module level. Bun's mock.module replaces the module for the
// entire file, so we configure the stream per-test via a shared variable.
let _nextEvents: BetaRawMessageStreamEvent[] = []
let _toolSearchEnabled = false
/** Captured arguments from the last chat.completions.create() call */
let _lastCreateArgs: Record<string, any> | null = null
mock.module('@ant/model-provider', () => ({
resolveOpenAIModel: (m: string) => m,
adaptOpenAIStreamToAnthropic: (_stream: any, _model: string) =>
eventStream(_nextEvents),
anthropicMessagesToOpenAI: (messages: any[]) =>
messages.map(msg => ({
role: msg.message?.role ?? 'user',
content: msg.message?.content ?? '',
})),
anthropicToolsToOpenAI: (tools: any[]) =>
tools.map(tool => ({
type: 'function',
function: {
name: tool.name,
description: tool.description ?? '',
parameters: tool.input_schema ?? { type: 'object', properties: {} },
},
})),
anthropicToolChoiceToOpenAI: () => undefined,
}))
mock.module('../../../../utils/envUtils.js', () => ({
isEnvTruthy: (value: string | undefined) =>
value === '1' || value === 'true' || value === 'yes' || value === 'on',
isEnvDefinedFalsy: (value: string | undefined) =>
value === '0' || value === 'false' || value === 'no' || value === 'off',
}))
mock.module('../../../../services/analytics/growthbook.js', () => ({
getFeatureValue_CACHED_MAY_BE_STALE: (_key: string, fallback: unknown) =>
fallback,
}))
mock.module('src/bootstrap/state.js', () => ({
isReplBridgeActive: () => false,
}))
mock.module('bun:bundle', () => ({
feature: () => false,
}))
mock.module('../client.js', () => ({
getOpenAIClient: () => ({
chat: {
@@ -252,6 +294,13 @@ mock.module('../../../../utils/context.js', () => ({
mock.module('../../../../utils/messages.js', () => ({
normalizeMessagesForAPI: (msgs: any) => msgs,
normalizeContentFromAPI: (blocks: any[]) => blocks,
createUserMessage: (opts: any) => ({
type: 'user',
message: { role: 'user', content: opts.content },
uuid: 'user-uuid',
timestamp: new Date().toISOString(),
isMeta: opts.isMeta,
}),
createAssistantAPIErrorMessage: (opts: any) => ({
type: 'assistant',
message: {
@@ -268,8 +317,9 @@ mock.module('../../../../utils/api.js', () => ({
}))
mock.module('../../../../utils/toolSearch.js', () => ({
isToolSearchEnabled: async () => false,
isToolSearchEnabled: async () => _toolSearchEnabled,
extractDiscoveredToolNames: () => new Set(),
isDeferredToolsDeltaEnabled: () => false,
}))
mock.module('../../../../tools/ToolSearchTool/prompt.js', () => ({
@@ -297,6 +347,16 @@ mock.module('../../../../utils/modelCost.js', () => ({
getModelPricingString: () => undefined,
}))
mock.module('../../../../services/langfuse/tracing.js', () => ({
recordLLMObservation: () => {},
}))
mock.module('../../../../services/langfuse/convert.js', () => ({
convertMessagesToLangfuse: () => [],
convertOutputToLangfuse: () => ({}),
convertToolsToLangfuse: () => [],
}))
mock.module('../../../../utils/debug.js', () => ({
logForDebugging: () => {},
logAntError: () => {},
@@ -543,3 +603,59 @@ describe('queryModelOpenAI — max_tokens forwarded to request', () => {
expect(_lastCreateArgs!.max_tokens).toBe(8192)
})
})
describe('queryModelOpenAI — deferred MCP tool visibility', () => {
test('prepends available deferred MCP tools to OpenAI messages', async () => {
_toolSearchEnabled = true
_nextEvents = [makeMessageStart(), makeMessageStop()]
try {
const { queryModelOpenAI } = await import('../index.js')
const tools: any[] = [
{
name: 'ToolSearch',
isMcp: false,
input_schema: { type: 'object', properties: {} },
prompt: async () => 'Search deferred tools',
},
{
name: 'mcp__wechat__send_message',
isMcp: true,
input_schema: { type: 'object', properties: {} },
prompt: async () => 'Send a WeChat message',
},
]
const options: any = {
model: 'test-model',
tools: [],
agents: [],
querySource: 'main_loop',
getToolPermissionContext: async () => ({
alwaysAllow: [],
alwaysDeny: [],
needsPermission: [],
mode: 'default',
isBypassingPermissions: false,
}),
}
for await (const _item of queryModelOpenAI(
[],
{ type: 'text', text: '' } as any,
tools as any,
new AbortController().signal,
options,
)) {
// Exhaust generator so request body is built.
}
expect(_lastCreateArgs).not.toBeNull()
expect(JSON.stringify(_lastCreateArgs!.messages)).toContain(
'<available-deferred-tools>\\nmcp__wechat__send_message\\n</available-deferred-tools>',
)
} finally {
_toolSearchEnabled = false
}
})
})

View File

@@ -5,6 +5,7 @@ import type {
StreamEvent,
SystemAPIErrorMessage,
AssistantMessage,
UserMessage,
} from '../../../types/message.js'
import type { AgentId } from '../../../types/ids.js'
import type { Tools } from '../../../Tool.js'
@@ -32,18 +33,58 @@ import type { Options } from '../claude.js'
import { randomUUID } from 'crypto'
import {
createAssistantAPIErrorMessage,
createUserMessage,
normalizeContentFromAPI,
} from '../../../utils/messages.js'
import type { SDKAssistantMessageError } from '../../../entrypoints/agentSdkTypes.js'
import {
isToolSearchEnabled,
extractDiscoveredToolNames,
isDeferredToolsDeltaEnabled,
} from '../../../utils/toolSearch.js'
import {
formatDeferredToolLine,
isDeferredTool,
TOOL_SEARCH_TOOL_NAME,
} from '@claude-code-best/builtin-tools/tools/ToolSearchTool/prompt.js'
/**
* Mirrors the Anthropic request path's deferred-tool announcement for OpenAI.
*
* OpenAI-compatible endpoints cannot consume Anthropic's `defer_loading` or
* `tool_reference` beta payloads directly, so the model needs the same textual
* list of deferred MCP tool names that Anthropic receives before it can ask
* ToolSearchTool to load their full schemas.
*/
function prependDeferredToolListIfNeeded(
messages: (AssistantMessage | UserMessage)[],
tools: Tools,
deferredToolNames: Set<string>,
useToolSearch: boolean,
): (AssistantMessage | UserMessage)[] {
if (!useToolSearch || isDeferredToolsDeltaEnabled()) return messages
const deferredToolList = tools
.filter(tool => deferredToolNames.has(tool.name))
.map(formatDeferredToolLine)
.sort()
.join('\n')
if (!deferredToolList) return messages
return [
createUserMessage({
content: `<available-deferred-tools>\n${deferredToolList}\n</available-deferred-tools>`,
isMeta: true,
}),
...messages,
]
}
function isOpenAIConvertibleMessage(msg: Message): msg is AssistantMessage | UserMessage {
return msg.type === 'assistant' || msg.type === 'user'
}
/**
* Assemble the final AssistantMessage (and optional max_tokens error) from
* accumulated stream state. Extracted to avoid duplication between the
@@ -176,9 +217,18 @@ export async function* queryModelOpenAI(
// 8. Convert messages and tools to OpenAI format
const enableThinking = isOpenAIThinkingEnabled(openaiModel)
const openaiMessages = anthropicMessagesToOpenAI(messagesForAPI, systemPrompt, {
enableThinking,
})
const openAIConvertibleMessages = messagesForAPI.filter(isOpenAIConvertibleMessage)
const messagesWithDeferredToolList = prependDeferredToolListIfNeeded(
openAIConvertibleMessages,
tools,
deferredToolNames,
useToolSearch,
)
const openaiMessages = anthropicMessagesToOpenAI(
messagesWithDeferredToolList,
systemPrompt,
{ enableThinking },
)
const openaiTools = anthropicToolsToOpenAI(standardTools)
const openaiToolChoice = anthropicToolChoiceToOpenAI(options.toolChoice)
@@ -356,7 +406,7 @@ export async function* queryModelOpenAI(
recordLLMObservation(options.langfuseTrace ?? null, {
model: openaiModel,
provider: 'openai',
input: convertMessagesToLangfuse(messagesForAPI, systemPrompt),
input: convertMessagesToLangfuse(openaiMessages),
output: convertOutputToLangfuse(collectedMessages),
usage: {
input_tokens: usage.input_tokens,

View File

@@ -184,6 +184,101 @@ describe('Langfuse integration', () => {
})
})
describe('convertMessagesToLangfuse', () => {
test('preserves OpenAI-style messages including deferred tool announcements', async () => {
const { convertMessagesToLangfuse } = await import('../convert.js')
const result = convertMessagesToLangfuse([
{
role: 'system',
content: 'system prompt',
},
{
role: 'user',
content:
'<available-deferred-tools>\nmcp__wechat__send_message\n</available-deferred-tools>',
},
])
expect(result).toEqual([
{ role: 'system', content: 'system prompt' },
{
role: 'user',
content:
'<available-deferred-tools>\nmcp__wechat__send_message\n</available-deferred-tools>',
},
])
})
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' },
])
})
test('merges assistant tool calls from OpenAI-style array content', async () => {
const { convertMessagesToLangfuse } = await import('../convert.js')
// Content part with embedded tool_calls is non-standard; cast for defensive test
const result = convertMessagesToLangfuse([
{
role: 'assistant',
content: [
{
type: 'text',
text: 'calling a tool',
tool_calls: [
{
id: 'call_from_part',
type: 'function',
function: { name: 'part_tool', arguments: '{}' },
},
],
},
],
tool_calls: [
{
id: 'call_from_message',
type: 'function',
function: { name: 'message_tool', arguments: '{"ok":true}' },
},
],
},
] as any)
expect(result).toEqual([
{
role: 'assistant',
content: 'calling a tool',
tool_calls: [
{
id: 'call_from_message',
type: 'function',
function: { name: 'message_tool', arguments: '{"ok":true}' },
},
{
id: 'call_from_part',
type: 'function',
function: { name: 'part_tool', arguments: '{}' },
},
],
},
])
})
})
// ── client tests ────────────────────────────────────────────────────────────
describe('isLangfuseEnabled', () => {

View File

@@ -10,7 +10,8 @@
* - tool_result blocks → separate { role: 'tool' } messages
*/
import type { Message, AssistantMessage, UserMessage } from 'src/types/message.js'
import type { AssistantMessage, UserMessage } from 'src/types/message.js'
import type { ChatCompletionMessageParam } from 'openai/resources/chat/completions/completions.mjs'
type LangfuseContentPart =
| { type: 'text'; text: string }
@@ -30,6 +31,61 @@ type LangfuseChatMessage = {
tool_call_id?: string
}
function isLangfuseRole(value: unknown): value is LangfuseChatMessage['role'] {
switch (value) {
case 'user':
case 'assistant':
case 'system':
case 'tool':
return true
default:
return false
}
}
function isRecord(value: unknown): value is Record<string, unknown> {
return value !== null && typeof value === 'object' && !Array.isArray(value)
}
function isLangfuseToolCall(value: unknown): value is LangfuseToolCall {
if (!isRecord(value)) return false
const fn = value.function
return (
typeof value.id === 'string' &&
value.type === 'function' &&
isRecord(fn) &&
typeof fn.name === 'string' &&
typeof fn.arguments === 'string'
)
}
function getToolCalls(value: unknown): LangfuseToolCall[] {
return Array.isArray(value) ? value.filter(isLangfuseToolCall) : []
}
function getContentToolCalls(content: unknown[]): LangfuseToolCall[] {
return content.flatMap(block =>
isRecord(block) ? getToolCalls(block.tool_calls) : [],
)
}
function mergeToolCalls(
...groups: readonly LangfuseToolCall[][]
): LangfuseToolCall[] {
const merged = new Map<string, LangfuseToolCall>()
for (const toolCall of groups.flat()) {
const key = toolCall.id || `${toolCall.function.name}:${toolCall.function.arguments}`
if (!merged.has(key)) merged.set(key, toolCall)
}
return [...merged.values()]
}
/** Union of all message formats accepted by Langfuse converters. */
type LangfuseInputMessage =
| UserMessage
| AssistantMessage
| ChatCompletionMessageParam
/** Normalize a content block into a LangfuseContentPart (non-tool_use, non-tool_result) */
function toContentPart(block: Record<string, unknown>): LangfuseContentPart | null {
const type = block.type as string | undefined
@@ -121,15 +177,15 @@ function collapseContent(parts: LangfuseContentPart[]): string | LangfuseContent
return parts
}
function toRole(msg: Message): 'user' | 'assistant' | 'system' {
function toRoleFromWrappedMessage(msg: Record<string, unknown>): 'user' | 'assistant' | 'system' {
if (msg.type === 'assistant') return 'assistant'
if (msg.type === 'system') return 'system'
return 'user'
}
/** Convert messagesForAPI (UserMessage | AssistantMessage)[] → Langfuse input format */
/** Convert internal or OpenAI-style messages → Langfuse input format */
export function convertMessagesToLangfuse(
messages: (UserMessage | AssistantMessage)[],
messages: readonly LangfuseInputMessage[],
systemPrompt?: readonly string[],
): LangfuseChatMessage[] {
const result: LangfuseChatMessage[] = []
@@ -139,18 +195,34 @@ export function convertMessagesToLangfuse(
}
}
for (const msg of messages) {
const inner = msg.message
if (!inner) continue
const role = (inner.role as 'user' | 'assistant' | undefined) ?? toRole(msg)
if (!isRecord(msg)) continue
const wrappedMessage = msg.message
const isWrappedMessage = isRecord(wrappedMessage)
const inner = isWrappedMessage ? wrappedMessage : msg
const role =
isLangfuseRole(inner.role) ? inner.role : isWrappedMessage ? toRoleFromWrappedMessage(msg) : 'user'
const rawContent = inner.content
if (typeof rawContent === 'string' || !Array.isArray(rawContent)) {
result.push({ role, content: String(rawContent ?? '') })
const toolCalls = getToolCalls(inner.tool_calls)
result.push({
role,
content: String(rawContent ?? ''),
...('tool_call_id' in inner && typeof inner.tool_call_id === 'string'
? { tool_call_id: inner.tool_call_id }
: {}),
...(toolCalls.length > 0 ? { tool_calls: toolCalls } : {}),
})
continue
}
if (role === 'assistant') {
// Extract tool_use → tool_calls at message level
const { tool_calls, rest } = extractToolCalls(rawContent)
const allToolCalls = mergeToolCalls(
tool_calls,
getToolCalls(inner.tool_calls),
getContentToolCalls(rest),
)
const parts = rest
.filter((b): b is Record<string, unknown> => b != null && typeof b === 'object')
.map(b => toContentPart(b))
@@ -158,7 +230,7 @@ export function convertMessagesToLangfuse(
result.push({
role: 'assistant',
content: collapseContent(parts),
...(tool_calls.length > 0 && { tool_calls }),
...(allToolCalls.length > 0 && { tool_calls: allToolCalls }),
})
} else {
// User messages: extract tool_result → separate tool messages
@@ -168,7 +240,18 @@ 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) })
const toolCalls = mergeToolCalls(
getToolCalls(inner.tool_calls),
getContentToolCalls(rest),
)
result.push({
role,
content: collapseContent(parts),
...('tool_call_id' in inner && typeof inner.tool_call_id === 'string'
? { tool_call_id: inner.tool_call_id }
: {}),
...(toolCalls.length > 0 ? { tool_calls: toolCalls } : {}),
})
}
result.push(...toolMessages)
}

View File

@@ -30,9 +30,11 @@ export type PermissionMode = InternalPermissionMode
// Runtime validation set: modes that are user-addressable (settings.json
// defaultMode, --permission-mode CLI flag, conversation recovery).
// 'auto' is always available — when TRANSCRIPT_CLASSIFIER is off, the
// classifier is unavailable and auto mode falls back to prompting.
export const INTERNAL_PERMISSION_MODES = [
...EXTERNAL_PERMISSION_MODES,
...(feature('TRANSCRIPT_CLASSIFIER') ? (['auto'] as const) : ([] as const)),
'auto' as const,
] as const satisfies readonly PermissionMode[]
export const PERMISSION_MODES = INTERNAL_PERMISSION_MODES

View File

@@ -36,7 +36,8 @@ export function modelSupportsEffort(model: string): boolean {
if (
m.includes('opus-4-7') ||
m.includes('opus-4-6') ||
m.includes('sonnet-4-6')
m.includes('sonnet-4-6') ||
m.includes('deepseek-v4-pro')
) {
return true
}
@@ -57,11 +58,16 @@ export function modelSupportsEffort(model: string): boolean {
// @[MODEL LAUNCH]: Add the new model to the allowlist if it supports 'max' effort.
// Per API docs, 'max' is Opus 4.6/4.7 only for public models — other models return an error.
// However, DeepSeek V4 Pro also supports max effort when using Anthropic-compatible API.
export function modelSupportsMaxEffort(model: string): boolean {
const supported3P = get3PModelCapabilityOverride(model, 'max_effort')
if (supported3P !== undefined) {
return supported3P
}
// Support DeepSeek V4 Pro specifically (Anthropic-compatible API)
if (model.toLowerCase().includes('deepseek-v4-pro')) {
return true
}
if (
model.toLowerCase().includes('opus-4-7') ||
model.toLowerCase().includes('opus-4-6')
@@ -267,7 +273,7 @@ export function getEffortLevelDescription(level: EffortLevel): string {
case 'xhigh':
return 'Extended reasoning beyond high, short of max (Opus 4.7 only)'
case 'max':
return 'Maximum capability with deepest reasoning (Opus 4.6/4.7 only)'
return 'Maximum capability with deepest reasoning (Opus 4.6/4.7/DeepSeek V4 Pro)'
}
}

View File

@@ -64,7 +64,7 @@ const PERMISSION_MODE_CONFIG: Partial<
external: 'acceptEdits',
},
bypassPermissions: {
title: 'Bypass Permissions',
title: 'Bypass',
shortTitle: 'Bypass',
symbol: '⏵⏵',
color: 'error',
@@ -77,17 +77,13 @@ const PERMISSION_MODE_CONFIG: Partial<
color: 'error',
external: 'dontAsk',
},
...(feature('TRANSCRIPT_CLASSIFIER')
? {
auto: {
title: 'Auto mode',
shortTitle: 'Auto',
symbol: '⏵⏵',
color: 'warning' as ModeColorKey,
external: 'default' as ExternalPermissionMode,
},
}
: {}),
auto: {
title: 'Auto',
shortTitle: 'Auto',
symbol: '⏵⏵',
color: 'warning' as ModeColorKey,
external: 'default' as ExternalPermissionMode,
},
}
/**

View File

@@ -70,7 +70,7 @@ describe("permissionModeTitle", () => {
expect(permissionModeTitle("default")).toBe("Default");
expect(permissionModeTitle("plan")).toBe("Plan Mode");
expect(permissionModeTitle("acceptEdits")).toBe("Accept edits");
expect(permissionModeTitle("bypassPermissions")).toBe("Bypass Permissions");
expect(permissionModeTitle("bypassPermissions")).toBe("Bypass");
expect(permissionModeTitle("dontAsk")).toBe("Don't Ask");
});

View File

@@ -57,11 +57,7 @@ export const PermissionsSchema = lazySchema(() =>
'List of permission rules that should always prompt for confirmation',
),
defaultMode: z
.enum(
feature('TRANSCRIPT_CLASSIFIER')
? PERMISSION_MODES
: EXTERNAL_PERMISSION_MODES,
)
.enum(PERMISSION_MODES)
.optional()
.describe('Default permission mode when Claude Code needs access'),
disableBypassPermissionsMode: z

View File

@@ -2,7 +2,7 @@
Updated: 2026-04-24
## Style
- Learns best with: Analogies (Memory page <-> Capsule hotel), Concrete trade-offs (Latency vs Throughput)
- Learns best with: Analogies (Memory page &lt;-&gt; Capsule hotel), Concrete trade-offs (Latency vs Throughput)
- Strength: Strong logical intuition regarding memory constraints.
- Pace: Fast. Grasped PagedAttention/TP concepts quickly from first principles.