librtmp

type AbortMessage struct {
	MessageBase
	ChunkStreamID int
}

type AcknowledgeMessage struct {
	MessageBase
	SequenceNumber int
}

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

type AudioCodec float64

type AudioMessage struct {
	MessageBase
	// contains filtered or unexported fields
}

type Chunk struct {
	ChunkBasicHeader
	ChunkMessageHeader
	Payload []byte
}

type ChunkBasicHeader struct {
	Fmt  MessageHeaderType //2 bits
	CsID uint32            //6, 14 or 22 bits
}

type ChunkMessageHeader struct {
	MessageTimeStamp uint32 //3bytes or 4bytes(extended timestamp)
	MessageTimeDelta uint32
	MessageLength    uint32 //3bytes
	MessageType      MessageType
	MessageStreamID  uint32 //little-endian 4bytes
}

type CommandMessage struct {
	MessageBase
	CommandName    string
	TranscationID  int
	CommandObject  ConnectReqCommandObject
	PublishingName string //releaseStream,FCPublish,publish
	//Type of publishing. Set to "live", "record", or "append".
	//TODO:record: The stream is published and the data is recorded to a new file. The file is stored on the server in a subdirectory within the directory that contains the server application. If the file already exists, it is overwritten.
	//TODO:append: The stream is published and the data is appended to a file. If no file is found, it is created.
	//live: Live data is published without recording it in a file.
	PublishingType string  //publish
	StreamName     string  //play
	Start          float64 //play
	Duration       float64 //play
	Reset          bool    //play
}

type CommandMessageResponse struct {
	MessageBase
	CommandName     string
	CommandRespName string
	TranscationID   int
	CommandObject   ConnectRespCommandObject
	StreamID        uint32
}

type ConnectReqCommandObject struct {
	App            string        `mapstructure:"app"`
	FlashVer       string        `mapstructure:"flashver"`
	SwfURL         string        `mapstructure:"swfUrl"`
	TcURL          string        `mapstructure:"tcUrl"`
	Fpad           bool          `mapstructure:"fpad"`
	AudioCodecs    AudioCodec    `mapstructure:"audioCodecs"`
	VideoCodecs    VideoCodec    `mapstructure:"videoCodecs"`
	VideoFunction  VideoFunction `mapstructure:"videoFunction"`
	PageURL        string        `mapstructure:"pageUrl"`
	ObjectEncoding float64       `mapstructure:"objectEncoding"`
	Type           string        `mapstructure:"type"`
	Capabilities   float64       `mapstructure:"capabilities"`
}

type ConnectRespCommandObject struct {
	FmsVer         string  `structs:"fmsVer,omitempty"`
	Level          string  `structs:"level,omitempty"`
	Code           string  `structs:"code,omitempty"`
	Description    string  `structs:"description,omitempty"`
	Capabilities   float64 `structs:"capabilities,omitempty"`
	ObjectEncoding float64 `structs:"object_encoding,omitempty"`
}

type DataMessage struct {
	MessageBase
	// contains filtered or unexported fields
}

type EventType uint16

type HandshakeMode int

type LimitType uint8

type Message interface {
	Append(*Chunk)
	Remain() uint32
	Done() bool
	GetInfo() *MessageBase
	Update(uint32)

	//Parse() parse binary data that receive from peer
	Parse() error
	//when receive the message, Do() operator fields in RTMP belongs to this message, and send response to peer
	Do() error
	//Send() post the message to peer which generated from NewXXX()
	Send() error
}

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

type MessageHeaderType uint8

type MessageType uint8

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

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

type Room struct {
	RoomID    string
	Publisher *RTMP //TODO: support multi publisher
	//Players   sync.Map     //peer ip+port, rtmp conn
	GOP *broadcast.Broadcast
}

type SetChunkSizeMessage struct {
	MessageBase
	NewChunkSize uint32
}

type SetPeerBandWidthMessage struct {
	MessageBase
	AcknowledgementWindowSize uint32
	LimitType                 LimitType
}

type UserControlMessage struct {
	MessageBase
	EventType EventType
	EventData []byte
}

type VideoCodec float64

type VideoFunction float64

type VideoMessage struct {
	MessageBase
	// contains filtered or unexported fields
}

type WindowAcknowledgeSizeMessage struct {
	MessageBase
	AcknowledgementWindowSize uint32
}