await deleting actions before update
This commit is contained in:
@@ -164,6 +164,20 @@ abstract class ChatPersistenceClient {
|
|||||||
];
|
];
|
||||||
}).where((it) => it != null);
|
}).where((it) => it != null);
|
||||||
|
|
||||||
|
final deleteReactions = deleteReactionsByMessageId(channelStates
|
||||||
|
.expand((it) => it.messages)
|
||||||
|
.map((m) => m.id)
|
||||||
|
.toList(growable: false));
|
||||||
|
|
||||||
|
final deleteMembers = deleteMembersByCids(
|
||||||
|
channelStates.map((it) => it.channel.cid).toList(growable: false),
|
||||||
|
);
|
||||||
|
|
||||||
|
await Future.wait([
|
||||||
|
deleteReactions,
|
||||||
|
deleteMembers,
|
||||||
|
]);
|
||||||
|
|
||||||
final users = channelStates
|
final users = channelStates
|
||||||
.map((cs) => [
|
.map((cs) => [
|
||||||
cs.channel?.createdBy,
|
cs.channel?.createdBy,
|
||||||
@@ -198,19 +212,6 @@ abstract class ChatPersistenceClient {
|
|||||||
return updateMembers(cid, members.toList(growable: false));
|
return updateMembers(cid, members.toList(growable: false));
|
||||||
}).toList(growable: false);
|
}).toList(growable: false);
|
||||||
|
|
||||||
final deleteReactions = deleteReactionsByMessageId(channelStates
|
|
||||||
.expand((it) => it.messages)
|
|
||||||
.map((m) => m.id)
|
|
||||||
.toList(growable: false));
|
|
||||||
|
|
||||||
final deleteMembers = deleteMembersByCids(
|
|
||||||
channelStates.map((it) => it.channel.cid).toList(growable: false),
|
|
||||||
);
|
|
||||||
|
|
||||||
await Future.wait([
|
|
||||||
deleteReactions,
|
|
||||||
deleteMembers,
|
|
||||||
]);
|
|
||||||
await Future.wait([
|
await Future.wait([
|
||||||
...updateMessagesFuture,
|
...updateMessagesFuture,
|
||||||
...updateReadsFuture,
|
...updateReadsFuture,
|
||||||
|
|||||||
Reference in New Issue
Block a user