update with new return signature

This commit is contained in:
Joel Wetzell
2026-06-14 15:29:38 -05:00
parent ae100ec567
commit 34dd6a0d31
2 changed files with 12 additions and 3 deletions
+4 -1
View File
@@ -212,7 +212,10 @@ func (scs *SIPCallServer) Output(ctx context.Context, payload any) error {
payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload) payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload)
if ok { if ok {
dtmfWriter := call.inDialog.AudioWriterDTMF() dtmfWriter, err := call.inDialog.AudioWriterDTMF()
if err != nil {
return err
}
time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait)) time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait))
for i, dtmfRune := range payloadDTMFResponse.Digits { for i, dtmfRune := range payloadDTMFResponse.Digits {
err := dtmfWriter.WriteDTMF(dtmfRune) err := dtmfWriter.WriteDTMF(dtmfRune)
+8 -2
View File
@@ -204,7 +204,10 @@ func (sds *SIPDTMFServer) HandleCall(inDialog *diago.DialogServerSession) error
inDialog.Ringing() inDialog.Ringing()
inDialog.Answer() inDialog.Answer()
reader := inDialog.AudioReaderDTMF() reader, err := inDialog.AudioReaderDTMF()
if err != nil {
return err
}
userString := "" userString := ""
return reader.Listen(func(dtmf rune) error { return reader.Listen(func(dtmf rune) error {
@@ -246,7 +249,10 @@ func (sds *SIPDTMFServer) Output(ctx context.Context, payload any) error {
payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload) payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload)
if ok { if ok {
dtmfWriter := call.inDialog.AudioWriterDTMF() dtmfWriter, err := call.inDialog.AudioWriterDTMF()
if err != nil {
return err
}
time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait)) time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait))
for i, dtmfRune := range payloadDTMFResponse.Digits { for i, dtmfRune := range payloadDTMFResponse.Digits {