diff --git a/lib/main.dart b/lib/main.dart index 2140a8d..2b06327 100644 --- a/lib/main.dart +++ b/lib/main.dart @@ -65,6 +65,7 @@ void main() async { twonlyDB = TwonlyDB(); await twonlyDB.messagesDao.purgeMessageTable(); + await twonlyDB.receiptsDao.purgeReceivedReceipts(); unawaited(MediaFileService.purgeTempFolder()); await initFileDownloader(); diff --git a/lib/src/database/daos/receipts.dao.dart b/lib/src/database/daos/receipts.dao.dart index 26a72e0..4b6a6a1 100644 --- a/lib/src/database/daos/receipts.dao.dart +++ b/lib/src/database/daos/receipts.dao.dart @@ -51,6 +51,18 @@ class ReceiptsDao extends DatabaseAccessor with _$ReceiptsDaoMixin { .go(); } + Future purgeReceivedReceipts() async { + await (delete(receivedReceipts) + ..where( + (t) => (t.createdAt.isSmallerThanValue( + clock.now().subtract( + const Duration(days: 25), + ), + )), + )) + .go(); + } + Future insertReceipt(ReceiptsCompanion entry) async { try { var insertEntry = entry; diff --git a/lib/src/database/twonly.db.dart b/lib/src/database/twonly.db.dart index 07ec778..1d27de6 100644 --- a/lib/src/database/twonly.db.dart +++ b/lib/src/database/twonly.db.dart @@ -166,6 +166,7 @@ class TwonlyDB extends _$TwonlyDB { )) .go(); await delete(receipts).go(); + await delete(receivedReceipts).go(); await update(contacts).write( const ContactsCompanion( avatarSvgCompressed: Value(null),