Function pipeUpstream

src/controllers/chat.js:368–404

(upstreamResponse)

    return { reasoning, content, residueOnly }
}

/**
 * Error de entrega para la ronda 100% residuo. Misma clase de fallo que el gemelo
 * (anthropic.js:2307 -> 502 `invalid_tool_call_error`), con la forma que este camino ya usa:
 * `writeOpenAIHttpError` emite JSON si aun no salieron cabeceras y un evento de error SSE si
 * ya salieron -- el mismo mecanismo por el que viaja el 422 del gate.
 */
const RESIDUE_ONLY_DETAIL = '整轮内容只有协议残渣，剥离后为空'
const writeResidueOnlyError = (res, label) => {
    logger.warn(
        `OpenAI ${label} Agent 工具协议失败，放弃交付 (${RESIDUE_ONLY_DETAIL})`,
        'AGENT'
    )
    writeOpenAIHttpError(res, {
        status: 502,
        message: `上游返回了残缺、非法或不存在的工具调用 (${RESIDUE_ONLY_DETAIL})`,
        code: 'invalid_tool_call'
    })
}

const handleOpenAIAgentStream = async (
    res,
    response,
    enableThinking,
    enableWebSearch,
    requestBody,
    options
) => {
    setResponseHeaders(res, true)
    const messageId = generateUUID()
    const created = Math.round(Date.now() / 1000)
    let firstDelta = true
    const writeDelta = (delta) => {
        if (!delta || Object.keys(delta).length === 0) return
        const normalizedDelta = firstDelta ? { role: 'assistant', ...delta } : delta
        firstDelta = false
        res.write(`data: ${JSON.stringify({
            id: `chatcmpl-${messageId}`,
            object: 'chat.completion.chunk',
            created,