tts

type AudioFrame struct {
	Data       []byte
	SampleRate int
	Channels   int
	PlayID     string
	Sequence   uint32
}

type AudioSender struct {
	// contains filtered or unexported fields
}

type AudioSenderConfig struct {
	// OutputCodec: output codec (e.g., "opus", "pcm")
	OutputCodec string
	// TargetSampleRate: target sample rate (default: 16000)
	TargetSampleRate int
	// FrameDuration: frame duration (default: 60ms)
	FrameDuration time.Duration
	// SendCallback: callback for sending encoded audio
	SendCallback func(data []byte) error
	// GetPendingCountFunc: optional callback to get pending packet count
	GetPendingCountFunc func() int
	// Logger: optional logging callback
	Logger func(string)
}

type Cache struct {
	// contains filtered or unexported fields
}

type CacheConfig struct {
	// Cache to use. nil → DefaultCache.
	Cache *Cache
	// VoiceKey identifies vendor + voice + sample rate + speed. Required.
	VoiceKey string
	// MaxRunes skips cache writes for longer texts. 0 = no limit.
	MaxRunes int
	// ChunkBytes controls replay chunk size. 0 → one shot.
	ChunkBytes int
}

type CachingTTSService struct {
	// contains filtered or unexported fields
}

type Capabilities struct {
	StreamingTTFB bool
	FirstMaxChars int
	FirstMinChars int
}

type EncodedFrame struct {
	Data     []byte
	PlayID   string
	Sequence uint32
}

type Speaker struct {
	// contains filtered or unexported fields
}

type SpeakerConfig struct {
	Pipeline     *TTSPipeline
	QueueSize    int
	Prefetch     int // buffered segments between synth and play (default 2)
	OnStarted    func(utteranceID, text string, chained bool)
	OnEnded      func(utteranceID string, ok bool, duration time.Duration, ttsFirstMs, e2eFirstMs int, moreQueued bool)
	OnFirstFrame func(utteranceID string, ttsFirstMs, e2eFirstMs int)
}

type TTSPipeline struct {
	// contains filtered or unexported fields
}

type TTSPipelineComponent interface {
	// Name returns the component name.
	Name() string

	// Process processes data through the component.
	// For text processors: input is string, output is string
	// For audio processors: input is []byte, output is []byte
	// Returns (processedData, shouldContinue, error)
	Process(ctx context.Context, data interface{}) (interface{}, bool, error)
}

type TTSPipelineConfig struct {
	// TTSService: the TTS service to use for synthesis
	TTSService TTSService
	// OutputCodec: output audio codec (e.g., "opus", "pcm")
	OutputCodec string
	// TargetSampleRate: target sample rate for output audio (default: 16000)
	TargetSampleRate int
	// FrameDuration: frame duration for audio processing (default: 60ms)
	FrameDuration time.Duration
	// TextProcessors: optional text processing components (e.g., text normalization)
	TextProcessors []TTSPipelineComponent
	// AudioProcessors: optional audio processing components (e.g., encoding)
	AudioProcessors []TTSPipelineComponent
	// SendCallback: callback for sending synthesized audio
	SendCallback func(data []byte) error
	// RecordCallback: optional callback for recording synthesized audio
	RecordCallback func(data []byte) error
	// Logger: optional logging callback
	Logger func(string)
	// PaceRealtime sleeps between frames so playback matches wall-clock (required for RTP/VoIP).
	PaceRealtime bool
}

type TTSService interface {
	// Synthesize synthesizes text to audio and calls the callback for each audio chunk.
	// The callback receives PCM audio data (typically 16-bit mono at 16kHz).
	Synthesize(ctx context.Context, text string, callback func([]byte) error) error
}

type TTSWorkerConfig struct {
	// TTSService: the TTS service to use
	TTSService TTSService
	// WorkerCount: number of worker goroutines (default: 1)
	WorkerCount int
	// Logger: optional logging callback
	Logger func(string)
}

type TTSWorkerPool struct {
	// contains filtered or unexported fields
}

type TextSegment struct {
	Text      string
	IsFinal   bool
	Timestamp time.Time
	PlayID    string
}

type TextSegmenterComponent struct {
	// contains filtered or unexported fields
}

type TextSegmenterConfig struct {
	DelayTimeout time.Duration

	// First segment (latency-optimized)
	FirstMinChars int // comma/pause flush once buffer has this many runes (default 6)
	FirstMaxChars int // first-chunk safety cap with punctuation-aware cut (default 18, 0=off)

	// Later segments (semantic priority)
	RestForceMaxChars int // emergency split only after this many runes without sentence end (default 120, 0=wait for OnComplete)

	// Deprecated: use FirstMinChars / FirstMaxChars. Kept for backward compatibility.
	MinChars int
	MaxChars int
}