Function channelHandler

_examples/stasisStart/main.go:84–133

(h *ari.ChannelHandle, startEvent *ari.StasisStart)

}

func channelHandler(h *ari.ChannelHandle, startEvent *ari.StasisStart) {
	log.Info("Running channel handler")

	// Subscribe to channel state changes
	stateChange := h.Subscribe(ari.Events.ChannelStateChange)
	defer stateChange.Cancel()

	// Subscribe to StasisEnd events (channel leaving ARI app)
	end := h.Subscribe(ari.Events.StasisEnd)
	defer end.Cancel()

	// Pull the current channel data
	data, err := h.Data()
	if err != nil {
		log.Error("Error getting data", "error", err)
		return
	}
	log.Info("Channel State", "state", data.State)

	var wg sync.WaitGroup

	wg.Add(1)
	go func() {
		log.Info("Waiting for channel events")

		defer wg.Done()

		for {
			select {
			case <-end.Events():
				log.Info("Got stasis end")
				return
			case e := <-stateChange.Events():
				v, ok := e.(*ari.ChannelStateChange)
				if !ok {
					log.Error("failed to interpret event as ChannelStateChange", "error", err)
					return
				}

				log.Info("New Channel State", "state", v.Channel.State)
			}
		}
	}()

	h.Answer()

	wg.Wait()

	h.Hangup()
}