perf(persistence): add indexes to speed up offline channel-list reads (v9)

packages/stream_chat_persistence/CHANGELOG.md

@@ -8,6 +8,8 @@
 
 - Read only the thread replies matching the `PaginationParams` from DB when calling `MessageDao.getThreadMessagesByParentId` instead of reading all replies for the thread and applying pagination in memory.
 - Read only the messages matching the `PaginationParams` from DB when calling `PinnedMessageDao.getMessagesByCid` instead of reading all pinned messages for the channel and applying pagination in memory.
+- Add indices on the `channel_cid` column on the `Messages`, `Members`, and `Reads` tables to improve read times on large databases.
+- Add indices on the `message_id` column on the `Reactions` table to improve read times on large databases.
 
 🐞 Fixed
 

packages/stream_chat_persistence/lib/src/db/drift_chat_database.dart

@@ -56,7 +56,7 @@ class DriftChatDatabase extends _$DriftChatDatabase {
 
   // you should bump this number whenever you change or add a table definition.
   @override
-  int get schemaVersion => 30;
+  int get schemaVersion => 31;
 
   // Store DateTime as ISO-8601 text to preserve sub-second precision.
   @override

packages/stream_chat_persistence/lib/src/entity/members.dart

@@ -5,6 +5,7 @@ import 'package:stream_chat_persistence/src/entity/channels.dart';
 
 /// Represents a [Members] table in [DriftChatDatabase].
 @DataClassName('MemberEntity')
+@TableIndex(name: 'idx_members_channel_cid', columns: {#channelCid})
 class Members extends Table {
   /// The interested user id
   TextColumn get userId => text()();

packages/stream_chat_persistence/lib/src/entity/messages.dart

@@ -7,6 +7,7 @@ import 'package:stream_chat_persistence/src/entity/channels.dart';
 
 /// Represents a [Messages] table in [DriftChatDatabase].
 @DataClassName('MessageEntity')
+@TableIndex(name: 'idx_messages_channel_cid', columns: {#channelCid})
 class Messages extends Table {
   /// The message id
   TextColumn get id => text()();

packages/stream_chat_persistence/lib/src/entity/reactions.dart

@@ -5,6 +5,7 @@ import 'package:stream_chat_persistence/src/entity/messages.dart';
 
 /// Represents a [Reactions] table in [DriftChatDatabase].
 @DataClassName('ReactionEntity')
+@TableIndex(name: 'idx_reactions_message_id', columns: {#messageId})
 class Reactions extends Table {
   /// The id of the user that sent the reaction
   TextColumn get userId => text()();

packages/stream_chat_persistence/lib/src/entity/reads.dart

@@ -4,6 +4,7 @@ import 'package:stream_chat_persistence/src/entity/channels.dart';
 
 /// Represents a [Reads] table in [DriftChatDatabase].
 @DataClassName('ReadEntity')
+@TableIndex(name: 'idx_reads_channel_cid', columns: {#channelCid})
 class Reads extends Table {
   /// Date of the read event
   DateTimeColumn get lastRead => dateTime()();