feat(meeting): map webrtc manager & socket handler

waterbustech · Oct 2, 2023 · 1535b64 · 1535b64
1 parent 5e44b61
commit 1535b64
Show file tree

Hide file tree

Showing 13 changed files with 469 additions and 130 deletions.
diff --git a/lib/core/constants/api_endpoints.dart b/lib/core/constants/api_endpoints.dart
@@ -13,4 +13,5 @@ class ApiEndpoints {
 
   // Meetings
   static const String meetings = 'meetings';
+  static const String participants = 'meetings/participants';
 }
diff --git a/lib/core/constants/constants.dart b/lib/core/constants/constants.dart
@@ -40,8 +40,8 @@ const Map<String, dynamic> configurationWebRTC = {
     },
     {
       "username":
-          "4rBa7ppl_U6p0eE5PZUrpQXRLWfn8ZZ1aglRQGlsReViBb_G_fbKp3P3IIW62N7RAAAAAGN18pZkaW5odHJvbmcwNTAz",
-      "credential": "f3d0dacc-6652-11ed-a6d5-0242ac120004",
+          "2PExpnKaMnfeEv-Q17l_AIzddJjcTYqYZBZG3P19ocYnPDpDaRo-HBkXfYhO7zQXAAAAAGUaT-BsYW1iaWVuZ2NvZGU=",
+      "credential": "78a9fdc6-60e1-11ee-9c54-0242ac120004",
       "urls": [
         "turn:hk-turn1.xirsys.com:80?transport=udp",
         "turn:hk-turn1.xirsys.com:3478?transport=udp",

diff --git a/lib/core/injection/injection_container.config.dart b/lib/core/injection/injection_container.config.dart
diff --git a/lib/features/meeting/data/datasources/meeting_remote_datasource.dart b/lib/features/meeting/data/datasources/meeting_remote_datasource.dart
@@ -7,6 +7,7 @@ import 'package:waterbus/core/constants/api_endpoints.dart';
 import 'package:waterbus/core/types/http_status_code.dart';
 import 'package:waterbus/core/utils/datasources/base_remote_data.dart';
 import 'package:waterbus/features/meeting/domain/entities/meeting.dart';
+import 'package:waterbus/features/meeting/domain/entities/participant.dart';
 
 abstract class MeetingRemoteDataSource {
   Future<Meeting?> createMeeting({
@@ -26,6 +27,7 @@ abstract class MeetingRemoteDataSource {
     required int code,
     required int participantId,
   });
+  Future<Participant?> getParticipant(int participantId);
 }
 
 @LazySingleton(as: MeetingRemoteDataSource)
@@ -129,4 +131,18 @@ class MeetingRemoteDataSourceImpl extends MeetingRemoteDataSource {
 
     return false;
   }
+
+  @override
+  Future<Participant?> getParticipant(int participantId) async {
+    final Response response = await _remoteData.getRoute(
+      '${ApiEndpoints.participants}/$participantId',
+    );
+
+    if (response.statusCode == StatusCode.ok) {
+      final Map<String, dynamic> rawData = response.data;
+      return Participant.fromMap(rawData['participant']);
+    }
+
+    return null;
+  }
 }
diff --git a/lib/features/meeting/data/repositories/meeting_repository_impl.dart b/lib/features/meeting/data/repositories/meeting_repository_impl.dart
@@ -8,6 +8,7 @@ import 'package:waterbus/features/app/bloc/bloc.dart';
 import 'package:waterbus/features/meeting/data/datasources/meeting_local_datasource.dart';
 import 'package:waterbus/features/meeting/data/datasources/meeting_remote_datasource.dart';
 import 'package:waterbus/features/meeting/domain/entities/meeting.dart';
+import 'package:waterbus/features/meeting/domain/entities/participant.dart';
 import 'package:waterbus/features/meeting/domain/repositories/meeting_repository.dart';
 import 'package:waterbus/features/meeting/domain/usecases/create_meeting.dart';
 import 'package:waterbus/features/meeting/domain/usecases/get_info_meeting.dart';
@@ -119,6 +120,20 @@ class MeetingRepositoryImpl extends MeetingRepository {
     return const Right(true);
   }
 
+  @override
+  Future<Either<Failure, Participant>> getParticipantById(
+    int participantId,
+  ) async {
+    final Participant? participant = await _remoteDataSource.getParticipant(
+      participantId,
+    );
+
+    if (participant == null) return Left(NullValue());
+
+    return Right(participant);
+  }
+
+  // MARK: private
   Meeting findMyParticipantObject(
     Meeting meeting, {
     int? participantId,

diff --git a/lib/features/meeting/domain/repositories/meeting_repository.dart b/lib/features/meeting/domain/repositories/meeting_repository.dart
@@ -4,6 +4,7 @@ import 'package:dartz/dartz.dart';
 // Project imports:
 import 'package:waterbus/core/error/failures.dart';
 import 'package:waterbus/features/meeting/domain/entities/meeting.dart';
+import 'package:waterbus/features/meeting/domain/entities/participant.dart';
 import 'package:waterbus/features/meeting/domain/usecases/create_meeting.dart';
 import 'package:waterbus/features/meeting/domain/usecases/get_info_meeting.dart';
 import 'package:waterbus/features/meeting/domain/usecases/leave_meeting.dart';
@@ -16,4 +17,5 @@ abstract class MeetingRepository {
   Future<Either<Failure, Meeting>> leaveMeeting(LeaveMeetingParams params);
   Future<Either<Failure, Meeting>> getInfoMeeting(GetMeetingParams params);
   Either<Failure, bool> cleanAllRecentJoined();
+  Future<Either<Failure, Participant>> getParticipantById(int participantId);
 }
diff --git a/lib/features/meeting/domain/usecases/get_participant.dart b/lib/features/meeting/domain/usecases/get_participant.dart
@@ -0,0 +1,33 @@
+// Package imports:
+import 'package:dartz/dartz.dart';
+import 'package:equatable/equatable.dart';
+import 'package:injectable/injectable.dart';
+
+// Project imports:
+import 'package:waterbus/core/error/failures.dart';
+import 'package:waterbus/core/usecase/usecase.dart';
+import 'package:waterbus/features/meeting/domain/entities/participant.dart';
+import 'package:waterbus/features/meeting/domain/repositories/meeting_repository.dart';
+
+@injectable
+class GetParticipant implements UseCase<Participant, GetPariticipantParams> {
+  final MeetingRepository repository;
+
+  GetParticipant(this.repository);
+
+  @override
+  Future<Either<Failure, Participant>> call(
+    GetPariticipantParams params,
+  ) async {
+    return await repository.getParticipantById(params.participantId);
+  }
+}
+
+class GetPariticipantParams extends Equatable {
+  final int participantId;
+
+  const GetPariticipantParams({required this.participantId});
+
+  @override
+  List<Object> get props => [participantId];
+}