agora

type AudioFrameReceiver interface {
	OnAudioFrame(context.Context, *model.AudioFrame)
}

type AudioHandler func(*model.AudioFrame)

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

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

type ChannelClient interface {
	Join(context.Context, Options, EventHandler, AudioHandler) error
	Leave(context.Context) error
	PublishPCM(context.Context, PCMFrame) error
}

type DataMessage struct {
	Channel   string
	Publisher string
	Payload   []byte
}

type DataMessageHandler func(context.Context, DataMessage) error

type DataMessageSubscriber interface {
	SetDataMessageHandler(DataMessageHandler)
}

type DataPublisher interface {
	PublishData(context.Context, []byte) error
	Close(context.Context) error
}

type Event struct {
	Kind    EventKind
	Channel string
	UserID  string
	Reason  int
	Err     error
}

type EventHandler func(Event)

type EventKind string

type Options struct {
	AppID          string
	AppCertificate string
	Channel        string
	UID            string
	RemoteStreamID string
	Token          string
	RTMUserID      string
	RTMToken       string
	PublishAudio   *bool
	SubscribeAudio *bool
	PublishData    *bool
	RTMEnabled     *bool
}

type PCMFrame struct {
	Data       []byte
	SampleRate int
	Channels   int
	StartPTSMS int64
}

type PCMFramePublisher interface {
	PublishPCM(context.Context, PCMFrame) error
}

type RTMMessageRouter struct {
	AgentUserID string
	Channel     string
	TextInput   TextInputHandler
}

type TextInputEvent struct {
	Text      string
	StreamID  string
	Channel   string
	Publisher string
}

type TextInputHandler func(context.Context, TextInputEvent) error

type TextInputTranscriber interface {
	EmitUserInputTranscribed(agent.UserInputTranscribedEvent)
}

type TextResponder interface {
	Interrupt(force bool) error
	GenerateReply(context.Context, string) (*agent.SpeechHandle, error)
}

type TextTurnClaimer interface {
	ClaimUserTurn(context.Context, func(context.Context) error) error
}

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

type TranscriptForwarderOptions struct {
	UserStreamID      string
	AssistantStreamID string
}

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