Function handleNonStreamResponse

src/controllers/chat.js:505–761

(res, response, enable_thinking, enable_web_search, model, requestBody = null, options = {})

    let bufferedContent = output.content
    const acceptedVisibleText = peelDeliverableText(attempt.visibleText, residueSpans)
    if (
        streamedVisibleText &&
        acceptedVisibleText.startsWith(streamedVisibleText) &&
        bufferedContent.startsWith(acceptedVisibleText)
    ) {
        // 正式回复的包装体已经按上游节奏实时发送，只补发极少数尚未发送的尾部，
        // 以及门禁通过后追加的搜索信息等派生内容。
        bufferedContent = `${acceptedVisibleText.slice(streamedVisibleText.length)}${bufferedContent.slice(acceptedVisibleText.length)}`
    } else if (streamedVisibleText && finishReason !== 'stop' && attempt.streamedControlState?.opened) {
        // length/content_filter 等中止发生在包装闭合前时，不能把带控制标签的原始
        // 缓冲再次作为正文回放；已发送的安全正文由对应 finish_reason 正常收尾。
        bufferedContent = ''
    }

    if (bufferedReasoning) writeDelta({ reasoning_content: bufferedReasoning })
    if (bufferedContent) writeDelta({ content: bufferedContent })

    const ARG_CHUNK_SIZE = 32
    for (const call of attempt.toolCalls || []) {
        writeDelta({
            tool_calls: [{
                index: call.index,
                id: call.id,
                type: 'function',
                function: { name: call.function.name, arguments: '' }
            }]
        })
        const args = call.function.arguments || '{}'
        for (let offset = 0; offset < args.length; offset += ARG_CHUNK_SIZE) {
            writeDelta({
                tool_calls: [{
                    index: call.index,
                    function: { arguments: args.slice(offset, offset + ARG_CHUNK_SIZE) }
                }]
            })
        }
    }
    const completionText = `${output.reasoning}${output.content}${JSON.stringify(attempt.toolCalls || [])}`
    const usage = normalizeAgentUsage(attempt, requestBody, completionText)
    attributeChatUsage(runtime.currentAccount || options.currentAccount, usage)
    res.write(`data: ${JSON.stringify({
        id: `chatcmpl-${messageId}`,
        object: 'chat.completion.chunk',
        created,
        choices: [{ index: 0, delta: {}, finish_reason: finishReason }]
    })}\n\n`)
    res.write(`data: ${JSON.stringify({
        id: `chatcmpl-${messageId}`,
        object: 'chat.completion.chunk',
        created,
        choices: [],
        usage
    })}\n\n`)
    res.write('data: [DONE]\n\n')
    if (typeof res.flush === 'function') res.flush()
    res.end()
}