Cutlery/immich
1
0
Fork 1
mirror of https://github.com/immich-app/immich.git synced 2025-07-08 18:54:18 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat: use sqlite timeline user provider (#19577)

Browse Source 
use sqlite timeline user provider

Co-authored-by: shenlong-tanwen <139912620+shalong-tanwen@users.noreply.github.com>
This commit is contained in:
shenlong 2025-06-27 18:59:27 +05:30 committed by GitHub
parent 30b4f334d8
commit 72a53f43c8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 33 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
mobile/lib/infrastructure/repositories/timeline.repository.dart
View File

@ -15,6 +15,21 @@ class DriftTimelineRepository extends DriftDatabaseRepository {
const DriftTimelineRepository(super._db) : _db = _db; const DriftTimelineRepository(super._db) : _db = _db;
Stream<List<String>> watchTimelineUserIds(String userId) {
final query = _db.partnerEntity.selectOnly()
..addColumns([_db.partnerEntity.sharedById])
..where(
_db.partnerEntity.inTimeline.equals(true) &
_db.partnerEntity.sharedWithId.equals(userId),
);
return query
.map((row) => row.read(_db.partnerEntity.sharedById)!)
.watch()
// Add current user ID to the list
.map((users) => users..add(userId));
}
List<Bucket> _generateBuckets(int count) { List<Bucket> _generateBuckets(int count) {
final numBuckets = (count / kTimelineNoneSegmentSize).floor(); final numBuckets = (count / kTimelineNoneSegmentSize).floor();
final buckets = List.generate( final buckets = List.generate(

8
mobile/lib/presentation/pages/dev/main_timeline.page.dart
View File

@ -5,7 +5,6 @@ import 'package:flutter/material.dart';
import 'package:hooks_riverpod/hooks_riverpod.dart'; import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:immich_mobile/presentation/widgets/timeline/timeline.widget.dart'; import 'package:immich_mobile/presentation/widgets/timeline/timeline.widget.dart';
import 'package:immich_mobile/providers/infrastructure/timeline.provider.dart'; import 'package:immich_mobile/providers/infrastructure/timeline.provider.dart';
import 'package:immich_mobile/providers/user.provider.dart';
@RoutePage() @RoutePage()
class MainTimelinePage extends StatelessWidget { class MainTimelinePage extends StatelessWidget {
@ -17,9 +16,10 @@ class MainTimelinePage extends StatelessWidget {
overrides: [ overrides: [
timelineServiceProvider.overrideWith( timelineServiceProvider.overrideWith(
(ref) { (ref) {
final timelineService = ref final timelineUsers =
.watch(timelineFactoryProvider) ref.watch(timelineUsersProvider).valueOrNull ?? [];
.main(ref.watch(timelineUsersIdsProvider)); final timelineService =
ref.watch(timelineFactoryProvider).main(timelineUsers);
ref.onDispose(() => unawaited(timelineService.dispose())); ref.onDispose(() => unawaited(timelineService.dispose()));
return timelineService; return timelineService;
}, },

14
mobile/lib/providers/infrastructure/timeline.provider.dart
View File

@ -4,6 +4,7 @@ import 'package:immich_mobile/infrastructure/repositories/timeline.repository.da
import 'package:immich_mobile/presentation/widgets/timeline/timeline.state.dart'; import 'package:immich_mobile/presentation/widgets/timeline/timeline.state.dart';
import 'package:immich_mobile/providers/infrastructure/db.provider.dart'; import 'package:immich_mobile/providers/infrastructure/db.provider.dart';
import 'package:immich_mobile/providers/infrastructure/setting.provider.dart'; import 'package:immich_mobile/providers/infrastructure/setting.provider.dart';
import 'package:immich_mobile/providers/user.provider.dart';
final timelineRepositoryProvider = Provider<DriftTimelineRepository>( final timelineRepositoryProvider = Provider<DriftTimelineRepository>(
(ref) => DriftTimelineRepository(ref.watch(driftProvider)), (ref) => DriftTimelineRepository(ref.watch(driftProvider)),
@ -25,3 +26,16 @@ final timelineFactoryProvider = Provider<TimelineFactory>(
settingsService: ref.watch(settingsProvider), settingsService: ref.watch(settingsProvider),
), ),
); );
final timelineUsersProvider = StreamProvider<List<String>>(
(ref) {
final currentUserId = ref.watch(currentUserProvider.select((u) => u?.id));
if (currentUserId == null) {
return Stream.value([]);
}
return ref
.watch(timelineRepositoryProvider)
.watchTimelineUserIds(currentUserId);
},
);