Function downloadContainerFile

packages/components/nodes/agentflow/utils.ts:518–567

(
    containerId: string,
    fileId: string,
    filename: string,
    modelNodeData: INodeData,
    options: ICommonObject
)

/** Downloads a file from an OpenAI container (used for file citations in responses). */
export const downloadContainerFile = async (
    containerId: string,
    fileId: string,
    filename: string,
    modelNodeData: INodeData,
    options: ICommonObject
): Promise<{ filePath: string; totalSize: number } | null> => {
    try {
        const credentialData = await getCredentialData(modelNodeData.credential ?? '', options)
        const openAIApiKey = getCredentialParam('openAIApiKey', credentialData, modelNodeData)

        if (!openAIApiKey) {
            console.warn('No OpenAI API key available for downloading container file')
            return null
        }

        const response = await fetch(`https://api.openai.com/v1/containers/${containerId}/files/${fileId}/content`, {
            method: 'GET',
            headers: {
                Accept: '*/*',
                Authorization: `Bearer ${openAIApiKey}`
            }
        })

        if (!response.ok) {
            console.warn(
                `Failed to download container file ${fileId} from container ${containerId}: ${response.status} ${response.statusText}`
            )
            return null
        }

        const data = await response.arrayBuffer()
        const dataBuffer = Buffer.from(data)
        const mimeType = getMimeTypeFromFilename(filename)

        const { path, totalSize } = await addSingleFileToStorage(
            mimeType,
            dataBuffer,
            filename,
            options.orgId,
            options.chatflowid,
            options.chatId
        )

        return { filePath: path, totalSize }
    } catch (error) {
        console.error('Error downloading container file:', error)
        return null
    }
}

// ─── Replacing inline image data with file references in responses ───────────