sippy_types

type CCEvent interface {
	GetSeq() int64
	GetRtime() *sippy_time.MonoTime
	GetOrigin() string
	GetExtraHeaders() []sippy_header.SipHeader
	SetReason(*sippy_header.SipReason)
	GetReason() *sippy_header.SipReason
	String() string
	AppendExtraHeader(sippy_header.SipHeader)
}

type CallController interface {
	RecvEvent(CCEvent, UA)
}

type CallMap interface {
	OnNewDialog(SipRequest, ServerTransaction) (UA, RequestReceiver, SipResponse)
}

type ClientTransaction interface {
	IncomingResponse(resp SipResponse, checksum string)
	SetOutboundProxy(*sippy_net.HostPort)
	SetAckRparams(*sippy_net.HostPort, *sippy_header.SipURL, []*sippy_header.SipRoute)
	Cancel(...sippy_header.SipHeader)
	GetACK() SipRequest
	SendACK()
	SetUAck(bool)
	BeforeRequestSent(SipRequest)
	TransmitData()
	SetOnSendComplete(func())
	// contains filtered or unexported methods
}

type MsgBody interface {
	String() string
	GetMtype() string
	LocalStr(hostport *sippy_net.HostPort) string
	GetCopy() MsgBody
	NeedsUpdate() bool
	SetNeedsUpdate(bool)
	GetParsedBody() (ParsedMsgBody, error)
	AppendAHeader(string)
}

type OnConnectListener func(*sippy_time.MonoTime, string)

type OnDeadListener func()

type OnDisconnectListener func(*sippy_time.MonoTime, string, int, SipRequest)

type OnFailureListener func(*sippy_time.MonoTime, string, int)

type OnLocalSdpChange func(MsgBody, CCEvent, func(MsgBody)) error

type OnRemoteSdpChange func(MsgBody, SipMsg, func(MsgBody)) error

type OnRingingListener func(*sippy_time.MonoTime, string, int)

type ParsedMsgBody interface {
	String() string
	LocalStr(hostport *sippy_net.HostPort) string
	GetCopy() ParsedMsgBody
	SetCHeaderAddr(string)
	GetCHeader() *sippy_sdp.SdpConnecton
	GetSections() []*sippy_sdp.SdpMediaDescription
	SetSections([]*sippy_sdp.SdpMediaDescription)
	RemoveSection(int)
	GetOHeader() *sippy_sdp.SdpOrigin
	SetOHeader(*sippy_sdp.SdpOrigin)
	AppendAHeader(string)
}

type RequestReceiver interface {
	RecvRequest(SipRequest, ServerTransaction) *Ua_context
}

type ResponseReceiver interface {
	RecvResponse(SipResponse, ClientTransaction)
}

type RtpProxyClient interface {
	SendCommand(string, func(string), sync.Locker)
	SBindSupported() bool
	IsLocal() bool
	TNotSupported() bool
	GetProxyAddress() string
	IsOnline() bool
	GoOnline()
	GoOffline()
	GetOpts() RtpProxyClientOpts
}

type RtpProxyClientOpts interface {
	GetNWorkers() *int
}

type RtpProxyUpdateResult interface {
	Address() string
}

type ServerTransaction interface {
	IncomingRequest(req SipRequest, checksum string)
	TimersAreActive() bool
	SetCancelCB(func(*sippy_time.MonoTime, SipRequest))
	SetNoackCB(func(*sippy_time.MonoTime))
	SendResponse(resp SipResponse, retrans bool, ack_cb func(SipRequest))
	SendResponseWithLossEmul(resp SipResponse, retrans bool, ack_cb func(SipRequest), lossemul int)
	Cleanup()
	UpgradeToSessionLock(sync.Locker)
	SetServer(*sippy_header.SipServer)
	SetBeforeResponseSent(func(SipResponse))
	// contains filtered or unexported methods
}

type SipMsg interface {
	GetSipUserAgent() *sippy_header.SipUserAgent
	GetSipServer() *sippy_header.SipServer
	LocalStr(hostport *sippy_net.HostPort, compact bool) string
	GetCSeq() *sippy_header.SipCSeq
	GetTId(wCSM, wBRN, wTTG bool) (*sippy_header.TID, error)
	GetTo() *sippy_header.SipTo
	GetReason() *sippy_header.SipReason
	AppendHeader(hdr sippy_header.SipHeader)
	GetVias() []*sippy_header.SipVia
	GetCallId() *sippy_header.SipCallId
	SetRtime(*sippy_time.MonoTime)
	GetTarget() *sippy_net.HostPort
	SetTarget(address *sippy_net.HostPort)
	InsertFirstVia(*sippy_header.SipVia)
	RemoveFirstVia()
	SetRoutes([]*sippy_header.SipRoute)
	GetFrom() *sippy_header.SipFrom
	GetRtime() *sippy_time.MonoTime
	GetAlso() []*sippy_header.SipAlso
	GetBody() MsgBody
	SetBody(MsgBody)
	GetContacts() []*sippy_header.SipContact
	GetRecordRoutes() []*sippy_header.SipRecordRoute
	GetCGUID() *sippy_header.SipCiscoGUID
	GetH323ConfId() *sippy_header.SipH323ConfId
	GetSipAuthorization() *sippy_header.SipAuthorization
	GetSource() *sippy_net.HostPort
	GetFirstHF(string) sippy_header.SipHeader
	GetHFs(string) []sippy_header.SipHeader
	GetSL() string
	GetMaxForwards() *sippy_header.SipMaxForwards
	SetMaxForwards(*sippy_header.SipMaxForwards)
}

type SipRequest interface {
	SipMsg
	GetSipProxyAuthorization() *sippy_header.SipProxyAuthorization
	GenResponse(int, string, MsgBody, *sippy_header.SipServer) SipResponse
	GetMethod() string
	GetExpires() *sippy_header.SipExpires
	GenACK(to *sippy_header.SipTo) (SipRequest, error)
	GenCANCEL() (SipRequest, error)
	GetRURI() *sippy_header.SipURL
	SetRURI(ruri *sippy_header.SipURL)
	GetReferTo() *sippy_header.SipReferTo
	GetNated() bool
}

type SipResponse interface {
	SipMsg
	GetSCode() (int, string)
	SetSCode(int, string)
	GetSCodeNum() int
	GetSCodeReason() string
	GetSipWWWAuthenticate() *sippy_header.SipWWWAuthenticate
	GetSipProxyAuthenticate() *sippy_header.SipProxyAuthenticate
	SetSCodeReason(string)
	GetCopy() SipResponse
}

type SipTransactionManager interface {
	RegConsumer(UA, string)
	UnregConsumer(UA, string)
	BeginNewClientTransaction(SipRequest, ResponseReceiver, sync.Locker, *sippy_net.HostPort, sippy_net.Transport, func(SipRequest)) (ClientTransaction, error)
	CreateClientTransaction(SipRequest, ResponseReceiver, sync.Locker, *sippy_net.HostPort, sippy_net.Transport, func(SipRequest)) (ClientTransaction, error)
	BeginClientTransaction(SipRequest, ClientTransaction)
	SendResponse(resp SipResponse, lock bool, ack_cb func(SipRequest))
	SendResponseWithLossEmul(resp SipResponse, lock bool, ack_cb func(SipRequest), lossemul int)
	Run()
	Shutdown()
}

type StatefulProxy interface {
	RequestReceiver
}

type UA interface {
	OnUnregister()
	RequestReceiver
	ResponseReceiver
	GetSessionLock() sync.Locker
	RecvEvent(CCEvent)
	SipTM() SipTransactionManager
	GetSetupTs() *sippy_time.MonoTime
	SetSetupTs(*sippy_time.MonoTime)
	GetDisconnectTs() *sippy_time.MonoTime
	SetDisconnectTs(*sippy_time.MonoTime)
	GetOrigin() string
	SetOrigin(string)
	HasOnLocalSdpChange() bool
	OnLocalSdpChange(MsgBody, CCEvent, func(MsgBody)) error
	SetOnLocalSdpChange(OnLocalSdpChange)
	ResetOnLocalSdpChange()
	OnRemoteSdpChange(MsgBody, SipMsg, func(MsgBody)) error
	HasOnRemoteSdpChange() bool
	ResetOnRemoteSdpChange()
	SetCallId(*sippy_header.SipCallId)
	GetCallId() *sippy_header.SipCallId
	SetRTarget(*sippy_header.SipURL)
	GetRAddr() *sippy_net.HostPort
	SetRAddr(addr *sippy_net.HostPort)
	GetRAddr0() *sippy_net.HostPort
	SetRAddr0(addr *sippy_net.HostPort)
	GetRTarget() *sippy_header.SipURL
	SetRUri(*sippy_header.SipTo)
	GetRuriUserparams() []string
	SetRuriUserparams([]string)
	GetRUri() *sippy_header.SipTo
	GetToUsername() string
	SetToUsername(string)
	GetUsername() string
	SetUsername(string)
	GetPassword() string
	SetPassword(string)
	SetLUri(*sippy_header.SipFrom)
	GetLUri() *sippy_header.SipFrom
	GetFromDomain() string
	SetFromDomain(string)
	GetLTag() string
	SetLCSeq(int)
	SetLContact(*sippy_header.SipContact)
	GetLContact() *sippy_header.SipContact
	GetLContacts() []*sippy_header.SipContact
	SetRoutes([]*sippy_header.SipRoute)
	GetCGUID() *sippy_header.SipCiscoGUID
	SetCGUID(*sippy_header.SipCiscoGUID)
	SetH323ConfId(*sippy_header.SipH323ConfId)
	GetLSDP() MsgBody
	SetLSDP(MsgBody)
	GetRSDP() MsgBody
	SetRSDP(MsgBody)
	GenRequest(method string, body MsgBody, nonce string, realm string, SipXXXAuthorization sippy_header.NewSipXXXAuthorizationFunc, extra_headers ...sippy_header.SipHeader) (SipRequest, error)
	IncLCSeq()
	GetSourceAddress() *sippy_net.HostPort
	SetSourceAddress(*sippy_net.HostPort)
	GetClientTransaction() ClientTransaction
	SetClientTransaction(ClientTransaction)
	GetOutboundProxy() *sippy_net.HostPort
	SetOutboundProxy(*sippy_net.HostPort)
	GetNoReplyTime() time.Duration
	SetNoReplyTime(time.Duration)
	GetExpireTime() time.Duration
	SetExpireTime(time.Duration)
	GetNoProgressTime() time.Duration
	SetNoProgressTime(time.Duration)
	StartNoReplyTimer(*sippy_time.MonoTime)
	StartNoProgressTimer(*sippy_time.MonoTime)
	StartExpireTimer(*sippy_time.MonoTime)
	CancelExpireTimer()
	DiscCb(*sippy_time.MonoTime, string, int, SipRequest)
	GetDiscCb() OnDisconnectListener
	SetDiscCb(OnDisconnectListener)
	FailCb(*sippy_time.MonoTime, string, int)
	GetFailCb() OnFailureListener
	SetFailCb(OnFailureListener)
	ConnCb(*sippy_time.MonoTime, string)
	GetConnCb() OnConnectListener
	SetConnCb(OnConnectListener)
	RingCb(*sippy_time.MonoTime, string, int)
	GetDeadCb() OnDeadListener
	SetDeadCb(OnDeadListener)
	IsYours(SipRequest, bool) bool
	GetLocalUA() *sippy_header.SipUserAgent
	SetLocalUA(*sippy_header.SipUserAgent)
	Enqueue(CCEvent)
	GetUasResp() SipResponse
	SetUasResp(SipResponse)
	CancelCreditTimer()
	StartCreditTimer(*sippy_time.MonoTime)
	SetCreditTime(time.Duration)
	ResetCreditTime(*sippy_time.MonoTime, map[int64]*sippy_time.MonoTime)
	ShouldUseRefer() bool
	GetState() UaState
	Disconnect(*sippy_time.MonoTime)
	SetKaInterval(time.Duration)
	GetKaInterval() time.Duration
	OnDead()
	GetGoDeadTimeout() time.Duration
	ChangeState(UaState)
	GetLastScode() int
	SetLastScode(int)
	HasNoReplyTimer() bool
	CancelNoReplyTimer()
	GetNpMtime() *sippy_time.MonoTime
	SetNpMtime(*sippy_time.MonoTime)
	GetExMtime() *sippy_time.MonoTime
	SetExMtime(*sippy_time.MonoTime)
	GetP100Ts() *sippy_time.MonoTime
	SetP100Ts(*sippy_time.MonoTime)
	HasNoProgressTimer() bool
	CancelNoProgressTimer()
	DelayedRemoteSdpUpdate(event CCEvent, remote_sdp_body MsgBody)
	GetP1xxTs() *sippy_time.MonoTime
	SetP1xxTs(*sippy_time.MonoTime)
	UpdateRouting(SipResponse, bool, bool)
	GetConnectTs() *sippy_time.MonoTime
	SetConnectTs(*sippy_time.MonoTime)
	SetBranch(string)
	SetAuth(sippy_header.SipHeader)
	GetNrMtime() *sippy_time.MonoTime
	SetNrMtime(*sippy_time.MonoTime)
	SendUasResponse(t ServerTransaction, scode int, reason string, body MsgBody, contacts []*sippy_header.SipContact, ack_wait bool, extra_headers ...sippy_header.SipHeader)
	EmitEvent(CCEvent)
	String() string
	GetPendingTr() ClientTransaction
	SetPendingTr(ClientTransaction)
	GetLateMedia() bool
	SetLateMedia(bool)
	GetPassAuth() bool
	GetOnLocalSdpChange() OnLocalSdpChange
	GetOnRemoteSdpChange() OnRemoteSdpChange
	SetOnRemoteSdpChange(OnRemoteSdpChange)
	GetRemoteUA() string
	SetExtraHeaders([]sippy_header.SipHeader)
	GetAcct(*sippy_time.MonoTime) (time.Duration, time.Duration, bool, bool)
	GetCLI() string
	GetCLD() string
	GetUasLossEmul() int
	UasLossEmul() int
	BeforeRequestSent(SipRequest)
	BeforeResponseSent(SipResponse)
	PrepTr(SipRequest) (ClientTransaction, error)
}

type UaState interface {
	RecvEvent(CCEvent) (UaState, error)
	RecvResponse(SipResponse, ClientTransaction) UaState
	RecvRequest(SipRequest, ServerTransaction) UaState
	Cancel(*sippy_time.MonoTime, SipRequest)
	OnStateChange()
	String() string
	OnActivation()
	RecvACK(SipRequest)
	IsConnected() bool
}

type Ua_context struct {
	Response SipResponse
	CancelCB func(*sippy_time.MonoTime, SipRequest)
	NoAckCB  func(*sippy_time.MonoTime)
}