stack

type DatagramTransport interface {
	ReadFrom(ctx context.Context, buf []byte) (n int, addr *net.UDPAddr, err error)
	WriteTo(ctx context.Context, p []byte, addr *net.UDPAddr) (n int, err error)
	Close() error
	LocalAddr() net.Addr
	String() string
}

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

type EndpointConfig struct {
	// Host is the local address to bind (empty or "0.0.0.0" / "::" = all interfaces).
	Host string
	// Port is the UDP port (typically 5060).
	Port int
	// Network selects the UDP socket family: "udp4", "udp6", or "udp" (dual-stack).
	// Default "udp4".
	Network string

	// ReadBufSize is the UDP receive buffer (default 65535, max single datagram size).
	ReadBufSize int
	// ReadDeadline is applied before each read so Serve can poll ctx.Done()
	// and shut down promptly (default 1s). Timeout reads are retried, not fatal.
	ReadDeadline time.Duration
	// SyncHandlers when true runs method handlers in the read loop; default is false
	// (each request is handled in its own goroutine so slow work does not block I/O).
	SyncHandlers bool

	// OnReadError is called once for non-timeout read errors before Serve returns.
	OnReadError func(err error)
	// OnDatagram receives every non-noise UDP payload before parsing (wire tap).
	OnDatagram func(raw []byte, addr *net.UDPAddr)
	// OnParseErr receives datagrams that failed Parse (malformed SIP).
	OnParseErr func(raw []byte, addr *net.UDPAddr, err error)
	// OnRequest is notified after a request is parsed, before the method handler runs.
	OnRequest func(req *Message, addr *net.UDPAddr)
	// OnResponse is notified when a handler returns a response, before UDP send.
	OnResponse func(req *Message, resp *Message, addr *net.UDPAddr)
	// OnResponseSent runs after the response bytes were written successfully.
	OnResponseSent func(req *Message, resp *Message, addr *net.UDPAddr)
	// OnSIPResponse receives every SIP response datagram (outbound transaction matching).
	OnSIPResponse func(resp *Message, addr *net.UDPAddr)
	// OnMessageSent runs after any outbound write via Endpoint.Send (UAC or UAS).
	OnMessageSent func(msg *Message, addr *net.UDPAddr)
	// OnEvent is a unified hook for metrics; see EventType constants.
	OnEvent func(e Event)
	// NoRouteHandler handles methods with no RegisterHandler entry.
	// When nil, DefaultNoRouteResponse (501 Not Implemented) is used.
	NoRouteHandler HandlerFunc
}

type Event struct {
	Type     EventType
	Addr     *net.UDPAddr
	Raw      []byte
	Request  *Message
	Response *Message
	Err      error
}

type EventType int

type HandlerFunc func(msg *Message, addr *net.UDPAddr) *Message

type Message struct {
	Method     string
	RequestURI string
	StatusCode int    // 200
	StatusText string // "OK"
	Version    string // "SIP/2.0"
	// Headers = map[string]string{
	//    "Via":        "SIP/2.0/UDP 192.168.1.100:5060;branch=z9hG4bK12345",
	//    "To":         "Bob <sip:bob@example.com>;tag=as12345",
	//    "From":       "Alice <sip:alice@example.com>;tag=1928301774",
	//    "Call-ID":    "a84b4c76e66710@pc33.atlanta.com",
	//    "CSeq":       "314159 INVITE",
	//    "Contact":    "<sip:bob@192.168.1.100:5060>",
	//    "Content-Type": "application/sdp",
	//    "Content-Length": "158",
	//}
	Headers map[string]string // first value per canonical header name
	// HeadersMulti = map[string][]string{
	//    "Via":        {"SIP/2.0/UDP 192.168.1.100:5060;branch=z9hG4bK12345"},
	//    "To":         {"Bob <sip:bob@example.com>;tag=as12345"},
	//    "From":       {"Alice <sip:alice@example.com>;tag=1928301774"},
	//    "Call-ID":    {"a84b4c76e66710@pc33.atlanta.com"},
	//    "CSeq":       {"314159 INVITE"},
	//    "Contact":    {"<sip:bob@192.168.1.100:5060>"},
	//    "Content-Type": {"application/sdp"},
	//    "Content-Length": {"158"},
	//}
	HeadersMulti map[string][]string // all values per canonical header name (e.g. Via)
	// Body input SDP 会话描述协议
	// v=0  => SDP Version
	// o=user2 2890844526 2890844526 	IN 		IP4 	192.168.1.100 会话所有者 / 会话 ID
	// 用户名 	会话ID 		版本号 	  网络类型  地址类型 		主机地址
	// s=Session SDP 会话名称
	// c=IN IP4 192.168.1.100 连接信息-指定媒体流收发地址
	// t=0 0	会话时长
	// m=audio 3456 RTP/AVP 0	媒体类型 端口 传输协议 编码格式
	// a=rtpmap:0 PCMU/8000
	// rtpmap：RTP 映射说明
	// 0：对应上面 m 行的负载类型 ID
	// PCMU：编码格式（G.711 μ 律，传统电话语音编码）
	// 8000：采样率 8000Hz（标准电话音质）
	Body      string
	IsRequest bool
}

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