turn

type Analyzer interface {
	// AppendAudio adds audio and returns the current end-of-turn state. It must
	// be fast and non-blocking; callers may invoke this on every audio frame.
	AppendAudio(buffer []byte, isSpeech bool) EndOfTurnState
	// AnalyzeEndOfTurn returns the last state synchronously as a cheap snapshot.
	AnalyzeEndOfTurn(ctx context.Context) (EndOfTurnState, error)
	// AnalyzeEndOfTurnAsync runs analysis in a goroutine and returns a channel
	// that receives one EndOfTurnResult then closes. Callers should select on
	// ctx.Done() and the channel. This is intended for analyzers that do
	// heavier work (e.g. ML); the silence implementation runs the same logic
	// in a goroutine but still follows the same contract.
	AnalyzeEndOfTurnAsync(ctx context.Context) <-chan EndOfTurnResult
	// SpeechTriggered reports whether speech has been detected and analysis is active.
	SpeechTriggered() bool
	// SetSampleRate sets the sample rate for audio processing.
	SetSampleRate(rate int)
	// Clear resets the analyzer to initial state.
	Clear()
	// UpdateVADStartSecs updates the VAD start trigger time (for pre-speech padding).
	UpdateVADStartSecs(secs float64)
	// UpdateParams updates turn parameters (e.g. StopSecs for IVR mode). Used when receiving VADParamsUpdateFrame.
	UpdateParams(p Params)
}

type EndOfTurnResult struct {
	State EndOfTurnState
	Err   error
}

type EndOfTurnState int

type Params struct {
	StopSecs        float64 // silence duration in seconds to end turn
	PreSpeechMs     float64 // milliseconds of audio before speech start to include
	MaxDurationSecs float64 // maximum segment duration in seconds
}

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

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

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

type UserTurnStartStrategy interface {
	Reset()
	// OnUserStartedSpeaking should be called when a VAD- or externally-driven
	// event indicates that the user has started speaking.
	OnUserStartedSpeaking()
	// ShouldStartTurn returns true when this strategy believes a user turn
	// should be started given current internal state.
	ShouldStartTurn() bool
}

type UserTurnStopStrategy interface {
	Reset()
	// OnUserStoppedSpeaking should be called when VAD or other signals indicate
	// the user has stopped speaking.
	OnUserStoppedSpeaking()
	// ShouldStopTurn returns true when this strategy believes the user turn
	// should be stopped (e.g. after sufficient silence).
	ShouldStopTurn() bool
}

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