paperless-mobile/lib/features/saved_view/cubit/saved_view_cubit.dart

import 'dart:async';

import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:freezed_annotation/freezed_annotation.dart';
import 'package:paperless_api/paperless_api.dart';
import 'package:paperless_mobile/core/repository/saved_view_repository.dart';

part 'saved_view_cubit.freezed.dart';
part 'saved_view_state.dart';

class SavedViewCubit extends Cubit<SavedViewState> {
  final SavedViewRepository _savedViewRepository;

  SavedViewCubit(this._savedViewRepository)
      : super(const SavedViewState.initial()) {
    _savedViewRepository.addListener(
      this,
      onChanged: (views) {
        views.when(
          initial: (savedViews) => emit(const SavedViewState.initial()),
          loading: (savedViews) => emit(const SavedViewState.loading()),
          loaded: (savedViews) =>
              emit(SavedViewState.loaded(savedViews: savedViews)),
          error: (savedViews) => emit(const SavedViewState.error()),
        );
      },
    );
  }

  Future<SavedView> add(SavedView view) async {
    return _savedViewRepository.create(view);
  }

  Future<int> remove(SavedView view) {
    return _savedViewRepository.delete(view);
  }

  Future<SavedView> update(SavedView view) async {
    return await _savedViewRepository.update(view);
  }

  Future<void> reload() async {
    final views = await _savedViewRepository.findAll();
    final values = {for (var element in views) element.id!: element};
    if (!isClosed) {
      emit(
        SavedViewState.loaded(
          savedViews: values,
        ),
      );
    }
  }

  @override
  Future<void> close() {
    _savedViewRepository.removeListener(this);
    return super.close();
  }
}