From 252783adf64a37df926db4f08a5b6134056fe3fb Mon Sep 17 00:00:00 2001
From: Sahil Kumar <xdsahil@gmail.com>
Date: Fri, 19 Mar 2021 16:52:08 +0530
Subject: [PATCH] test(persistence): add getMessagesByCid along with pagination
 test in message, pinned message dao.

Signed-off-by: Sahil Kumar <xdsahil@gmail.com>
---
 .../test/src/dao/message_dao_test.dart        | 27 +++++++++++++++++++
 .../test/src/dao/pinned_message_dao_test.dart | 27 +++++++++++++++++++
 2 files changed, 54 insertions(+)

diff --git a/packages/stream_chat_persistence/test/src/dao/message_dao_test.dart b/packages/stream_chat_persistence/test/src/dao/message_dao_test.dart
index 7207002e..377c949e 100644
--- a/packages/stream_chat_persistence/test/src/dao/message_dao_test.dart
+++ b/packages/stream_chat_persistence/test/src/dao/message_dao_test.dart
@@ -241,6 +241,33 @@ void main() {
     }
   });
 
+  test('getMessagesByCid along with pagination', () async {
+    const cid = 'testCid';
+    const pagination = PaginationParams(
+      limit: 15,
+      lessThan: 'testMessageId${cid}25',
+      greaterThanOrEqual: 'testMessageId${cid}5',
+    );
+
+    // Should be empty initially
+    final messages = await messageDao.getMessagesByCid(
+      cid,
+      messagePagination: pagination,
+    );
+    expect(messages, isEmpty);
+
+    // Preparing test data
+    final insertedMessages = await _prepareTestData(cid, count: 30);
+    expect(insertedMessages, isNotEmpty);
+
+    // Fetched message should match the inserted messages
+    final fetchedMessages = await messageDao.getMessagesByCid(
+      cid,
+      messagePagination: pagination,
+    );
+    expect(fetchedMessages.length, 15);
+  });
+
   test('updateMessages', () async {
     const cid = 'testCid';
 
diff --git a/packages/stream_chat_persistence/test/src/dao/pinned_message_dao_test.dart b/packages/stream_chat_persistence/test/src/dao/pinned_message_dao_test.dart
index 3e197e2b..66875990 100644
--- a/packages/stream_chat_persistence/test/src/dao/pinned_message_dao_test.dart
+++ b/packages/stream_chat_persistence/test/src/dao/pinned_message_dao_test.dart
@@ -242,6 +242,33 @@ void main() {
     }
   });
 
+  test('getMessagesByCid along with pagination', () async {
+    const cid = 'testCid';
+    const pagination = PaginationParams(
+      limit: 15,
+      lessThan: 'testMessageId${cid}25',
+      greaterThanOrEqual: 'testMessageId${cid}5',
+    );
+
+    // Should be empty initially
+    final messages = await pinnedMessageDao.getMessagesByCid(
+      cid,
+      messagePagination: pagination,
+    );
+    expect(messages, isEmpty);
+
+    // Preparing test data
+    final insertedMessages = await _prepareTestData(cid, count: 30);
+    expect(insertedMessages, isNotEmpty);
+
+    // Fetched message should match the inserted messages
+    final fetchedMessages = await pinnedMessageDao.getMessagesByCid(
+      cid,
+      messagePagination: pagination,
+    );
+    expect(fetchedMessages.length, 15);
+  });
+
   test('updateMessages', () async {
     const cid = 'testCid';