grail/gf-lt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix: flushchan signal

Browse Source
This commit is contained in:
Grail Finder
2026-01-10 10:59:27 +03:00
parent 8474b87c43
commit c498ed6424
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
bot.go
View File

@@ -664,11 +664,15 @@ out:
if scrollToEndEnabled { if scrollToEndEnabled {
tv.ScrollToEnd() tv.ScrollToEnd()
} }
// Send chunk to audio stream handler
if cfg.TTS_ENABLED { if cfg.TTS_ENABLED {
// Send chunk to audio stream handler
TTSTextChan <- chunk TTSTextChan <- chunk
} }
} }
if cfg.TTS_ENABLED {
// msg is done; flush it down
TTSFlushChan <- true
}
break out break out
} }
} }

5
extra/tts.go
View File

@@ -371,14 +371,12 @@ func (o *GoogleTranslateOrator) GetLogger() *slog.Logger {
func (o *GoogleTranslateOrator) Speak(text string) error { func (o *GoogleTranslateOrator) Speak(text string) error {
o.logger.Debug("fn: Speak is called", "text-len", len(text)) o.logger.Debug("fn: Speak is called", "text-len", len(text))
// Generate MP3 data using google-translate-tts // Generate MP3 data using google-translate-tts
reader, err := o.speech.GenerateSpeech(text) reader, err := o.speech.GenerateSpeech(text)
if err != nil { if err != nil {
o.logger.Error("generate speech failed", "error", err) o.logger.Error("generate speech failed", "error", err)
return fmt.Errorf("generate speech failed: %w", err) return fmt.Errorf("generate speech failed: %w", err)
} }
// Decode the mp3 audio from reader (wrap with NopCloser for io.ReadCloser) // Decode the mp3 audio from reader (wrap with NopCloser for io.ReadCloser)
streamer, format, err := mp3.Decode(io.NopCloser(reader)) streamer, format, err := mp3.Decode(io.NopCloser(reader))
if err != nil { if err != nil {
@@ -386,7 +384,6 @@ func (o *GoogleTranslateOrator) Speak(text string) error {
return fmt.Errorf("mp3 decode failed: %w", err) return fmt.Errorf("mp3 decode failed: %w", err)
} }
defer streamer.Close() defer streamer.Close()
playbackStreamer := beep.Streamer(streamer) playbackStreamer := beep.Streamer(streamer)
speed := o.speech.Speed speed := o.speech.Speed
if speed <= 0 { if speed <= 0 {
@@ -395,12 +392,10 @@ func (o *GoogleTranslateOrator) Speak(text string) error {
if speed != 1.0 { if speed != 1.0 {
playbackStreamer = beep.ResampleRatio(3, float64(speed), streamer) playbackStreamer = beep.ResampleRatio(3, float64(speed), streamer)
} }
// Initialize speaker with the format's sample rate // Initialize speaker with the format's sample rate
if err := speaker.Init(format.SampleRate, format.SampleRate.N(time.Second/10)); err != nil { if err := speaker.Init(format.SampleRate, format.SampleRate.N(time.Second/10)); err != nil {
o.logger.Debug("failed to init speaker", "error", err) o.logger.Debug("failed to init speaker", "error", err)
} }
done := make(chan bool) done := make(chan bool)
// Create controllable stream and store reference // Create controllable stream and store reference
o.currentStream = &beep.Ctrl{Streamer: beep.Seq(playbackStreamer, beep.Callback(func() { o.currentStream = &beep.Ctrl{Streamer: beep.Seq(playbackStreamer, beep.Callback(func() {