janus

type AckMsg struct {
	Type string `json:"janus"`
	ID   string `json:"transaction"`
	Hint string `json:"hint,omitempty"`
}

type BaseMsg struct {
	Type    string `json:"janus"`
	ID      string `json:"transaction"`
	Session uint64 `json:"session_id,omitempty"`
	Handle  uint64 `json:"sender,omitempty"`
	Plugin  string `json:"plugin,omitempty"`
}

type DetachedMsg struct{}

type ErrorData struct {
	Code   int
	Reason string
}

type ErrorMsg struct {
	BaseMsg
	Err ErrorData `json:"error"`
}

type EventMsg struct {
	Type       string                 `json:"janus"`
	ID         string                 `json:"transaction"`
	Session    uint64                 `json:"session_id"`
	Handle     uint64                 `json:"sender,omitempty"`
	Plugindata PluginData             `json:"plugindata"`
	Jsep       map[string]interface{} `json:"jsep"`
}

type Gateway struct {
	// Sessions is a map of the currently active sessions to the gateway.
	Sessions map[uint64]*Session

	// Access to the Sessions map should be synchronized with the Gateway.Lock()
	// and Gateway.Unlock() methods provided by the embeded sync.Mutex.
	sync.RWMutex
	// contains filtered or unexported fields
}

type Handle struct {
	// ID is the handle_id of this plugin handle
	ID uint64

	// Type   // pub  or sub
	Type string

	//User   // Userid
	User string

	// Events is a receive only channel that can be used to receive events
	// related to this handle from the gateway.
	Events chan interface{}
	// contains filtered or unexported fields
}

type HandlerMessage struct {
	BaseMsg
	Handle uint64         `json:"handle_id,omitempty"`
	Body   map[string]any `json:"body"`
}

type HandlerMessageJsep struct {
	HandlerMessage
	Jsep map[string]any `json:"jsep,omitempty"`
}

type HangupMsg struct {
	Type    string `json:"janus"`
	Reason  string
	Session uint64 `json:"session_id,omitempty"`
	Handle  uint64 `json:"sender,omitempty"`
}

type InfoMsg struct {
	Name          string
	Version       int
	VersionString string `json:"version_string"`
	Author        string
	DataChannels  bool   `json:"data_channels"`
	IPv6          bool   `json:"ipv6"`
	LocalIP       string `json:"local-ip"`
	IceTCP        bool   `json:"ice-tcp"`
	Transports    map[string]PluginInfo
	Plugins       map[string]PluginInfo
}

type MediaMsg struct {
	Type      string `json:"janus"`
	Session   uint64 `json:"session_id,omitempty"`
	Handle    uint64 `json:"sender,omitempty"`
	Mid       string `json:"mid"`
	MediaType string `json:"type"`
	Receiving bool   `json:"receiving"`
}

type PluginData struct {
	Plugin string                 `json:"plugin"`
	Data   map[string]interface{} `json:"data"`
}

type PluginInfo struct {
	Name          string
	Author        string
	Description   string
	Version       int
	VersionString string `json:"version_string"`
}

type Session struct {
	// ID is the session_id of this session
	ID uint64

	Data map[string]any // Additional data for the session injected by external sources

	// Handles is a map of plugin handles within this session
	Handles map[uint64]*Handle

	Events chan interface{}

	// Access to the Handles map should be synchronized with the Session.Lock()
	// and Session.Unlock() methods provided by the embeded sync.Mutex.
	sync.Mutex
	// contains filtered or unexported fields
}

type SlowLinkMsg struct {
	Type    string `json:"janus"`
	Session uint64 `json:"session_id,omitempty"`
	Handle  uint64 `json:"sender,omitempty"`
	Uplink  bool
	Lost    int64
}

type SuccessData struct {
	ID uint64 `json:"id"`
}

type SuccessMsg struct {
	Type string      `json:"janus"`
	ID   string      `json:"transaction"`
	Data SuccessData `json:"data,omitempty"`
}

type TimeoutMsg struct {
	Session uint64 `json:"session_id"`
}

type TrickleMany struct {
	BaseMsg
	HandleR    uint64 `json:"handle_id,omitempty"`
	Candidates []any  `json:"candidates"`
}

type TrickleOne struct {
	BaseMsg
	HandleR   uint64 `json:"handle_id,omitempty"`
	Candidate any    `json:"candidate"`
}

type WebRTCUpMsg struct {
	Type    string `json:"janus"`
	Session uint64 `json:"session_id,omitempty"`
	Handle  uint64 `json:"sender,omitempty"`
}