talksik/stream-chat-flutter
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix persistence abstract class

Browse Source
This commit is contained in:
Salvatore Giordano
2021-04-19 15:44:46 +02:00
parent 1c7c1dd81c
commit 7f29ca52e1
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat/lib/src/db/chat_persistence_client.dart
+10 -9
View File
@@ -76,11 +76,11 @@ abstract class ChatPersistenceClient {
getPinnedMessagesByCid(cid, messagePagination: pinnedMessagePagination),
]);
return ChannelState(
members: (data[0] as List<Member>?)!,
read: (data[1] as List<Read>?)!,
channel: data[2] as ChannelModel?,
messages: (data[3] as List<Message>?)!,
pinnedMessages: (data[4] as List<Message>?)!,
members: data[0] as List<Member>,
read: data[1] as List<Read>,
channel: data[2] as ChannelModel,
messages: data[3] as List<Message>,
pinnedMessages: data[4] as List<Message>,
);
}
@@ -195,9 +195,10 @@ abstract class ChatPersistenceClient {
final reactions = channelStates.expand((it) => it.messages).expand((it) => [
if (it.ownReactions != null)
...it.ownReactions!.where((r) => r.userId != null),
...it.ownReactions?.where((r) => r.userId != null) ?? <Reaction>[],
if (it.latestReactions != null)
...it.latestReactions!.where((r) => r.userId != null)
...it.latestReactions?.where((r) => r.userId != null) ??
<Reaction>[],
]);
final users = channelStates
@@ -207,9 +208,9 @@ abstract class ChatPersistenceClient {
.map((m) => [
m.user,
if (m.latestReactions != null)
...m.latestReactions!.map((r) => r.user),
...m.latestReactions?.map((r) => r.user) ?? [],
if (m.ownReactions != null)
...m.ownReactions!.map((r) => r.user),
...m.ownReactions?.map((r) => r.user) ?? [],
])
.expand((v) => v),
...cs.read.map((r) => r.user),