Untitled
unknown
plain_text
3 years ago
965 B
12
Indexable
leaveSub := h.Subscribe(ari.Events.ChannelLeftBridge)
for {
select {
case <-ctx.Done():
return
case <-destroySub.Events():
log.Debug("bridge destroyed")
return
case e, ok := <-enterSub.Events():
if !ok {
log.Error("channel entered subscription closed")
return
}
v := e.(*ari.ChannelEnteredBridge)
log.Debug("channel entered bridge", "channel", v.Channel.Name)
go func() {
if err := play.Play(ctx, h, play.URI("sound:confbridge-join")).Err(); err != nil {
log.Error("failed to play join sound", "error", err)
}
}()
case e, ok := <-leaveSub.Events():
if !ok {
log.Error("channel left subscription closed")
return
}
v := e.(*ari.ChannelLeftBridge)
log.Debug("channel left bridge", "channel", v.Channel.Name)
go func() {
if err := play.Play(ctx, h, play.URI("sound:confbridge-leave")).Err(); err != nil {
log.Error("failed to play leave sound", "error", err)
}
}()
}
}Editor is loading...