mirror of
https://github.com/gabehf/Fladder.git
synced 2026-03-07 13:38:13 -08:00
100 lines
3.6 KiB
Dart
100 lines
3.6 KiB
Dart
import 'package:chopper/chopper.dart';
|
|
import 'package:fladder/providers/service_provider.dart';
|
|
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
|
|
|
import 'package:fladder/jellyfin/jellyfin_open_api.swagger.dart';
|
|
import 'package:fladder/models/boxset_model.dart';
|
|
import 'package:fladder/models/item_base_model.dart';
|
|
import 'package:fladder/providers/api_provider.dart';
|
|
import 'package:fladder/util/map_bool_helper.dart';
|
|
|
|
class _CollectionSetModel {
|
|
final List<ItemBaseModel> items;
|
|
final Map<BoxSetModel, bool?> collections;
|
|
_CollectionSetModel({
|
|
required this.items,
|
|
required this.collections,
|
|
});
|
|
|
|
_CollectionSetModel copyWith({
|
|
List<ItemBaseModel>? items,
|
|
Map<BoxSetModel, bool?>? collections,
|
|
}) {
|
|
return _CollectionSetModel(
|
|
items: items ?? this.items,
|
|
collections: collections ?? this.collections,
|
|
);
|
|
}
|
|
}
|
|
|
|
final collectionsProvider = StateNotifierProvider.autoDispose<BoxSetNotifier, _CollectionSetModel>((ref) {
|
|
return BoxSetNotifier(ref);
|
|
});
|
|
|
|
class BoxSetNotifier extends StateNotifier<_CollectionSetModel> {
|
|
BoxSetNotifier(this.ref) : super(_CollectionSetModel(items: [], collections: {}));
|
|
final Ref ref;
|
|
|
|
late final JellyService api = ref.read(jellyApiProvider);
|
|
|
|
Future<void> setItems(List<ItemBaseModel> items) async {
|
|
state = state.copyWith(items: items);
|
|
return _init();
|
|
}
|
|
|
|
Future<void> _init() async {
|
|
final collections = await api.usersUserIdItemsGet(
|
|
recursive: true,
|
|
includeItemTypes: [
|
|
BaseItemKind.boxset,
|
|
],
|
|
);
|
|
|
|
final boxsets = collections.body?.items?.map((e) => BoxSetModel.fromBaseDto(e, ref)).toList();
|
|
|
|
if (state.items.length == 1 && (boxsets?.length ?? 0) < 25) {
|
|
final List<Future<bool>> itemChecks = boxsets?.map((element) async {
|
|
final itemList = await api.usersUserIdItemsGet(
|
|
parentId: element.id,
|
|
);
|
|
final List<String?> items = (itemList.body?.items ?? []).map((e) => e.id).toList();
|
|
return items.contains(state.items.firstOrNull?.id);
|
|
}).toList() ??
|
|
[];
|
|
|
|
final List<bool> results = await Future.wait(itemChecks);
|
|
|
|
final Map<BoxSetModel, bool?> boxSetContainsItemMap = Map.fromIterables(boxsets ?? [], results);
|
|
|
|
state = state.copyWith(collections: boxSetContainsItemMap);
|
|
} else {
|
|
final Map<BoxSetModel, bool?> boxSetContainsItemMap =
|
|
Map.fromIterables(boxsets ?? [], List.generate(boxsets?.length ?? 0, (index) => null));
|
|
state = state.copyWith(collections: boxSetContainsItemMap);
|
|
}
|
|
}
|
|
|
|
Future<Response> toggleCollection(
|
|
{required BoxSetModel boxSet, required bool value, required ItemBaseModel item}) async {
|
|
final Response response = value
|
|
? await api.collectionsCollectionIdItemsPost(collectionId: boxSet.id, ids: [item.id])
|
|
: await api.collectionsCollectionIdItemsDelete(collectionId: boxSet.id, ids: [item.id]);
|
|
|
|
if (response.isSuccessful) {
|
|
state = state.copyWith(collections: state.collections.setKey(boxSet, response.isSuccessful ? value : !value));
|
|
}
|
|
return response;
|
|
}
|
|
|
|
Future<Response> addToCollection({required BoxSetModel boxSet, required bool add}) async => add
|
|
? await api.collectionsCollectionIdItemsPost(collectionId: boxSet.id, ids: state.items.map((e) => e.id).toList())
|
|
: await api.collectionsCollectionIdItemsDelete(
|
|
collectionId: boxSet.id, ids: state.items.map((e) => e.id).toList());
|
|
|
|
Future<void> addToNewCollection({required String name}) async {
|
|
final result = await api.collectionsPost(name: name, ids: state.items.map((e) => e.id).toList());
|
|
if (result.isSuccessful) {
|
|
await _init();
|
|
}
|
|
}
|
|
}
|