From 3aea367dfd4d189e6a743432e25ced869f5f16d5 Mon Sep 17 00:00:00 2001 From: otsmr Date: Sat, 7 Feb 2026 23:02:43 +0100 Subject: [PATCH] remove unused code --- lib/src/database/daos/messages.dao.dart | 139 ------------------------ 1 file changed, 139 deletions(-) diff --git a/lib/src/database/daos/messages.dao.dart b/lib/src/database/daos/messages.dao.dart index 998e51f..72a8d59 100644 --- a/lib/src/database/daos/messages.dao.dart +++ b/lib/src/database/daos/messages.dao.dart @@ -131,53 +131,6 @@ class MessagesDao extends DatabaseAccessor with _$MessagesDaoMixin { } } - // Future> getAllMessagesPendingDownloading() { - // return (select(messages) - // ..where( - // (t) => - // t.downloadState.equals(DownloadState.downloaded.index).not() & - // t.messageOtherId.isNotNull() & - // t.errorWhileSending.equals(false) & - // t.kind.equals(MessageKind.media.name), - // )) - // .get(); - // } - - // Future> getAllNonACKMessagesFromUser() { - // return (select(messages) - // ..where( - // (t) => - // t.acknowledgeByUser.equals(false) & - // t.messageOtherId.isNull() & - // t.errorWhileSending.equals(false) & - // t.sendAt.isBiggerThanValue( - // clock.now().subtract(const Duration(minutes: 10)), - // ), - // )) - // .get(); - // } - - // Stream> getAllStoredMediaFiles() { - // return (select(messages) - // ..where((t) => t.mediaStored.equals(true)) - // ..orderBy([(t) => OrderingTerm.desc(t.sendAt)])) - // .watch(); - // } - - // Future> getAllMessagesPendingUpload() { - // return (select(messages) - // ..where( - // (t) => - // t.acknowledgeByServer.equals(false) & - // t.messageOtherId.isNull() & - // t.mediaUploadId.isNotNull() & - // t.downloadState.equals(DownloadState.pending.index) & - // t.errorWhileSending.equals(false) & - // t.kind.equals(MessageKind.media.name), - // )) - // .get(); - // } - Future openedAllTextMessages(String groupId) { final updates = MessagesCompanion(openedAt: Value(clock.now())); return (update(messages) @@ -322,32 +275,6 @@ class MessagesDao extends DatabaseAccessor with _$MessagesDaoMixin { return members.length == actions.length; } - // Future updateMessageByOtherUser( - // int userId, - // int messageId, - // MessagesCompanion updatedValues, - // ) { - // return (update(messages) - // ..where( - // (c) => c.contactId.equals(userId) & c.messageId.equals(messageId), - // )) - // .write(updatedValues); - // } - - // Future updateMessageByOtherMessageId( - // int userId, - // int messageOtherId, - // MessagesCompanion updatedValues, - // ) { - // return (update(messages) - // ..where( - // (c) => - // c.contactId.equals(userId) & - // c.messageOtherId.equals(messageOtherId), - // )) - // .write(updatedValues); - // } - Future updateMessageId( String messageId, MessagesCompanion updatedValues, @@ -445,27 +372,6 @@ class MessagesDao extends DatabaseAccessor with _$MessagesDaoMixin { }); } - // Future deleteMessagesByContactId(int contactId) { - // return (delete(messages) - // ..where( - // (t) => t.contactId.equals(contactId) & t.mediaStored.equals(false), - // )) - // .go(); - // } - - // Future deleteMessagesByContactIdAndOtherMessageId( - // int contactId, - // int messageOtherId, - // ) { - // return (delete(messages) - // ..where( - // (t) => - // t.contactId.equals(contactId) & - // t.messageOtherId.equals(messageOtherId), - // )) - // .go(); - // } - Future deleteMessagesById(String messageId) { return (delete(messages)..where((t) => t.messageId.equals(messageId))).go(); } @@ -474,24 +380,6 @@ class MessagesDao extends DatabaseAccessor with _$MessagesDaoMixin { return (delete(messages)..where((t) => t.groupId.equals(groupId))).go(); } - // Future deleteAllMessagesByContactId(int contactId) { - // return (delete(messages)..where((t) => t.contactId.equals(contactId))).go(); - // } - - // Future containsOtherMessageId( - // int fromUserId, - // int messageOtherId, - // ) async { - // final query = select(messages) - // ..where( - // (t) => - // t.messageOtherId.equals(messageOtherId) & - // t.contactId.equals(fromUserId), - // ); - // final entry = await query.get(); - // return entry.isNotEmpty; - // } - SingleOrNullSelectable getMessageById(String messageId) { return select(messages)..where((t) => t.messageId.equals(messageId)); } @@ -519,31 +407,4 @@ class MessagesDao extends DatabaseAccessor with _$MessagesDaoMixin { ..orderBy([(t) => OrderingTerm.desc(t.createdAt)])) .watch(); } - - // Future> getMessagesByMediaUploadId(int mediaUploadId) async { - // return (select(messages) - // ..where((t) => t.mediaUploadId.equals(mediaUploadId))) - // .get(); - // } - - // SingleOrNullSelectable getMessageByOtherMessageId( - // int fromUserId, - // int messageId, - // ) { - // return select(messages) - // ..where( - // (t) => - // t.messageOtherId.equals(messageId) & t.contactId.equals(fromUserId), - // ); - // } - - // SingleOrNullSelectable getMessageByIdAndContactId( - // int fromUserId, - // int messageId, - // ) { - // return select(messages) - // ..where( - // (t) => t.messageId.equals(messageId) & t.contactId.equals(fromUserId), - // ); - // } }