diff --git a/lib/src/constants.dart b/lib/src/constants.dart index 54039be..b78fccf 100644 --- a/lib/src/constants.dart +++ b/lib/src/constants.dart @@ -1,7 +1,7 @@ class Timeouts { - static const connection = Duration(seconds: 5); + static const connection = Duration(seconds: 10); static const debounce = Duration(milliseconds: 100); - static const publish = Duration(seconds: 3); - static const iceConnection = Duration(seconds: 5); + static const publish = Duration(seconds: 10); + static const iceConnection = Duration(seconds: 10); static const iceRestart = Duration(seconds: 10); } diff --git a/lib/src/participant/remote_participant.dart b/lib/src/participant/remote_participant.dart index 5dfef6e..6369253 100644 --- a/lib/src/participant/remote_participant.dart +++ b/lib/src/participant/remote_participant.dart @@ -47,7 +47,6 @@ class RemoteParticipant extends Participant { RemoteParticipant.fromInfo({ required Room room, required lk_models.ParticipantInfo info, - required EventsEmitter roomEvents, }) : super( room: room, sid: info.sid, @@ -75,6 +74,7 @@ class RemoteParticipant extends Participant { RemoteTrackPublication? pub = getTrackPublication(trackSid); if (pub == null) { logger.fine('addSubscribedMediaTrack() pub is null, will wait...'); + logger.fine('addSubscribedMediaTrack() tracks: $trackPublications'); // Wait for the metadata to arrive final event = await events.waitFor( filter: (event) => @@ -128,6 +128,7 @@ class RemoteParticipant extends Participant { @override @internal Future updateFromInfo(lk_models.ParticipantInfo info) async { + logger.fine('RemoteParticipant.updateFromInfo(info: $info)'); final hadInfo = hasInfo; super.updateFromInfo(info); diff --git a/lib/src/room.dart b/lib/src/room.dart index 51ecc7b..f72d729 100644 --- a/lib/src/room.dart +++ b/lib/src/room.dart @@ -125,7 +125,11 @@ class Room extends DisposableChangeNotifier with EventsEmittable { info: joinResponse.participant, ); + logger.fine('DEBUG_01 Did connect'); + for (final info in joinResponse.otherParticipants) { + logger.fine( + 'DEBUG_01 Existing Participant: ${info.sid}(${info.identity}) tracks:${info.tracks.map((e) => e.sid)}'); _getOrCreateRemoteParticipant(info.sid, info); } } @@ -164,6 +168,8 @@ class Room extends DisposableChangeNotifier with EventsEmittable { } }) ..on((event) async { + logger.fine('DEBUG_01 EngineTrackAddedEvent id:${event.track.id}'); + final idParts = event.stream.id.split('|'); final participantSid = idParts[0]; final trackSid = idParts.elementAtOrNull(1) ?? event.track.id; @@ -181,7 +187,7 @@ class Room extends DisposableChangeNotifier with EventsEmittable { trackSid, ); } on TrackSubscriptionExceptionEvent catch (event) { - logger.warning('addSubscribedMediaTrack() throwed ${event}'); + logger.severe('addSubscribedMediaTrack() throwed ${event}'); [participant.room.events, participant.events].emit(event); } catch (exception) { // We don't want to pass up any exception so catch everything here. @@ -210,6 +216,7 @@ class Room extends DisposableChangeNotifier with EventsEmittable { } if (info == null) { + logger.warning('DEBUG_01 RemoteParticipant.info is null... sid:$sid'); participant = RemoteParticipant( room: this, sid: sid, @@ -219,7 +226,6 @@ class Room extends DisposableChangeNotifier with EventsEmittable { participant = RemoteParticipant.fromInfo( room: this, info: info, - roomEvents: events, ); }