feat: asset count

Author: alextran1502

mobile/lib/domain/models/album/album.model.dart

@@ -21,6 +21,7 @@ class Album {
   final String? thumbnailAssetId;
   final bool isActivityEnabled;
   final AlbumAssetOrder order;
+  final int assetCount;
 
   const Album({
     required this.id,
@@ -32,6 +33,7 @@ class Album {
     this.thumbnailAssetId,
     required this.isActivityEnabled,
     required this.order,
+    required this.assetCount,
   });
 
   @override
@@ -46,6 +48,7 @@ class Album {
    isActivityEnabled: $isActivityEnabled,
    order: $order,
    thumbnailAssetId: ${thumbnailAssetId ?? "<NA>"}
+  assetCount: $assetCount
  }''';
   }
 
@@ -61,7 +64,8 @@ class Album {
         updatedAt == other.updatedAt &&
         thumbnailAssetId == other.thumbnailAssetId &&
         isActivityEnabled == other.isActivityEnabled &&
-        order == other.order;
+        order == other.order &&
+        assetCount == other.assetCount;
   }
 
   @override
@@ -74,6 +78,7 @@ class Album {
         updatedAt.hashCode ^
         thumbnailAssetId.hashCode ^
         isActivityEnabled.hashCode ^
-        order.hashCode;
+        order.hashCode ^
+        assetCount.hashCode;
   }
 }

mobile/lib/domain/services/sync_stream.service.dart

@@ -51,7 +51,6 @@ class SyncStreamService {
 
     final type = batch.first.type;
     await _handleSyncData(type, batch.map((e) => e.data));
-    print("Processed ${batch.last.ack.length} events of type $type");
     await _syncApiRepository.ack([batch.last.ack]);
     batch.clear();
   }

mobile/lib/infrastructure/repositories/remote_album.repository.dart

@@ -10,26 +10,43 @@ class DriftRemoteAlbumRepository extends DriftDatabaseRepository {
   const DriftRemoteAlbumRepository(this._db) : super(_db);
 
   Future<List<Album>> getAll({Set<SortRemoteAlbumsBy> sortBy = const {}}) {
-    final query = _db.remoteAlbumEntity.select();
+    final assetCount = _db.remoteAlbumAssetEntity.assetId.count();
+
+    final query = _db.remoteAlbumEntity.select().join([
+      leftOuterJoin(
+        _db.remoteAlbumAssetEntity,
+        _db.remoteAlbumAssetEntity.albumId.equalsExp(_db.remoteAlbumEntity.id),
+        useColumns: false,
+      ),
+    ]);
+    query
+      ..addColumns([assetCount])
+      ..groupBy([_db.remoteAlbumEntity.id]);
 
     if (sortBy.isNotEmpty) {
-      final orderings = <OrderClauseGenerator<$RemoteAlbumEntityTable>>[];
+      final orderings = <OrderingTerm>[];
       for (final sort in sortBy) {
         orderings.add(
           switch (sort) {
-            SortRemoteAlbumsBy.id => (row) => OrderingTerm.asc(row.id),
+            SortRemoteAlbumsBy.id => OrderingTerm.asc(_db.remoteAssetEntity.id),
           },
         );
       }
       query.orderBy(orderings);
     }
 
-    return query.map((row) => row.toDto()).get();
+    return query
+        .map(
+          (row) => row
+              .readTable(_db.remoteAlbumEntity)
+              .toDto(assetCount: row.read(assetCount) ?? 0),
+        )
+        .get();
   }
 }
 
 extension on RemoteAlbumEntityData {
-  Album toDto() {
+  Album toDto({int assetCount = 0}) {
     return Album(
       id: id,
       name: name,
@@ -40,6 +57,7 @@ extension on RemoteAlbumEntityData {
       thumbnailAssetId: thumbnailAssetId,
       isActivityEnabled: isActivityEnabled,
       order: order,
+      assetCount: assetCount,
     );
   }
 }

mobile/lib/infrastructure/repositories/sync_api.repository.dart

@@ -15,7 +15,6 @@ class SyncApiRepository {
   SyncApiRepository(this._api);
 
   Future<void> ack(List<String> data) {
-    print("Sending sync acks: $data");
     return _api.syncApi.sendSyncAck(SyncAckSetDto(acks: data));
   }