diff --git a/mobile/lib/interfaces/timeline.interface.dart b/mobile/lib/interfaces/timeline.interface.dart index 3a4cce3cb6..ecdc0dcf0c 100644 --- a/mobile/lib/interfaces/timeline.interface.dart +++ b/mobile/lib/interfaces/timeline.interface.dart @@ -14,7 +14,7 @@ abstract class ITimelineRepository { Album album, GroupAssetsBy groupAssetsBy, ); - Stream watchAllVideosTimeline(); + Stream watchAllVideosTimeline(String userId); Stream watchHomeTimeline( String userId, diff --git a/mobile/lib/repositories/timeline.repository.dart b/mobile/lib/repositories/timeline.repository.dart index 039013f7d7..aa5bdeb4e4 100644 --- a/mobile/lib/repositories/timeline.repository.dart +++ b/mobile/lib/repositories/timeline.repository.dart @@ -98,8 +98,10 @@ class TimelineRepository extends DatabaseRepository } @override - Stream watchAllVideosTimeline() { + Stream watchAllVideosTimeline(String userId) { final query = db.assets + .where() + .ownerIdEqualToAnyChecksum(fastHash(userId)) .filter() .isTrashedEqualTo(false) .visibilityEqualTo(AssetVisibilityEnum.timeline) diff --git a/mobile/lib/services/timeline.service.dart b/mobile/lib/services/timeline.service.dart index 7ecad43ca7..d7d1e7cf25 100644 --- a/mobile/lib/services/timeline.service.dart +++ b/mobile/lib/services/timeline.service.dart @@ -75,7 +75,9 @@ class TimelineService { } Stream watchAllVideosTimeline() { - return _timelineRepository.watchAllVideosTimeline(); + final user = _userService.getMyUser(); + + return _timelineRepository.watchAllVideosTimeline(user.id); } Future getTimelineFromAssets(