icsanalyzesip.go deleted
jiyoungcheon
3 weeks ago
parent
4f4ee4afac
commit
8081bd62f0
@ -1,211 +0,0 @@
|
|||||||
package icssessionmanager
|
|
||||||
|
|
||||||
import (
|
|
||||||
"strconv"
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"gitlab.com/cinnamon/voiceagent/icserror"
|
|
||||||
"gitlab.com/cinnamon/voiceagent/icslog"
|
|
||||||
"gitlab.com/cinnamon/voiceagent/icsmediaconv"
|
|
||||||
"gitlab.com/cinnamon/voiceagent/icsnet"
|
|
||||||
"gitlab.com/cinnamon/voiceagent/icspacketparser"
|
|
||||||
"gitlab.com/cinnamon/voiceagent/icssvc"
|
|
||||||
"gitlab.com/cinnamon/voiceagent/recorddata/writecallsignal"
|
|
||||||
)
|
|
||||||
|
|
||||||
func (s *IcsSession) analyzeSIP(sip *icspacketparser.SIP) *icserror.IcsError {
|
|
||||||
// fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>")
|
|
||||||
// fmt.Println("sip.Method", sip.Method)
|
|
||||||
// fmt.Println("sip.Version", sip.Version)
|
|
||||||
// fmt.Println("sip.Headers", sip.Headers)
|
|
||||||
// fmt.Println("sip.Source", sip.Source)
|
|
||||||
|
|
||||||
// fmt.Printf("%+v\n", sip)
|
|
||||||
//fmt.Println(">>>>>>>>>>>>>>>>>>>>>>> sip.Method", sip.Method)
|
|
||||||
|
|
||||||
l := icslog.GetIcsLog()
|
|
||||||
// fmt.Println(">>>>>>>>>>>>>>>>>>>>>>> sip.Method", sip.Method)
|
|
||||||
|
|
||||||
if sip.Method == icspacketparser.ICS_SIP_METHOD_INVITE {
|
|
||||||
s.setSrcPort(sip)
|
|
||||||
|
|
||||||
payload, err := s.setSDPMediaPayload(sip)
|
|
||||||
if err != nil {
|
|
||||||
return icserror.ICSERRSDPAudiotagPortValue
|
|
||||||
} else {
|
|
||||||
s.invitePayloads = payload
|
|
||||||
}
|
|
||||||
} else if strings.Contains(sip.Cseq, " INVITE") {
|
|
||||||
s.setDstPort(sip)
|
|
||||||
}
|
|
||||||
|
|
||||||
if sip.Method == icspacketparser.ICS_SIP_METHOD_SIP20 && !s.isFoundPayload {
|
|
||||||
// fmt.Println(">>>>>>>>>>>>>>> ICS_SIP_METHOD_SIP20", sip.ResType, sip.ContentType, sip.ContentLength)
|
|
||||||
if strings.Contains(sip.ContentType, "sdp") && sip.ContentLength > 0 {
|
|
||||||
payload, err := s.compareSDPMediaPayload(sip)
|
|
||||||
if err != nil {
|
|
||||||
return icserror.ICSERRSDPAudiotagPortValue
|
|
||||||
} else {
|
|
||||||
s.isFoundPayload = true
|
|
||||||
s.payloadType = icspacketparser.PayloadType(payload)
|
|
||||||
//fmt.Println("s.payload >>>>>>>>>>>>>>>", s.payloadType)
|
|
||||||
|
|
||||||
//create media decoder
|
|
||||||
var cerr *icserror.IcsError
|
|
||||||
s.TxConverter, cerr = icsmediaconv.NewConverter(s.ID, s.payloadType)
|
|
||||||
if cerr != nil {
|
|
||||||
//s.isFoundPayload = false
|
|
||||||
//cerr.Print()
|
|
||||||
l.Printf(icslog.LOG_LEVEL_FATAL, s.ID, "Failed to New Tx Converter-%v", cerr)
|
|
||||||
s.SendVoiceGatewayByeSignal()
|
|
||||||
return cerr
|
|
||||||
} else {
|
|
||||||
l.Print(icslog.LOG_LEVEL_INFO, s.ID, "New Tx Converter(Decoder)")
|
|
||||||
}
|
|
||||||
s.RxConverter, cerr = icsmediaconv.NewConverter(s.ID, s.payloadType)
|
|
||||||
if cerr != nil {
|
|
||||||
//s.isFoundPayload = false
|
|
||||||
l.Printf(icslog.LOG_LEVEL_FATAL, s.ID, "Failed to New Rx Converter-%v", cerr)
|
|
||||||
s.SendVoiceGatewayByeSignal()
|
|
||||||
return cerr
|
|
||||||
} else {
|
|
||||||
l.Print(icslog.LOG_LEVEL_INFO, s.ID, "New Rx Converter(Decoder)")
|
|
||||||
}
|
|
||||||
|
|
||||||
//init VoiceAgent net
|
|
||||||
conf := icssvc.GetServiceStatus().GetIcsConfig()
|
|
||||||
if conf != nil {
|
|
||||||
//set call signal remote addr
|
|
||||||
csraddr := icsnet.NewNetAddrWithIPPort("127.0.0.1", 1111)
|
|
||||||
csladdr := icsnet.NewNetAddrWithIPPort("127.0.0.1", 2222)
|
|
||||||
//csraddr := icsnet.NewNetAddrWithIPPort(conf.VoiceAgentConfig.AgentAddr.VoiceAgentIP, conf.VoiceAgentConfig.AgentAddr.CallSignalPort)
|
|
||||||
//csladdr := icsnet.NewNetAddrWithIPPort(conf.VoiceAgentConfig.MyAddr.ServerIP, conf.VoiceAgentConfig.MyAddr.ServerPort)
|
|
||||||
|
|
||||||
//set Voice remote addr
|
|
||||||
vraddr := icsnet.NewNetAddrWithIPPort("127.0.0.1", 3333)
|
|
||||||
//vraddr := icsnet.NewNetAddrWithIPPort(conf.VoiceAgentConfig.AgentAddr.VoiceAgentIP, conf.VoiceAgentConfig.AgentAddr.VoicePort)
|
|
||||||
//vladdr := icsnet.NewNetAddrWithIPPort(conf.VoiceAgentConfig.MyAddr.ServerIP, conf.VoiceAgentConfig.MyAddr.BasePort)
|
|
||||||
|
|
||||||
s.VoiceNeter = icsnet.NewUDP(nil, &vraddr)
|
|
||||||
//s.VoiceNeter = icsnet.NewUDP(&vladdr, &vraddr)
|
|
||||||
conerr := s.VoiceNeter.Connect()
|
|
||||||
if conerr != nil {
|
|
||||||
l.Printf(icslog.LOG_LEVEL_ERROR, s.ID, "Error init Voice Neter[%s->%s]-%v", s.VoiceNeter.LocalAddr().String(), vraddr.String(), conerr.GetError())
|
|
||||||
s.SendVoiceGatewayByeSignal()
|
|
||||||
return conerr
|
|
||||||
}
|
|
||||||
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "Voice(UDP) Connected to VoiceAgent[%s->%s]", s.VoiceNeter.LocalAddr().String(), vraddr.String())
|
|
||||||
|
|
||||||
//send call signal data to VoiceAgent
|
|
||||||
defer func() {
|
|
||||||
if err := recover(); err != nil {
|
|
||||||
l.Print(icslog.LOG_LEVEL_WARN, s.ID, icserror.ICSERRNETNotConnectError.GetMessage())
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
var inout string = "O"
|
|
||||||
if s.GetDirection() {
|
|
||||||
inout = "I"
|
|
||||||
}
|
|
||||||
callsignal := writecallsignal.NewCallSignalData()
|
|
||||||
//callsignal := recorddata.NewCallSignalData()
|
|
||||||
//s.StartTimeStamp = time.Now().UnixNano() / 1e6
|
|
||||||
s.StartTimeStamp = time.Now().UnixNano()
|
|
||||||
callsignal.SetData(s.ChannelID, s.ServerID, s.Station, "CUSTID", s.StartTimeStamp, 0, "S", inout)
|
|
||||||
wlen, werr := icsnet.SendCallSignal(&csladdr, &csraddr, callsignal.GetData())
|
|
||||||
if werr == nil {
|
|
||||||
l.Printf(icslog.LOG_LEVEL_INFO, s.ID, "Transmitted Call-Start signal to VoiceAgent(%d)", wlen)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *IcsSession) setSrcPort(sip *icspacketparser.SIP) *icserror.IcsError {
|
|
||||||
if sip.Content == nil {
|
|
||||||
//error 처리 invite인데, sdp 데이터가 없음
|
|
||||||
return icserror.ICSERRINVITERequired
|
|
||||||
} else {
|
|
||||||
// fmt.Println("sdpMedias", *sip.Content.Media)
|
|
||||||
port, err := s.findSDPMediaAudioPort(sip)
|
|
||||||
if err != nil {
|
|
||||||
return icserror.ICSERRSDPAudiotagPortValue
|
|
||||||
} else {
|
|
||||||
s.srcPort = port
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *IcsSession) setDstPort(sip *icspacketparser.SIP) *icserror.IcsError {
|
|
||||||
// fmt.Println(">>>>>>>>>>>>>>>>>>>>>>> sip.Cseq", sip.Cseq, sip.Method)
|
|
||||||
if sip.Method == icspacketparser.ICS_SIP_METHOD_SIP20 && sip.ResType == "200" {
|
|
||||||
if sip.Content == nil {
|
|
||||||
//error 처리 INVITE처리의 200 OK인데, sdp 데이터가 없음
|
|
||||||
return icserror.ICSERR200OKRequired
|
|
||||||
} else {
|
|
||||||
// fmt.Println("sdpMedias", *sip.Content.Media)
|
|
||||||
port, err := s.findSDPMediaAudioPort(sip)
|
|
||||||
if err != nil {
|
|
||||||
return icserror.ICSERRSDPAudiotagPortValue
|
|
||||||
} else {
|
|
||||||
s.dstPort = port
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else if sip.Method == icspacketparser.ICS_SIP_METHOD_BYE {
|
|
||||||
//fmt.Println(">>>>>>>>>>> haup up event")
|
|
||||||
// s.RemoveSession()
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *IcsSession) findSDPMediaAudioPort(sip *icspacketparser.SIP) (int, *icserror.IcsError) {
|
|
||||||
for _, value := range *sip.Content.Media {
|
|
||||||
if strings.Contains(value.MediaDescription, "audio ") {
|
|
||||||
arrSdpMedia := strings.Split(value.MediaDescription, " ")
|
|
||||||
port, err := strconv.Atoi(arrSdpMedia[1])
|
|
||||||
if err != nil {
|
|
||||||
return -1, icserror.ICSERRSDPAudiotagPortValue
|
|
||||||
} else {
|
|
||||||
//fmt.Println(">>>>>>>>>>>>>>>>>>>>>>> port", port)
|
|
||||||
return port, nil
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
return -1, icserror.ICSERRNotFoundSdpMedia
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return -1, icserror.ICSERRNotFoundSdpMedia
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *IcsSession) setSDPMediaPayload(sip *icspacketparser.SIP) ([]string, *icserror.IcsError) {
|
|
||||||
for _, value := range *sip.Content.Media {
|
|
||||||
if strings.Contains(value.MediaDescription, "audio ") {
|
|
||||||
//fmt.Println("value.Payload >>>>>>>>>>>", value.Payload)
|
|
||||||
return value.Payload, nil
|
|
||||||
} else {
|
|
||||||
return nil, icserror.ICSERRNotFoundSdpMedia
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil, icserror.ICSERRNotFoundSdpMedia
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *IcsSession) compareSDPMediaPayload(sip *icspacketparser.SIP) (int, *icserror.IcsError) {
|
|
||||||
for _, value := range *sip.Content.Media {
|
|
||||||
for _, thisPayload := range value.Payload {
|
|
||||||
for _, invitePayload := range s.invitePayloads {
|
|
||||||
if thisPayload == invitePayload {
|
|
||||||
payload, err := strconv.Atoi(thisPayload)
|
|
||||||
if err != nil {
|
|
||||||
return -1, icserror.ICSERRSDPAudiotagPortValue
|
|
||||||
} else {
|
|
||||||
return payload, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return -1, icserror.ICSERRNotFoundSdpMedia
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue