[LLC -> Client] Expose queryChannelsOnline and queryChannelsOffline

Signed-off-by: Sahil Kumar <[email protected]>
This commit is contained in:
Sahil Kumar
2021-02-26 18:35:26 +05:30
parent 623d48e32b
commit 771076c29c
2 changed files with 8 additions and 6 deletions
+7 -5
View File
@@ -491,7 +491,7 @@ class StreamChatClient {
if (status == ConnectionStatus.connected &&
state.channels?.isNotEmpty == true) {
unawaited(_queryChannels(filter: {
unawaited(queryChannelsOnline(filter: {
'cid': {
'\$in': state.channels.keys.toList(),
},
@@ -615,7 +615,7 @@ class StreamChatClient {
yield await _queryChannelsStreams[hash];
} else {
if (true) {
final channels = await _queryChannelsOffline(
final channels = await queryChannelsOffline(
filter: filter,
sort: sort,
paginationParams: paginationParams,
@@ -623,7 +623,7 @@ class StreamChatClient {
if (channels.isNotEmpty) yield channels;
}
final newQueryChannelsFuture = _queryChannels(
final newQueryChannelsFuture = queryChannelsOnline(
filter: filter,
sort: sort,
options: options,
@@ -637,7 +637,8 @@ class StreamChatClient {
}
}
Future<List<Channel>> _queryChannels({
/// Requests channels with a given query from the API.
Future<List<Channel>> queryChannelsOnline({
@required Map<String, dynamic> filter,
List<SortOption<ChannelModel>> sort,
Map<String, dynamic> options,
@@ -712,7 +713,8 @@ class StreamChatClient {
return updateData.value;
}
Future<List<Channel>> _queryChannelsOffline({
/// Requests channels with a given query from the Persistence client.
Future<List<Channel>> queryChannelsOffline({
@required Map<String, dynamic> filter,
@required List<SortOption<ChannelModel>> sort,
PaginationParams paginationParams = const PaginationParams(limit: 10),
@@ -73,7 +73,7 @@ abstract class ChatPersistenceClient {
getReadsByCid(cid),
getChannelByCid(cid),
getMessagesByCid(cid, messagePagination: messagePagination),
getPinnedMessagesByCid(cid,messagePagination: pinnedMessagePagination),
getPinnedMessagesByCid(cid, messagePagination: pinnedMessagePagination),
]);
return ChannelState(
members: data[0],