|
|
// Copyright 2020, Chef. All rights reserved.
|
|
|
// https://github.com/q191201771/lal
|
|
|
//
|
|
|
// Use of this source code is governed by a MIT-style license
|
|
|
// that can be found in the License file.
|
|
|
//
|
|
|
// Author: Chef (191201771@qq.com)
|
|
|
|
|
|
package rtsp
|
|
|
|
|
|
import (
|
|
|
"fmt"
|
|
|
"time"
|
|
|
|
|
|
"github.com/q191201771/lal/pkg/base"
|
|
|
)
|
|
|
|
|
|
// rfc2326 10.1 OPTIONS
|
|
|
|
|
|
// CSeq
|
|
|
var ResponseOptionsTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"Server: " + base.LALRTSPOptionsResponseServer + "\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"Public:DESCRIBE, ANNOUNCE, SETUP, PLAY, PAUSE, RECORD, TEARDOWN\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// rfc2326 10.3 ANNOUNCE
|
|
|
//var RequestAnnounceTmpl = "not impl"
|
|
|
|
|
|
// CSeq
|
|
|
var ResponseAnnounceTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// rfc2326 10.2 DESCRIBE
|
|
|
|
|
|
// CSeq, Date, Content-Length,
|
|
|
var ResponseDescribeTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"Date: %s\r\n" +
|
|
|
"Content-Type: application/sdp\r\n" +
|
|
|
"Content-Length: %d\r\n" +
|
|
|
"\r\n" +
|
|
|
"%s"
|
|
|
|
|
|
// rfc2326 10.4 SETUP
|
|
|
// TODO chef: mode=record，这个是咋作用，是应该pub有sub没有吗，我的pack实现没有严格区分
|
|
|
|
|
|
// CSeq, Date, Session, Transport(client_port, server_rtp_port, server_rtcp_port)
|
|
|
var ResponseSetupTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"Date: %s\r\n" +
|
|
|
"Session: %s\r\n" +
|
|
|
"Transport:RTP/AVP/UDP;unicast;client_port=%d-%d;server_port=%d-%d\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// CSeq, Date, Session, Transport
|
|
|
var ResponseSetupTCPTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"Date: %s\r\n" +
|
|
|
"Session: %s\r\n" +
|
|
|
"Transport:%s\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// rfc2326 10.11 RECORD
|
|
|
//var RequestRecordTmpl = "not impl"
|
|
|
|
|
|
// CSeq, Session
|
|
|
var ResponseRecordTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"Session: %s\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// rfc2326 10.5 PLAY
|
|
|
|
|
|
// CSeq Date
|
|
|
var ResponsePlayTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"Date: %s\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// rfc2326 10.8 GET_PARAMETER
|
|
|
// uri CSeq Session
|
|
|
var RequestGetParameterTmpl = "GET_PARAMETER %s RTSP/1.0\r\n" +
|
|
|
"CSeq: %d\r\n" +
|
|
|
"Session: %s\r\n" +
|
|
|
"User-Agent: " + base.LALRTSPPullSessionUA + "\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// rfc2326 10.7 TEARDOWN
|
|
|
//var RequestTeardownTmpl = "not impl"
|
|
|
|
|
|
// CSeq
|
|
|
var ResponseTeardownTmpl = "RTSP/1.0 200 OK\r\n" +
|
|
|
"CSeq: %s\r\n" +
|
|
|
"\r\n"
|
|
|
|
|
|
// @param auth 可以为空，如果为空，则请求中不包含`Authorization`字段
|
|
|
func PackRequestOptions(uri string, cseq int, auth string) string {
|
|
|
headers := map[string]string{
|
|
|
HeaderFieldCSeq: fmt.Sprintf("%d", cseq),
|
|
|
HeaderUserAgent: base.LALRTSPPullSessionUA,
|
|
|
}
|
|
|
if auth != "" {
|
|
|
headers[HeaderAuthorization] = auth
|
|
|
}
|
|
|
return packRequest(MethodOptions, uri, headers)
|
|
|
}
|
|
|
|
|
|
// @param auth 可以为空，如果为空，则请求中不包含`Authorization`字段
|
|
|
func PackRequestDescribe(uri string, cseq int, auth string) string {
|
|
|
headers := map[string]string{
|
|
|
HeaderAccept: "application/sdp",
|
|
|
HeaderFieldCSeq: fmt.Sprintf("%d", cseq),
|
|
|
HeaderUserAgent: base.LALRTSPPullSessionUA,
|
|
|
}
|
|
|
if auth != "" {
|
|
|
headers[HeaderAuthorization] = auth
|
|
|
}
|
|
|
return packRequest(MethodDescribe, uri, headers)
|
|
|
}
|
|
|
|
|
|
// @param sessionID 可以为空，如果为空，则请求中不包含`Session`字段
|
|
|
// @param auth 可以为空，如果为空，则请求中不包含`Authorization`字段
|
|
|
func PackRequestSetup(uri string, cseq int, rtpClientPort int, rtcpClientPort int, sessionID string, auth string) string {
|
|
|
headers := map[string]string{
|
|
|
HeaderFieldTransport: fmt.Sprintf("RTP/AVP/UDP;unicast;client_port=%d-%d", rtpClientPort, rtcpClientPort),
|
|
|
HeaderFieldCSeq: fmt.Sprintf("%d", cseq),
|
|
|
HeaderUserAgent: base.LALRTSPPullSessionUA,
|
|
|
}
|
|
|
if sessionID != "" {
|
|
|
headers[HeaderFieldSession] = sessionID
|
|
|
}
|
|
|
if auth != "" {
|
|
|
headers[HeaderAuthorization] = auth
|
|
|
}
|
|
|
return packRequest(MethodSetup, uri, headers)
|
|
|
}
|
|
|
|
|
|
// @param sessionID 可以为空，如果为空，则请求中不包含`Session`字段
|
|
|
// @param auth 可以为空，如果为空，则请求中不包含`Authorization`字段
|
|
|
func PackRequestSetupTCP(uri string, cseq int, rtpChannel int, rtcpChannel int, sessionID string, auth string) string {
|
|
|
headers := map[string]string{
|
|
|
HeaderFieldCSeq: fmt.Sprintf("%d", cseq),
|
|
|
HeaderFieldTransport: fmt.Sprintf("RTP/AVP/TCP;unicast;interleaved=%d-%d", rtpChannel, rtcpChannel),
|
|
|
HeaderUserAgent: base.LALRTSPPullSessionUA,
|
|
|
}
|
|
|
if sessionID != "" {
|
|
|
headers[HeaderFieldSession] = sessionID
|
|
|
}
|
|
|
if auth != "" {
|
|
|
headers[HeaderAuthorization] = auth
|
|
|
}
|
|
|
return packRequest(MethodSetup, uri, headers)
|
|
|
}
|
|
|
|
|
|
func PackRequestPlay(uri string, cseq int, sessionID string, auth string) string {
|
|
|
headers := map[string]string{
|
|
|
HeaderFieldCSeq: fmt.Sprintf("%d", cseq),
|
|
|
HeaderFieldRange: "npt=0.000-",
|
|
|
HeaderFieldSession: sessionID,
|
|
|
HeaderUserAgent: base.LALRTSPPullSessionUA,
|
|
|
}
|
|
|
if auth != "" {
|
|
|
headers[HeaderAuthorization] = auth
|
|
|
}
|
|
|
return packRequest(MethodPlay, uri, headers)
|
|
|
}
|
|
|
|
|
|
func PackRequestGetParameter(uri string, cseq int, sessionID string) string {
|
|
|
return fmt.Sprintf(RequestGetParameterTmpl, uri, cseq, sessionID)
|
|
|
}
|
|
|
|
|
|
func PackResponseOptions(cseq string) string {
|
|
|
return fmt.Sprintf(ResponseOptionsTmpl, cseq)
|
|
|
}
|
|
|
|
|
|
func PackResponseAnnounce(cseq string) string {
|
|
|
return fmt.Sprintf(ResponseAnnounceTmpl, cseq)
|
|
|
}
|
|
|
|
|
|
func PackResponseDescribe(cseq, sdp string) string {
|
|
|
date := time.Now().Format(time.RFC1123)
|
|
|
return fmt.Sprintf(ResponseDescribeTmpl, cseq, date, len(sdp), sdp)
|
|
|
}
|
|
|
|
|
|
// @param transportC:
|
|
|
// pub example:
|
|
|
// RTP/AVP/UDP;unicast;client_port=24254-24255;mode=record
|
|
|
// RTP/AVP/UDP;unicast;client_port=24256-24257;mode=record
|
|
|
// sub example:
|
|
|
// RTP/AVP/UDP;unicast;client_port=9420-9421
|
|
|
func PackResponseSetup(cseq string, rRTPPort, rRTCPPort, lRTPPort, lRTCPPort uint16) string {
|
|
|
date := time.Now().Format(time.RFC1123)
|
|
|
|
|
|
return fmt.Sprintf(ResponseSetupTmpl, cseq, date, sessionID, rRTPPort, rRTCPPort, lRTPPort, lRTCPPort)
|
|
|
}
|
|
|
|
|
|
func PackResponseSetupTCP(cseq string, ts string) string {
|
|
|
date := time.Now().Format(time.RFC1123)
|
|
|
|
|
|
return fmt.Sprintf(ResponseSetupTCPTmpl, cseq, date, sessionID, ts)
|
|
|
}
|
|
|
|
|
|
func PackResponseRecord(cseq string) string {
|
|
|
return fmt.Sprintf(ResponseRecordTmpl, cseq, sessionID)
|
|
|
}
|
|
|
|
|
|
func PackResponsePlay(cseq string) string {
|
|
|
date := time.Now().Format(time.RFC1123)
|
|
|
return fmt.Sprintf(ResponsePlayTmpl, cseq, date)
|
|
|
}
|
|
|
|
|
|
func PackResponseTeardown(cseq string) string {
|
|
|
return fmt.Sprintf(ResponseTeardownTmpl, cseq)
|
|
|
}
|
|
|
|
|
|
func packRequest(method, uri string, headers map[string]string) (ret string) {
|
|
|
ret = method + " " + uri + " RTSP/1.0\r\n"
|
|
|
for k, v := range headers {
|
|
|
ret += k + ": " + v + "\r\n"
|
|
|
}
|
|
|
ret += "\r\n"
|
|
|
return ret
|
|
|
}
|