sms

type AddMediaServerInput struct {
	IP                string           `json:"ip"`
	HookIP            string           `json:"hook_ip"`
	SDPIP             string           `json:"sdpip"`
	StreamIP          string           `json:"stream_ip"`
	Ports             MediaServerPorts `json:"ports"`
	AutoConfig        bool             `json:"auto_config"`
	Secret            string           `json:"secret"`
	HookAliveInterval int              `json:"hook_alive_interval"`
	RTPEnable         bool             `json:"rtpenable"`
	Status            bool             `json:"status"`
	RTPPortRange      string           `json:"rtpport_range"`
	SendRTPPortRange  string           `json:"send_rtpport_range"`
	RecordAssistPort  int              `json:"record_assist_port"`
	LastKeepaliveAt   orm.Time         `json:"last_keepalive_at"`
	IsDefault         bool             `json:"is_default"`
	RecordDay         int              `json:"record_day"`
	RecordPath        string           `json:"record_path"`
	Type              string           `json:"type"`
	TranscodeSuffix   string           `json:"transcode_suffix"`
}

type AddStreamProxyRequest struct {
	App     string `json:"app"`      // 添加的流的应用名，例如 live
	Stream  string `json:"stream"`   // 添加的流的 id 名，例如 test
	URL     string `json:"url"`      // 拉流地址，例如 rtmp://live.hkstv.hk.lxdns.com/live/hks2
	RTPType int    `json:"rtp_type"` // rtsp 拉流时，拉流方式，0：tcp，1：udp，2：组播

}

type Core struct {
	*NodeManager
	// contains filtered or unexported fields
}

type Driver interface {
	// Protocol 返回协议/类型名称，如 "zlm", "srs"
	Protocol() string

	// Connect 测试连接并获取初始信息 (对应目前的 connection 方法中的部分逻辑)
	Connect(ctx context.Context, ms *MediaServer) error

	// Setup 下发配置到流媒体服务 (对应目前的 connection 方法中的配置逻辑)
	Setup(ctx context.Context, ms *MediaServer, webhookURL string) error

	// Ping 主动探测服务是否在线
	Ping(ctx context.Context, ms *MediaServer) error

	// Stream Operations
	OpenRTPServer(ctx context.Context, ms *MediaServer, req *zlm.OpenRTPServerRequest) (*zlm.OpenRTPServerResponse, error)
	CloseRTPServer(ctx context.Context, ms *MediaServer, req *zlm.CloseRTPServerRequest) (*zlm.CloseRTPServerResponse, error)
	AddStreamProxy(ctx context.Context, ms *MediaServer, req *AddStreamProxyRequest) (*zlm.AddStreamProxyResponse, error)
	GetSnapshot(ctx context.Context, ms *MediaServer, req *GetSnapRequest) ([]byte, error)

	GetStreamLiveAddr(ctx context.Context, ms *MediaServer, httpPrefix, host, app, stream string) StreamLiveAddr
}

type EditMediaServerInput struct {
	IP     string `json:"ip"`
	HookIP string `json:"hook_ip"`
	SDPIP  string `json:"sdp_ip"`
	// StreamIP          string           `json:"stream_ip"`
	// Ports MediaServerPorts `json:"ports"`
	// AutoConfig        bool             `json:"auto_config"`
	Secret string `json:"secret"`
	Type   string `json:"type"` // lalmax/zlm

}

type FindMediaServerInput struct {
	web.PagerFilter
	IP                string           `form:"ip"`
	HookIP            string           `form:"hook_ip"`
	SDPIP             string           `form:"sdpip"`
	StreamIP          string           `form:"stream_ip"`
	Ports             MediaServerPorts `form:"ports"`
	AutoConfig        bool             `form:"auto_config"`
	Secret            string           `form:"secret"`
	HookAliveInterval int              `form:"hook_alive_interval"`
	RTPEnable         bool             `form:"rtpenable"`
	Status            bool             `form:"status"`
	RTPPortRange      string           `form:"rtpport_range"`
	SendRTPPortRange  string           `form:"send_rtpport_range"`
	RecordAssistPort  int              `form:"record_assist_port"`
	LastKeepaliveAt   orm.Time         `form:"last_keepalive_at"`
	IsDefault         bool             `form:"is_default"`
	RecordDay         int              `form:"record_day"`
	RecordPath        string           `form:"record_path"`
	Type              string           `form:"type"`
	TranscodeSuffix   string           `form:"transcode_suffix"`
}

type GetSnapRequest struct {
	zlm.GetSnapRequest
	// lalmax
	Stream string `json:"stream"`
}

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

type MediaServer struct {
	ID                string           `gorm:"primaryKey" json:"id"`
	IP                string           `gorm:"column:ip;notNull;default:''" json:"ip"`
	CreatedAt         orm.Time         `gorm:"column:created_at;notNull;default:CURRENT_TIMESTAMP" json:"created_at"`
	UpdatedAt         orm.Time         `gorm:"column:updated_at;notNull;default:CURRENT_TIMESTAMP" json:"updated_at"`
	HookIP            string           `gorm:"column:hook_ip;notNull;default:''" json:"hook_ip"`
	SDPIP             string           `gorm:"column:sdp_ip;notNull;default:''" json:"sdp_ip"`
	StreamIP          string           `gorm:"column:stream_ip;notNull;default:''" json:"stream_ip"`
	Ports             MediaServerPorts `gorm:"column:ports;notNull;default:'{}';type:jsonb" json:"ports"`
	AutoConfig        bool             `gorm:"column:auto_config;notNull;default:FALSE" json:"auto_config"`
	Secret            string           `gorm:"column:secret;notNull;default:''" json:"secret"`
	HookAliveInterval int              `gorm:"column:hook_alive_interval;notNull;default:0" json:"hook_alive_interval"`
	RTPEnable         bool             `gorm:"column:rtpenable;notNull;default:FALSE" json:"rtpenable"`
	Status            bool             `gorm:"column:status;notNull;default:FALSE" json:"status"`
	RTPPortRange      string           `gorm:"column:rtpport_range;notNull;default:''" json:"rtpport_range"`
	SendRTPPortRange  string           `gorm:"column:send_rtpport_range;notNull;default:''" json:"send_rtpport_range"`
	RecordAssistPort  int              `gorm:"column:record_assist_port;notNull;default:0" json:"record_assist_port"`
	LastKeepaliveAt   orm.Time         `gorm:"column:last_keepalive_at;notNull;default:CURRENT_TIMESTAMP" json:"last_keepalive_at"`
	RecordDay         int              `gorm:"column:record_day;notNull;default:0" json:"record_day"`
	RecordPath        string           `gorm:"column:record_path;notNull;default:''" json:"record_path"`
	Type              string           `gorm:"column:type;notNull;default:''" json:"type"`
	TranscodeSuffix   string           `gorm:"column:transcode_suffix;notNull;default:''" json:"transcode_suffix"`
}

type MediaServerPorts struct {
	HTTP     int `json:"http"`
	HTTPS    int `json:"https"`
	RTMP     int `json:"rtmp"`
	FLV      int `json:"flv"`
	FLVs     int `json:"flvs"`
	WsFLV    int `json:"ws_flv"`
	WsFLVs   int `json:"ws_flvs"`
	RTMPs    int `json:"rtmps"`
	RTPPorxy int `json:"rtpporxy"`
	RTSP     int `json:"rtsp"`
	RTSPs    int `json:"rtsps"`
}

type MediaServerStorer interface {
	Find(context.Context, *[]*MediaServer, orm.Pager, ...orm.QueryOption) (int64, error)
	Get(context.Context, *MediaServer, ...orm.QueryOption) error
	Add(context.Context, *MediaServer) error
	Edit(context.Context, *MediaServer, func(*MediaServer), ...orm.QueryOption) error
	Del(context.Context, *MediaServer, ...orm.QueryOption) error
}

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

type NodeServicer any

type Storer interface {
	MediaServer() MediaServerStorer
}

type StreamLiveAddr struct {
	Label   string `json:"label"`
	WSFLV   string `json:"ws_flv"`
	HTTPFLV string `json:"http_flv"`
	RTMP    string `json:"rtmp"`
	RTSP    string `json:"rtsp"`
	WebRTC  string `json:"webrtc"`
	HLS     string `json:"hls"`
}

type WarpMediaServer struct {
	IsOnline      bool
	LastUpdatedAt time.Time
	Config        *MediaServer
}

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