From d0f844ed08302625a2dfec23f3aaecfd5a0e5406 Mon Sep 17 00:00:00 2001 From: Penlane Date: Sat, 1 Aug 2026 18:54:57 +0200 Subject: [PATCH] feat(mobile): remove filter from main queries --- .../repositories/timeline.repository.dart | 17 ++++------------- 1 file changed, 4 insertions(+), 13 deletions(-) diff --git a/mobile/lib/infrastructure/repositories/timeline.repository.dart b/mobile/lib/infrastructure/repositories/timeline.repository.dart index f68bf71782..d8c168b54c 100644 --- a/mobile/lib/infrastructure/repositories/timeline.repository.dart +++ b/mobile/lib/infrastructure/repositories/timeline.repository.dart @@ -53,29 +53,20 @@ class DriftTimelineRepository extends DriftDatabaseRepository { origin: TimelineOrigin.main, ); - Stream> _watchMainBucket( - List userIds, { - GroupAssetsBy groupBy = GroupAssetsBy.day, - required AssetOriginFilter filter, - }) { + Stream> _watchMainBucket(List userIds, {GroupAssetsBy groupBy = GroupAssetsBy.day}) { if (groupBy == GroupAssetsBy.none) { throw UnsupportedError("GroupAssetsBy.none is not supported for watchMainBucket"); } - return _db.mergedAssetDrift.mergedBucket(userIds: userIds, groupBy: groupBy.index, filter: filter.index).map((row) { + return _db.mergedAssetDrift.mergedBucket(userIds: userIds, groupBy: groupBy.index).map((row) { final date = row.bucketDate.truncateDate(groupBy); return TimeBucket(date: date, assetCount: row.assetCount); }).watch(); } - Future> _getMainBucketAssets( - List userIds, { - required int offset, - required int count, - required AssetOriginFilter filter, - }) { + Future> _getMainBucketAssets(List userIds, {required int offset, required int count}) { return _db.mergedAssetDrift - .mergedAsset(userIds: userIds, limit: Limit(count, offset), filter: filter.index) + .mergedAsset(userIds: userIds, limit: (_) => Limit(count, offset)) .map( (row) => row.remoteId != null && row.ownerId != null ? RemoteAsset(