Function handleTTSClick

packages/ui/src/views/chatmessage/ChatMessage.jsx:1771–1871

(messageId, messageText)

    }

    const handleTTSClick = async (messageId, messageText) => {
        if (isTTSLoading[messageId]) return

        if (isTTSPlaying[messageId] || ttsAudio[messageId]) {
            handleTTSStop(messageId)
            return
        }

        setTTSAction(true)

        // abort all ongoing streams and clear audio sources
        await handleTTSAbortAll()
        stopAllTTS()

        handleTTSStart({ chatMessageId: messageId, format: 'mp3' })
        try {
            const abortController = new AbortController()
            setTtsStreamingState((prev) => ({ ...prev, abortController }))

            const response = await fetch('/api/v1/text-to-speech/generate', {
                method: 'POST',
                headers: {
                    'Content-Type': 'application/json',
                    'x-request-from': 'internal'
                },
                credentials: 'include',
                signal: abortController.signal,
                body: JSON.stringify({
                    chatflowId: chatflowid,
                    chatId: chatId,
                    chatMessageId: messageId,
                    text: messageText
                })
            })

            if (!response.ok) {
                throw new Error(`TTS request failed: ${response.status}`)
            }

            const reader = response.body.getReader()
            const decoder = new TextDecoder()
            let buffer = ''

            let done = false
            while (!done) {
                if (abortController.signal.aborted) {
                    break
                }

                const result = await reader.read()
                done = result.done
                if (done) {
                    break
                }
                const value = result.value
                const chunk = decoder.decode(value, { stream: true })
                buffer += chunk