FVS-84: fix duplicate participant, dateTime parsing, reset StreamVideo on uregister (#491)

Author: kanat

dogfooding/lib/di/injector.dart

@@ -1,16 +1,16 @@
 // 📦 Package imports:
 import 'package:flutter/foundation.dart';
+// 🌎 Project imports:
+import 'package:flutter_dogfooding/core/repos/app_preferences.dart';
+import 'package:flutter_dogfooding/core/repos/user_chat_repository.dart';
 import 'package:get_it/get_it.dart';
 import 'package:google_sign_in/google_sign_in.dart';
 import 'package:share_plus/share_plus.dart';
 import 'package:shared_preferences/shared_preferences.dart';
 import 'package:stream_chat_flutter/stream_chat_flutter.dart' hide User;
 import 'package:stream_video_flutter/stream_video_flutter.dart';
-
-// 🌎 Project imports:
-import 'package:flutter_dogfooding/core/repos/app_preferences.dart';
-import 'package:flutter_dogfooding/core/repos/user_chat_repository.dart';
 import 'package:stream_video_push_notification/stream_video_push_notification.dart';
+
 import '../app/user_auth_controller.dart';
 import '../core/repos/token_service.dart';
 import '../core/repos/user_auth_repository.dart';
@@ -69,6 +69,7 @@ class AppInjector {
   static StreamVideo registerStreamVideo(User user) {
     _setupLogger();
     return locator.registerSingleton(
+      dispose: (_) => StreamVideo.reset(),
       _initStreamVideo(
         user,
         tokenLoader: switch (user.type) {

packages/stream_video/lib/open_api/video/coordinator/api_helper.dart

@@ -102,3 +102,17 @@ DateTime? mapDateTime(dynamic map, String key, [String? pattern]) {
   }
   return null;
 }
+
+extension on Map<String, String> {
+  Map<String, DateTime> convertValueToDateTime() {
+    final Map<String, DateTime> output = {};
+    for (var key in keys) {
+      final value = this[key];
+      if (value == null) continue;
+      final dateTime = DateTime.tryParse(value);
+      if (dateTime == null) continue;
+      output[key] = dateTime;
+    }
+    return output;
+  }
+}

packages/stream_video/lib/open_api/video/coordinator/model/call_session_response.dart

@@ -141,16 +141,17 @@ class CallSessionResponse {
         });
         return true;
       }());
-
       return CallSessionResponse(
-        acceptedBy: mapCastOfType<String, DateTime>(json, r'accepted_by')!,
+        acceptedBy: mapCastOfType<String, String>(json, r'accepted_by')!
+            .convertValueToDateTime(),
         endedAt: mapDateTime(json, r'ended_at', ''),
         id: mapValueOfType<String>(json, r'id')!,
         liveEndedAt: mapDateTime(json, r'live_ended_at', ''),
         liveStartedAt: mapDateTime(json, r'live_started_at', ''),
         participants: CallParticipantResponse.listFromJson(json[r'participants']),
         participantsCountByRole: mapCastOfType<String, int>(json, r'participants_count_by_role')!,
-        rejectedBy: mapCastOfType<String, DateTime>(json, r'rejected_by')!,
+        rejectedBy: mapCastOfType<String, String>(json, r'rejected_by')!
+            .convertValueToDateTime(),
         startedAt: mapDateTime(json, r'started_at', ''),
       );
     }

packages/stream_video/lib/src/call/state/call_state_notifier.dart

@@ -1,6 +1,7 @@
 import 'package:state_notifier/state_notifier.dart';
 
 import '../../call_state.dart';
+import '../../logger/impl/tagged_logger.dart';
 import '../../models/call_preferences.dart';
 import '../../state_emitter.dart';
 import 'mixins/state_call_actions_mixin.dart';
@@ -24,6 +25,8 @@ class CallStateNotifier extends StateNotifier<CallState>
         MutableStateEmitterImpl<CallState>(initialState, sync: true);
   }
 
+  final _logger = taggedLogger(tag: 'CallStateNotifier');
+
   @override
   final CallPreferences callPreferences;
 
@@ -32,6 +35,11 @@ class CallStateNotifier extends StateNotifier<CallState>
 
   @override
   set state(CallState value) {
+    _logger.v(() => '[setState] ${value.status} <= ${super.state.status}');
+    _logger.v(() => '[setState] ${value.callParticipants.map((it) {
+      return (it.sessionId, it.userId);
+    })}',);
+
     super.state = value;
     callStateStream.value = value;
   }

packages/stream_video/lib/src/call/state/mixins/state_sfu_mixin.dart

@@ -48,7 +48,8 @@ mixin StateSfuMixin on StateNotifier<CallState> {
     final participants = event.callState.participants.map((aParticipant) {
       final isLocal = aParticipant.userId == state.currentUserId;
       final existing = state.callParticipants.firstWhereOrNull(
-        (it) => it.userId == aParticipant.userId,
+        (it) => it.userId == aParticipant.userId
+            && it.sessionId == aParticipant.sessionId,
       );
       final existingName = existing?.name ?? '';
       final existingRole = existing?.role ?? '';
@@ -212,10 +213,20 @@ mixin StateSfuMixin on StateNotifier<CallState> {
       isLocal: isLocal,
       isOnline: !isLocal,
     );
+    var isExisting = false;
+    final participants = state.callParticipants.map((it) {
+      if (it.userId == participant.userId &&
+          it.sessionId == participant.sessionId) {
+        isExisting = true;
+        return participant;
+      } else {
+        return it;
+      }
+    });
     state = state.copyWith(
       callParticipants: [
-        ...state.callParticipants,
-        participant,
+        ...participants,
+        if (!isExisting) participant,
       ],
     );
   }