chat_setup_cubit.dart

part 'chat_setup_state.dart';
part 'chat_setup_cubit.freezed.dart';

@lazySingleton
class ChatSetupCubit extends HydratedCubit<ChatSetupState> {
  late StreamSubscription<ChatUserModel>? _chatUserSubscription;

  late final IChatService _chatService;

  ChatSetupCubit() : super(ChatSetupState.empty()) {
    _chatService = getIt<IChatService>();

    _chatUserSubscription =
        _chatService.chatAuthStateChanges.listen(_listenChatUserAuthStateChangesStream);
  }

  @override
  Future<void> close() async {
    await _chatUserSubscription?.cancel();

    super.close();
  }

  Future<void> _listenChatUserAuthStateChangesStream(
    ChatUserModel chatUser,
  ) async {
    emit(
      state.copyWith(chatUser: chatUser, isUserCheckedFromChatService: true),
    );
  }

  @override
  ChatSetupState? fromJson(Map<String, dynamic> json) {
    return ChatSetupState.empty().copyWith(
      chatUser: json["chatUser"],
    );
  }

  @override
  Map<String, dynamic>? toJson(ChatSetupState state) {
    return {
      "chatUser": state.chatUser.toJson(),
    };
  }
}