Merge pull request #176 from baihua666/baihua_dev

Add accept and reject call example

Author: cloudwebrtc

lib/src/call_sample/call_sample.dart

@@ -21,6 +21,8 @@ class _CallSampleState extends State<CallSample> {
   bool _inCalling = false;
   Session? _session;
 
+  bool _waitAccept = false;
+
   // ignore: unused_element
   _CallSampleState();
 
@@ -55,15 +57,31 @@ class _CallSampleState extends State<CallSample> {
       }
     };
 
-    _signaling?.onCallStateChange = (Session session, CallState state) {
+    _signaling?.onCallStateChange = (Session session, CallState state) async {
       switch (state) {
         case CallState.CallStateNew:
           setState(() {
             _session = session;
-            _inCalling = true;
           });
           break;
+        case CallState.CallStateRinging:
+          bool? accept = await _showAcceptDialog();
+          if (accept!) {
+            _accept();
+            setState(() {
+              _inCalling = true;
+            });
+          }
+          else {
+            _reject();
+          }
+          break;
         case CallState.CallStateBye:
+          if (_waitAccept) {
+            print('peer reject');
+            _waitAccept = false;
+            Navigator.of(context).pop(false);
+          }
           setState(() {
             _localRenderer.srcObject = null;
             _remoteRenderer.srcObject = null;
@@ -72,7 +90,19 @@ class _CallSampleState extends State<CallSample> {
           });
           break;
         case CallState.CallStateInvite:
+          _waitAccept = true;
+          _showInvateDialog();
+          break;
         case CallState.CallStateConnected:
+          if (_waitAccept) {
+            _waitAccept = false;
+            Navigator.of(context).pop(false);
+          }
+          setState(() {
+            _inCalling = true;
+          });
+
+          break;
         case CallState.CallStateRinging:
       }
     };
@@ -97,12 +127,70 @@ class _CallSampleState extends State<CallSample> {
     });
   }
 
+  Future<bool?> _showAcceptDialog() {
+    return showDialog<bool?>(
+      context: context,
+      builder: (context) {
+        return AlertDialog(
+          title: Text("title"),
+          content: Text("accept?"),
+          actions: <Widget>[
+            TextButton(
+              child: Text("reject"),
+              onPressed: () => Navigator.of(context).pop(false),
+            ),
+            TextButton(
+              child: Text("accept"),
+              onPressed: () {
+                Navigator.of(context).pop(true);
+              },
+            ),
+          ],
+        );
+      },
+    );
+  }
+
+  Future<bool?> _showInvateDialog() {
+    return showDialog<bool?>(
+      context: context,
+      builder: (context) {
+        return AlertDialog(
+          title: Text("title"),
+          content: Text("waiting"),
+          actions: <Widget>[
+            TextButton(
+              child: Text("cancel"),
+              onPressed: () {
+                Navigator.of(context).pop(false);
+                _hangUp();
+                },
+
+            ),
+          ],
+        );
+      },
+    );
+  }
+
   _invitePeer(BuildContext context, String peerId, bool useScreen) async {
     if (_signaling != null && peerId != _selfId) {
       _signaling?.invite(peerId, 'video', useScreen);
     }
   }
 
+  _accept() {
+    if (_session != null) {
+      _signaling?.accept(_session!.sid);
+    }
+  }
+
+  _reject() {
+    if (_session != null) {
+      _signaling?.reject(_session!.sid);
+    }
+  }
+
   _hangUp() {
     if (_session != null) {
       _signaling?.bye(_session!.sid);

lib/src/call_sample/signaling.dart

@@ -120,6 +120,7 @@ class Signaling {
     }
     _createOffer(session, media);
     onCallStateChange?.call(session, CallState.CallStateNew);
+    onCallStateChange?.call(session, CallState.CallStateInvite);
   }
 
   void bye(String sessionId) {
@@ -133,6 +134,22 @@ class Signaling {
     }
   }
 
+  void accept(String sessionId) {
+    var session = _sessions[sessionId];
+    if (session == null) {
+      return;
+    }
+    _createAnswer(session, 'video');
+  }
+
+  void reject(String sessionId) {
+    var session = _sessions[sessionId];
+    if (session == null) {
+      return;
+    }
+    bye(session.sid);
+  }
+
   void onMessage(message) async {
     Map<String, dynamic> mapData = message;
     var data = mapData['data'];
@@ -164,14 +181,17 @@ class Signaling {
           _sessions[sessionId] = newSession;
           await newSession.pc?.setRemoteDescription(
               RTCSessionDescription(description['sdp'], description['type']));
-          await _createAnswer(newSession, media);
+          // await _createAnswer(newSession, media);
+
           if (newSession.remoteCandidates.length > 0) {
             newSession.remoteCandidates.forEach((candidate) async {
               await newSession.pc?.addCandidate(candidate);
             });
             newSession.remoteCandidates.clear();
           }
           onCallStateChange?.call(newSession, CallState.CallStateNew);
+
+          onCallStateChange?.call(newSession, CallState.CallStateRinging);
         }
         break;
       case 'answer':
@@ -181,6 +201,7 @@ class Signaling {
           var session = _sessions[sessionId];
           session?.pc?.setRemoteDescription(
               RTCSessionDescription(description['sdp'], description['type']));
+          onCallStateChange?.call(session!, CallState.CallStateConnected);
         }
         break;
       case 'candidate':
@@ -274,7 +295,7 @@ class Signaling {
       onMessage(_decoder.convert(message));
     };
 
-    _socket?.onClose = (int code, String reason) {
+    _socket?.onClose = (int? code, String? reason) {
       print('Closed by server [$code => $reason]!');
       onSignalingStateChange?.call(SignalingState.ConnectionClosed);
     };
@@ -399,7 +420,7 @@ class Signaling {
                 'to': peerId,
                 'from': _selfId,
                 'candidate': {
-                  'sdpMLineIndex': candidate.sdpMlineIndex,
+                  'sdpMLineIndex': candidate.sdpMLineIndex,
                   'sdpMid': candidate.sdpMid,
                   'candidate': candidate.candidate,
                 },

lib/src/utils/websocket.dart

@@ -8,7 +8,7 @@ class SimpleWebSocket {
   var _socket;
   Function()? onOpen;
   Function(dynamic msg)? onMessage;
-  Function(int code, String reaso)? onClose;
+  Function(int? code, String? reaso)? onClose;
   SimpleWebSocket(this._url);
 
   connect() async {

pubspec.yaml

@@ -11,7 +11,7 @@ dependencies:
     sdk: flutter
 
   cupertino_icons: ^1.0.3
-  flutter_webrtc: ^0.7.0+hotfix.1
+  flutter_webrtc: ^0.8.3
   shared_preferences: ^2.0.7
   http: ^0.13.3
   path_provider: ^2.0.2