Method applicationSubscribe

server/application.go:68–85

(ctx context.Context, reply string, req *proxy.Request)

}

func (s *Server) applicationSubscribe(ctx context.Context, reply string, req *proxy.Request) {
	err := s.ari.Application().Subscribe(req.Key, req.ApplicationSubscribe.EventSource)
	if err != nil {
		s.sendError(reply, err)
		return
	}

	if req.Key.Dialog != "" {
		eType, eID, err := parseEventSource(req.ApplicationSubscribe.EventSource)
		if err != nil {
			s.Log.Warn("failed to parse event source", "error", err, "eventsource", req.ApplicationSubscribe.EventSource)
		} else {
			s.Dialog.Bind(req.Key.Dialog, eType, eID)
		}
	}

	s.sendError(reply, nil)
}

func (s *Server) applicationUnsubscribe(ctx context.Context, reply string, req *proxy.Request) {
	s.sendError(reply, s.ari.Application().Unsubscribe(req.Key, req.ApplicationSubscribe.EventSource))