dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-05-23 12:35:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

accept any participant type source to BroadcastMetricsForRoom (#3063)

Browse Source
This commit is contained in:
Paul Wells
2024-10-03 05:51:02 -07:00
committed by GitHub
parent 119e11e191
commit c9d2552cb3
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/rtc/participant.go
+5 -5
View File
@@ -1661,7 +1661,7 @@ func (p *ParticipantImpl) onDataMessage(kind livekit.DataPacket_Kind, data []byt
// only forward on user payloads
switch payload := dp.Value.(type) {
case *livekit.DataPacket_User:
if payload == nil || payload.User == nil {
if payload.User == nil {
return
}
u := payload.User
@@ -1678,18 +1678,18 @@ func (p *ParticipantImpl) onDataMessage(kind livekit.DataPacket_Kind, data []byt
dp.DestinationIdentities = u.DestinationIdentities
}
case *livekit.DataPacket_SipDtmf:
if payload == nil || payload.SipDtmf == nil {
if payload.SipDtmf == nil {
return
}
case *livekit.DataPacket_Transcription:
if payload == nil || payload.Transcription == nil {
if payload.Transcription == nil {
return
}
if !p.IsAgent() {
shouldForwardData = false
}
case *livekit.DataPacket_ChatMessage:
if payload == nil || payload.ChatMessage == nil {
if payload.ChatMessage == nil {
return
}
if p.IsAgent() && dp.ParticipantIdentity != "" && string(p.params.Identity) != dp.ParticipantIdentity {
@@ -1698,7 +1698,7 @@ func (p *ParticipantImpl) onDataMessage(kind livekit.DataPacket_Kind, data []byt
}
shouldForwardData = true
case *livekit.DataPacket_Metrics:
if payload == nil || payload.Metrics == nil {
if payload.Metrics == nil {
return
}
shouldForwardData = false
pkg/rtc/room.go
+1 -1
View File
@@ -1795,7 +1795,7 @@ func BroadcastDataPacketForRoom(r types.Room, source types.LocalParticipant, kin
})
}
func BroadcastMetricsForRoom(r types.Room, source types.LocalParticipant, dp *livekit.DataPacket, logger logger.Logger) {
func BroadcastMetricsForRoom(r types.Room, source types.Participant, dp *livekit.DataPacket, logger logger.Logger) {
switch payload := dp.Value.(type) {
case *livekit.DataPacket_Metrics:
utils.ParallelExec(r.GetLocalParticipants(), dataForwardLoadBalanceThreshold, 1, func(op types.LocalParticipant) {