paperless-mobile/lib/features/labels/bloc/label_cubit.dart

import 'dart:async';

import 'package:flutter/foundation.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:paperless_api/paperless_api.dart';
import 'package:paperless_mobile/core/repository/label_repository.dart';
import 'package:paperless_mobile/features/labels/bloc/label_state.dart';

class LabelCubit<T extends Label> extends Cubit<LabelState<T>> {
  final LabelRepository<T> _repository;

  late StreamSubscription _subscription;

  LabelCubit(LabelRepository<T> repository)
      : _repository = repository,
        super(LabelState(labels: repository.current, isLoaded: true)) {
    _subscription = _repository.labels.listen(
      (update) => emit(
        LabelState(isLoaded: true, labels: update),
      ),
    );
  }

  ///
  /// Adds  [item] to the current state. A new state is automatically pushed
  /// due to the subscription to the repository, which updates the state on
  /// operation.
  ///
  Future<T> add(T item) async {
    assert(item.id == null);
    final addedItem = await _repository.create(item);
    return addedItem;
  }

  Future<void> reload() {
    return _repository.findAll();
  }

  Future<T> replace(T item) async {
    assert(item.id != null);
    final updatedItem = await _repository.update(item);
    return updatedItem;
  }

  Future<void> remove(T item) async {
    assert(item.id != null);
    if (state.labels.containsKey(item.id)) {
      await _repository.delete(item);
    }
  }

  void reset() {
    emit(LabelState(isLoaded: false, labels: {}));
  }

  @override
  Future<void> close() {
    _subscription.cancel();
    return super.close();
  }
}