workflows

type AgentTaskAdapter[Result, UserData any] struct {
	// contains filtered or unexported fields
}

type ChatSummarizer interface {
	SummarizeChatContext(context.Context, *llm.ChatContext) (*llm.ChatContext, error)
}

type ChatSummarizerFunc func(context.Context, *llm.ChatContext) (*llm.ChatContext, error)

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

type InstructionParts struct {
	Persona *InstructionPart
	Extra   *InstructionPart
}

type Task interface {
	Run(context.Context) (any, error)
	ChatContext() *llm.ChatContext
	UpdateChatContext(context.Context, *llm.ChatContext) error
	ToolContext() *llm.Context
	UpdateTools(context.Context, *llm.Context) error
}

type TaskCompletedEvent struct {
	AgentTask Task
	TaskID    string
	Result    any
}

type TaskFactory func() Task

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

type TaskGroupOptions struct {
	// Nil preserves the agents-js default (true).
	SummarizeChatCtx *bool
	ReturnExceptions bool
	ChatCtx          *llm.ChatContext
	OnTaskCompleted  func(context.Context, TaskCompletedEvent) error
	// PreserveFunctionCallHistory is exposed for parity with AgentTask even
	// though TaskGroup always retains tool results until optional summarization.
	PreserveFunctionCallHistory bool

	// LLM supplies the agents-js standard-LLM summarizer. Summarizer overrides
	// LLM and is useful for custom/realtime model stacks.
	LLM        llm.LLM
	Summarizer ChatSummarizer

	// MaxExecutions bounds regressions caused by out_of_scope. Zero selects
	// DefaultTaskGroupMaxExecutions.
	MaxExecutions int
}

type TaskGroupResult struct {
	TaskResults map[string]any `json:"taskResults"`
}

type TaskRegistration struct {
	ID          string
	Description string
}

type TaskRunner[Result, UserData any] func(context.Context, *voice.AgentTask[Result, UserData]) (Result, error)

type WarmTransferBackend interface {
	CallerRoomName(context.Context) (string, error)
	CallerLocalIdentity(context.Context) (string, error)
	CallerPresent(context.Context) (bool, error)
	CallerDisconnected() <-chan WarmTransferParticipantEvent

	CaptureCallerIO(context.Context) (WarmTransferIOState, error)
	SetCallerIO(context.Context, WarmTransferIOState) error
	StartHold(context.Context, WarmTransferHoldAudio) (WarmTransferHold, error)

	Dial(context.Context, WarmTransferDialRequest) (WarmTransferConsultation, error)
	MoveParticipant(context.Context, string, string, string) error
	RemoveParticipant(context.Context, string, string) error
	DeleteRoom(context.Context, string) error
}

type WarmTransferBackendFuncs struct {
	CallerRoomNameFunc      func(context.Context) (string, error)
	CallerLocalIdentityFunc func(context.Context) (string, error)
	CallerPresentFunc       func(context.Context) (bool, error)
	CallerDisconnectedChan  <-chan WarmTransferParticipantEvent
	CaptureCallerIOFunc     func(context.Context) (WarmTransferIOState, error)
	SetCallerIOFunc         func(context.Context, WarmTransferIOState) error
	StartHoldFunc           func(context.Context, WarmTransferHoldAudio) (WarmTransferHold, error)
	DialFunc                func(context.Context, WarmTransferDialRequest) (WarmTransferConsultation, error)
	MoveParticipantFunc     func(context.Context, string, string, string) error
	RemoveParticipantFunc   func(context.Context, string, string) error
	DeleteRoomFunc          func(context.Context, string) error
	PostMergeCleanupFunc    func(context.Context, string) error
}

type WarmTransferConsultation interface {
	RoomName() string
	Session() WarmTransferSession
	Disconnected() <-chan error
	Close(context.Context) error
}

type WarmTransferDialRequest struct {
	CallerRoomName     string
	CallerIdentity     string
	HumanRoomName      string
	HumanIdentity      string
	SIPCallTo          string
	SIPTrunkID         string
	SIPConnection      *livekit.SIPOutboundConfig
	SIPNumber          string
	SIPHeaders         map[string]string
	DTMF               *string
	RingingTimeout     *time.Duration
	Instructions       llm.Instructions
	ChatContext        *llm.ChatContext
	Tools              *llm.Context
	AllowInterruptions *bool
	STT                agents.Override[stt.STT]
	VAD                agents.Override[vad.VAD]
	LLM                agents.Override[llm.LLM]
	TTS                agents.Override[tts.TTS]
	TurnHandling       *voice.TurnHandlingOptions
}

type WarmTransferHold interface {
	Stop(context.Context) error
}

type WarmTransferHoldAudio struct {
	Source string
	Volume float64
}

type WarmTransferIOState struct {
	AudioInput          bool
	AudioOutput         bool
	TranscriptionOutput bool
}

type WarmTransferInstructionConfig struct {
	Full  *string
	Parts *InstructionParts
}

type WarmTransferParticipantEvent struct {
	Identity string
	Kind     livekit.ParticipantInfo_Kind
}

type WarmTransferPostMergeBackend interface {
	DeleteCallerRoomOnDisconnect(context.Context, string) error
}

type WarmTransferResult struct {
	HumanAgentIdentity string `json:"humanAgentIdentity"`
}

type WarmTransferSession interface {
	Say(context.Context, string, voice.SayOptions) (*voice.SpeechHandle, error)
	GenerateReply(context.Context, voice.GenerateReplyOptions) (*voice.SpeechHandle, error)
	Interrupt(context.Context, bool) error
	Close(context.Context, ...voice.CloseOptions) error
}

type WarmTransferSpeech struct {
	Text  *string
	Start func(context.Context, WarmTransferSession) (*voice.SpeechHandle, error)
}

type WarmTransferTask[UserData any] struct {
	// contains filtered or unexported fields
}

type WarmTransferTaskOptions[UserData any] struct {
	AbortContext context.Context
	Backend      WarmTransferBackend

	SIPCallTo      string
	SIPTrunkID     agents.Override[string]
	SIPConnection  *livekit.SIPOutboundConfig
	SIPNumber      string
	SIPHeaders     map[string]string
	DTMF           *string
	RingingTimeout *time.Duration
	RoomName       *string

	// Zero inherits the agents-js default hold music at volume 0.8. Use
	// agents.Disable[WarmTransferHoldAudio]() for holdAudio: null.
	HoldAudio agents.Override[WarmTransferHoldAudio]

	GreetingSpeech          WarmTransferSpeech
	CallerHangupSpeech      WarmTransferSpeech
	CallerHangupInstruction *string // Deprecated: prefer CallerHangupSpeech.
	Instructions            WarmTransferInstructionConfig
	ChatCtx                 *llm.ChatContext
	Tools                   *llm.Context
	STT                     agents.Override[stt.STT]
	VAD                     agents.Override[vad.VAD]
	LLM                     agents.Override[llm.LLM]
	TTS                     agents.Override[tts.TTS]
	TurnHandling            *voice.TurnHandlingOptions
	AllowInterruptions      *bool

	CallerHangupNoticeTimeout  time.Duration
	CallerHangupCleanupTimeout time.Duration
	CleanupTimeout             time.Duration
	MergeTimeout               time.Duration
	DialDrainTimeout           time.Duration
	OnError                    func(error)
}