87 lines
2.1 KiB
Go
87 lines
2.1 KiB
Go
// Copyright (c) 2026 Storm Dragon
|
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
|
|
|
package speech
|
|
|
|
import (
|
|
"context"
|
|
"reflect"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestSpeechPreludeFinishesBeforeSpeechAndPreservesFIFO(t *testing.T) {
|
|
fake := new_recording_transport()
|
|
service := New(fake)
|
|
defer service.Close()
|
|
release := make(chan struct{})
|
|
service.Say_after("notification", func(ctx context.Context) {
|
|
fake.record("sound:start")
|
|
select {
|
|
case <-release:
|
|
case <-ctx.Done():
|
|
}
|
|
fake.record("sound:drained")
|
|
})
|
|
service.Say("following text")
|
|
wait_event(t, fake.changed, "sound:start")
|
|
fake.mu.Lock()
|
|
events := append([]string(nil), fake.events...)
|
|
fake.mu.Unlock()
|
|
if !reflect.DeepEqual(events, []string{"sound:start"}) {
|
|
t.Fatal(events)
|
|
}
|
|
close(release)
|
|
wait_event(t, fake.changed, "sent:following text")
|
|
fake.mu.Lock()
|
|
defer fake.mu.Unlock()
|
|
want := []string{"sound:start", "sound:drained", "say:notification", "sent:notification", "say:following text", "sent:following text"}
|
|
if !reflect.DeepEqual(fake.events, want) {
|
|
t.Fatal(fake.events)
|
|
}
|
|
}
|
|
|
|
func TestSpeechPreludeInterruptMuteAndCloseDiscardDelayedSpeech(t *testing.T) {
|
|
for _, action := range []string{"interrupt", "mute", "close"} {
|
|
t.Run(action, func(t *testing.T) {
|
|
fake := new_recording_transport()
|
|
service := New(fake)
|
|
defer service.Close()
|
|
entered, stopped := make(chan struct{}), make(chan struct{})
|
|
service.Say_after("discarded notification", func(ctx context.Context) {
|
|
close(entered)
|
|
<-ctx.Done()
|
|
close(stopped)
|
|
})
|
|
<-entered
|
|
switch action {
|
|
case "interrupt":
|
|
service.Interrupt()
|
|
case "mute":
|
|
service.Toggle_mute()
|
|
case "close":
|
|
service.Close()
|
|
}
|
|
select {
|
|
case <-stopped:
|
|
case <-time.After(time.Second):
|
|
t.Fatal("sound wait was not canceled")
|
|
}
|
|
if action == "mute" {
|
|
service.Toggle_mute()
|
|
}
|
|
if action != "close" {
|
|
service.Say("fresh review")
|
|
wait_event(t, fake.changed, "sent:fresh review")
|
|
}
|
|
fake.mu.Lock()
|
|
defer fake.mu.Unlock()
|
|
for _, event := range fake.events {
|
|
if event == "say:discarded notification" {
|
|
t.Fatal("late notification speech escaped cancellation")
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|