mirror of
https://github.com/Monibuca/plugin-gb28181.git
synced 2025-12-24 13:27:57 +08:00
56 lines
1.8 KiB
Go
56 lines
1.8 KiB
Go
package transaction
|
||
|
||
import (
|
||
"fmt"
|
||
"github.com/Monibuca/plugin-gb28181/v3/sip"
|
||
"net"
|
||
"strings"
|
||
)
|
||
|
||
//=====================================================sip message utils
|
||
//The branch ID parameter in the Via header field values serves as a transaction identifier,
|
||
//and is used by proxies to detect loops.
|
||
//The branch parameter in the topmost Via header field of the request
|
||
// is examined. If it is present and begins with the magic cookie
|
||
// "z9hG4bK", the request was generated by a client transaction
|
||
// compliant to this specification.
|
||
//参考RFC3261
|
||
func getMessageTransactionID(m *sip.Message) string {
|
||
if m.GetMethod() == sip.ACK {
|
||
//TODO：在匹配服务端事务的ACK中，创建事务的请求的方法为INVITE。所以ACK消息匹配事务的时候需要注意？？？？
|
||
}
|
||
return string(m.GetMethod()) + "_" + m.GetBranch()
|
||
}
|
||
|
||
func checkMessage(msg *sip.Message) error {
|
||
//TODO:sip消息解析成功之后，检查必要元素，如果失败，则返回 ErrorCheckMessage
|
||
|
||
//检查头域字段：callID via startline 等
|
||
//检查seq、method等
|
||
//不可以有router？
|
||
//是否根据消息是接收还是发送检查？
|
||
if msg == nil {
|
||
return ErrorCheck
|
||
}
|
||
return nil
|
||
}
|
||
|
||
//fix via header,add send-by info,
|
||
func fixReceiveMessageViaParams(msg *sip.Message, addr net.Addr) {
|
||
rport := msg.Via.Params["rport"]
|
||
if rport == "" || rport == "0" || rport == "-1" {
|
||
arr := strings.Split(addr.String(), ":")
|
||
if len(arr) == 2 {
|
||
msg.Via.Params["rport"] = arr[1]
|
||
if msg.Via.Host != arr[0] {
|
||
msg.Via.Params["received"] = arr[0]
|
||
}
|
||
} else {
|
||
//TODO：数据报的地址错误？？
|
||
fmt.Println("packet handle > invalid addr :", addr.String())
|
||
}
|
||
} else {
|
||
fmt.Println("sip message has have send-by info:", msg.Via.GetSendBy())
|
||
}
|
||
}
|