refactor(*): Migrate to explicit exceptions: part 2

lib/exceptions/exceptions.dart

@@ -143,3 +143,13 @@ final class LogoutFormHashNotFoundException extends AppException
 @MappableClass()
 final class LogoutFailedException extends AppException
     with LogoutFailedExceptionMappable {}
+
+/// Document contains chat data not found.
+@MappableClass()
+final class ChatDataDocumentNotFoundException extends AppException
+    with ChatDataDocumentNotFoundExceptionMappable {}
+
+/// Failed to load emoji
+@MappableClass()
+final class EmojiLoadFailedException extends AppException
+    with EmojiLoadFailedExceptionMappable {}

lib/features/chat/bloc/chat_bloc.dart

@@ -3,16 +3,13 @@ import 'dart:async';
 import 'package:collection/collection.dart';
 import 'package:dart_mappable/dart_mappable.dart';
 import 'package:flutter_bloc/flutter_bloc.dart';
-import 'package:tsdm_client/exceptions/exceptions.dart';
-import 'package:tsdm_client/features/chat/exceptions/exceptions.dart';
 import 'package:tsdm_client/features/chat/models/models.dart';
 import 'package:tsdm_client/features/chat/repository/chat_repository.dart';
 import 'package:tsdm_client/utils/logger.dart';
 import 'package:universal_html/html.dart' as uh;
 
 part 'chat_bloc.mapper.dart';
 part 'chat_event.dart';
-
 part 'chat_state.dart';
 
 /// Emit
@@ -37,16 +34,14 @@ final class ChatBloc extends Bloc<ChatEvent, ChatState> with LoggerMixin {
     _Emit emit,
   ) async {
     emit(state.copyWith(status: ChatStatus.loading));
-    try {
-      final document = await _chatRepository.fetchChat(event.uid);
-      _updateState(document, emit);
-    } on HttpRequestFailedException catch (e) {
-      error('failed to fetch chat data: $e');
-      emit(state.copyWith(status: ChatStatus.failure));
-    } on ChatDataDocumentNotFoundException catch (e) {
-      error('failed to fetch chat data: $e');
-      emit(state.copyWith(status: ChatStatus.failure));
-    }
+
+    await await _chatRepository.fetchChat(event.uid).match(
+      (e) {
+        handle(e);
+        emit(state.copyWith(status: ChatStatus.failure));
+      },
+      (v) async => _updateState(v, emit),
+    ).run();
   }
 
   void _updateState(uh.Document document, _Emit emit) {

lib/features/chat/bloc/chat_history_bloc.dart

@@ -2,7 +2,6 @@ import 'dart:async';
 
 import 'package:bloc/bloc.dart';
 import 'package:dart_mappable/dart_mappable.dart';
-import 'package:tsdm_client/exceptions/exceptions.dart';
 import 'package:tsdm_client/extensions/string.dart';
 import 'package:tsdm_client/features/authentication/repository/models/models.dart';
 import 'package:tsdm_client/features/chat/models/models.dart';
@@ -37,16 +36,18 @@ final class ChatHistoryBloc extends Bloc<ChatHistoryEvent, ChatHistoryState>
     } else {
       emit(state.copyWith(status: ChatHistoryStatus.loadingMore));
     }
-    try {
-      final document = await _chatRepository.fetchChatHistory(
-        event.uid,
-        page: event.page,
-      );
-      await _updateState(document, emit, event.page);
-    } on HttpRequestFailedException catch (e) {
-      error('failed to fetch chat history: $e');
-      emit(state.copyWith(status: ChatHistoryStatus.failure));
-    }
+    await await _chatRepository
+        .fetchChatHistory(
+      event.uid,
+      page: event.page,
+    )
+        .match(
+      (e) {
+        handle(e);
+        emit(state.copyWith(status: ChatHistoryStatus.failure));
+      },
+      (v) async => _updateState(v, emit, event.page),
+    ).run();
   }
 
   FutureOr<void> _updateState(

lib/features/chat/repository/chat_repository.dart

@@ -1,8 +1,8 @@
 import 'dart:io' if (dart.libaray.js) 'package:web/web.dart';
 
+import 'package:fpdart/fpdart.dart';
 import 'package:tsdm_client/constants/url.dart';
 import 'package:tsdm_client/exceptions/exceptions.dart';
-import 'package:tsdm_client/features/chat/exceptions/exceptions.dart';
 import 'package:tsdm_client/instance.dart';
 import 'package:tsdm_client/shared/providers/net_client_provider/net_client_provider.dart';
 import 'package:universal_html/html.dart' as uh;
@@ -14,38 +14,31 @@ final class ChatRepository {
   const ChatRepository();
 
   /// Fetch the chat history with user [uid].
-  ///
-  /// # Exceptions
-  ///
-  /// * **HttpRequestFailedException** if http request failed.
-  Future<uh.Document> fetchChatHistory(String uid, {int? page}) async {
-    final resp = await getIt.get<NetClientProvider>().get(
-          formatChatFullHistoryUrl(uid, page: page),
-        );
-    if (resp.statusCode != HttpStatus.ok) {
-      throw HttpRequestFailedException(resp.statusCode);
-    }
-    final document = parseHtmlDocument(resp.data as String);
-    return document;
-  }
+  AsyncEither<uh.Document> fetchChatHistory(String uid, {int? page}) =>
+      AsyncEither(() async {
+        final resp = await getIt.get<NetClientProvider>().get(
+              formatChatFullHistoryUrl(uid, page: page),
+            );
+        if (resp.statusCode != HttpStatus.ok) {
+          return left(HttpRequestFailedException(resp.statusCode));
+        }
+        final document = parseHtmlDocument(resp.data as String);
+        return right(document);
+      });
 
   /// Fetch the chat history with user [uid].
-  ///
-  /// # Exceptions
-  ///
-  /// * **HttpRequestFailedException** if http request failed.
-  /// * **ChatDataDocumentNotFoundException** if chat html document not found.
-  Future<uh.Document> fetchChat(String uid) async {
-    final resp = await getIt.get<NetClientProvider>().get(formatChatUrl(uid));
-    if (resp.statusCode != HttpStatus.ok) {
-      throw HttpRequestFailedException(resp.statusCode);
-    }
-    final xmlDoc = parseXmlDocument(resp.data as String);
-    final htmlBodyData = xmlDoc.documentElement?.nodes.firstOrNull?.text;
-    if (htmlBodyData == null) {
-      throw ChatDataDocumentNotFoundException();
-    }
-    final document = parseHtmlDocument(htmlBodyData);
-    return document;
-  }
+  AsyncEither<uh.Document> fetchChat(String uid) => AsyncEither(() async {
+        final resp =
+            await getIt.get<NetClientProvider>().get(formatChatUrl(uid));
+        if (resp.statusCode != HttpStatus.ok) {
+          return left(HttpRequestFailedException(resp.statusCode));
+        }
+        final xmlDoc = parseXmlDocument(resp.data as String);
+        final htmlBodyData = xmlDoc.documentElement?.nodes.firstOrNull?.text;
+        if (htmlBodyData == null) {
+          return left(ChatDataDocumentNotFoundException());
+        }
+        final document = parseHtmlDocument(htmlBodyData);
+        return right(document);
+      });
 }

lib/features/editor/bloc/emoji_bloc.dart

@@ -1,7 +1,6 @@
 import 'package:bloc/bloc.dart';
 import 'package:dart_mappable/dart_mappable.dart';
 import 'package:tsdm_client/exceptions/exceptions.dart';
-import 'package:tsdm_client/features/editor/exceptions/exceptions.dart';
 import 'package:tsdm_client/features/editor/repository/editor_repository.dart';
 import 'package:tsdm_client/shared/models/models.dart';
 import 'package:tsdm_client/utils/logger.dart';
@@ -32,18 +31,18 @@ final class EmojiBloc extends Bloc<EmojiEvent, EmojiState> with LoggerMixin {
     EmojiEmitter emit,
   ) async {
     emit(state.copyWith(status: EmojiStatus.loading));
-    try {
-      await _editorRepository.loadEmojiFromCacheOrServer();
-      emit(
+    await _editorRepository.loadEmojiFromCacheOrServer().match(
+      (e) {
+        handle(e);
+        emit(state.copyWith(status: EmojiStatus.failure));
+      },
+      (v) => emit(
         state.copyWith(
           status: EmojiStatus.success,
           emojiGroupList: _editorRepository.emojiGroupList,
         ),
-      );
-    } on EmojiRelatedException catch (e) {
-      error('failed to load emoji from cache: $e');
-      emit(state.copyWith(status: EmojiStatus.failure));
-    }
+      ),
+    ).run();
   }
 
   Future<void> _onEmojiFetchFromServerEvent(

lib/features/editor/repository/editor_repository.dart

@@ -1,7 +1,8 @@
 import 'dart:io' if (dart.libaray.js) 'package:web/web.dart';
 
+import 'package:fpdart/fpdart.dart';
 import 'package:tsdm_client/constants/url.dart';
-import 'package:tsdm_client/features/editor/exceptions/exceptions.dart';
+import 'package:tsdm_client/exceptions/exceptions.dart';
 import 'package:tsdm_client/instance.dart';
 import 'package:tsdm_client/shared/models/models.dart';
 import 'package:tsdm_client/shared/providers/image_cache_provider/image_cache_provider.dart';
@@ -234,21 +235,18 @@ final class EditorRepository with LoggerMixin {
   /// Only load the emoji info, do not load the emoji image data.
   ///
   /// Currently there there is no validation on emoji and emoji groups.
-  ///
-  /// # Sealed Exceptions
-  ///
-  /// * **[EmojiRelatedException]** when failed to load emoji.
-  Future<void> loadEmojiFromCacheOrServer() async {
-    final cacheProvider = getIt.get<ImageCacheProvider>();
-    if (await cacheProvider.validateEmojiCache()) {
-      // Have valid emoji cache.
-      emojiGroupList = await cacheProvider.loadEmojiInfo();
-    } else {
-      // Do not have valid emoji cache, reload from server.
-      final ret = await loadEmojiFromServer();
-      if (!ret) {
-        throw EmojiLoadFailedException();
-      }
-    }
-  }
+  AsyncVoidEither loadEmojiFromCacheOrServer() => AsyncVoidEither(() async {
+        final cacheProvider = getIt.get<ImageCacheProvider>();
+        if (await cacheProvider.validateEmojiCache()) {
+          // Have valid emoji cache.
+          emojiGroupList = await cacheProvider.loadEmojiInfo();
+        } else {
+          // Do not have valid emoji cache, reload from server.
+          final ret = await loadEmojiFromServer();
+          if (!ret) {
+            return left(EmojiLoadFailedException());
+          }
+        }
+        return rightVoid();
+      });
 }