feat: drift album page (#19564)

* feat: drift album page * feat: page renderred * feat: asset count * refactor: use statefulwidget * refactor: private widgets * refactor: service layer * refactor: import * feat: get owner name * pr feedback * pr feedback * pr feedback * pr feedback
2025-06-30 21:24:50 -05:00
parent bb8755021d
commit 3f330c6476
12 changed files with 1135 additions and 25 deletions
@@ -1,7 +1,9 @@
 import 'package:hooks_riverpod/hooks_riverpod.dart';
+import 'package:immich_mobile/domain/services/remote_album.service.dart';
 import 'package:immich_mobile/infrastructure/repositories/local_album.repository.dart';
 import 'package:immich_mobile/infrastructure/repositories/remote_album.repository.dart';
 import 'package:immich_mobile/providers/infrastructure/db.provider.dart';
+import 'package:immich_mobile/providers/infrastructure/remote_album.provider.dart';

 final localAlbumRepository = Provider<DriftLocalAlbumRepository>(
  (ref) => DriftLocalAlbumRepository(ref.watch(driftProvider)),
@@ -10,3 +12,14 @@ final localAlbumRepository = Provider<DriftLocalAlbumRepository>(
 final remoteAlbumRepository = Provider<DriftRemoteAlbumRepository>(
  (ref) => DriftRemoteAlbumRepository(ref.watch(driftProvider)),
 );
+
+final remoteAlbumServiceProvider = Provider<RemoteAlbumService>(
+  (ref) => RemoteAlbumService(ref.watch(remoteAlbumRepository)),
+  dependencies: [remoteAlbumRepository],
+);
+
+final remoteAlbumProvider =
+    NotifierProvider<RemoteAlbumNotifier, RemoteAlbumState>(
+  RemoteAlbumNotifier.new,
+  dependencies: [remoteAlbumServiceProvider],
+);
@@ -0,0 +1,121 @@
+import 'package:collection/collection.dart';
+import 'package:immich_mobile/domain/models/album/album.model.dart';
+import 'package:immich_mobile/domain/services/remote_album.service.dart';
+import 'package:immich_mobile/models/albums/album_search.model.dart';
+import 'package:immich_mobile/utils/remote_album.utils.dart';
+import 'package:riverpod_annotation/riverpod_annotation.dart';
+
+import 'album.provider.dart';
+
+class RemoteAlbumState {
+  final List<Album> albums;
+  final List<Album> filteredAlbums;
+  final bool isLoading;
+  final String? error;
+
+  const RemoteAlbumState({
+    required this.albums,
+    List<Album>? filteredAlbums,
+    this.isLoading = false,
+    this.error,
+  }) : filteredAlbums = filteredAlbums ?? albums;
+
+  RemoteAlbumState copyWith({
+    List<Album>? albums,
+    List<Album>? filteredAlbums,
+    bool? isLoading,
+    String? error,
+  }) {
+    return RemoteAlbumState(
+      albums: albums ?? this.albums,
+      filteredAlbums: filteredAlbums ?? this.filteredAlbums,
+      isLoading: isLoading ?? this.isLoading,
+      error: error ?? this.error,
+    );
+  }
+
+  @override
+  String toString() =>
+      'RemoteAlbumState(albums: ${albums.length}, filteredAlbums: ${filteredAlbums.length}, isLoading: $isLoading, error: $error)';
+
+  @override
+  bool operator ==(covariant RemoteAlbumState other) {
+    if (identical(this, other)) return true;
+    final listEquals = const DeepCollectionEquality().equals;
+
+    return listEquals(other.albums, albums) &&
+        listEquals(other.filteredAlbums, filteredAlbums) &&
+        other.isLoading == isLoading &&
+        other.error == error;
+  }
+
+  @override
+  int get hashCode =>
+      albums.hashCode ^
+      filteredAlbums.hashCode ^
+      isLoading.hashCode ^
+      error.hashCode;
+}
+
+class RemoteAlbumNotifier extends Notifier<RemoteAlbumState> {
+  late final RemoteAlbumService _remoteAlbumService;
+
+  @override
+  RemoteAlbumState build() {
+    _remoteAlbumService = ref.read(remoteAlbumServiceProvider);
+    return const RemoteAlbumState(albums: [], filteredAlbums: []);
+  }
+
+  Future<List<Album>> getAll() async {
+    state = state.copyWith(isLoading: true, error: null);
+
+    try {
+      final albums = await _remoteAlbumService.getAll();
+      state = state.copyWith(
+        albums: albums,
+        filteredAlbums: albums,
+        isLoading: false,
+      );
+      return albums;
+    } catch (e) {
+      state = state.copyWith(isLoading: false, error: e.toString());
+      rethrow;
+    }
+  }
+
+  Future<void> refresh() async {
+    await getAll();
+  }
+
+  void searchAlbums(
+    String query,
+    String? userId, [
+    QuickFilterMode filterMode = QuickFilterMode.all,
+  ]) {
+    final filtered = _remoteAlbumService.searchAlbums(
+      state.albums,
+      query,
+      userId,
+      filterMode,
+    );
+
+    state = state.copyWith(
+      filteredAlbums: filtered,
+    );
+  }
+
+  void clearSearch() {
+    state = state.copyWith(
+      filteredAlbums: state.albums,
+    );
+  }
+
+  void sortFilteredAlbums(
+    RemoteAlbumSortMode sortMode, {
+    bool isReverse = false,
+  }) {
+    final sortedAlbums = _remoteAlbumService
+        .sortAlbums(state.filteredAlbums, sortMode, isReverse: isReverse);
+    state = state.copyWith(filteredAlbums: sortedAlbums);
+  }
+}