feat: Create notifications client

lib/main.dart

@@ -22,6 +22,7 @@ import 'package:rtu_mirea_app/presentation/bloc/map_cubit/map_cubit.dart';
 import 'package:rtu_mirea_app/presentation/bloc/news_bloc/news_bloc.dart';
 import 'package:rtu_mirea_app/presentation/bloc/nfc_feedback_bloc/nfc_feedback_bloc.dart';
 import 'package:rtu_mirea_app/presentation/bloc/nfc_pass_bloc/nfc_pass_bloc.dart';
+import 'package:rtu_mirea_app/presentation/bloc/notification_preferences/notification_preferences_bloc.dart';
 
 import 'package:rtu_mirea_app/presentation/bloc/schedule_bloc/schedule_bloc.dart';
 import 'package:rtu_mirea_app/presentation/bloc/scores_bloc/scores_bloc.dart';
@@ -59,14 +60,14 @@ class GlobalBlocObserver extends BlocObserver {
 Future<void> main() async {
   WidgetsFlutterBinding.ensureInitialized();
 
-  await dependency_injection.setup();
-
-  WidgetDataProvider.initData();
-
   await Firebase.initializeApp(
     options: DefaultFirebaseOptions.currentPlatform,
   );
 
+  await dependency_injection.setup();
+
+  WidgetDataProvider.initData();
+
   if (Platform.isAndroid || Platform.isIOS) {
     await FirebaseAnalytics.instance.logAppOpen();
   }
@@ -181,6 +182,9 @@ class App extends StatelessWidget {
         BlocProvider<NfcFeedbackBloc>(
           create: (_) => getIt<NfcFeedbackBloc>(),
         ),
+        BlocProvider<NotificationPreferencesBloc>(
+          create: (_) => getIt<NotificationPreferencesBloc>(),
+        ),
       ],
       child: Consumer<AppNotifier>(
         builder: (BuildContext context, AppNotifier value, Widget? child) {

lib/presentation/bloc/notification_preferences/notification_preferences_bloc.dart

@@ -0,0 +1,278 @@
+import 'dart:async';
+
+import 'package:equatable/equatable.dart';
+import 'package:flutter_bloc/flutter_bloc.dart';
+import 'package:notifications_repository/notifications_repository.dart';
+
+part 'notification_preferences_state.dart';
+part 'notification_preferences_event.dart';
+
+enum Category {
+  /// Общеуниверситетские объявления.
+  announcements,
+
+  /// Уведомления, связанные с изменениями в расписании. Привязаны к группе.
+  scheduleUpdates,
+
+  /// Уведомления для конкретной группы. Обязательная категория, которую
+  /// пользователь не может отключить.
+  group,
+}
+
+const visibleCategoryNames = {
+  Category.announcements: 'Объявления',
+  Category.scheduleUpdates: 'Обновления расписания',
+};
+
+/// Транслитерирует название группы для использования в качестве названия
+/// категории уведомлений.
+String transletirateGroupName(String groupName) {
+  final transliteration = {
+    'А': 'A',
+    'Б': 'B',
+    'В': 'V',
+    'Г': 'G',
+    'Д': 'D',
+    'Е': 'E',
+    'Ё': 'E',
+    'Ж': 'Zh',
+    'З': 'Z',
+    'И': 'I',
+    'Й': 'I',
+    'К': 'K',
+    'Л': 'L',
+    'М': 'M',
+    'Н': 'N',
+    'О': 'O',
+    'П': 'P',
+    'Р': 'R',
+    'С': 'S',
+    'Т': 'T',
+    'У': 'U',
+    'Ф': 'F',
+    'Х': 'Kh',
+    'Ц': 'Ts',
+    'Ч': 'Ch',
+    'Ш': 'Sh',
+    'Щ': 'Shch',
+    'Ъ': '',
+    'Ы': 'Y',
+    'Ь': '',
+    'Э': 'E',
+    'Ю': 'Yu',
+    'Я': 'Ya',
+  };
+
+  return groupName
+      .split('-')
+      .map((word) =>
+          word.split('').map((char) => transliteration[char] ?? char).join(''))
+      .join('-');
+}
+
+/// Категория уведомлений. [toString] возвращает название категории, которое
+/// используется при подписке на уведомления. [fromString] возвращает объект
+/// [Topic] из названия категории.
+class Topic extends Equatable {
+  Topic({
+    required this.topic,
+    String? groupName,
+  }) {
+    if (topic == Category.group || topic == Category.scheduleUpdates) {
+      assert(groupName != null);
+
+      this.groupName = transletirateGroupName(groupName ?? '');
+    } else {
+      this.groupName = null;
+    }
+  }
+
+  final Category topic;
+  late final String? groupName;
+
+  @override
+  String toString() {
+    switch (topic) {
+      case Category.announcements:
+        return 'Announcements';
+      case Category.scheduleUpdates:
+        return 'ScheduleUpdates__${groupName!}';
+      case Category.group:
+        return groupName!;
+    }
+  }
+
+  String getVisibleName() {
+    switch (topic) {
+      case Category.announcements:
+        return visibleCategoryNames[Category.announcements]!;
+      case Category.scheduleUpdates:
+        return visibleCategoryNames[Category.scheduleUpdates]!;
+      case Category.group:
+        return groupName!;
+    }
+  }
+
+  static Topic fromVisibleName(String name, String groupName) {
+    switch (name) {
+      case 'Объявления':
+        return Topic(topic: Category.announcements);
+      case 'Обновления расписания':
+        return Topic(
+          topic: Category.scheduleUpdates,
+          groupName: groupName,
+        );
+      default:
+        return Topic(
+          topic: Category.group,
+          groupName: name,
+        );
+    }
+  }
+
+  static Topic fromString(String category) {
+    final categoryParts = category.split('__');
+    final topic = categoryParts[0];
+
+    switch (topic) {
+      case 'Announcements':
+        return Topic(topic: Category.announcements);
+      case 'ScheduleUpdates':
+        return Topic(
+          topic: Category.scheduleUpdates,
+          groupName: categoryParts[1],
+        );
+      default:
+        return Topic(
+          topic: Category.group,
+          groupName: category,
+        );
+    }
+  }
+
+  @override
+  List<Object?> get props => [topic, groupName];
+}
+
+class NotificationPreferencesBloc
+    extends Bloc<NotificationPreferencesEvent, NotificationPreferencesState> {
+  NotificationPreferencesBloc({
+    required NotificationsRepository notificationsRepository,
+  })  : _notificationsRepository = notificationsRepository,
+        super(
+          NotificationPreferencesState.initial(),
+        ) {
+    on<CategoriesPreferenceToggled>(
+      _onCategoriesPreferenceToggled,
+    );
+    on<InitialCategoriesPreferencesRequested>(
+      _onInitialCategoriesPreferencesRequested,
+    );
+  }
+
+  final NotificationsRepository _notificationsRepository;
+
+  FutureOr<void> _onCategoriesPreferenceToggled(
+    CategoriesPreferenceToggled event,
+    Emitter<NotificationPreferencesState> emit,
+  ) async {
+    emit(state.copyWith(status: NotificationPreferencesStatus.loading));
+
+    final updatedCategories = Set<String>.from(state.selectedCategories);
+
+    updatedCategories.contains(event.category)
+        ? updatedCategories.remove(event.category)
+        : updatedCategories.add(event.category);
+
+    try {
+      final categoriesToSubscribe = updatedCategories
+          .map((category) => Topic.fromVisibleName(category, event.group))
+          .toSet();
+
+      /// Добавляем в категории названия академической группы для подписки на
+      /// уведомления для группы. Это обязательная категория, которую
+      /// пользователь не может отключить.
+      categoriesToSubscribe.add(
+        Topic(topic: Category.group, groupName: event.group),
+      );
+
+      /// Убираем те категории, название которых содержит название группы, но
+      /// не совпадает с названием группы в [event.group].
+      categoriesToSubscribe.removeWhere((category) {
+        if (category.groupName == null) {
+          return false;
+        }
+
+        final groupName = category.groupName!.toLowerCase();
+        final eventGroupName =
+            transletirateGroupName(event.group).toLowerCase();
+
+        return groupName != eventGroupName;
+      });
+
+      emit(
+        state.copyWith(
+          status: NotificationPreferencesStatus.success,
+          selectedCategories: updatedCategories,
+        ),
+      );
+
+      await _notificationsRepository.setCategoriesPreferences(
+          categoriesToSubscribe.map((e) => e.toString()).toSet());
+    } catch (error, stackTrace) {
+      emit(
+        state.copyWith(status: NotificationPreferencesStatus.failure),
+      );
+      addError(error, stackTrace);
+    }
+  }
+
+  FutureOr<void> _onInitialCategoriesPreferencesRequested(
+    InitialCategoriesPreferencesRequested event,
+    Emitter<NotificationPreferencesState> emit,
+  ) async {
+    emit(state.copyWith(status: NotificationPreferencesStatus.loading));
+
+    try {
+      Set<Topic> selectedCategories = await _notificationsRepository
+          .fetchCategoriesPreferences()
+          .then((categories) =>
+              categories?.map((e) => Topic.fromString(e)).toSet() ?? {});
+
+      /// Подписываемся на уведомления для группы [event.group] и отписываемся
+      /// от уведомлений для других групп.
+      if (!selectedCategories.contains(
+        Topic(topic: Category.group, groupName: event.group),
+      )) {
+        selectedCategories = selectedCategories
+            .where((category) => category.topic != Category.group)
+            .toSet();
+
+        selectedCategories.add(
+          Topic(topic: Category.group, groupName: event.group),
+        );
+
+        await _notificationsRepository.setCategoriesPreferences(
+            selectedCategories.map((e) => e.toString()).toSet());
+      }
+
+      await _notificationsRepository.toggleNotifications(
+        enable: selectedCategories.isNotEmpty,
+      );
+
+      emit(
+        state.copyWith(
+          status: NotificationPreferencesStatus.success,
+          selectedCategories:
+              selectedCategories.map((e) => e.getVisibleName()).toSet(),
+          categories: visibleCategoryNames.values.toSet(),
+        ),
+      );
+    } catch (error, stackTrace) {
+      emit(
+        state.copyWith(status: NotificationPreferencesStatus.failure),
+      );
+      addError(error, stackTrace);
+    }
+  }
+}

lib/presentation/bloc/notification_preferences/notification_preferences_event.dart

@@ -0,0 +1,29 @@
+part of 'notification_preferences_bloc.dart';
+
+abstract class NotificationPreferencesEvent extends Equatable {
+  const NotificationPreferencesEvent();
+}
+
+class CategoriesPreferenceToggled extends NotificationPreferencesEvent {
+  const CategoriesPreferenceToggled(
+      {required this.category, required this.group});
+
+  final String category;
+
+  /// Название академической группы.
+  final String group;
+
+  @override
+  List<Object?> get props => [category, group];
+}
+
+class InitialCategoriesPreferencesRequested
+    extends NotificationPreferencesEvent {
+  const InitialCategoriesPreferencesRequested({required this.group});
+
+  /// Название академической группы.
+  final String group;
+
+  @override
+  List<Object?> get props => [group];
+}

lib/presentation/bloc/notification_preferences/notification_preferences_state.dart

@@ -0,0 +1,42 @@
+part of 'notification_preferences_bloc.dart';
+
+enum NotificationPreferencesStatus {
+  initial,
+  loading,
+  success,
+  failure,
+}
+
+class NotificationPreferencesState extends Equatable {
+  const NotificationPreferencesState({
+    required this.selectedCategories,
+    required this.status,
+    required this.categories,
+  });
+
+  NotificationPreferencesState.initial()
+      : this(
+          selectedCategories: {},
+          status: NotificationPreferencesStatus.initial,
+          categories: {},
+        );
+
+  final NotificationPreferencesStatus status;
+  final Set<String> categories;
+  final Set<String> selectedCategories;
+
+  @override
+  List<Object?> get props => [selectedCategories, status, categories];
+
+  NotificationPreferencesState copyWith({
+    Set<String>? selectedCategories,
+    NotificationPreferencesStatus? status,
+    Set<String>? categories,
+  }) {
+    return NotificationPreferencesState(
+      selectedCategories: selectedCategories ?? this.selectedCategories,
+      status: status ?? this.status,
+      categories: categories ?? this.categories,
+    );
+  }
+}