If starting a message flow from an ivr trigger, send reject response

core/ivr/ivr.go

@@ -68,7 +68,7 @@ type Service interface {
 	HangupCall(externalID string) (*httpx.Trace, error)
 
 	WriteSessionResponse(ctx context.Context, rt *runtime.Runtime, channel *models.Channel, call *models.Call, session *models.Session, number urns.URN, resumeURL string, req *http.Request, w http.ResponseWriter) error
-	WriteHangupResponse(w http.ResponseWriter) error
+	WriteRejectResponse(w http.ResponseWriter) error
 	WriteErrorResponse(w http.ResponseWriter, err error) error
 	WriteEmptyResponse(w http.ResponseWriter, msg string) error
 

core/tasks/ivr/worker_test.go

@@ -92,7 +92,7 @@ func (s *MockService) WriteSessionResponse(ctx context.Context, rt *runtime.Runt
 	return nil
 }
 
-func (s *MockService) WriteHangupResponse(w http.ResponseWriter) error {
+func (s *MockService) WriteRejectResponse(w http.ResponseWriter) error {
 	return nil
 }
 

services/ivr/twiml/client.go

@@ -3,6 +3,10 @@ package twiml
 // BaseURL is our default base URL for TWIML channels (public for testing overriding)
 var BaseURL = `https://api.twilio.com`
 
+type Reject struct {
+	XMLName string `xml:"Reject"`
+}
+
 type Say struct {
 	XMLName  string `xml:"Say"`
 	Text     string `xml:",chardata"`

services/ivr/twiml/service.go

@@ -376,9 +376,9 @@ func (s *service) WriteSessionResponse(ctx context.Context, rt *runtime.Runtime,
 	return nil
 }
 
-func (s *service) WriteHangupResponse(w http.ResponseWriter) error {
+func (s *service) WriteRejectResponse(w http.ResponseWriter) error {
 	return s.writeResponse(w, &Response{
-		Commands: []any{Hangup{}},
+		Commands: []any{Reject{}},
 	})
 }
 

services/ivr/vonage/service.go

@@ -616,9 +616,12 @@ func (s *service) WriteSessionResponse(ctx context.Context, rt *runtime.Runtime,
 	return nil
 }
 
-func (s *service) WriteHangupResponse(w http.ResponseWriter) error {
+func (s *service) WriteRejectResponse(w http.ResponseWriter) error {
 	w.Header().Set("Content-Type", "application/json")
-	_, err := w.Write([]byte(`[]`))
+	_, err := w.Write(jsonx.MustMarshal([]any{Talk{
+		Action: "talk",
+		Text:   "This number is not accepting calls",
+	}}))
 	return err
 }
 

web/ivr/ivr.go

@@ -142,9 +142,9 @@ func handleIncoming(ctx context.Context, rt *runtime.Runtime, oa *models.OrgAsse
 
 	// if we matched with an incoming-call trigger, we'll have a session
 	if session != nil {
-		// that might have started a non-voice flow, in which case we need to hangup this call
+		// that might have started a non-voice flow, in which case we need to reject this call
 		if session.SessionType() != models.FlowTypeVoice {
-			return call, svc.WriteHangupResponse(w)
+			return call, svc.WriteRejectResponse(w)
 		}
 
 		// build our resume URL