Mirrors/nc-photos
1
0
Fork 0
mirror of https://gitlab.com/nkming2/nc-photos.git synced 2025-03-27 17:34:44 +01:00
Code Issues Projects Releases Packages Wiki Activity

Handle share removed event in batch

Browse source
This commit is contained in:
Ming Ming 2021-10-25 18:44:43 +08:00
parent 3fcb4e2090
commit 6dade916b5
1 changed files with 20 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
lib/bloc/list_sharing.dart
View file

@ -10,7 +10,9 @@ import 'package:nc_photos/entity/file_util.dart' as file_util;
import 'package:nc_photos/entity/share.dart';
import 'package:nc_photos/entity/share/data_source.dart';
import 'package:nc_photos/event/event.dart';
import 'package:nc_photos/iterable_extension.dart';
import 'package:nc_photos/remote_storage_util.dart' as remote_storage_util;
import 'package:nc_photos/throttler.dart';
import 'package:nc_photos/use_case/find_file.dart';
import 'package:nc_photos/use_case/ls.dart';
import 'package:path/path.dart' as path;
@ -51,16 +53,16 @@ class ListSharingBlocQuery extends ListSharingBlocEvent {
}
class _ListSharingBlocShareRemoved extends ListSharingBlocEvent {
const _ListSharingBlocShareRemoved(this.share);
const _ListSharingBlocShareRemoved(this.shares);
@override
toString() {
return "$runtimeType {"
"share: $share, "
"shares: ${shares.toReadableString()}, "
"}";
}
final Share share;
final List<Share> shares;
}
abstract class ListSharingBlocState {
@ -132,6 +134,13 @@ class ListSharingBlocFailure extends ListSharingBlocState {
class ListSharingBloc extends Bloc<ListSharingBlocEvent, ListSharingBlocState> {
ListSharingBloc() : super(ListSharingBlocInit()) {
_shareRemovedListener.begin();
_refreshThrottler = Throttler<Share>(
onTriggered: (shares) {
add(_ListSharingBlocShareRemoved(shares));
},
logTag: "ListSharingBloc.refresh",
);
}
static ListSharingBloc of(Account account) {
@ -176,7 +185,7 @@ class ListSharingBloc extends Bloc<ListSharingBlocEvent, ListSharingBlocState> {
return;
}
final newItems = List.of(state.items)
.where((element) => !identical(element.share, ev.share))
.where((element) => !ev.shares.containsIdentical(element.share))
.toList();
// i love hacks :)
yield (state as dynamic).copyWith(
@ -185,7 +194,11 @@ class ListSharingBloc extends Bloc<ListSharingBlocEvent, ListSharingBlocState> {
}
void _onShareRemovedEvent(ShareRemovedEvent ev) {
add(_ListSharingBlocShareRemoved(ev.share));
_refreshThrottler.trigger(
maxResponceTime: const Duration(seconds: 3),
maxPendingCount: 10,
data: ev.share,
);
}
Future<List<ListSharingItem>> _query(ListSharingBlocQuery ev) async {
@ -327,5 +340,7 @@ class ListSharingBloc extends Bloc<ListSharingBlocEvent, ListSharingBlocState> {
late final _shareRemovedListener =
AppEventListener<ShareRemovedEvent>(_onShareRemovedEvent);
late Throttler _refreshThrottler;
static final _log = Logger("bloc.list_sharing.ListSharingBloc");
}