Support in band (rfc2833).

Author: cloudwebrtc

example/lib/src/register.dart

@@ -108,6 +108,7 @@ class _MyRegisterWidget extends State<RegisterWidget>
     settings.password = _password;
     settings.displayName = _displayName;
     settings.userAgent = 'Dart SIP Client v1.0.0';
+    settings.dtmfMode = DtmfMode.RFC2833;
 
     helper.start(settings);
   }

lib/src/config.dart

@@ -1,3 +1,5 @@
+import 'package:sip_ua/sip_ua.dart';
+
 import 'constants.dart';
 import 'constants.dart' as DartSIP_C;
 import 'exceptions.dart' as Exceptions;
@@ -39,6 +41,9 @@ class Settings {
   dynamic registrar_server;
   Map<String, dynamic> register_extra_contact_uri_params;
 
+  // Dtmf mode
+  DtmfMode dtmf_mode = DtmfMode.INFO;
+
   // Connection options.
   List<WebSocketInterface> sockets = <WebSocketInterface>[];
   int connection_recovery_max_interval = 30;
@@ -237,7 +242,14 @@ class Checks {
       if (use_preloaded_route is bool) {
         dst.use_preloaded_route = use_preloaded_route;
       }
-    }
+    },
+    'dtmf_mode': (Settings src, Settings dst) {
+      DtmfMode dtmf_mode = src.dtmf_mode;
+      if (dtmf_mode == null) return;
+      if (dtmf_mode is DtmfMode) {
+        dst.dtmf_mode = dtmf_mode;
+      }
+    },
   };
 }
 

lib/src/rtc_session.dart

@@ -2,6 +2,7 @@ import 'dart:async';
 
 import 'package:flutter_webrtc/flutter_webrtc.dart';
 import 'package:sdp_transform/sdp_transform.dart' as sdp_transform;
+import 'package:sip_ua/sip_ua.dart';
 
 import 'constants.dart';
 import 'constants.dart' as DartSIP_C;
@@ -192,6 +193,9 @@ class RTCSession extends EventManager {
 
   RTCPeerConnection get connection => _connection;
 
+  RTCDTMFSender get dtmfSender =>
+      _connection.createDtmfSender(_localMediaStream.getAudioTracks()[0]);
+
   String get contact => _contact;
 
   String get direction => _direction;
@@ -833,6 +837,8 @@ class RTCSession extends EventManager {
 
     options = options ?? <String, dynamic>{};
 
+    DtmfMode mode = _ua.configuration.dtmf_mode;
+
     // sensible defaults
     int duration = options['duration'] ?? RTCSession_DTMF.C.DEFAULT_DURATION;
     int interToneGap =
@@ -892,6 +898,8 @@ class RTCSession extends EventManager {
       interToneGap = utils.Math.abs(interToneGap);
     }
 
+    options['interToneGap'] = interToneGap;
+
     //// ***************** and follows the actual code to queue DTMF tone(s) **********************
 
     ///using dtmfFuture to queue the playing of the tones
@@ -913,7 +921,7 @@ class RTCSession extends EventManager {
             return;
           }
 
-          RTCSession_DTMF.DTMF dtmf = RTCSession_DTMF.DTMF(this);
+          RTCSession_DTMF.DTMF dtmf = RTCSession_DTMF.DTMF(this, mode: mode);
 
           EventManager handlers = EventManager();
           handlers.on(EventCallFailed(), (EventCallFailed event) {

lib/src/rtc_session/dtmf.dart

@@ -1,3 +1,6 @@
+import 'package:flutter_webrtc/flutter_webrtc.dart';
+import 'package:sip_ua/sip_ua.dart';
+
 import '../constants.dart';
 import '../event_manager/event_manager.dart';
 import '../event_manager/internal_events.dart';
@@ -16,12 +19,16 @@ class C {
 }
 
 class DTMF extends EventManager {
-  DTMF(this._session);
+  DTMF(this._session, {DtmfMode mode = DtmfMode.INFO}) {
+    _mode = mode;
+  }
 
   final rtc.RTCSession _session;
+  DtmfMode _mode;
   String _direction;
   String _tone;
   int _duration;
+  int _interToneGap;
   IncomingRequest _request;
   EventManager _eventHandlers;
 
@@ -66,40 +73,47 @@ class DTMF extends EventManager {
 
     // Duration is checked/corrected in RTCSession.
     _duration = options['duration'];
-
-    extraHeaders.add('Content-Type: application/dtmf-relay');
-
-    String body = 'Signal=$_tone\r\n';
-
-    body += 'Duration=$_duration';
-
-    _session.newDTMF('local', this, _request);
-
-    EventManager handlers = EventManager();
-    handlers.on(EventOnSuccessResponse(), (EventOnSuccessResponse event) {
-      emit(EventSucceeded(originator: 'remote', response: event.response));
-    });
-    handlers.on(EventOnErrorResponse(), (EventOnErrorResponse event) {
-      _eventHandlers.emit(EventOnFialed());
-      emit(EventOnFialed());
-      emit(EventCallFailed(originator: 'remote', response: event.response));
-    });
-    handlers.on(EventOnRequestTimeout(), (EventOnRequestTimeout event) {
-      _session.onRequestTimeout();
-    });
-    handlers.on(EventOnTransportError(), (EventOnTransportError event) {
-      _session.onTransportError();
-    });
-
-    handlers.on(EventOnDialogError(), (EventOnDialogError event) {
-      _session.onDialogError();
-    });
-
-    _session.sendRequest(SipMethod.INFO, <String, dynamic>{
-      'extraHeaders': extraHeaders,
-      'eventHandlers': handlers,
-      'body': body
-    });
+    _interToneGap = options['interToneGap'];
+
+    if (_mode == DtmfMode.RFC2833) {
+      RTCDTMFSender dtmfSender = _session.dtmfSender;
+      dtmfSender.insertDTMF(_tone,
+          duration: _duration, interToneGap: _interToneGap);
+    } else if (_mode == DtmfMode.INFO) {
+      extraHeaders.add('Content-Type: application/dtmf-relay');
+
+      String body = 'Signal=$_tone\r\n';
+
+      body += 'Duration=$_duration';
+
+      _session.newDTMF('local', this, _request);
+
+      EventManager handlers = EventManager();
+      handlers.on(EventOnSuccessResponse(), (EventOnSuccessResponse event) {
+        emit(EventSucceeded(originator: 'remote', response: event.response));
+      });
+      handlers.on(EventOnErrorResponse(), (EventOnErrorResponse event) {
+        _eventHandlers.emit(EventOnFialed());
+        emit(EventOnFialed());
+        emit(EventCallFailed(originator: 'remote', response: event.response));
+      });
+      handlers.on(EventOnRequestTimeout(), (EventOnRequestTimeout event) {
+        _session.onRequestTimeout();
+      });
+      handlers.on(EventOnTransportError(), (EventOnTransportError event) {
+        _session.onTransportError();
+      });
+
+      handlers.on(EventOnDialogError(), (EventOnDialogError event) {
+        _session.onDialogError();
+      });
+
+      _session.sendRequest(SipMethod.INFO, <String, dynamic>{
+        'extraHeaders': extraHeaders,
+        'eventHandlers': handlers,
+        'body': body
+      });
+    }
   }
 
   void init_incoming(IncomingRequest request) {

lib/src/sip_ua_helper.dart

@@ -106,6 +106,7 @@ class SIPUAHelper extends EventManager {
     _settings.register_expires = uaSettings.register_expires;
     _settings.register_extra_contact_uri_params =
         uaSettings.registerParams.extraContactUriParams;
+    _settings.dtmf_mode = uaSettings.dtmfMode;
 
     try {
       _ua = UA(_settings);
@@ -543,6 +544,11 @@ class WebSocketSettings {
   bool allowBadCertificate = false;
 }
 
+enum DtmfMode {
+  INFO,
+  RFC2833,
+}
+
 class UaSettings {
   String webSocketUrl;
   WebSocketSettings webSocketSettings = WebSocketSettings();
@@ -565,6 +571,9 @@ class UaSettings {
   String ha1;
   String displayName;
 
+  /// DTMF mode, in band (rfc2833) or out of band (sip info)
+  DtmfMode dtmfMode = DtmfMode.INFO;
+
   List<Map<String, String>> iceServers = <Map<String, String>>[
     <String, String>{'url': 'stun:stun.l.google.com:19302'},
 // turn server configuration example.