Function handleStreamResponse

src/controllers/chat.js:100–492

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

 */
const requiresToolCall = (toolChoice) => {
    if (toolChoice === 'required') return true
    if (toolChoice && typeof toolChoice === 'object' && toolChoice.type === 'function' && toolChoice.function?.name) {
        return true
    }
    return false
}

/**
 * 构建 tool_choice=required 重试时追加的强约束提示
 * @param {string|Object} toolChoice - OpenAI tool_choice
 * @returns {string} 重试提示词
 */
const buildRequiredRetryHint = (toolChoice) => {
    if (toolChoice && typeof toolChoice === 'object' && toolChoice.function?.name) {
        return `You did not call any tool in your previous reply. You MUST now call the tool \`${toolChoice.function.name}\` using the ${TOOL_CALL_OPEN}...${TOOL_CALL_CLOSE} format and nothing else.`
    }
    return `You did not call any tool in your previous reply. You MUST now call exactly one tool using the ${TOOL_CALL_OPEN}...${TOOL_CALL_CLOSE} format and nothing else.`
}

const buildEmptyOutputRetryHint = () => [
    'Your previous reply produced no visible final answer or executable tool call.',
    `Continue the Agent task now. If any action remains, emit the required \`${TOOL_CALL_OPEN}\` block immediately with no preamble.`,
    'Only give a normal final answer when the task is actually complete; do not repeat hidden reasoning.'
].join(' ')

const buildMissingToolRetryHint = () => [
    'Your previous reply described an action but did not execute any tool call.',
    `Perform that action now by emitting the real \`${TOOL_CALL_OPEN}\` block immediately with no preamble.`,
    'Do not describe the action again or claim completion without a tool result.'
].join(' ')

const appendRetryHintToRequestBody = (requestBody, hint) => {
    const messages = Array.isArray(requestBody?.messages)
        ? requestBody.messages.map(message => ({ ...message }))
        : []
    if (messages.length === 0) {
        messages.push({ role: 'user', content: hint })
    } else {
        const last = messages[messages.length - 1]
        if (typeof last.content === 'string') {
            last.content = `${last.content}\n\n# Tool-call retry\n${hint}`
        } else if (Array.isArray(last.content)) {
            const textPart = last.content.find(part => part?.type === 'text')
            if (textPart) {
                textPart.text = `${textPart.text || ''}\n\n# Tool-call retry\n${hint}`
            } else {
                last.content = [{ type: 'text', text: hint }, ...last.content]
            }
        }
    }
    return { ...requestBody, messages }
}

/**
 * 处理流式响应
 * @param {object} res - Express 响应对象
 * @param {object} response - 上游响应流
 * @param {boolean} enable_thinking - 是否启用思考模式