feat: private messages implemented

Author: DenzelCode

assets/tones/message_tone.mp3

@@ -4,6 +4,8 @@ PODS:
     - AppAuth/ExternalUserAgent (= 1.4.0)
   - AppAuth/Core (1.4.0)
   - AppAuth/ExternalUserAgent (1.4.0)
+  - audioplayers (0.0.1):
+    - Flutter
   - FBAEMKit (11.2.1):
     - FBAEMKit/AEM (= 11.2.1)
   - FBAEMKit/AEM (11.2.1):
@@ -119,16 +121,20 @@ PODS:
     - nanopb/encode (= 2.30908.0)
   - nanopb/decode (2.30908.0)
   - nanopb/encode (2.30908.0)
+  - path_provider (0.0.1):
+    - Flutter
   - PromisesObjC (2.0.0)
   - sign_in_with_apple (0.0.1):
     - Flutter
 
 DEPENDENCIES:
+  - audioplayers (from `.symlinks/plugins/audioplayers/ios`)
   - Firebase/Analytics
   - Flutter (from `Flutter`)
   - flutter_facebook_auth (from `.symlinks/plugins/flutter_facebook_auth/ios`)
   - flutter_secure_storage (from `.symlinks/plugins/flutter_secure_storage/ios`)
   - google_sign_in (from `.symlinks/plugins/google_sign_in/ios`)
+  - path_provider (from `.symlinks/plugins/path_provider/ios`)
   - sign_in_with_apple (from `.symlinks/plugins/sign_in_with_apple/ios`)
 
 SPEC REPOS:
@@ -153,6 +159,8 @@ SPEC REPOS:
     - PromisesObjC
 
 EXTERNAL SOURCES:
+  audioplayers:
+    :path: ".symlinks/plugins/audioplayers/ios"
   Flutter:
     :path: Flutter
   flutter_facebook_auth:
@@ -161,11 +169,14 @@ EXTERNAL SOURCES:
     :path: ".symlinks/plugins/flutter_secure_storage/ios"
   google_sign_in:
     :path: ".symlinks/plugins/google_sign_in/ios"
+  path_provider:
+    :path: ".symlinks/plugins/path_provider/ios"
   sign_in_with_apple:
     :path: ".symlinks/plugins/sign_in_with_apple/ios"
 
 SPEC CHECKSUMS:
   AppAuth: 31bcec809a638d7bd2f86ea8a52bd45f6e81e7c7
+  audioplayers: 455322b54050b30ea4b1af7cd9e9d105f74efa8c
   FBAEMKit: 5de0a7aaa854eec69bb5be20795952a63d38a5f6
   FBSDKCoreKit: bf655f808b040ed66a72b9922911b39d703e64f4
   FBSDKCoreKit_Basics: 73ebe3a27eb688ac5b5aa7e99f68992993042115
@@ -186,6 +197,7 @@ SPEC CHECKSUMS:
   GTMAppAuth: ad5c2b70b9a8689e1a04033c9369c4915bfcbe89
   GTMSessionFetcher: 43748f93435c2aa068b1cbe39655aaf600652e91
   nanopb: a0ba3315591a9ae0a16a309ee504766e90db0c96
+  path_provider: d1e9807085df1f9cc9318206cd649dc0b76be3de
   PromisesObjC: 68159ce6952d93e17b2dfe273b8c40907db5ba58
   sign_in_with_apple: f3bf75217ea4c2c8b91823f225d70230119b8440
 

ios/Podfile.lock

@@ -2,6 +2,7 @@ import 'package:auth/src/features/auth/views/screens/login_screen.dart';
 import 'package:auth/src/features/auth/views/screens/recover_screen.dart';
 import 'package:auth/src/features/auth/views/screens/register_screen.dart';
 import 'package:auth/src/features/home/views/screens/home_screen.dart';
+import 'package:auth/src/features/messages/views/screens/direct_message_screen.dart';
 import 'package:auth/src/features/room/views/screens/room_screen.dart';
 import 'package:auth/src/features/room/views/screens/rooms_screen.dart';
 import 'package:flutter/material.dart';
@@ -21,6 +22,8 @@ class AppRouter {
         return RoomsScreen.route();
       case RoomScreen.routeName:
         return RoomScreen.route(settings);
+      case DirectMessageScreen.routeName:
+        return DirectMessageScreen.route(settings);
       default:
         return HomeScreen.route();
     }

lib/src/app_router.dart

@@ -45,5 +45,5 @@ class User extends Equatable implements Comparable {
   }
 
   @override
-  List<Object?> get props => [id, username, email];
+  List<Object?> get props => [id, username, email, online];
 }

lib/src/features/auth/logic/models/user.dart

@@ -0,0 +1,111 @@
+import 'dart:async';
+
+import 'package:auth/src/core/socket.dart';
+import 'package:auth/src/features/auth/logic/models/user.dart';
+import 'package:auth/src/features/user/logic/repository/user_repository.dart';
+import 'package:bloc/bloc.dart';
+import 'package:equatable/equatable.dart';
+import 'package:socket_io_client/socket_io_client.dart';
+
+part 'direct_message_event.dart';
+part 'direct_message_state.dart';
+
+class DirectMessageBloc extends Bloc<DirectMessageEvent, DirectMessageState> {
+  final String username;
+
+  final _userRepository = UserRepository();
+
+  final Socket socket = socketManager.socket;
+
+  Timer? updateTimer;
+
+  final bool fromMessages;
+
+  DirectMessageBloc(this.username, {this.fromMessages = false})
+      : super(DirectMessageInitialState()) {
+    initEvents();
+  }
+
+  void initSockets() {
+    socket.onConnect((_) => add(SocketConnectedEvent()));
+
+    if (socket.connected) {
+      add(SocketConnectedEvent());
+    }
+
+    socket.onDisconnect((_) => add(SocketDisconnectedEvent()));
+
+    socket.connect();
+  }
+
+  void initEvents() {
+    on<UserLoadedEvent>(_onLoaded);
+    on<SocketConnectedEvent>(_onConnected);
+    on<SocketDisconnectedEvent>(_onDisconnected);
+
+    updateTimer = Timer.periodic(
+      Duration(seconds: 5),
+      (_) => add(UserLoadedEvent()),
+    );
+  }
+
+  FutureOr<void> _onLoaded(
+    UserLoadedEvent event,
+    Emitter<DirectMessageState> emit,
+  ) async {
+    if (state is UserLoadInProgressState) {
+      return;
+    }
+
+    final isInitial = state is DirectMessageInitialState;
+
+    if (isInitial) {
+      emit.call(UserLoadInProgressState());
+    }
+
+    try {
+      final user = await _userRepository.getUser(username);
+
+      if (state is SocketConnectState) {
+        emit.call(SocketConnectState(user));
+      } else {
+        emit.call(UserLoadSuccessState(user));
+
+        if (isInitial) {
+          initSockets();
+        }
+      }
+    } catch (_) {
+      emit.call(UserLoadFailureState());
+    }
+  }
+
+  @override
+  Future<void> close() {
+    updateTimer?.cancel();
+
+    if (!fromMessages) {
+      socketManager.dispose();
+    }
+
+    return super.close();
+  }
+
+  FutureOr<void> _onConnected(
+    SocketConnectedEvent event,
+    Emitter<DirectMessageState> emit,
+  ) {
+    final data = state as DirectUserState;
+
+    emit.call(SocketConnectState(data.user));
+  }
+
+  FutureOr<void> _onDisconnected(
+    SocketDisconnectedEvent event,
+    Emitter<DirectMessageState> emit,
+  ) {
+    final data = state as DirectUserState;
+
+    emit.call(SocketDisconnectState(data.user));
+  }
+}

lib/src/features/messages/logic/bloc/direct_message_bloc.dart

@@ -0,0 +1,14 @@
+part of 'direct_message_bloc.dart';
+
+abstract class DirectMessageEvent extends Equatable {
+  const DirectMessageEvent();
+
+  @override
+  List<Object> get props => [];
+}
+
+class UserLoadedEvent extends DirectMessageEvent {}
+
+class SocketDisconnectedEvent extends DirectMessageEvent {}
+
+class SocketConnectedEvent extends DirectMessageEvent {}

lib/src/features/messages/logic/bloc/direct_message_event.dart

@@ -0,0 +1,35 @@
+part of 'direct_message_bloc.dart';
+
+abstract class DirectMessageState extends Equatable {
+  const DirectMessageState();
+
+  @override
+  List<Object> get props => [];
+}
+
+class DirectMessageInitialState extends DirectMessageState {}
+
+class UserLoadInProgressState extends DirectMessageState {}
+
+class UserLoadFailureState extends DirectMessageState {}
+
+abstract class DirectUserState extends DirectMessageState {
+  final User user;
+
+  DirectUserState(this.user) : super();
+
+  @override
+  List<Object> get props => [user];
+}
+
+class UserLoadSuccessState extends DirectUserState {
+  UserLoadSuccessState(User user) : super(user);
+}
+
+class SocketConnectState extends DirectUserState {
+  SocketConnectState(User user) : super(user);
+}
+
+class SocketDisconnectState extends DirectUserState {
+  SocketDisconnectState(User user) : super(user);
+}

lib/src/features/messages/logic/bloc/direct_message_state.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:audioplayers/audioplayers.dart';
 import 'package:auth/src/app.dart';
 import 'package:auth/src/core/socket.dart';
 import 'package:auth/src/features/auth/logic/cubit/auth_cubit.dart';
@@ -10,6 +11,7 @@ import 'package:auth/src/features/messages/logic/models/typing.dart';
 import 'package:auth/src/features/messages/logic/repository/message_repository.dart';
 import 'package:bloc/bloc.dart';
 import 'package:equatable/equatable.dart';
+import 'package:flutter/material.dart';
 import 'package:flutter_bloc/flutter_bloc.dart';
 
 part 'message_event.dart';
@@ -21,6 +23,8 @@ class MessageBloc extends Bloc<MessageEvent, MessageState> {
   final socket = socketManager.socket;
   final repository = MessageRepository();
 
+  final audioCache = AudioCache();
+
   final limit = 30;
   final typingTimeout = 5000;
 
@@ -29,10 +33,20 @@ class MessageBloc extends Bloc<MessageEvent, MessageState> {
 
   Map<String, Timer> typingTimers = {};
 
+  final BuildContext context;
+
+  User? currentUser;
+
+  final bool fromMessages;
+
   MessageBloc({
     required this.partnerId,
     required this.type,
+    required this.context,
+    this.fromMessages = false,
   }) : super(MessageInitial()) {
+    currentUser = context.read<AuthCubit>().state;
+
     initEvents();
 
     initSockets();
@@ -56,7 +70,10 @@ class MessageBloc extends Bloc<MessageEvent, MessageState> {
       (data) {
         final message = Message.fromJson(data);
 
-        if (!_isCurrentPartner([message.from.id, message.room])) {
+        if (!_isCurrentPartner([
+          message.to != currentUser?.id ? message.to : message.from.id,
+          message.room
+        ])) {
           return;
         }
 
@@ -90,7 +107,7 @@ class MessageBloc extends Bloc<MessageEvent, MessageState> {
 
   bool _isCurrentPartner([List<String?> partners = const []]) {
     for (final partner in partners) {
-      if (partner == partnerId) {
+      if (partner == partnerId || currentUser?.id == partner) {
         return true;
       }
     }
@@ -100,7 +117,9 @@ class MessageBloc extends Bloc<MessageEvent, MessageState> {
 
   @override
   Future<void> close() {
-    socketManager.dispose();
+    if (!fromMessages) {
+      socketManager.dispose();
+    }
 
     return super.close();
   }
@@ -231,6 +250,12 @@ class MessageBloc extends Bloc<MessageEvent, MessageState> {
 
     cancelTypingTimer(event.message.from);
 
+    final currentUser = context.read<AuthCubit>().state;
+
+    if (event.message.from.id != currentUser?.id) {
+      audioCache.play('tones/message_tone.mp3', isNotification: true);
+    }
+
     emit.call(MessageReceiveState(
       [
         ...data.messages,