Function writeToolCallsDelta

src/controllers/chat.js:195–251

(calls)

    if (typeof res?.writeProcessing !== 'function') return work()
    const heartbeatMs = Math.max(1, Number(intervalMs) || 15000)
    const heartbeat = setInterval(() => {
        if (res.headersSent || res.writableEnded || res.destroyed) return
        try {
            // 102 是临时响应，不会提交最终状态码/响应头。这样既能保持长 thinking
            // 连接活跃，又能在门禁耗尽时返回真正的 HTTP 429/503。
            res.writeProcessing()
        } catch (_) {
            // 某些 HTTP/2/反代适配器不实现临时响应；跳过即可，不能改发 SSE 注释。
        }
    }, heartbeatMs)
    heartbeat.unref?.()
    try {
        return await work()
    } finally {
        clearInterval(heartbeat)
    }
}

const runWithSSEHeartbeat = async (res, work, intervalMs = 15000) => {
    const heartbeatMs = Math.max(1, Number(intervalMs) || 15000)
    const heartbeat = setInterval(() => {
        if (res.writableEnded || res.destroyed) return
        try {
            // SSE 已经提交 200 响应后，用注释帧保活。注释不会进入 OpenAI delta，
            // 但能阻止反代在长 thinking 或纠正 attempt 期间把连接判为空闲。
            res.write(': qwen2api-agent-keepalive\n\n')
            if (typeof res.flush === 'function') res.flush()
        } catch (_) {
            // 客户端断开会由后续流消费/写入路径统一收敛。
        }
    }, heartbeatMs)
    heartbeat.unref?.()
    try {
        return await work()
    } finally {
        clearInterval(heartbeat)
    }
}

const normalizeAgentUsage = (attempt, requestBody, completionText) => {
    let usage = { ...(attempt?.totalTokens || {}) }
    if (!usage.prompt_tokens && !usage.completion_tokens) {
        usage = createUsageObject(requestBody?.messages || [], completionText, null)
    }
    usage.prompt_tokens = Math.max(0, Number(usage.prompt_tokens) || 0)
    usage.completion_tokens = Math.max(0, Number(usage.completion_tokens) || 0)
    usage.total_tokens = usage.prompt_tokens + usage.completion_tokens
    return usage
}

const prepareAgentOutput = async (attempt, enableThinking, enableWebSearch, { suppressVisibleText = false } = {}) => {
    let reasoning = String(attempt?.reasoning || '')
    // 工具调用旁的正文照常交付（OpenAI 允许 content 与 tool_calls 并存）：严格门禁下文本
    // 通道的调用到这里 visibleText 必为空白；原生晋升的回合带着调用前的正文过来 —— 除非
    // 门禁判定那段正文混着写坏的文本 [TOOL CALL]（suppressVisibleText），那就一个字节不发。
    const visibleText = suppressVisibleText ? '' : String(attempt?.visibleText || '')
    let content = attempt?.toolCalls?.length > 0 && !visibleText.trim() ? '' : visibleText