chore(persistence): fix drift generated code and tests (#2039)

Author: xsahil03x

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

@@ -43,7 +43,7 @@ class Channels extends Table {
   TextColumn get createdById => text().nullable()();
 
   /// Map of custom channel extraData
-  TextColumn get extraData => text().nullable().map(MapConverter<Object?>())();
+  TextColumn get extraData => text().nullable().map(MapConverter())();
 
   @override
   Set<Column> get primaryKey => {cid};

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

@@ -124,7 +124,7 @@ class Messages extends Table {
       text().nullable().map(NullableMapConverter<String>())();
 
   /// Message custom extraData
-  TextColumn get extraData => text().nullable().map(MapConverter<Object?>())();
+  TextColumn get extraData => text().nullable().map(MapConverter())();
 
   @override
   Set<Column> get primaryKey => {id};

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

@@ -23,7 +23,7 @@ class Reactions extends Table {
   IntColumn get score => integer().withDefault(const Constant(0))();
 
   /// Reaction custom extraData
-  TextColumn get extraData => text().nullable().map(MapConverter<Object?>())();
+  TextColumn get extraData => text().nullable().map(MapConverter())();
 
   @override
   Set<Column> get primaryKey => {

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

@@ -30,7 +30,7 @@ class Users extends Table {
   BoolColumn get banned => boolean().withDefault(const Constant(false))();
 
   /// Map of custom user extraData
-  TextColumn get extraData => text().map(MapConverter<Object?>())();
+  TextColumn get extraData => text().map(MapConverter())();
 
   @override
   Set<Column> get primaryKey => {id};

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

@@ -28,6 +28,7 @@ extension PinnedMessageEntityX on PinnedMessageEntity {
         localUpdatedAt: localUpdatedAt,
         deletedAt: remoteDeletedAt,
         localDeletedAt: localDeletedAt,
+        messageTextUpdatedAt: messageTextUpdatedAt,
         id: id,
         type: type,
         state: MessageState.fromJson(jsonDecode(state)),
@@ -78,6 +79,7 @@ extension PMessageX on Message {
         userId: user?.id,
         remoteDeletedAt: remoteDeletedAt,
         localDeletedAt: localDeletedAt,
+        messageTextUpdatedAt: messageTextUpdatedAt,
         messageText: text,
         pinned: pinned,
         pinnedAt: pinnedAt,

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

@@ -55,6 +55,7 @@ void main() {
       state: jsonEncode(MessageState.sent),
       localUpdatedAt: DateTime.now(),
       remoteUpdatedAt: DateTime.now().add(const Duration(seconds: 1)),
+      messageTextUpdatedAt: DateTime.now().add(const Duration(minutes: 5)),
       extraData: {'extra_test_data': 'extraData'},
       userId: user.id,
       localDeletedAt: DateTime.now(),
@@ -99,6 +100,10 @@ void main() {
     expect(message.state, MessageState.fromJson(jsonDecode(entity.state)));
     expect(message.localUpdatedAt, isSameDateAs(entity.localUpdatedAt));
     expect(message.remoteUpdatedAt, isSameDateAs(entity.remoteUpdatedAt));
+    expect(
+      message.messageTextUpdatedAt,
+      isSameDateAs(entity.messageTextUpdatedAt),
+    );
     expect(message.extraData, entity.extraData);
     expect(message.user!.id, entity.userId);
     expect(message.localDeletedAt, isSameDateAs(entity.localDeletedAt));
@@ -166,6 +171,7 @@ void main() {
       ),
       localUpdatedAt: DateTime.now(),
       updatedAt: DateTime.now().add(const Duration(seconds: 1)),
+      messageTextUpdatedAt: DateTime.now().add(const Duration(minutes: 5)),
       extraData: const {'extra_test_data': 'extraData'},
       user: user,
       localDeletedAt: DateTime.now(),
@@ -200,6 +206,10 @@ void main() {
     expect(entity.state, jsonEncode(message.state));
     expect(entity.localUpdatedAt, isSameDateAs(message.localUpdatedAt));
     expect(entity.remoteUpdatedAt, isSameDateAs(message.remoteUpdatedAt));
+    expect(
+      entity.messageTextUpdatedAt,
+      isSameDateAs(message.messageTextUpdatedAt),
+    );
     expect(entity.extraData, message.extraData);
     expect(entity.userId, message.user!.id);
     expect(entity.localDeletedAt, isSameDateAs(message.localDeletedAt));

packages/stream_chat_persistence/test/src/mapper/message_mapper_test.dart

@@ -55,6 +55,7 @@ void main() {
       state: jsonEncode(MessageState.sent),
       localUpdatedAt: DateTime.now(),
       remoteUpdatedAt: DateTime.now().add(const Duration(seconds: 1)),
+      messageTextUpdatedAt: DateTime.now().add(const Duration(minutes: 5)),
       extraData: {'extra_test_data': 'extraData'},
       userId: user.id,
       localDeletedAt: DateTime.now(),
@@ -99,6 +100,10 @@ void main() {
     expect(message.state, MessageState.fromJson(jsonDecode(entity.state)));
     expect(message.localUpdatedAt, isSameDateAs(entity.localUpdatedAt));
     expect(message.remoteUpdatedAt, isSameDateAs(entity.remoteUpdatedAt));
+    expect(
+      message.messageTextUpdatedAt,
+      isSameDateAs(entity.messageTextUpdatedAt),
+    );
     expect(message.extraData, entity.extraData);
     expect(message.user!.id, entity.userId);
     expect(message.localDeletedAt, isSameDateAs(entity.localDeletedAt));
@@ -166,6 +171,7 @@ void main() {
       ),
       localUpdatedAt: DateTime.now(),
       updatedAt: DateTime.now().add(const Duration(seconds: 1)),
+      messageTextUpdatedAt: DateTime.now().add(const Duration(minutes: 5)),
       extraData: const {'extra_test_data': 'extraData'},
       user: user,
       localDeletedAt: DateTime.now(),
@@ -200,6 +206,10 @@ void main() {
     expect(entity.state, jsonEncode(message.state));
     expect(entity.localUpdatedAt, isSameDateAs(message.localUpdatedAt));
     expect(entity.remoteUpdatedAt, isSameDateAs(message.remoteUpdatedAt));
+    expect(
+      message.messageTextUpdatedAt,
+      isSameDateAs(entity.messageTextUpdatedAt),
+    );
     expect(entity.extraData, message.extraData);
     expect(entity.userId, message.user!.id);
     expect(entity.localDeletedAt, isSameDateAs(message.localDeletedAt));