From 771076c29c63363aac2ce19f69714eba9786bb8c Mon Sep 17 00:00:00 2001
From: Sahil Kumar <xdsahil@gmail.com>
Date: Fri, 26 Feb 2021 18:35:26 +0530
Subject: [PATCH] [LLC -> Client] Expose `queryChannelsOnline` and
 `queryChannelsOffline`

Signed-off-by: Sahil Kumar <xdsahil@gmail.com>
---
 packages/stream_chat/lib/src/client.dart             | 12 +++++++-----
 .../lib/src/db/chat_persistence_client.dart          |  2 +-
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/packages/stream_chat/lib/src/client.dart b/packages/stream_chat/lib/src/client.dart
index 55212b89..aa93e480 100644
--- a/packages/stream_chat/lib/src/client.dart
+++ b/packages/stream_chat/lib/src/client.dart
@@ -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),
diff --git a/packages/stream_chat/lib/src/db/chat_persistence_client.dart b/packages/stream_chat/lib/src/db/chat_persistence_client.dart
index e95dadb2..da99f34e 100644
--- a/packages/stream_chat/lib/src/db/chat_persistence_client.dart
+++ b/packages/stream_chat/lib/src/db/chat_persistence_client.dart
@@ -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],