Enhance content management

lib/content_management/bloc/archived_headlines/archived_headlines_bloc.dart

@@ -0,0 +1,118 @@
+import 'package:bloc/bloc.dart';
+import 'package:core/core.dart';
+import 'package:data_repository/data_repository.dart';
+import 'package:equatable/equatable.dart';
+
+part 'archived_headlines_event.dart';
+part 'archived_headlines_state.dart';
+
+class ArchivedHeadlinesBloc
+    extends Bloc<ArchivedHeadlinesEvent, ArchivedHeadlinesState> {
+  ArchivedHeadlinesBloc({
+    required DataRepository<Headline> headlinesRepository,
+  })  : _headlinesRepository = headlinesRepository,
+        super(const ArchivedHeadlinesState()) {
+    on<LoadArchivedHeadlinesRequested>(_onLoadArchivedHeadlinesRequested);
+    on<RestoreHeadlineRequested>(_onRestoreHeadlineRequested);
+    on<DeleteHeadlineForeverRequested>(_onDeleteHeadlineForeverRequested);
+  }
+
+  final DataRepository<Headline> _headlinesRepository;
+
+  Future<void> _onLoadArchivedHeadlinesRequested(
+    LoadArchivedHeadlinesRequested event,
+    Emitter<ArchivedHeadlinesState> emit,
+  ) async {
+    emit(state.copyWith(status: ArchivedHeadlinesStatus.loading));
+    try {
+      final isPaginating = event.startAfterId != null;
+      final previousHeadlines = isPaginating ? state.headlines : <Headline>[];
+
+      final paginatedHeadlines = await _headlinesRepository.readAll(
+        filter: {'status': ContentStatus.archived.name},
+        sort: [const SortOption('updatedAt', SortOrder.desc)],
+        pagination: PaginationOptions(
+          cursor: event.startAfterId,
+          limit: event.limit,
+        ),
+      );
+      emit(
+        state.copyWith(
+          status: ArchivedHeadlinesStatus.success,
+          headlines: [...previousHeadlines, ...paginatedHeadlines.items],
+          cursor: paginatedHeadlines.cursor,
+          hasMore: paginatedHeadlines.hasMore,
+        ),
+      );
+    } on HttpException catch (e) {
+      emit(
+        state.copyWith(
+          status: ArchivedHeadlinesStatus.failure,
+          exception: e,
+        ),
+      );
+    } catch (e) {
+      emit(
+        state.copyWith(
+          status: ArchivedHeadlinesStatus.failure,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
+
+  Future<void> _onRestoreHeadlineRequested(
+    RestoreHeadlineRequested event,
+    Emitter<ArchivedHeadlinesState> emit,
+  ) async {
+    final originalHeadlines = List<Headline>.from(state.headlines);
+    final headlineIndex = originalHeadlines.indexWhere((h) => h.id == event.id);
+    if (headlineIndex == -1) return;
+
+    final headlineToRestore = originalHeadlines[headlineIndex];
+    final updatedHeadlines = originalHeadlines..removeAt(headlineIndex);
+
+    emit(state.copyWith(headlines: updatedHeadlines));
+
+    try {
+      await _headlinesRepository.update(
+        id: event.id,
+        item: headlineToRestore.copyWith(status: ContentStatus.active),
+      );
+    } on HttpException catch (e) {
+      emit(state.copyWith(headlines: originalHeadlines, exception: e));
+    } catch (e) {
+      emit(
+        state.copyWith(
+          headlines: originalHeadlines,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
+
+  Future<void> _onDeleteHeadlineForeverRequested(
+    DeleteHeadlineForeverRequested event,
+    Emitter<ArchivedHeadlinesState> emit,
+  ) async {
+    final originalHeadlines = List<Headline>.from(state.headlines);
+    final headlineIndex = originalHeadlines.indexWhere((h) => h.id == event.id);
+    if (headlineIndex == -1) return;
+
+    final updatedHeadlines = originalHeadlines..removeAt(headlineIndex);
+    emit(state.copyWith(headlines: updatedHeadlines));
+
+    try {
+      await _headlinesRepository.delete(id: event.id);
+    } on HttpException catch (e) {
+      emit(state.copyWith(headlines: originalHeadlines, exception: e));
+    } catch (e) {
+      emit(
+        state.copyWith(
+          headlines: originalHeadlines,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
+}

lib/content_management/bloc/archived_headlines/archived_headlines_event.dart

@@ -0,0 +1,39 @@
+part of 'archived_headlines_bloc.dart';
+
+sealed class ArchivedHeadlinesEvent extends Equatable {
+  const ArchivedHeadlinesEvent();
+
+  @override
+  List<Object?> get props => [];
+}
+
+/// Event to request loading of archived headlines.
+final class LoadArchivedHeadlinesRequested extends ArchivedHeadlinesEvent {
+  const LoadArchivedHeadlinesRequested({this.startAfterId, this.limit});
+
+  final String? startAfterId;
+  final int? limit;
+
+  @override
+  List<Object?> get props => [startAfterId, limit];
+}
+
+/// Event to restore an archived headline.
+final class RestoreHeadlineRequested extends ArchivedHeadlinesEvent {
+  const RestoreHeadlineRequested(this.id);
+
+  final String id;
+
+  @override
+  List<Object?> get props => [id];
+}
+
+/// Event to permanently delete an archived headline.
+final class DeleteHeadlineForeverRequested extends ArchivedHeadlinesEvent {
+  const DeleteHeadlineForeverRequested(this.id);
+
+  final String id;
+
+  @override
+  List<Object?> get props => [id];
+}

lib/content_management/bloc/archived_headlines/archived_headlines_state.dart

@@ -0,0 +1,51 @@
+part of 'archived_headlines_bloc.dart';
+
+/// Represents the status of archived content operations.
+enum ArchivedHeadlinesStatus {
+  initial,
+  loading,
+  success,
+  failure,
+}
+
+/// The state for the archived content feature.
+class ArchivedHeadlinesState extends Equatable {
+  const ArchivedHeadlinesState({
+    this.status = ArchivedHeadlinesStatus.initial,
+    this.headlines = const [],
+    this.cursor,
+    this.hasMore = false,
+    this.exception,
+  });
+
+  final ArchivedHeadlinesStatus status;
+  final List<Headline> headlines;
+  final String? cursor;
+  final bool hasMore;
+  final HttpException? exception;
+
+  ArchivedHeadlinesState copyWith({
+    ArchivedHeadlinesStatus? status,
+    List<Headline>? headlines,
+    String? cursor,
+    bool? hasMore,
+    HttpException? exception,
+  }) {
+    return ArchivedHeadlinesState(
+      status: status ?? this.status,
+      headlines: headlines ?? this.headlines,
+      cursor: cursor ?? this.cursor,
+      hasMore: hasMore ?? this.hasMore,
+      exception: exception ?? this.exception,
+    );
+  }
+
+  @override
+  List<Object?> get props => [
+        status,
+        headlines,
+        cursor,
+        hasMore,
+        exception,
+      ];
+}

lib/content_management/bloc/archived_sources/archived_sources_bloc.dart

@@ -0,0 +1,92 @@
+import 'package:bloc/bloc.dart';
+import 'package:core/core.dart';
+import 'package:data_repository/data_repository.dart';
+import 'package:equatable/equatable.dart';
+
+part 'archived_sources_event.dart';
+part 'archived_sources_state.dart';
+
+class ArchivedSourcesBloc
+    extends Bloc<ArchivedSourcesEvent, ArchivedSourcesState> {
+  ArchivedSourcesBloc({
+    required DataRepository<Source> sourcesRepository,
+  })  : _sourcesRepository = sourcesRepository,
+        super(const ArchivedSourcesState()) {
+    on<LoadArchivedSourcesRequested>(_onLoadArchivedSourcesRequested);
+    on<RestoreSourceRequested>(_onRestoreSourceRequested);
+  }
+
+  final DataRepository<Source> _sourcesRepository;
+
+  Future<void> _onLoadArchivedSourcesRequested(
+    LoadArchivedSourcesRequested event,
+    Emitter<ArchivedSourcesState> emit,
+  ) async {
+    emit(state.copyWith(status: ArchivedSourcesStatus.loading));
+    try {
+      final isPaginating = event.startAfterId != null;
+      final previousSources = isPaginating ? state.sources : <Source>[];
+
+      final paginatedSources = await _sourcesRepository.readAll(
+        filter: {'status': ContentStatus.archived.name},
+        sort: [const SortOption('updatedAt', SortOrder.desc)],
+        pagination: PaginationOptions(
+          cursor: event.startAfterId,
+          limit: event.limit,
+        ),
+      );
+      emit(
+        state.copyWith(
+          status: ArchivedSourcesStatus.success,
+          sources: [...previousSources, ...paginatedSources.items],
+          cursor: paginatedSources.cursor,
+          hasMore: paginatedSources.hasMore,
+        ),
+      );
+    } on HttpException catch (e) {
+      emit(
+        state.copyWith(
+          status: ArchivedSourcesStatus.failure,
+          exception: e,
+        ),
+      );
+    } catch (e) {
+      emit(
+        state.copyWith(
+          status: ArchivedSourcesStatus.failure,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
+
+  Future<void> _onRestoreSourceRequested(
+    RestoreSourceRequested event,
+    Emitter<ArchivedSourcesState> emit,
+  ) async {
+    final originalSources = List<Source>.from(state.sources);
+    final sourceIndex = originalSources.indexWhere((s) => s.id == event.id);
+    if (sourceIndex == -1) return;
+
+    final sourceToRestore = originalSources[sourceIndex];
+    final updatedSources = originalSources..removeAt(sourceIndex);
+
+    emit(state.copyWith(sources: updatedSources));
+
+    try {
+      await _sourcesRepository.update(
+        id: event.id,
+        item: sourceToRestore.copyWith(status: ContentStatus.active),
+      );
+    } on HttpException catch (e) {
+      emit(state.copyWith(sources: originalSources, exception: e));
+    } catch (e) {
+      emit(
+        state.copyWith(
+          sources: originalSources,
+          exception: UnknownException('An unexpected error occurred: $e'),
+        ),
+      );
+    }
+  }
+}

lib/content_management/bloc/archived_sources/archived_sources_event.dart

@@ -0,0 +1,29 @@
+part of 'archived_sources_bloc.dart';
+
+sealed class ArchivedSourcesEvent extends Equatable {
+  const ArchivedSourcesEvent();
+
+  @override
+  List<Object?> get props => [];
+}
+
+/// Event to request loading of archived sources.
+final class LoadArchivedSourcesRequested extends ArchivedSourcesEvent {
+  const LoadArchivedSourcesRequested({this.startAfterId, this.limit});
+
+  final String? startAfterId;
+  final int? limit;
+
+  @override
+  List<Object?> get props => [startAfterId, limit];
+}
+
+/// Event to restore an archived source.
+final class RestoreSourceRequested extends ArchivedSourcesEvent {
+  const RestoreSourceRequested(this.id);
+
+  final String id;
+
+  @override
+  List<Object?> get props => [id];
+}

lib/content_management/bloc/archived_sources/archived_sources_state.dart

@@ -0,0 +1,51 @@
+part of 'archived_sources_bloc.dart';
+
+/// Represents the status of archived content operations.
+enum ArchivedSourcesStatus {
+  initial,
+  loading,
+  success,
+  failure,
+}
+
+/// The state for the archived content feature.
+class ArchivedSourcesState extends Equatable {
+  const ArchivedSourcesState({
+    this.status = ArchivedSourcesStatus.initial,
+    this.sources = const [],
+    this.cursor,
+    this.hasMore = false,
+    this.exception,
+  });
+
+  final ArchivedSourcesStatus status;
+  final List<Source> sources;
+  final String? cursor;
+  final bool hasMore;
+  final HttpException? exception;
+
+  ArchivedSourcesState copyWith({
+    ArchivedSourcesStatus? status,
+    List<Source>? sources,
+    String? cursor,
+    bool? hasMore,
+    HttpException? exception,
+  }) {
+    return ArchivedSourcesState(
+      status: status ?? this.status,
+      sources: sources ?? this.sources,
+      cursor: cursor ?? this.cursor,
+      hasMore: hasMore ?? this.hasMore,
+      exception: exception ?? this.exception,
+    );
+  }
+
+  @override
+  List<Object?> get props => [
+        status,
+        sources,
+        cursor,
+        hasMore,
+        exception,
+      ];
+}