feat(all): Implement MAL import for anime and manga lists

lib/src/ui/bloc/settings_bloc.dart

@@ -0,0 +1,205 @@
+import 'dart:async';
+import 'dart:convert';
+import 'package:anitrack/src/data/anime.dart';
+import 'package:anitrack/src/data/manga.dart';
+import 'package:anitrack/src/data/type.dart';
+import 'package:anitrack/src/service/database.dart';
+import 'package:archive/archive_io.dart';
+import 'package:bloc/bloc.dart';
+import 'package:freezed_annotation/freezed_annotation.dart';
+import 'package:get_it/get_it.dart';
+import 'package:jikan_api/jikan_api.dart';
+import 'package:xml/xml.dart';
+
+part 'settings_state.dart';
+part 'settings_event.dart';
+part 'settings_bloc.freezed.dart';
+
+MediumTrackingState malStatusToTrackingState(String status) {
+  switch (status) {
+    case 'Completed':
+      return MediumTrackingState.completed;
+    case 'Reading':
+    case 'Watching':
+      return MediumTrackingState.ongoing;
+    case 'Plan to Read':
+    case 'Plan to Watch':
+      return MediumTrackingState.planned;
+    case 'Dropped':
+      return MediumTrackingState.dropped;
+    case 'On-Hold':
+      return MediumTrackingState.paused;
+    default:
+      assert(false, 'Invalid status $status');
+      return MediumTrackingState.planned;
+  }
+}
+
+class SettingsBloc extends Bloc<SettingsEvent, SettingsState> {
+  SettingsBloc() : super(SettingsState()) {
+    on<AnimeListImportedEvent>(_onAnimeListImported);
+    on<MangaListImportedEvent>(_onMangaListImported);
+  }
+
+  void _showLoadingSpinner(Emitter<SettingsState> emit) {
+    emit(
+      state.copyWith(
+        importSpinnerVisible: true,
+      ),
+    );
+  }
+
+  void _hideLoadingSpinner(Emitter<SettingsState> emit) {
+    emit(
+      state.copyWith(
+        importSpinnerVisible: false,
+      ),
+    );
+  }
+
+  Future<void> _onAnimeListImported(
+    AnimeListImportedEvent event,
+    Emitter<SettingsState> emit,
+  ) async {
+    assert(
+      event.type == ImportListType.mal,
+      'Only MAL imports are currently supported',
+    );
+
+    _showLoadingSpinner(emit);
+    final inputStream = InputFileStream(event.path);
+    final listRaw = GZipDecoder().decodeBuffer(inputStream);
+    final listXml = utf8.decode(listRaw);
+    final document = XmlDocument.parse(listXml);
+    final mal = document.getElement('myanimelist');
+    if (mal == null) {
+      print('Invalid MAL list export');
+      _hideLoadingSpinner(emit);
+      return;
+    }
+
+    emit(
+      state.copyWith(
+        importCurrent: 0,
+        importTotal: mal.childElements.length - 1,
+      ),
+    );
+
+    for (final anime in mal.childElements) {
+      if (anime.qualifiedName == 'myinfo') {
+        continue;
+      }
+
+      emit(
+        state.copyWith(
+          importCurrent: state.importCurrent + 1,
+        ),
+      );
+
+      final title = anime.getElement('series_title')!.text;
+      final totalEpisodes =
+          int.parse(anime.getElement('series_episodes')!.text);
+      final id = anime.getElement('series_animedb_id')!.text;
+
+      print('Waiting 500ms to not hammer Jikan ($title)');
+      await Future<void>.delayed(const Duration(milliseconds: 500));
+
+      // Query the MAL api
+      final data = await Jikan().getAnime(int.parse(id));
+
+      // Add the anime
+      await GetIt.I.get<DatabaseService>().addAnime(
+            AnimeTrackingData(
+              id,
+              malStatusToTrackingState(
+                anime.getElement('my_status')!.text,
+              ),
+              title,
+              int.parse(anime.getElement('my_watched_episodes')!.text),
+              // 0 means that MAL does not know
+              totalEpisodes == 0 ? null : totalEpisodes,
+              data.imageUrl,
+            ),
+          );
+    }
+
+    // Hide the spinner again
+    _hideLoadingSpinner(emit);
+  }
+
+  Future<void> _onMangaListImported(
+    MangaListImportedEvent event,
+    Emitter<SettingsState> emit,
+  ) async {
+    assert(
+      event.type == ImportListType.mal,
+      'Only MAL imports are currently supported',
+    );
+
+    _showLoadingSpinner(emit);
+    final inputStream = InputFileStream(event.path);
+    final listRaw = GZipDecoder().decodeBuffer(inputStream);
+    final listXml = utf8.decode(listRaw);
+    final document = XmlDocument.parse(listXml);
+    final mal = document.getElement('myanimelist');
+    if (mal == null) {
+      print('Invalid MAL list export');
+      _hideLoadingSpinner(emit);
+      return;
+    }
+
+    emit(
+      state.copyWith(
+        importCurrent: 0,
+        importTotal: mal.childElements.length - 1,
+      ),
+    );
+
+    for (final manga in mal.childElements) {
+      if (manga.qualifiedName == 'myinfo') {
+        continue;
+      }
+
+      emit(
+        state.copyWith(
+          importCurrent: state.importCurrent + 1,
+        ),
+      );
+
+      final title = manga.getElement('manga_title')!.text;
+      final totalChapters = int.parse(manga.getElement('manga_chapters')!.text);
+      final id = manga.getElement('manga_mangadb_id')!.text;
+
+      print('Waiting 500ms to not hammer Jikan ($title)');
+      await Future<void>.delayed(const Duration(milliseconds: 500));
+
+      // Query the MAL api
+      Manga data;
+      try {
+        data = await Jikan().getManga(int.parse(id));
+      } catch (_) {
+        print('API request failed');
+        continue;
+      }
+
+      // Add the manga
+      await GetIt.I.get<DatabaseService>().addManga(
+            MangaTrackingData(
+              id,
+              malStatusToTrackingState(
+                manga.getElement('my_status')!.text,
+              ),
+              title,
+              int.parse(manga.getElement('my_read_chapters')!.text),
+              0,
+              // 0 means that MAL does not know
+              totalChapters == 0 ? null : totalChapters,
+              data.imageUrl,
+            ),
+          );
+    }
+
+    // Hide the spinner again
+    _hideLoadingSpinner(emit);
+  }
+}