From 120e28f5e81080cd12c7ce1c9b79cff93b50e35a Mon Sep 17 00:00:00 2001 From: VelikovPetar Date: Fri, 15 May 2026 09:38:13 +0200 Subject: [PATCH] fix(llc): forward filter param in Client.queryDrafts --- packages/stream_chat/CHANGELOG.md | 6 +++++ .../stream_chat/lib/src/client/client.dart | 1 + .../test/src/client/client_test.dart | 23 +++++++++++++++---- 3 files changed, 26 insertions(+), 4 deletions(-) diff --git a/packages/stream_chat/CHANGELOG.md b/packages/stream_chat/CHANGELOG.md index 1998c95779..d0ba0436b0 100644 --- a/packages/stream_chat/CHANGELOG.md +++ b/packages/stream_chat/CHANGELOG.md @@ -1,3 +1,9 @@ +# Upcoming + +🐞 Fixed + +- Fixed `StreamChatClient.queryDrafts` not forwarding the `filter` argument to the API. + ## 9.23.0 - Minor bug fixes and improvements diff --git a/packages/stream_chat/lib/src/client/client.dart b/packages/stream_chat/lib/src/client/client.dart index 6682ec28cc..872d70cdb7 100644 --- a/packages/stream_chat/lib/src/client/client.dart +++ b/packages/stream_chat/lib/src/client/client.dart @@ -1914,6 +1914,7 @@ class StreamChatClient { PaginationParams? pagination, }) => _chatApi.message.queryDrafts( + filter: filter, sort: sort, pagination: pagination, ); diff --git a/packages/stream_chat/test/src/client/client_test.dart b/packages/stream_chat/test/src/client/client_test.dart index 932398336d..a41ea7bda7 100644 --- a/packages/stream_chat/test/src/client/client_test.dart +++ b/packages/stream_chat/test/src/client/client_test.dart @@ -3255,6 +3255,10 @@ void main() { const channelId = 'test-channel-id'; const channelType = 'test-channel-type'; + final filter = Filter.equal('channel_cid', '$channelType:$channelId'); + final sort = [const SortOption.desc('created_at')]; + const pagination = PaginationParams(limit: 20); + final drafts = [ Draft( channelCid: '$channelType:$channelId', @@ -3263,15 +3267,26 @@ void main() { ) ]; - when(() => api.message.queryDrafts()) - .thenAnswer((_) async => QueryDraftsResponse()..drafts = drafts); + when(() => api.message.queryDrafts( + filter: filter, + sort: sort, + pagination: pagination, + )).thenAnswer((_) async => QueryDraftsResponse()..drafts = drafts); - final res = await client.queryDrafts(); + final res = await client.queryDrafts( + filter: filter, + sort: sort, + pagination: pagination, + ); expect(res, isNotNull); expect(res.drafts.length, drafts.length); - verify(() => api.message.queryDrafts()).called(1); + verify(() => api.message.queryDrafts( + filter: filter, + sort: sort, + pagination: pagination, + )).called(1); verifyNoMoreInteractions(api.message); });