Merge pull request #431 from GetStream/fix/mentionedUsers

fix: [CDS-299] mentioned users

packages/stream_chat/lib/src/api/channel.dart

@@ -22,7 +22,7 @@ class Channel {
     this._client,
     this._type,
     this._id, {
-    Map<String, Object> extraData = const {},
+    Map<String, Object?> extraData = const {},
   })  : _cid = _id != null ? '$_type:$_id' : null,
         _extraData = extraData {
     _client.logger.info('New Channel instance not initialized created');
@@ -630,7 +630,7 @@ class Channel {
   Future<SendReactionResponse> sendReaction(
     Message message,
     String type, {
-    Map<String, Object> extraData = const {},
+    Map<String, Object?> extraData = const {},
     bool enforceUnique = false,
   }) async {
     _checkInitialized();

packages/stream_chat/lib/src/client.dart

@@ -1194,7 +1194,7 @@ class StreamChatClient {
   Channel channel(
     String type, {
     String? id,
-    Map<String, Object> extraData = const {},
+    Map<String, Object?> extraData = const {},
   }) {
     if (id != null && state.channels.containsKey('$type:$id')) {
       return state.channels['$type:$id']!;

packages/stream_chat/lib/src/models/attachment.dart

@@ -114,7 +114,7 @@ class Attachment extends Equatable {
     includeIfNull: false,
     defaultValue: {},
   )
-  final Map<String, Object> extraData;
+  final Map<String, Object?> extraData;
 
   /// The attachment ID.
   ///
@@ -183,7 +183,7 @@ class Attachment extends Equatable {
     List<Action>? actions,
     AttachmentFile? file,
     UploadState? uploadState,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
   }) =>
       Attachment(
         id: id ?? this.id,

packages/stream_chat/lib/src/models/attachment.g.dart

@@ -30,10 +30,7 @@ Attachment _$AttachmentFromJson(Map<String, dynamic> json) {
             ?.map((e) => Action.fromJson(e as Map<String, dynamic>))
             .toList() ??
         [],
-    extraData: (json['extra_data'] as Map<String, dynamic>?)?.map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-          (k, e) => MapEntry(k, e as Object),
-        ) ??
-        {},
     file: json['file'] == null
         ? null
         : AttachmentFile.fromJson(json['file'] as Map<String, dynamic>),

packages/stream_chat/lib/src/models/attachment_file.freezed.dart

@@ -132,9 +132,8 @@ class _$PreparingCopyWithImpl<$Res> extends _$UploadStateCopyWithImpl<$Res>
   Preparing get _value => super._value as Preparing;
 }
 
-@JsonSerializable()
-
 /// @nodoc
+@JsonSerializable()
 class _$Preparing implements Preparing {
   const _$Preparing();
 
@@ -253,9 +252,8 @@ class _$InProgressCopyWithImpl<$Res> extends _$UploadStateCopyWithImpl<$Res>
   }
 }
 
-@JsonSerializable()
-
 /// @nodoc
+@JsonSerializable()
 class _$InProgress implements InProgress {
   const _$InProgress({required this.uploaded, required this.total});
 
@@ -382,9 +380,8 @@ class _$SuccessCopyWithImpl<$Res> extends _$UploadStateCopyWithImpl<$Res>
   Success get _value => super._value as Success;
 }
 
-@JsonSerializable()
-
 /// @nodoc
+@JsonSerializable()
 class _$Success implements Success {
   const _$Success();
 
@@ -497,9 +494,8 @@ class _$FailedCopyWithImpl<$Res> extends _$UploadStateCopyWithImpl<$Res>
   }
 }
 
-@JsonSerializable()
-
 /// @nodoc
+@JsonSerializable()
 class _$Failed implements Failed {
   const _$Failed({required this.error});
 

packages/stream_chat/lib/src/models/attachment_file.g.dart

@@ -8,10 +8,10 @@ part of 'attachment_file.dart';
 
 AttachmentFile _$AttachmentFileFromJson(Map<String, dynamic> json) {
   return AttachmentFile(
+    size: json['size'] as int?,
     path: json['path'] as String?,
     name: json['name'] as String?,
     bytes: _fromString(json['bytes'] as String?),
-    size: json['size'] as int?,
   );
 }
 

packages/stream_chat/lib/src/models/channel_model.dart

@@ -87,7 +87,7 @@ class ChannelModel {
     includeIfNull: false,
     defaultValue: {},
   )
-  final Map<String, Object> extraData;
+  final Map<String, Object?> extraData;
 
   /// The team the channel belongs to
   @JsonKey(includeIfNull: false, toJson: Serialization.readOnly)
@@ -132,7 +132,7 @@ class ChannelModel {
     DateTime? updatedAt,
     DateTime? deletedAt,
     int? memberCount,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
     String? team,
   }) =>
       ChannelModel(

packages/stream_chat/lib/src/models/channel_model.g.dart

@@ -31,10 +31,7 @@ ChannelModel _$ChannelModelFromJson(Map<String, dynamic> json) {
         ? null
         : DateTime.parse(json['deleted_at'] as String),
     memberCount: json['member_count'] as int? ?? 0,
-    extraData: (json['extra_data'] as Map<String, dynamic>?)?.map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-          (k, e) => MapEntry(k, e as Object),
-        ) ??
-        {},
     team: json['team'] as String?,
   );
 }

packages/stream_chat/lib/src/models/event.dart

@@ -93,7 +93,7 @@ class Event {
 
   /// Map of custom channel extraData
   @JsonKey(defaultValue: {})
-  final Map<String, Object> extraData;
+  final Map<String, Object?> extraData;
 
   /// Known top level fields.
   /// Useful for [Serialization] methods.
@@ -140,7 +140,7 @@ class Event {
     int? unreadChannels,
     bool? online,
     String? parentId,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
   }) =>
       Event(
         type: type ?? this.type,
@@ -180,7 +180,7 @@ class EventChannel extends ChannelModel {
     required DateTime updatedAt,
     DateTime? deletedAt,
     required int memberCount,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
   }) : super(
           id: id,
           type: type,

packages/stream_chat/lib/src/models/event.g.dart

@@ -38,10 +38,7 @@ Event _$EventFromJson(Map<String, dynamic> json) {
     channelId: json['channel_id'] as String?,
     channelType: json['channel_type'] as String?,
     parentId: json['parent_id'] as String?,
-    extraData: (json['extra_data'] as Map<String, dynamic>?)?.map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-          (k, e) => MapEntry(k, e as Object),
-        ) ??
-        {},
     isLocal: json['is_local'] as bool? ?? false,
   );
 }
@@ -89,10 +86,7 @@ EventChannel _$EventChannelFromJson(Map<String, dynamic> json) {
         ? null
         : DateTime.parse(json['deleted_at'] as String),
     memberCount: json['member_count'] as int? ?? 0,
-    extraData: (json['extra_data'] as Map<String, dynamic>?)?.map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-          (k, e) => MapEntry(k, e as Object),
-        ) ??
-        {},
   );
 }
 

packages/stream_chat/lib/src/models/message.dart

@@ -208,7 +208,7 @@ class Message extends Equatable {
     includeIfNull: false,
     defaultValue: {},
   )
-  final Map<String, Object> extraData;
+  final Map<String, Object?> extraData;
 
   /// True if the message is a system info
   bool get isSystem => type == 'system';
@@ -289,7 +289,7 @@ class Message extends Equatable {
     DateTime? pinnedAt,
     Object? pinExpires = _pinExpires,
     User? pinnedBy,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
     MessageSendingStatus? status,
     bool? skipPush,
   }) {

packages/stream_chat/lib/src/models/message.g.dart

@@ -63,10 +63,7 @@ Message _$MessageFromJson(Map<String, dynamic> json) {
     pinnedBy: json['pinned_by'] == null
         ? null
         : User.fromJson(json['pinned_by'] as Map<String, dynamic>),
-    extraData: (json['extra_data'] as Map<String, dynamic>?)?.map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-          (k, e) => MapEntry(k, e as Object),
-        ) ??
-        {},
     deletedAt: json['deleted_at'] == null
         ? null
         : DateTime.parse(json['deleted_at'] as String),

packages/stream_chat/lib/src/models/own_user.dart

@@ -23,7 +23,7 @@ class OwnUser extends User {
     DateTime? updatedAt,
     DateTime? lastActive,
     bool online = false,
-    Map<String, Object> extraData = const {},
+    Map<String, Object?> extraData = const {},
     bool banned = false,
   }) : super(
           id: id,

packages/stream_chat/lib/src/models/own_user.g.dart

@@ -34,9 +34,7 @@ OwnUser _$OwnUserFromJson(Map<String, dynamic> json) {
         ? null
         : DateTime.parse(json['last_active'] as String),
     online: json['online'] as bool? ?? false,
-    extraData: (json['extra_data'] as Map<String, dynamic>).map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-      (k, e) => MapEntry(k, e as Object),
-    ),
     banned: json['banned'] as bool? ?? false,
   );
 }

packages/stream_chat/lib/src/models/reaction.dart

@@ -15,7 +15,7 @@ class Reaction {
     this.user,
     String? userId,
     this.score = 0,
-    this.extraData,
+    this.extraData = const {},
   })  : userId = userId ?? user?.id,
         createdAt = createdAt ?? DateTime.now();
 
@@ -49,8 +49,11 @@ class Reaction {
   final String? userId;
 
   /// Reaction custom extraData
-  @JsonKey(includeIfNull: false)
+  @JsonKey(
-  final Map<String, Object>? extraData;
+    includeIfNull: false,
+    defaultValue: {},
+  )
+  final Map<String, Object?> extraData;
 
   /// Map of custom user extraData
   static const topLevelFields = [
@@ -75,7 +78,7 @@ class Reaction {
     User? user,
     String? userId,
     int? score,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
   }) =>
       Reaction(
         messageId: messageId ?? this.messageId,

packages/stream_chat/lib/src/models/reaction.g.dart

@@ -18,9 +18,7 @@ Reaction _$ReactionFromJson(Map<String, dynamic> json) {
         : User.fromJson(json['user'] as Map<String, dynamic>),
     userId: json['user_id'] as String?,
     score: json['score'] as int? ?? 0,
-    extraData: (json['extra_data'] as Map<String, dynamic>?)?.map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-      (k, e) => MapEntry(k, e as Object),
-    ),
   );
 }
 
@@ -40,6 +38,6 @@ Map<String, dynamic> _$ReactionToJson(Reaction instance) {
   writeNotNull('user', readonly(instance.user));
   val['score'] = instance.score;
   writeNotNull('user_id', readonly(instance.userId));
-  writeNotNull('extra_data', instance.extraData);
+  val['extra_data'] = instance.extraData;
   return val;
 }

packages/stream_chat/lib/src/models/user.dart

@@ -74,8 +74,11 @@ class User {
   final bool banned;
 
   /// Map of custom user extraData
-  @JsonKey(includeIfNull: false)
+  @JsonKey(
-  final Map<String, Object> extraData;
+    includeIfNull: false,
+    defaultValue: {},
+  )
+  final Map<String, Object?> extraData;
 
   @override
   int get hashCode => id.hashCode;
@@ -107,7 +110,7 @@ class User {
     DateTime? updatedAt,
     DateTime? lastActive,
     bool? online,
-    Map<String, Object>? extraData,
+    Map<String, Object?>? extraData,
     bool? banned,
     List<String>? teams,
   }) =>

packages/stream_chat/lib/src/models/user.g.dart

@@ -20,9 +20,7 @@ User _$UserFromJson(Map<String, dynamic> json) {
         ? null
         : DateTime.parse(json['last_active'] as String),
     online: json['online'] as bool? ?? false,
-    extraData: (json['extra_data'] as Map<String, dynamic>).map(
+    extraData: json['extra_data'] as Map<String, dynamic>? ?? {},
-      (k, e) => MapEntry(k, e as Object),
-    ),
     banned: json['banned'] as bool? ?? false,
     teams:
         (json['teams'] as List<dynamic>?)?.map((e) => e as String).toList() ??

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

@@ -57,7 +57,7 @@ class MoorChatDatabase extends _$MoorChatDatabase {
 
   // you should bump this number whenever you change or add a table definition.
   @override
-  int get schemaVersion => 2;
+  int get schemaVersion => 3;
 
   @override
   MigrationStrategy get migration => MigrationStrategy(

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

@@ -42,22 +42,20 @@ class ChannelEntity extends DataClass implements Insertable<ChannelEntity> {
   final String? createdById;
 
   /// Map of custom channel extraData
-  final Map<String, Object>? extraData;
+  final Map<String, Object?>? extraData;
-
+  ChannelEntity(
-  ChannelEntity({
+      {required this.id,
-    required this.id,
+      required this.type,
-    required this.type,
+      required this.cid,
-    required this.cid,
+      required this.config,
-    required this.config,
+      required this.frozen,
-    required this.frozen,
+      this.lastMessageAt,
-    this.lastMessageAt,
+      required this.createdAt,
-    required this.createdAt,
+      required this.updatedAt,
-    required this.updatedAt,
+      this.deletedAt,
-    this.deletedAt,
+      required this.memberCount,
-    required this.memberCount,
+      this.createdById,
-    this.createdById,
+      this.extraData});
-    this.extraData,
-  });
   factory ChannelEntity.fromData(
       Map<String, dynamic> data, GeneratedDatabase db,
       {String? prefix}) {
@@ -135,7 +133,7 @@ class ChannelEntity extends DataClass implements Insertable<ChannelEntity> {
       deletedAt: serializer.fromJson<DateTime?>(json['deletedAt']),
       memberCount: serializer.fromJson<int>(json['memberCount']),
       createdById: serializer.fromJson<String?>(json['createdById']),
-      extraData: serializer.fromJson<Map<String, Object>?>(json['extraData']),
+      extraData: serializer.fromJson<Map<String, Object?>?>(json['extraData']),
     );
   }
   @override
@@ -153,7 +151,7 @@ class ChannelEntity extends DataClass implements Insertable<ChannelEntity> {
       'deletedAt': serializer.toJson<DateTime?>(deletedAt),
       'memberCount': serializer.toJson<int>(memberCount),
       'createdById': serializer.toJson<String?>(createdById),
-      'extraData': serializer.toJson<Map<String, Object>?>(extraData),
+      'extraData': serializer.toJson<Map<String, Object?>?>(extraData),
     };
   }
 
@@ -169,7 +167,7 @@ class ChannelEntity extends DataClass implements Insertable<ChannelEntity> {
           Value<DateTime?> deletedAt = const Value.absent(),
           int? memberCount,
           Value<String?> createdById = const Value.absent(),
-          Value<Map<String, Object>?> extraData = const Value.absent()}) =>
+          Value<Map<String, Object?>?> extraData = const Value.absent()}) =>
       ChannelEntity(
         id: id ?? this.id,
         type: type ?? this.type,
@@ -257,7 +255,7 @@ class ChannelsCompanion extends UpdateCompanion<ChannelEntity> {
   final Value<DateTime?> deletedAt;
   final Value<int> memberCount;
   final Value<String?> createdById;
-  final Value<Map<String, Object>?> extraData;
+  final Value<Map<String, Object?>?> extraData;
   const ChannelsCompanion({
     this.id = const Value.absent(),
     this.type = const Value.absent(),
@@ -301,7 +299,7 @@ class ChannelsCompanion extends UpdateCompanion<ChannelEntity> {
     Expression<DateTime?>? deletedAt,
     Expression<int>? memberCount,
     Expression<String?>? createdById,
-    Expression<Map<String, Object>?>? extraData,
+    Expression<Map<String, Object?>?>? extraData,
   }) {
     return RawValuesInsertable({
       if (id != null) 'id': id,
@@ -331,7 +329,7 @@ class ChannelsCompanion extends UpdateCompanion<ChannelEntity> {
       Value<DateTime?>? deletedAt,
       Value<int>? memberCount,
       Value<String?>? createdById,
-      Value<Map<String, Object>?>? extraData}) {
+      Value<Map<String, Object?>?>? extraData}) {
     return ChannelsCompanion(
       id: id ?? this.id,
       type: type ?? this.type,
@@ -638,8 +636,8 @@ class $ChannelsTable extends Channels
 
   static TypeConverter<Map<String, dynamic>, String> $converter0 =
       MapConverter();
-  static TypeConverter<Map<String, Object>, String> $converter1 =
+  static TypeConverter<Map<String, Object?>, String> $converter1 =
-      MapConverter<Object>();
+      MapConverter<Object?>();
 }
 
 class MessageEntity extends DataClass implements Insertable<MessageEntity> {
@@ -714,7 +712,7 @@ class MessageEntity extends DataClass implements Insertable<MessageEntity> {
   final String? channelCid;
 
   /// Message custom extraData
-  final Map<String, Object>? extraData;
+  final Map<String, Object?>? extraData;
   MessageEntity(
       {required this.id,
       this.messageText,
@@ -901,7 +899,7 @@ class MessageEntity extends DataClass implements Insertable<MessageEntity> {
       pinExpires: serializer.fromJson<DateTime?>(json['pinExpires']),
       pinnedByUserId: serializer.fromJson<String?>(json['pinnedByUserId']),
       channelCid: serializer.fromJson<String?>(json['channelCid']),
-      extraData: serializer.fromJson<Map<String, Object>?>(json['extraData']),
+      extraData: serializer.fromJson<Map<String, Object?>?>(json['extraData']),
     );
   }
   @override
@@ -931,7 +929,7 @@ class MessageEntity extends DataClass implements Insertable<MessageEntity> {
       'pinExpires': serializer.toJson<DateTime?>(pinExpires),
       'pinnedByUserId': serializer.toJson<String?>(pinnedByUserId),
       'channelCid': serializer.toJson<String?>(channelCid),
-      'extraData': serializer.toJson<Map<String, Object>?>(extraData),
+      'extraData': serializer.toJson<Map<String, Object?>?>(extraData),
     };
   }
 
@@ -959,7 +957,7 @@ class MessageEntity extends DataClass implements Insertable<MessageEntity> {
           Value<DateTime?> pinExpires = const Value.absent(),
           Value<String?> pinnedByUserId = const Value.absent(),
           Value<String?> channelCid = const Value.absent(),
-          Value<Map<String, Object>?> extraData = const Value.absent()}) =>
+          Value<Map<String, Object?>?> extraData = const Value.absent()}) =>
       MessageEntity(
         id: id ?? this.id,
         messageText: messageText.present ? messageText.value : this.messageText,
@@ -1121,7 +1119,7 @@ class MessagesCompanion extends UpdateCompanion<MessageEntity> {
   final Value<DateTime?> pinExpires;
   final Value<String?> pinnedByUserId;
   final Value<String?> channelCid;
-  final Value<Map<String, Object>?> extraData;
+  final Value<Map<String, Object?>?> extraData;
   const MessagesCompanion({
     this.id = const Value.absent(),
     this.messageText = const Value.absent(),
@@ -1200,7 +1198,7 @@ class MessagesCompanion extends UpdateCompanion<MessageEntity> {
     Expression<DateTime?>? pinExpires,
     Expression<String?>? pinnedByUserId,
     Expression<String?>? channelCid,
-    Expression<Map<String, Object>?>? extraData,
+    Expression<Map<String, Object?>?>? extraData,
   }) {
     return RawValuesInsertable({
       if (id != null) 'id': id,
@@ -1254,7 +1252,7 @@ class MessagesCompanion extends UpdateCompanion<MessageEntity> {
       Value<DateTime?>? pinExpires,
       Value<String?>? pinnedByUserId,
       Value<String?>? channelCid,
-      Value<Map<String, Object>?>? extraData}) {
+      Value<Map<String, Object?>?>? extraData}) {
     return MessagesCompanion(
       id: id ?? this.id,
       messageText: messageText ?? this.messageText,
@@ -1818,8 +1816,8 @@ class $MessagesTable extends Messages
       MapConverter<int>();
   static TypeConverter<Map<String, int>, String> $converter4 =
       MapConverter<int>();
-  static TypeConverter<Map<String, Object>, String> $converter5 =
+  static TypeConverter<Map<String, Object?>, String> $converter5 =
-      MapConverter<Object>();
+      MapConverter<Object?>();
 }
 
 class PinnedMessageEntity extends DataClass
@@ -1895,7 +1893,7 @@ class PinnedMessageEntity extends DataClass
   final String? channelCid;
 
   /// Message custom extraData
-  final Map<String, Object>? extraData;
+  final Map<String, Object?>? extraData;
   PinnedMessageEntity(
       {required this.id,
       this.messageText,
@@ -2082,7 +2080,7 @@ class PinnedMessageEntity extends DataClass
       pinExpires: serializer.fromJson<DateTime?>(json['pinExpires']),
       pinnedByUserId: serializer.fromJson<String?>(json['pinnedByUserId']),
       channelCid: serializer.fromJson<String?>(json['channelCid']),
-      extraData: serializer.fromJson<Map<String, Object>?>(json['extraData']),
+      extraData: serializer.fromJson<Map<String, Object?>?>(json['extraData']),
     );
   }
   @override
@@ -2112,7 +2110,7 @@ class PinnedMessageEntity extends DataClass
       'pinExpires': serializer.toJson<DateTime?>(pinExpires),
       'pinnedByUserId': serializer.toJson<String?>(pinnedByUserId),
       'channelCid': serializer.toJson<String?>(channelCid),
-      'extraData': serializer.toJson<Map<String, Object>?>(extraData),
+      'extraData': serializer.toJson<Map<String, Object?>?>(extraData),
     };
   }
 
@@ -2140,7 +2138,7 @@ class PinnedMessageEntity extends DataClass
           Value<DateTime?> pinExpires = const Value.absent(),
           Value<String?> pinnedByUserId = const Value.absent(),
           Value<String?> channelCid = const Value.absent(),
-          Value<Map<String, Object>?> extraData = const Value.absent()}) =>
+          Value<Map<String, Object?>?> extraData = const Value.absent()}) =>
       PinnedMessageEntity(
         id: id ?? this.id,
         messageText: messageText.present ? messageText.value : this.messageText,
@@ -2302,7 +2300,7 @@ class PinnedMessagesCompanion extends UpdateCompanion<PinnedMessageEntity> {
   final Value<DateTime?> pinExpires;
   final Value<String?> pinnedByUserId;
   final Value<String?> channelCid;
-  final Value<Map<String, Object>?> extraData;
+  final Value<Map<String, Object?>?> extraData;
   const PinnedMessagesCompanion({
     this.id = const Value.absent(),
     this.messageText = const Value.absent(),
@@ -2381,7 +2379,7 @@ class PinnedMessagesCompanion extends UpdateCompanion<PinnedMessageEntity> {
     Expression<DateTime?>? pinExpires,
     Expression<String?>? pinnedByUserId,
     Expression<String?>? channelCid,
-    Expression<Map<String, Object>?>? extraData,
+    Expression<Map<String, Object?>?>? extraData,
   }) {
     return RawValuesInsertable({
       if (id != null) 'id': id,
@@ -2435,7 +2433,7 @@ class PinnedMessagesCompanion extends UpdateCompanion<PinnedMessageEntity> {
       Value<DateTime?>? pinExpires,
       Value<String?>? pinnedByUserId,
       Value<String?>? channelCid,
-      Value<Map<String, Object>?>? extraData}) {
+      Value<Map<String, Object?>?>? extraData}) {
     return PinnedMessagesCompanion(
       id: id ?? this.id,
       messageText: messageText ?? this.messageText,
@@ -3000,8 +2998,8 @@ class $PinnedMessagesTable extends PinnedMessages
       MapConverter<int>();
   static TypeConverter<Map<String, int>, String> $converter4 =
       MapConverter<int>();
-  static TypeConverter<Map<String, Object>, String> $converter5 =
+  static TypeConverter<Map<String, Object?>, String> $converter5 =
-      MapConverter<Object>();
+      MapConverter<Object?>();
 }
 
 class ReactionEntity extends DataClass implements Insertable<ReactionEntity> {
@@ -3021,7 +3019,7 @@ class ReactionEntity extends DataClass implements Insertable<ReactionEntity> {
   final int score;
 
   /// Reaction custom extraData
-  final Map<String, Object>? extraData;
+  final Map<String, Object?>? extraData;
   ReactionEntity(
       {required this.userId,
       required this.messageId,
@@ -3073,7 +3071,7 @@ class ReactionEntity extends DataClass implements Insertable<ReactionEntity> {
       type: serializer.fromJson<String>(json['type']),
       createdAt: serializer.fromJson<DateTime>(json['createdAt']),
       score: serializer.fromJson<int>(json['score']),
-      extraData: serializer.fromJson<Map<String, Object>?>(json['extraData']),
+      extraData: serializer.fromJson<Map<String, Object?>?>(json['extraData']),
     );
   }
   @override
@@ -3085,7 +3083,7 @@ class ReactionEntity extends DataClass implements Insertable<ReactionEntity> {
       'type': serializer.toJson<String>(type),
       'createdAt': serializer.toJson<DateTime>(createdAt),
       'score': serializer.toJson<int>(score),
-      'extraData': serializer.toJson<Map<String, Object>?>(extraData),
+      'extraData': serializer.toJson<Map<String, Object?>?>(extraData),
     };
   }
 
@@ -3095,7 +3093,7 @@ class ReactionEntity extends DataClass implements Insertable<ReactionEntity> {
           String? type,
           DateTime? createdAt,
           int? score,
-          Value<Map<String, Object>?> extraData = const Value.absent()}) =>
+          Value<Map<String, Object?>?> extraData = const Value.absent()}) =>
       ReactionEntity(
         userId: userId ?? this.userId,
         messageId: messageId ?? this.messageId,
@@ -3144,7 +3142,7 @@ class ReactionsCompanion extends UpdateCompanion<ReactionEntity> {
   final Value<String> type;
   final Value<DateTime> createdAt;
   final Value<int> score;
-  final Value<Map<String, Object>?> extraData;
+  final Value<Map<String, Object?>?> extraData;
   const ReactionsCompanion({
     this.userId = const Value.absent(),
     this.messageId = const Value.absent(),
@@ -3169,7 +3167,7 @@ class ReactionsCompanion extends UpdateCompanion<ReactionEntity> {
     Expression<String>? type,
     Expression<DateTime>? createdAt,
     Expression<int>? score,
-    Expression<Map<String, Object>?>? extraData,
+    Expression<Map<String, Object?>?>? extraData,
   }) {
     return RawValuesInsertable({
       if (userId != null) 'user_id': userId,
@@ -3187,7 +3185,7 @@ class ReactionsCompanion extends UpdateCompanion<ReactionEntity> {
       Value<String>? type,
       Value<DateTime>? createdAt,
       Value<int>? score,
-      Value<Map<String, Object>?>? extraData}) {
+      Value<Map<String, Object?>?>? extraData}) {
     return ReactionsCompanion(
       userId: userId ?? this.userId,
       messageId: messageId ?? this.messageId,
@@ -3357,8 +3355,8 @@ class $ReactionsTable extends Reactions
     return $ReactionsTable(_db, alias);
   }
 
-  static TypeConverter<Map<String, Object>, String> $converter0 =
+  static TypeConverter<Map<String, Object?>, String> $converter0 =
-      MapConverter<Object>();
+      MapConverter<Object?>();
 }
 
 class UserEntity extends DataClass implements Insertable<UserEntity> {
@@ -3384,7 +3382,7 @@ class UserEntity extends DataClass implements Insertable<UserEntity> {
   final bool banned;
 
   /// Map of custom user extraData
-  final Map<String, Object> extraData;
+  final Map<String, Object?> extraData;
   UserEntity(
       {required this.id,
       this.role,
@@ -3449,7 +3447,7 @@ class UserEntity extends DataClass implements Insertable<UserEntity> {
       lastActive: serializer.fromJson<DateTime?>(json['lastActive']),
       online: serializer.fromJson<bool>(json['online']),
       banned: serializer.fromJson<bool>(json['banned']),
-      extraData: serializer.fromJson<Map<String, Object>>(json['extraData']),
+      extraData: serializer.fromJson<Map<String, Object?>>(json['extraData']),
     );
   }
   @override
@@ -3463,7 +3461,7 @@ class UserEntity extends DataClass implements Insertable<UserEntity> {
       'lastActive': serializer.toJson<DateTime?>(lastActive),
       'online': serializer.toJson<bool>(online),
       'banned': serializer.toJson<bool>(banned),
-      'extraData': serializer.toJson<Map<String, Object>>(extraData),
+      'extraData': serializer.toJson<Map<String, Object?>>(extraData),
     };
   }
 
@@ -3475,7 +3473,7 @@ class UserEntity extends DataClass implements Insertable<UserEntity> {
           Value<DateTime?> lastActive = const Value.absent(),
           bool? online,
           bool? banned,
-          Map<String, Object>? extraData}) =>
+          Map<String, Object?>? extraData}) =>
       UserEntity(
         id: id ?? this.id,
         role: role.present ? role.value : this.role,
@@ -3536,7 +3534,7 @@ class UsersCompanion extends UpdateCompanion<UserEntity> {
   final Value<DateTime?> lastActive;
   final Value<bool> online;
   final Value<bool> banned;
-  final Value<Map<String, Object>> extraData;
+  final Value<Map<String, Object?>> extraData;
   const UsersCompanion({
     this.id = const Value.absent(),
     this.role = const Value.absent(),
@@ -3555,7 +3553,7 @@ class UsersCompanion extends UpdateCompanion<UserEntity> {
     this.lastActive = const Value.absent(),
     this.online = const Value.absent(),
     this.banned = const Value.absent(),
-    required Map<String, Object> extraData,
+    required Map<String, Object?> extraData,
   })   : id = Value(id),
         extraData = Value(extraData);
   static Insertable<UserEntity> custom({
@@ -3566,7 +3564,7 @@ class UsersCompanion extends UpdateCompanion<UserEntity> {
     Expression<DateTime?>? lastActive,
     Expression<bool>? online,
     Expression<bool>? banned,
-    Expression<Map<String, Object>>? extraData,
+    Expression<Map<String, Object?>>? extraData,
   }) {
     return RawValuesInsertable({
       if (id != null) 'id': id,
@@ -3588,7 +3586,7 @@ class UsersCompanion extends UpdateCompanion<UserEntity> {
       Value<DateTime?>? lastActive,
       Value<bool>? online,
       Value<bool>? banned,
-      Value<Map<String, Object>>? extraData}) {
+      Value<Map<String, Object?>>? extraData}) {
     return UsersCompanion(
       id: id ?? this.id,
       role: role ?? this.role,
@@ -3791,8 +3789,8 @@ class $UsersTable extends Users with TableInfo<$UsersTable, UserEntity> {
     return $UsersTable(_db, alias);
   }
 
-  static TypeConverter<Map<String, Object>, String> $converter0 =
+  static TypeConverter<Map<String, Object?>, String> $converter0 =
-      MapConverter<Object>();
+      MapConverter<Object?>();
 }
 
 class MemberEntity extends DataClass implements Insertable<MemberEntity> {

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

@@ -39,7 +39,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<Object?>())();
 
   @override
   Set<Column> get primaryKey => {cid};

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

@@ -81,7 +81,7 @@ class Messages extends Table {
       'NULLABLE REFERENCES channels(cid) ON DELETE CASCADE')();
 
   /// Message custom extraData
-  TextColumn get extraData => text().nullable().map(MapConverter<Object>())();
+  TextColumn get extraData => text().nullable().map(MapConverter<Object?>())();
 
   @override
   Set<Column> get primaryKey => {id};

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

@@ -22,7 +22,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<Object?>())();
 
   @override
   Set<Column> get primaryKey => {

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

@@ -27,7 +27,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<Object?>())();
 
   @override
   Set<Column> get primaryKey => {id};

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

@@ -42,6 +42,8 @@ extension MessageEntityX on MessageEntity {
         pinnedAt: pinnedAt,
         pinExpires: pinExpires,
         pinnedBy: pinnedBy,
+        mentionedUsers:
+            mentionedUsers.map((e) => User.fromJson(jsonDecode(e))).toList(),
       );
 }
 

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

@@ -5,7 +5,7 @@ import 'package:stream_chat_persistence/src/db/moor_chat_database.dart';
 extension ReactionEntityX on ReactionEntity {
   /// Maps a [ReactionEntity] into [Reaction]
   Reaction toReaction({User? user}) => Reaction(
-        extraData: extraData,
+        extraData: extraData ?? {},
         type: type,
         createdAt: createdAt,
         userId: userId,

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

@@ -48,7 +48,9 @@ void main() {
         (prev, curr) =>
             prev?..update(curr.type, (value) => value + 1, ifAbsent: () => 1),
       ),
-      mentionedUsers: const [],
+      mentionedUsers: [
+        jsonEncode(User(id: 'testuser')),
+      ],
       status: MessageSendingStatus.sent,
       updatedAt: DateTime.now(),
       extraData: {'extra_test_data': 'extraData'},
@@ -77,6 +79,11 @@ void main() {
     expect(message.createdAt, isSameDateAs(entity.createdAt));
     expect(message.shadowed, entity.shadowed);
     expect(message.showInChannel, entity.showInChannel);
+    for (var i = 0; i < message.mentionedUsers.length; i++) {
+      final entityMentionedUser =
+          User.fromJson(jsonDecode(entity.mentionedUsers[i]));
+      expect(message.mentionedUsers[i].id, entityMentionedUser.id);
+    }
     expect(message.replyCount, entity.replyCount);
     expect(message.reactionScores, entity.reactionScores);
     expect(message.reactionCounts, entity.reactionCounts);
@@ -135,6 +142,9 @@ void main() {
       shadowed: math.Random().nextBool(),
       showInChannel: math.Random().nextBool(),
       replyCount: 33,
+      mentionedUsers: [
+        User(id: 'testuser'),
+      ],
       reactionScores: {for (final r in reactions) r.type: r.score},
       reactionCounts: reactions.fold(
         {},
@@ -163,6 +173,8 @@ void main() {
     expect(entity.shadowed, message.shadowed);
     expect(entity.showInChannel, message.showInChannel);
     expect(entity.replyCount, message.replyCount);
+    expect(entity.mentionedUsers,
+        message.mentionedUsers.map((e) => jsonEncode(e)).toList());
     expect(entity.reactionScores, message.reactionScores);
     expect(entity.reactionCounts, message.reactionCounts);
     expect(entity.status, message.status);