( ctx context.Context, roomID livekit.RoomID, roomName livekit.RoomName, participantID livekit.ParticipantID, identity livekit.ParticipantIdentity, track *livekit.TrackInfo, shouldSendEvent bool, )
| 243 | } |
| 244 | |
| 245 | func (t *telemetryService) TrackPublished( |
| 246 | ctx context.Context, |
| 247 | roomID livekit.RoomID, |
| 248 | roomName livekit.RoomName, |
| 249 | participantID livekit.ParticipantID, |
| 250 | identity livekit.ParticipantIdentity, |
| 251 | track *livekit.TrackInfo, |
| 252 | shouldSendEvent bool, |
| 253 | ) { |
| 254 | t.enqueue(func() { |
| 255 | prometheus.AddPublishedTrack(track.Type.String()) |
| 256 | prometheus.RecordTrackPublishSuccess(track.Type.String()) |
| 257 | if !shouldSendEvent { |
| 258 | return |
| 259 | } |
| 260 | |
| 261 | room := toMinimalRoomProto(roomID, roomName) |
| 262 | participant := &livekit.ParticipantInfo{ |
| 263 | Sid: string(participantID), |
| 264 | Identity: string(identity), |
| 265 | } |
| 266 | t.NotifyEvent(ctx, &livekit.WebhookEvent{ |
| 267 | Event: webhook.EventTrackPublished, |
| 268 | Room: room, |
| 269 | Participant: participant, |
| 270 | Track: track, |
| 271 | }) |
| 272 | |
| 273 | ev := newTrackEvent(livekit.AnalyticsEventType_TRACK_PUBLISHED, room, participantID, track) |
| 274 | ev.Participant = participant |
| 275 | t.SendEvent(ctx, ev) |
| 276 | }) |
| 277 | } |
| 278 | |
| 279 | func (t *telemetryService) TrackPublishedUpdate( |
| 280 | ctx context.Context, |
nothing calls this directly
no test coverage detected