config

type Config map[string]any

type Console struct {
	Server        string `default:"console.monibuca.com:44944"` //远程控制台地址
	Secret        string //远程控制台密钥
	PublicAddr    string //公网地址，提供远程控制台访问的地址，不配置的话使用自动识别的地址
	PublicAddrTLS string
}

type Engine struct {
	Publish
	Subscribe
	HTTP
	Console
	EnableAVCC          bool          `default:"true"`  //启用AVCC格式，rtmp、http-flv协议使用
	EnableRTP           bool          `default:"true"`  //启用RTP格式，rtsp、webrtc等协议使用,已废弃，在 rtp 下面配置
	EnableSubEvent      bool          `default:"true"`  //启用订阅事件,禁用可以提高性能
	EnableAuth          bool          `default:"true"`  //启用鉴权
	LogLang             string        `default:"zh"`    //日志语言
	LogLevel            string        `default:"info"`  //日志级别
	EventBusSize        int           `default:"10"`    //事件总线大小
	PulseInterval       time.Duration `default:"5s"`    //心跳事件间隔
	DisableAll          bool          `default:"false"` //禁用所有插件
	RTPReorderBufferLen int           `default:"50"`    //RTP重排序缓冲区长度
	PoolSize            int           //内存池大小
	// contains filtered or unexported fields
}

type HTTP struct {
	ListenAddr    string
	ListenAddrTLS string
	CertFile      string
	KeyFile       string
	CORS          bool `default:"true"` //是否自动添加CORS头
	UserName      string
	Password      string
	ReadTimeout   time.Duration
	WriteTimeout  time.Duration
	IdleTimeout   time.Duration
	// contains filtered or unexported fields
}

type HTTPConfig interface {
	GetHTTPConfig() *HTTP
	Listen(ctx context.Context) error
	Handle(string, http.Handler)
	Handler(*http.Request) (http.Handler, string)
	AddMiddleware(Middleware)
}

type HTTPPlugin interface {
	Plugin
	http.Handler
}

type Middleware func(string, http.Handler) http.Handler

type Plugin interface {
	// 可能的入参类型：FirstConfig 第一次初始化配置，Config 后续配置更新，SE系列（StateEvent）流状态变化事件
	OnEvent(any)
}

type Publish struct {
	PubAudio          bool          `default:"true"`
	PubVideo          bool          `default:"true"`
	InsertSEI         bool          // 是否启用SEI插入
	KickExist         bool          // 是否踢掉已经存在的发布者
	PublishTimeout    time.Duration `default:"10s"` // 发布无数据超时
	WaitCloseTimeout  time.Duration // 延迟自动关闭（等待重连）
	DelayCloseTimeout time.Duration // 延迟自动关闭（无订阅时）
	IdleTimeout       time.Duration // 空闲(无订阅)超时
	PauseTimeout      time.Duration `default:"30s"` // 暂停超时
	BufferTime        time.Duration // 缓冲长度(单位：秒)，0代表取最近关键帧
	SpeedLimit        time.Duration `default:"500ms"` //速度限制最大等待时间
	Key               string        // 发布鉴权key
	SecretArgName     string        `default:"secret"`   // 发布鉴权参数名
	ExpireArgName     string        `default:"expire"`   // 发布鉴权失效时间参数名
	RingSize          string        `default:"256-1024"` // 初始缓冲区大小
}

type PublishConfig interface {
	GetPublishConfig() Publish
}

type Pull struct {
	RePull       int               // 断开后自动重拉,0 表示不自动重拉，-1 表示无限重拉，高于0 的数代表最大重拉次数
	EnableRegexp bool              // 是否启用正则表达式
	PullOnStart  map[string]string // 启动时拉流的列表
	PullOnSub    map[string]string // 订阅时自动拉流的列表
	Proxy        string            // 代理地址
}

type PullConfig interface {
	GetPullConfig() *Pull
}

type Push struct {
	EnableRegexp bool              // 是否启用正则表达式
	RePush       int               // 断开后自动重推,0 表示不自动重推，-1 表示无限重推，高于0 的数代表最大重推次数
	PushList     map[string]string // 自动推流列表
	Proxy        string            // 代理地址
}

type PushConfig interface {
	GetPushConfig() *Push
}

type Quic struct {
	ListenAddr string
	CertFile   string
	KeyFile    string
}

type QuicConfig interface {
	ListenQuic(context.Context, QuicPlugin) error
}

type QuicPlugin interface {
	Plugin
	ServeQuic(quic.Connection)
}

type Subscribe struct {
	SubAudio        bool          `default:"true"`
	SubVideo        bool          `default:"true"`
	SubVideoArgName string        `default:"vts"`  // 指定订阅的视频轨道参数名
	SubAudioArgName string        `default:"ats"`  // 指定订阅的音频轨道参数名
	SubDataArgName  string        `default:"dts"`  // 指定订阅的数据轨道参数名
	SubModeArgName  string        `default:"mode"` // 指定订阅的模式参数名
	SubAudioTracks  []string      // 指定订阅的音频轨道
	SubVideoTracks  []string      // 指定订阅的视频轨道
	SubDataTracks   []string      // 指定订阅的数据轨道
	SubMode         int           // 0，实时模式：追赶发布者进度，在播放首屏后等待发布者的下一个关键帧，然后跳到该帧。1、首屏后不进行追赶。2、从缓冲最大的关键帧开始播放，也不追赶，需要发布者配置缓存长度
	SyncMode        int           // 0，采用时间戳同步，1，采用写入时间同步
	IFrameOnly      bool          // 只要关键帧
	WaitTimeout     time.Duration `default:"10s"` // 等待流超时
	WriteBufferSize int           `default:"0"`   // 写缓冲大小
	Key             string        // 订阅鉴权key
	SecretArgName   string        `default:"secret"` // 订阅鉴权参数名
	ExpireArgName   string        `default:"expire"` // 订阅鉴权失效时间参数名
	Internal        bool          `default:"false"`  // 是否内部订阅
}

type SubscribeConfig interface {
	GetSubscribeConfig() *Subscribe
}

type TCP struct {
	ListenAddr    string
	ListenAddrTLS string
	CertFile      string
	KeyFile       string
	ListenNum     int  //同时并行监听数量，0为CPU核心数量
	NoDelay       bool //是否禁用Nagle算法
}

type TCPConfig interface {
	ListenTCP(context.Context, TCPPlugin) error
}

type TCPPlugin interface {
	Plugin
	ServeTCP(net.Conn)
}