fix(persistence): persist channel team field (#2700)

Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
Co-authored-by: Sahil Kumar <sahil@getstream.io>
Co-authored-by: VelikovPetar <petarvelikov95@gmail.com>
Co-authored-by: Sahil Kumar <xdsahil@gmail.com>

Author: 4 people

packages/stream_chat_persistence/CHANGELOG.md

@@ -4,6 +4,10 @@
 
 - Reduce the number of DB reads in the `ChatPersistenceClient.getChannelStates` method.
 
+🐛 Fixed
+
+- Fixed missing persistence of the `team` field on channel entities.
+
 🔄 Changed
 
 - Changed how dates are stored in the local cache, from integer seconds to ISO-8601 strings, in order to preserve millisecond precision.

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

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

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

@@ -48,6 +48,9 @@ class Channels extends Table {
   /// List of filter tags for this channel
   TextColumn get filterTags => text().nullable().map(ListConverter<String>())();
 
+  /// The team the channel belongs to
+  TextColumn get team => text().nullable()();
+
   /// Map of custom channel extraData
   TextColumn get extraData => text().nullable().map(MapConverter())();
 

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

@@ -21,6 +21,7 @@ extension ChannelEntityX on ChannelEntity {
       deletedAt: deletedAt,
       createdBy: createdBy,
       filterTags: filterTags,
+      team: team,
       extraData: extraData ?? {},
     );
   }
@@ -60,6 +61,7 @@ extension ChannelModelX on ChannelModel {
         messageCount: messageCount,
         createdById: createdBy?.id,
         filterTags: filterTags,
+        team: team,
         extraData: extraData,
       );
 }

packages/stream_chat_persistence/lib/src/mapper/channel_mapper.dart

@@ -87,6 +87,7 @@ void main() {
         createdAt: now,
         memberCount: index + 3,
         lastMessageAt: now.add(Duration(hours: index)),
+        team: 'testTeam$index',
       ),
     ).toList(growable: false);
 
@@ -124,6 +125,7 @@ void main() {
         expect(updatedChannel.cid, insertedChannel.cid);
         expect(updatedChannel.memberCount, insertedChannel.memberCount);
         expect(updatedChannel.filterTags, insertedChannel.filterTags);
+        expect(updatedChannel.team, insertedChannel.team);
 
         // Should match createdAt date
         expect(

packages/stream_chat_persistence/test/src/dao/channel_query_dao_test.dart

@@ -26,6 +26,7 @@ void main() {
       createdById: user.id,
       filterTags: ['tag1', 'tag2'],
       extraData: {'test_extra_data': 'testData'},
+      team: 'testTeam',
     );
 
     test('toChannelModel should map entity into ChannelModel', () {
@@ -45,6 +46,7 @@ void main() {
       expect(channelModel.createdBy!.id, entity.createdById);
       expect(channelModel.filterTags, entity.filterTags);
       expect(channelModel.extraData, entity.extraData);
+      expect(channelModel.team, entity.team);
     });
 
     test('toChannelState should map entity into ChannelState ', () {
@@ -109,6 +111,7 @@ void main() {
       createdBy: createdBy,
       filterTags: ['tag1', 'tag2'],
       extraData: {'test_extra_data': 'testData'},
+      team: 'testTeam',
     );
 
     final channelEntity = model.toEntity();
@@ -130,5 +133,6 @@ void main() {
     expect(channelEntity.filterTags, model.filterTags);
     expect(channelEntity.extraData, model.extraData);
     expect(channelEntity.createdById, model.createdBy!.id);
+    expect(channelEntity.team, model.team);
   });
 }