chore: missing missed call parts (#700)

* [PBE-1710] make example app Firebase friendly

* [PBE-1710] support reject.reason & show notification

* fix ios, improve setup

* support pronto-staging

* write openapi script + generate new API

* added missing parts of missed call feature

---------

Co-authored-by: kanat <[email protected]>

Author: Brazol

packages/stream_video/lib/src/coordinator/models/coordinator_events.dart

@@ -125,6 +125,28 @@ class CoordinatorCallRingingEvent extends CoordinatorCallEvent {
       ];
 }
 
+/// Sent when someone misses a call.
+class CoordinatorCallMissedEvent extends CoordinatorCallEvent {
+  const CoordinatorCallMissedEvent({
+    required this.callCid,
+    required this.sessionId,
+    required this.createdAt,
+  });
+
+  final String sessionId;
+  final DateTime createdAt;
+
+  @override
+  final StreamCallCid callCid;
+
+  @override
+  List<Object?> get props => [
+        ...super.props,
+        sessionId,
+        createdAt,
+      ];
+}
+
 /// Sent when a call gets updated.
 class CoordinatorCallUpdatedEvent extends CoordinatorCallEvent {
   const CoordinatorCallUpdatedEvent({

packages/stream_video/lib/src/coordinator/open_api/event/event_type.dart

@@ -8,6 +8,7 @@ enum EventType {
   callCreated('call.created'),
   callAccepted('call.accepted'),
   callRejected('call.rejected'),
+  callMissed('call.missed'),
   callRing('call.ring'),
   callUpdated('call.updated'),
   callEnded('call.ended'),

packages/stream_video/lib/src/coordinator/open_api/event/open_api_event.dart

@@ -14,6 +14,7 @@ class OpenApiEvent with EquatableMixin {
     this.connected,
     this.healthCheck,
     this.callCreated,
+    this.callMissed,
     this.callRing,
     this.callNotification,
     this.callAccepted,
@@ -151,6 +152,9 @@ class OpenApiEvent with EquatableMixin {
       case EventType.callRecordingFailed:
         final event = open.CallRecordingFailedEvent.fromJson(jsonObj);
         return result.copyWith(callRecordingFailed: event);
+      case EventType.callMissed:
+        final event = open.CallMissedEvent.fromJson(jsonObj);
+        return result.copyWith(callMissed: event);
       case EventType.unknown:
         streamLog.e(_tag, () => '[fromJson] unexpected event: $jsonObj');
         return result.copyWith(unknown: jsonObj);
@@ -161,6 +165,7 @@ class OpenApiEvent with EquatableMixin {
   final open.ConnectedEvent? connected;
   final open.HealthCheckEvent? healthCheck;
   final open.CallCreatedEvent? callCreated;
+  final open.CallMissedEvent? callMissed;
   final open.CallRingEvent? callRing;
   final open.CallNotificationEvent? callNotification;
   final open.CallAcceptedEvent? callAccepted;
@@ -196,6 +201,7 @@ class OpenApiEvent with EquatableMixin {
     open.ConnectedEvent? connected,
     open.HealthCheckEvent? healthCheck,
     open.CallCreatedEvent? callCreated,
+    open.CallMissedEvent? callMissed,
     open.CallRingEvent? callRing,
     open.CallNotificationEvent? callNotification,
     open.CallAcceptedEvent? callAccepted,
@@ -231,6 +237,7 @@ class OpenApiEvent with EquatableMixin {
       connected: connected ?? this.connected,
       healthCheck: healthCheck ?? this.healthCheck,
       callCreated: callCreated ?? this.callCreated,
+      callMissed: callMissed ?? this.callMissed,
       callRing: callRing ?? this.callRing,
       callNotification: callNotification ?? this.callNotification,
       callAccepted: callAccepted ?? this.callAccepted,
@@ -279,6 +286,7 @@ class OpenApiEvent with EquatableMixin {
         connected,
         healthCheck,
         callCreated,
+        callMissed,
         callRing,
         callNotification,
         callAccepted,

packages/stream_video/lib/src/coordinator/open_api/open_api_mapper_extensions.dart

@@ -33,6 +33,14 @@ extension WebsocketEventMapperExt on OpenApiEvent {
           ),
           createdAt: event.createdAt,
         );
+      case EventType.callMissed:
+        final event = callMissed!;
+        final call = event.call;
+        return CoordinatorCallMissedEvent(
+          callCid: StreamCallCid(cid: call.cid),
+          sessionId: event.sessionId,
+          createdAt: event.createdAt,
+        );
       case EventType.callRing:
         final event = callRing!;
         final call = event.call;

packages/stream_video/lib/src/stream_video.dart

@@ -593,11 +593,6 @@ class StreamVideo extends Disposable {
     final sender = payload['sender'] as String?;
     if (sender != 'stream.video') return false;
 
-    // Only handle ringing calls.
-    final type = payload['type'] as String?;
-    if (type != 'call.ring') return false;
-
-    // Return if the payload does not contain a call cid.
     final callCid = payload['call_cid'] as String?;
     if (callCid == null) return false;
 
@@ -614,6 +609,22 @@ class StreamVideo extends Disposable {
     final createdById = payload['created_by_id'] as String?;
     final createdByName = payload['created_by_display_name'] as String?;
 
+    final type = payload['type'] as String?;
+    if (type == 'call.missed') {
+      unawaited(
+        manager.showMissedCall(
+          uuid: callUUID,
+          handle: createdById,
+          nameCaller: createdByName,
+          callCid: callCid,
+        ),
+      );
+
+      return true;
+    } else if (type != 'call.ring') {
+      return false;
+    }
+
     final callRingingState = await getCallRingingState(
       // ignore: deprecated_member_use_from_same_package
       type: callType.value,
@@ -637,14 +648,6 @@ class StreamVideo extends Disposable {
       case CallRingingState.rejected:
         return false;
       case CallRingingState.ended:
-        unawaited(
-          manager.showMissedCall(
-            uuid: callUUID,
-            handle: createdById,
-            nameCaller: createdByName,
-            callCid: callCid,
-          ),
-        );
         return false;
     }
   }

packages/stream_video_flutter/lib/src/call_participants/call_participant.dart

@@ -3,7 +3,6 @@ import 'package:flutter/material.dart';
 import 'package:flutter_webrtc/flutter_webrtc.dart';
 
 import '../../stream_video_flutter.dart';
-import '../utils/extensions.dart';
 import 'indicators/connection_quality_indicator.dart';
 import 'participant_label.dart';
 

packages/stream_video_flutter/lib/src/call_participants/overlay_app_bar.dart

@@ -2,7 +2,6 @@ import 'package:collection/collection.dart';
 import 'package:flutter/material.dart';
 
 import '../../stream_video_flutter.dart';
-import '../utils/extensions.dart';
 
 /// A widget that represents a semi-transparent toolbar that is displayed
 /// over the [StreamCallParticipants] widget on mobile devices in landscape

packages/stream_video_flutter/lib/src/call_screen/call_container.dart

@@ -179,6 +179,7 @@ class _StreamCallContainerState extends State<StreamCallContainer> {
     _logger.d(() => '[leave] no args');
     // play tone
     final bool popped;
+
     if (mounted) {
       popped = await Navigator.maybePop(context);
     } else {

packages/stream_video_flutter/lib/src/call_screen/call_content/call_app_bar.dart

@@ -1,7 +1,6 @@
 import 'package:flutter/material.dart' hide ConnectionState;
 
 import '../../../stream_video_flutter.dart';
-import '../../utils/extensions.dart';
 
 /// Widget that represents the default app bar that's shown in calls.
 class CallAppBar extends StatelessWidget implements PreferredSizeWidget {

packages/stream_video_flutter/lib/src/call_screen/incoming_call/incoming_call_content.dart

@@ -1,7 +1,6 @@
 import 'package:flutter/material.dart';
 
 import '../../../stream_video_flutter.dart';
-import '../../utils/extensions.dart';
 import '../common/call_background.dart';
 import '../common/calling_participants.dart';
 import '../common/participant_avatars.dart';
@@ -152,7 +151,7 @@ class _StreamIncomingCallContentState extends State<StreamIncomingCallContent> {
     if (widget.onDeclineCallTap != null) {
       widget.onDeclineCallTap!();
     } else {
-      await widget.call.reject();
+      await widget.call.reject(reason: 'decline');
       await widget.call.leave();
     }
   }