Bridge onsolo

bridge.go

func (a app) wait(ctx context.Context) stateFn {
	brSub := a.Bridge.Subscribe(ari.Events.ChannelLeftBridge)
	defer brSub.Cancel()

	err := a.Bridge.AddChannel(a.channel)
	if err != nil {
		a.log.Error("Failed to add caller to bridge", "error", err)
		return a.failure
	}

	// Wait for bridge events
	for {
		select {
		case ctx.Done():
			return nil
		case e := <-brSub.Events():
			data, err := a.Bridge.Data()
			if err != nil {
				a.log.Error("Failed to get bridge data", "error", err)
				return a.failure
			}
			if len(data.ChannelIDs) < 2 {
				a.log.Debug("Bridge soloed")
				return nil
			}
		}
	}
}