dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-08-26 02:49:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

WiP

Browse Source
This commit is contained in:
Benjamin Pracht
2024-10-09 20:51:51 -07:00
parent 5eb2cd1a90
commit dcb53d2957
1 changed files with 37 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/telemetry/events.go
+37 -1
View File
@@ -526,6 +526,42 @@ func (t *telemetryService) SIPOutboundTrunkDeleted(ctx context.Context, out *liv
})
}
func (t *telemetryService) SIPDispatchRuleCreated(ctx context.Context, dispatchRule *livekit.SIPDispatchRuleInfo) {
t.enqueue(func() {
t.SendEvent(ctx, newSIPDispatchRuleEvent(livekit.AnalyticsEventType_SIP_DISPATCH_RULE_CREATED, dispatchRule))
})
}
func (t *telemetryService) SIPDispatchRuleDeleted(ctx context.Context, dispatchRule *livekit.SIPDispatchRuleInfo) {
t.enqueue(func() {
t.SendEvent(ctx, newSIPDispatchRuleEvent(livekit.AnalyticsEventType_SIP_DISPATCH_RULE_DELETED, dispatchRule))
})
}
func (t *telemetryService) SIPParticipantCreated(ctx context.Context, sipCall *livekit.SIPCallInfo) {
t.enqueue(func() {
t.SendEvent(ctx, newSIPCallEvent(livekit.AnalyticsEventType_SIP_PARTICIPANT_CREATED, sipCall))
})
}
func (t *telemetryService) SIPCallAccepted(ctx context.Context, sipCall *livekit.SIPCallInfo) {
t.enqueue(func() {
t.SendEvent(ctx, newSIPCallEvent(livekit.AnalyticsEventType_SIP_CALL_ACCEPTED, sipCall))
})
}
func (t *telemetryService) SIPCallStarted(ctx context.Context, sipCall *livekit.SIPCallInfo) {
t.enqueue(func() {
t.SendEvent(ctx, newSIPCallEvent(livekit.AnalyticsEventType_SIP_CALL_STARTED, sipCall))
})
}
func (t *telemetryService) SIPCallEnded(ctx context.Context, sipCall *livekit.SIPCallInfo) {
t.enqueue(func() {
t.SendEvent(ctx, newSIPCallEvent(livekit.AnalyticsEventType_SIP_CALL_ENDED, sipCall))
})
}
// returns a livekit.Room with only name and sid filled out
// returns nil if room is not found
func (t *telemetryService) getRoomDetails(participantID livekit.ParticipantID) *livekit.Room {
@@ -603,7 +639,7 @@ func newSIPOutboundTrunkEvent(event livekit.AnalyticsEventType, out *livekit.SIP
return &livekit.AnalyticsEvent{
Type: event,
Timestamp: timestamppb.Now(),
SipTrunkId: in.SipTrunkId,
SipTrunkId: out.SipTrunkId,
SipOutboundTrunk: out,
}
}