livekit

type AcceptedJobRoomConnectOptions struct {
	Room          *lksdk.Room
	URL           string
	Token         string
	Job           *lkprotocol.Job
	APIKey        string
	APISecret     string
	Accept        JobAcceptArguments
	Identity      string
	AutoSubscribe string
	Connector     RoomConnector
}

type AgentNameEnvOptions struct {
	AgentName      string
	AgentNameIsEnv bool
	LookupEnv      func(string) string
}

type AgentNameEnvResult struct {
	AgentName      string
	AgentNameIsEnv bool
}

type AssignmentContextValueOptions struct {
	Assignment      AssignmentInfo
	AcceptArguments JobAcceptArguments
	WorkerID        string
}

type AssignmentContextValuesResult struct {
	Job             *lkprotocol.Job
	JobID           string
	URL             string
	Token           string
	WorkerID        string
	AcceptArguments JobAcceptArguments
	EnableRecording bool
}

type AssignmentInfo struct {
	Job             *lkprotocol.Job
	JobID           string
	URL             string
	Token           string
	EnableRecording bool
}

type AudioDecoder interface {
	Decode(data []byte) ([]byte, error)
	Close() error
}

type AudioEncoder interface {
	Encode(pcm []byte) ([]byte, error)
	Close() error
}

type AutoSubscribe string

type AvailabilityAcceptOptions = JobAcceptArguments

type AvailabilityAnswerOptions struct {
	Request                  *AvailabilityRequest
	AgentName                string
	AvailableForJob          func() bool
	ReserveSlot              func()
	ReleaseSlot              func()
	StoreAccept              func(jobID string, args JobAcceptArguments)
	Send                     func(*lkprotocol.WorkerMessage) error
	HandleRequest            func(*JobRequest) error
	OnRequestError           func(error, string)
	OnUnavailableRejectError func(error, string)
}

type AvailabilityRejectOptions = JobRejectArguments

type AvailabilityRequest = lkprotocol.AvailabilityRequest

type AvailabilityRequestInfo struct {
	Job   *lkprotocol.Job
	JobID string
}

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

type AvailabilityResponderOptions struct {
	Request     *AvailabilityRequest
	AgentName   string
	StoreAccept func(jobID string, args JobAcceptArguments)
	Send        func(*lkprotocol.WorkerMessage) error
}

type AvatarStartInfoOptions struct {
	URL           string
	Token         string
	RoomName      string
	AgentIdentity string
}

type ClaimGrants = auth.ClaimGrants

type ConnectInfoOptions struct {
	APIKey                string
	APISecret             string
	RoomName              string
	ParticipantName       string
	ParticipantIdentity   string
	ParticipantMetadata   string
	ParticipantAttributes map[string]string
}

type ConnectOptions struct {
	AutoSubscribe AutoSubscribe
}

type DeleteRoomAPI interface {
	DeleteRoom(context.Context, *lkprotocol.DeleteRoomRequest) (*lkprotocol.DeleteRoomResponse, error)
}

type DeleteRoomPlanResult struct {
	Skip     bool
	Response *lkprotocol.DeleteRoomResponse
}

type DeleteRoomResponse = lkprotocol.DeleteRoomResponse

type EntrypointResult struct {
	Status    lkprotocol.JobStatus
	Err       error
	Recovered any
}

type Job = lkprotocol.Job

type JobAPI struct {
	RoomService JobRoomServiceAPI
	SIP         JobSIPAPI
}

type JobAcceptArguments struct {
	Name       string            `json:"name"`
	Identity   string            `json:"identity"`
	Metadata   string            `json:"metadata"`
	Attributes map[string]string `json:"attributes,omitempty"`
}

type JobAssignment = lkprotocol.JobAssignment

type JobCompletionPlan struct {
	Finish          bool
	WaitForShutdown bool
	SendStatus      bool
	SendAfterFinish bool
}

type JobEntrypointLifecycleOptions struct {
	Context      context.Context
	Entrypoint   func() error
	MarkDone     func()
	OnResult     func(EntrypointResult)
	Terminated   func() bool
	ShutdownDone <-chan struct{}
	Shutdown     func(string)
	Finish       func() bool
	SendStatus   func(lkprotocol.JobStatus) error
}

type JobFinishPlanResult struct {
	Finish bool
	JobID  string
}

type JobRejectArguments struct {
	Terminate bool
}

type JobRequest struct {
	Job *lkprotocol.Job
	// contains filtered or unexported fields
}

type JobRoomServiceAPI interface {
	DeleteRoom(context.Context, *lkprotocol.DeleteRoomRequest) (*lkprotocol.DeleteRoomResponse, error)
	MoveParticipant(context.Context, *lkprotocol.MoveParticipantRequest) (*lkprotocol.MoveParticipantResponse, error)
}

type JobSIPAPI interface {
	CreateSIPParticipant(context.Context, *lkprotocol.CreateSIPParticipantRequest) (*lkprotocol.SIPParticipantInfo, error)
	TransferSIPParticipant(context.Context, *lkprotocol.TransferSIPParticipantRequest) (*emptypb.Empty, error)
}

type JobSessionEndPlanOptions struct {
	Job            *lkprotocol.Job
	TimeoutSeconds float64
}

type JobSessionEndPlanResult struct {
	JobID   string
	Timeout time.Duration
}

type JobSessionReportUploadPlanOptions struct {
	Job       *lkprotocol.Job
	FakeJob   bool
	Report    *agent.SessionReport
	URL       string
	APIKey    string
	APISecret string
	AgentName string
}

type JobSessionReportUploadPlanResult struct {
	Upload    bool
	JobID     string
	Report    *agent.SessionReport
	URL       string
	APIKey    string
	APISecret string
	AgentName string
}

type JobStatus = lkprotocol.JobStatus

type JobTermination = lkprotocol.JobTermination

type JobTerminationPlan struct {
	MarkTerminated bool
	Shutdown       bool
	WaitEntrypoint bool
	Finish         bool
}

type LocalJobContextSetupPlanOptions = LocalJobContextValueOptions

type LocalJobContextSetupPlanResult struct {
	Job              *lkprotocol.Job
	AcceptIdentity   string
	Token            string
	FakeJob          bool
	InitRecording    bool
	RecordingOptions agent.RecordingOptions
	SessionDirectory string
}

type LocalJobContextValueOptions struct {
	RoomName            string
	ParticipantIdentity string
	APIKey              string
	APISecret           string
	TTL                 time.Duration
	Options             LocalJobOptions
	NewIdentity         func(string) string
}

type LocalJobContextValuesResult struct {
	Job                 *lkprotocol.Job
	ParticipantIdentity string
	Token               string
}

type LocalJobExecutorPlanResult = LocalJobRuntimeInfo

type LocalJobOptions struct {
	FakeJob           bool
	RoomInfo          *lkprotocol.Room
	Token             string
	RecordingOptions  agent.RecordingOptions
	SessionReportPath string
	SessionDirectory  string
}

type LocalJobRuntimeInfo struct {
	JobID      string
	ExecutorID string
}

type LocalParticipant = lksdk.LocalParticipant

type LocalRoomJobOptions struct {
	RoomName string
	RoomInfo *lkprotocol.Room
	FakeJob  bool
	NewID    func(prefix string) string
}

type MetricInfo struct {
	RoomName string
}

type MoveParticipantAPI interface {
	MoveParticipant(context.Context, *lkprotocol.MoveParticipantRequest) (*lkprotocol.MoveParticipantResponse, error)
}

type MoveParticipantPlanResult struct {
	Skip bool
}

type ParticipantDetails struct {
	Identity string
	Kind     lkprotocol.ParticipantInfo_Kind
}

type ParticipantEntrypointRegistrationOptions struct {
	Entrypoint            uintptr
	RegisteredEntrypoints []uintptr
	Kinds                 []lkprotocol.ParticipantInfo_Kind
}

type ParticipantEntrypointRegistrationPlanResult struct {
	Kinds []lkprotocol.ParticipantInfo_Kind
}

type ParticipantEntrypointTaskPlanResult struct {
	Schedule    bool
	Participant ParticipantDetails
	TaskKey     ParticipantTaskKey
}

type ParticipantInfo = lkprotocol.ParticipantInfo

type ParticipantInfoKind = lkprotocol.ParticipantInfo_Kind

type ParticipantTaskKey struct {
	Identity   string
	Entrypoint uintptr
}

type PendingAcceptStoreOptions struct {
	Pending   map[string]JobAcceptArguments
	Timers    map[string]*time.Timer
	JobID     string
	Args      JobAcceptArguments
	Timeout   time.Duration
	OnTimeout func(jobID string, timer *time.Timer)
}

type PendingAssignmentTimer interface {
	Stop() bool
}

type PlaybackFinishedEvent struct {
	PlaybackPosition          time.Duration
	Interrupted               bool
	SynchronizedTranscript    string
	HasSynchronizedTranscript bool
	AudioFrames               int
	AudioBytes                int
	AudioEncodedFrames        int
	AudioSampleRate           uint32
	AudioChannels             uint32
	AudioLastError            string
}

type PlaybackStartedEvent struct {
	CreatedAt time.Time
}

type PreConnectAudioBuffer struct {
	Timestamp time.Time
	Frames    []*model.AudioFrame
}

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

type PreparedRoomConnectOptions struct {
	Room          *lksdk.Room
	URL           string
	Token         string
	Job           *lkprotocol.Job
	APIKey        string
	APISecret     string
	Accept        ConnectInfoOptions
	AutoSubscribe string
	Connector     RoomConnector
}

type RecorderIO struct {
	Session *agent.AgentSession

	InputStartTime  *time.Time
	OutputStartTime *time.Time
	// contains filtered or unexported fields
}

type RegisterMessageInfo struct {
	WorkerID   string
	ServerInfo *lkprotocol.ServerInfo
}

type RegisterWorkerOptions struct {
	JobType     lkprotocol.JobType
	AgentName   string
	Version     string
	Permissions WorkerPermissions
}

type ReloadedJobContextValueOptions = RunningJobContextValueOptions

type ReloadedJobEntrypointLifecycleOptions struct {
	Context         context.Context
	Entrypoint      func() error
	MarkDone        func()
	OnResult        func(EntrypointResult)
	ShutdownDone    <-chan struct{}
	Shutdown        func(string)
	Finish          func() bool
	SendStatus      func(lkprotocol.JobStatus) error
	OnStatusSkipped func()
}

type RemoteParticipant = lksdk.RemoteParticipant

type RemoteParticipantView interface {
	SID() string
	Identity() string
	Name() string
	Kind() lksdk.ParticipantKind
	Metadata() string
	Attributes() map[string]string
}

type RemoteTrackPublication = lksdk.RemoteTrackPublication

type RemoteTrackPublicationView interface {
	SID() string
	Kind() lksdk.TrackKind
	SetSubscribed(bool) error
}

type RemoteTrackSubscriptionResult struct {
	Attempted bool
	TrackSID  string
	Err       error
}

type Room = lkprotocol.Room

type RoomCallback = lksdk.RoomCallback

type RoomCallbackHandlers struct {
	AutoSubscribe             string
	OnDisconnected            func()
	OnDisconnectedWithReason  func(lksdk.DisconnectionReason)
	OnReconnecting            func()
	OnReconnected             func()
	OnRoomMoved               func(roomName string, token string)
	OnParticipantConnected    func(RemoteParticipantView)
	OnParticipantDisconnected func(RemoteParticipantView)
	OnLocalTrackPublished     func(*lksdk.LocalTrackPublication, *lksdk.LocalParticipant)
	OnLocalTrackSubscribed    func(*lksdk.LocalTrackPublication, *lksdk.LocalParticipant)
	OnTrackSubscribed         func(*webrtc.TrackRemote, *lksdk.RemoteTrackPublication, *lksdk.RemoteParticipant)
	OnTrackUnpublished        func(*lksdk.RemoteTrackPublication, *lksdk.RemoteParticipant)
	OnTrackPublishedEvent     func(*lksdk.RemoteTrackPublication, *lksdk.RemoteParticipant)
	OnAttributesChanged       func(map[string]string, lksdk.Participant)
	OnIsSpeakingChanged       func(lksdk.Participant)
	OnDataPacket              func(lksdk.DataPacket, lksdk.DataReceiveParams)
	OnTrackSubscribeError     func(RemoteTrackSubscriptionResult)
}

type RoomConnectOptions struct {
	URL           string
	Token         string
	Job           *lkprotocol.Job
	APIKey        string
	APISecret     string
	Accept        ConnectInfoOptions
	AutoSubscribe string
	Callback      *lksdk.RoomCallback
	Connector     RoomConnector
}

type RoomConnectionStateChangedEvent struct {
	State string
}

type RoomConnector struct {
	ConnectWithToken func(string, string, *lksdk.RoomCallback, ...lksdk.ConnectOption) (*lksdk.Room, error)
	Connect          func(string, lksdk.ConnectInfo, *lksdk.RoomCallback, ...lksdk.ConnectOption) (*lksdk.Room, error)
	JoinWithToken    func(context.Context, *lksdk.Room, string, string, ...lksdk.ConnectOption) error
	Join             func(context.Context, *lksdk.Room, string, lksdk.ConnectInfo, ...lksdk.ConnectOption) error
}

type RoomDisconnectedEvent struct{}

type RoomEvent interface {
	Type() string
}

type RoomIO struct {
	Room         *lksdk.Room
	AgentSession *agent.AgentSession
	Options      RoomOptions
	Recorder     *RecorderIO
	// contains filtered or unexported fields
}

type RoomIOAudioOutputDiagnostics struct {
	TrackID                     string
	TrackPublished              bool
	TrackSubscribed             bool
	FramesReceived              int
	FramesPublished             int
	BytesReceived               int
	BytesPublished              int
	EncodedFramesPublished      int
	LastInputSampleRate         uint32
	LastInputSamplesPerChannel  uint32
	LastInputChannels           uint32
	LastPublishedSampleRate     uint32
	LastPublishedSamplesPerChan uint32
	LastPublishedChannels       uint32
	LastFrameAt                 time.Time
	LastPublishedAt             time.Time
	LastError                   string
	LastErrorAt                 time.Time
}

type RoomLocalTrackPublishedEvent struct {
	Publication *lksdk.LocalTrackPublication
	Participant *lksdk.LocalParticipant
}

type RoomMovedEvent struct {
	RoomName string
	Token    string
}

type RoomOptions struct {
	AudioTrackName             string
	AudioSubscriptionTimeout   time.Duration
	PreConnectAudioTimeout     time.Duration
	DisablePreConnectAudio     bool
	DisableAudioInput          bool
	DisableTextInput           bool
	DisableAudioOutput         bool
	DisableTranscriptionOutput bool
	TranscriptionJSONFormat    bool
	TranscriptionNextOutput    TranscriptionTextOutput
	DisableCloseOnDisconnect   bool
	DeleteRoomOnClose          bool
	DeleteRoom                 func(context.Context, string) error
	TextInputCallback          TextInputCallback
	ParticipantIdentity        string
	ParticipantKinds           []lksdk.ParticipantKind
}

type RoomParticipantActiveEvent struct {
	Participant lksdk.Participant
}

type RoomParticipantAttributesChangedEvent struct {
	Changed     map[string]string
	Participant lksdk.Participant
}

type RoomParticipantConnectedEvent struct {
	Participant *lksdk.RemoteParticipant
}

type RoomParticipantDisconnectedEvent struct {
	Participant *lksdk.RemoteParticipant
}

type RoomSipDTMFReceivedEvent struct {
	Event  *livekit.SipDTMF
	Params lksdk.DataReceiveParams
}

type RoomTrackPublishedEvent struct {
	Publication *lksdk.RemoteTrackPublication
	Participant *lksdk.RemoteParticipant
}

type RoomTrackSubscribedEvent struct {
	Track       *webrtc.TrackRemote
	Publication *lksdk.RemoteTrackPublication
	Participant *lksdk.RemoteParticipant
}

type RoomTrackUnpublishedEvent struct {
	Publication *lksdk.RemoteTrackPublication
	Participant *lksdk.RemoteParticipant
}

type RunningJobContextValueOptions struct {
	Info            RunningJobInfo
	OverrideURL     string
	DefaultWorkerID string
}

type RunningJobContextValuesResult struct {
	Job             *lkprotocol.Job
	JobID           string
	URL             string
	Token           string
	WorkerID        string
	AcceptArguments JobAcceptArguments
	FakeJob         bool
	EnableRecording bool
}

type RunningJobEntrypointLifecycleOptions struct {
	Context            context.Context
	Entrypoint         func() error
	MarkStarted        func()
	MarkDone           func()
	ShutdownDone       <-chan struct{}
	Shutdown           func(string)
	WaitEntrypointDone func(time.Duration) bool
	CloseWait          time.Duration
	Finish             func() bool
	OnPanic            func(any)
	OnError            func(error)
	OnCancelTimeout    func()
}

type RunningJobInfo struct {
	AcceptArguments JobAcceptArguments `json:"accept_arguments"`
	Job             *lkprotocol.Job    `json:"job"`
	URL             string             `json:"url"`
	Token           string             `json:"token"`
	WorkerID        string             `json:"worker_id"`
	FakeJob         bool               `json:"fake_job"`
}

type RunningJobInfoOptions struct {
	AcceptArguments JobAcceptArguments
	Job             *lkprotocol.Job
	URL             string
	Token           string
	WorkerID        string
	FakeJob         bool
}

type RuntimeJobInfo struct {
	JobID           string
	EnableRecording bool
}

type SDKRoom = lksdk.Room

type SIPAPI interface {
	CreateSIPParticipant(context.Context, *lkprotocol.CreateSIPParticipantRequest) (*lkprotocol.SIPParticipantInfo, error)
	TransferSIPParticipant(context.Context, *lkprotocol.TransferSIPParticipantRequest) (*emptypb.Empty, error)
}

type SIPCreateParticipantPlanResult struct {
	Skip bool
	Info *lkprotocol.SIPParticipantInfo
}

type SIPCreateParticipantRequest = lkprotocol.CreateSIPParticipantRequest

type SIPParticipantInfo = lkprotocol.SIPParticipantInfo

type SIPTransferParticipantPlanResult struct {
	Skip bool
}

type ServerAvailableWorkerStatusMessageOptions struct {
	Load         float64
	JobCount     uint32
	CanAcceptJob bool
}

type ServerConnectionEnvOptions struct {
	ServerConnectionOptions
	Setenv func(string, string) error
}

type ServerConnectionOptions struct {
	WSURL     string
	APIKey    string
	APISecret string
}

type ServerConnectionResolveOptions = WorkerConnectionOptions

type ServerInfo = lkprotocol.ServerInfo

type ServerMessage = lkprotocol.ServerMessage

type ServerMessageDispatchInfo struct {
	Kind         ServerMessageKind
	Register     RegisterMessageInfo
	Availability *lkprotocol.AvailabilityRequest
	Assignment   *JobAssignment
	Termination  *JobTermination
}

type ServerMessageKind string

type ServerMessageLoopOptions struct {
	ReadMessage   func() (int, []byte, error)
	Close         func() error
	Handle        func(*ServerMessage)
	OnDecodeError func(error)
}

type ServerMessageRouteOptions struct {
	Message        *lkprotocol.ServerMessage
	OnRegister     func(WorkerRegisteredEvent)
	OnAvailability func(*lkprotocol.AvailabilityRequest)
	OnAssignment   func(*JobAssignment)
	OnTermination  func(*JobTermination)
	OnUnknown      func()
}

type ServerRegisterWorkerMessageOptions struct {
	WorkerType  WorkerType
	AgentName   string
	Version     string
	Permissions *WorkerPermissions
}

type SessionReportInfo struct {
	JobID  string
	RoomID string
	Room   string
}

type TerminationInfo struct {
	JobID string
}

type TextInputCallback func(context.Context, *agent.AgentSession, TextInputEvent) error

type TextInputEvent struct {
	Text                string
	Info                lksdk.TextStreamInfo
	ParticipantIdentity string
}

type TrackPublicationWaitOptions = utils.TrackPublicationWaitOptions

type TrackType = lkprotocol.TrackType

type TranscriptionTextOutput interface {
	CaptureText(context.Context, string) error
	Flush()
}

type WorkerConnect struct {
	URL    string
	Header http.Header
}

type WorkerConnectOptions struct {
	WSURL       string
	WorkerToken string
	APIKey      string
	APISecret   string
	TTL         time.Duration
}

type WorkerConnectionOptions struct {
	WSURL          string
	LegacyWSURL    string
	APIKey         string
	APISecret      string
	WorkerToken    string
	AgentName      string
	AgentNameIsEnv bool
	Getenv         func(string) string
}

type WorkerEnvOptions struct {
	URL       string
	APIKey    string
	APISecret string
	Setenv    func(string, string) error
}

type WorkerMessage = lkprotocol.WorkerMessage

type WorkerMessageLoopOptions struct {
	Reader        WorkerWebSocketReader
	Close         func() error
	Handle        func(*lkprotocol.ServerMessage)
	OnDecodeError func(error)
}

type WorkerMessageWebSocketWriter interface {
	WriteMessage(int, []byte) error
}

type WorkerMetadataOptions struct {
	AgentName       string
	AgentNameIsEnv  bool
	WorkerType      string
	WorkerLoad      float64
	ActiveJobs      int
	SDKVersion      string
	ProtocolVersion int
	NodeName        string
	Hosted          bool
}

type WorkerMetadataResponse struct {
	AgentName       string  `json:"agent_name"`
	AgentNameIsEnv  bool    `json:"agent_name_is_env"`
	WorkerType      string  `json:"worker_type"`
	WorkerLoad      float64 `json:"worker_load"`
	ActiveJobs      int     `json:"active_jobs"`
	SDKVersion      string  `json:"sdk_version"`
	ProtocolVersion int     `json:"protocol_version"`
	ProjectType     string  `json:"project_type"`
	NodeName        string  `json:"node_name"`
	Hosted          bool    `json:"hosted"`
}

type WorkerPermissions struct {
	CanPublish        bool
	CanSubscribe      bool
	CanPublishData    bool
	CanUpdateMetadata bool
	CanPublishSources []lkprotocol.TrackSource
	Hidden            bool
}

type WorkerRegisterWebSocket interface {
	WorkerMessageWebSocketWriter
	ReadMessage() (int, []byte, error)
}

type WorkerRegisteredEvent struct {
	WorkerID   string
	ServerInfo *ServerInfo
}

type WorkerRegisteredHandler func(workerID string, serverInfo *ServerInfo)

type WorkerRegistrationOptions struct {
	WorkerType  string
	AgentName   string
	Version     string
	Permissions *WorkerPermissions
}

type WorkerRuntimeMetadataOptions struct {
	AgentName       string
	AgentNameIsEnv  bool
	WorkerType      string
	WorkerLoad      float64
	ActiveJobs      int
	SDKVersion      string
	ProtocolVersion int
	NodeName        func() string
	IsHosted        func() bool
}

type WorkerStatusUpdateOptions struct {
	Draining     bool
	Load         float64
	JobCount     uint32
	CanAcceptJob bool
}

type WorkerType string

type WorkerWebSocketConnectOptions struct {
	Dialer   *websocket.Dialer
	URL      string
	Headers  http.Header
	MaxRetry int
	Dial     WorkerWebSocketDialFunc
	Sleep    WorkerWebSocketSleepFunc
}

type WorkerWebSocketDialFunc func(context.Context, *websocket.Dialer, string, http.Header) (*websocket.Conn, *http.Response, error)

type WorkerWebSocketOpenOptions struct {
	WSURL       string
	WorkerToken string
	APIKey      string
	APISecret   string
	TTL         time.Duration
	HTTPProxy   string
	MaxRetry    int
	Dial        WorkerWebSocketDialFunc
	Sleep       WorkerWebSocketSleepFunc
}

type WorkerWebSocketOpenResult struct {
	Conn          *websocket.Conn
	Response      *http.Response
	ConnectFailed bool
}

type WorkerWebSocketReadFunc func() (int, []byte, error)

type WorkerWebSocketReader interface {
	ReadMessage() (int, []byte, error)
}

type WorkerWebSocketSleepFunc func(context.Context, time.Duration) error