Merge pull request #167 from GetStream/support-extraData-null-value

Author: sachaarbonel

packages/stream_feed/CHANGELOG.md

@@ -1,3 +1,9 @@
+## 0.4.0+1: 07/12/2021
+
+- fix: support null values `extraData`'s map
+- fix: utc date parsing with a `JsonConverter<DateTime,String>` and `intl`
+- fix: unread/unseen count in `NotificationFeedMeta` model
+  
 ## 0.4.0: 29/10/2021
 
 - breaking: `StreamFeedClient.connect` is now `StreamFeedClient` for better user session handling.

packages/stream_feed/README.md

@@ -227,7 +227,7 @@ await client.flatFeed('user', 'ken').updateActivityToTargets('foreign_id:1234',
 
 ### Realtime (Faye)
 
-Stream uses [Faye](http://faye.jcoglan.com) for realtime notifications. Below is quick guide to subscribing to feed changes
+Stream uses [Faye](https://faye.jcoglan.com) for realtime notifications. Below is quick guide to subscribing to feed changes
 
 ```dart
 

packages/stream_feed/lib/src/client/notification_feed.dart

@@ -9,6 +9,7 @@ import 'package:stream_feed/src/core/models/enrichment_flags.dart';
 import 'package:stream_feed/src/core/models/feed_id.dart';
 import 'package:stream_feed/src/core/models/filter.dart';
 import 'package:stream_feed/src/core/models/group.dart';
+import 'package:stream_feed/src/core/models/notification_feed_meta.dart';
 import 'package:stream_feed/src/core/util/default.dart';
 import 'package:stream_feed/src/core/util/token_helper.dart';
 
@@ -98,6 +99,22 @@ class NotificationFeed extends AggregatedFeed {
     return data;
   }
 
+  /// Retrieves unread an unseen count of notification feeds
+  Future<NotificationFeedMeta> getUnreadUnseenCounts({
+    Filter? filter,
+    ActivityMarker? marker,
+  }) async {
+    final options = {
+      'limit': 0,
+      ...filter?.params ?? Default.filter.params,
+      ...marker?.params ?? Default.marker.params,
+    };
+    final token = userToken ??
+        TokenHelper.buildFeedToken(secret!, TokenAction.read, feedId);
+    final result = await feed.getActivities(token, feedId, options);
+    return NotificationFeedMeta.fromJson(result.data!);
+  }
+
   /// Retrieve activities with reaction enrichment
   ///
   /// {@macro filter}

packages/stream_feed/lib/src/core/models/activity.dart

@@ -2,6 +2,7 @@ import 'package:equatable/equatable.dart';
 import 'package:json_annotation/json_annotation.dart';
 import 'package:stream_feed/src/core/models/feed_id.dart';
 import 'package:stream_feed/src/core/util/serializer.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 part 'activity.g.dart';
 
@@ -15,6 +16,7 @@ part 'activity.g.dart';
 ///
 /// Read more about Activities [here](https://getstream.io/activity-feeds/docs/flutter-dart/adding_activities/?language=dart) and [here](https://activitystrea.ms/specs/json/1.0/).
 @JsonSerializable()
+@DateTimeUTCConverter()
 class Activity extends Equatable {
   /// Builds an [Activity].
   const Activity({

packages/stream_feed/lib/src/core/models/activity_update.dart

@@ -1,11 +1,13 @@
 import 'package:equatable/equatable.dart';
 import 'package:json_annotation/json_annotation.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 part 'activity_update.g.dart';
 
 /// For updating only parts of one or more activities by changing,
 /// adding, or removing fields.
 @JsonSerializable()
+@DateTimeUTCConverter()
 class ActivityUpdate extends Equatable {
   /// Builds an [ActivityUpdate].
   const ActivityUpdate({

packages/stream_feed/lib/src/core/models/collection_entry.dart

@@ -1,5 +1,6 @@
 import 'package:equatable/equatable.dart';
 import 'package:json_annotation/json_annotation.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 import 'package:stream_feed/stream_feed.dart';
 
 part 'collection_entry.g.dart';
@@ -20,6 +21,7 @@ part 'collection_entry.g.dart';
 /// Collection endpoints can be used both client-side and server-side except
 /// the batch methods that are only available server-side.
 @JsonSerializable()
+@DateTimeUTCConverter()
 class CollectionEntry extends Equatable {
   /// Builds a [CollectionEntry].
   const CollectionEntry({

packages/stream_feed/lib/src/core/models/enriched_activity.dart

@@ -5,6 +5,7 @@ import 'package:stream_feed/src/core/models/collection_entry.dart';
 import 'package:stream_feed/src/core/models/reaction.dart';
 import 'package:stream_feed/src/core/models/user.dart';
 import 'package:stream_feed/src/core/util/serializer.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 part 'enriched_activity.g.dart';
 
@@ -30,9 +31,10 @@ part 'enriched_activity.g.dart';
 /// * T = [target]
 /// * Or = [origin]
 @JsonSerializable(genericArgumentFactories: true)
+@DateTimeUTCConverter()
 class GenericEnrichedActivity<A, Ob, T, Or> extends Equatable {
   //TODO: improve this
-  // when type parameter to can a default type in Dart
+  // when type parameter can have a default type in Dart
   //i.e. https://github.com/dart-lang/language/issues/283#issuecomment-839603127
   /// Builds an [GenericEnrichedActivity].
   const GenericEnrichedActivity({
@@ -62,7 +64,7 @@ class GenericEnrichedActivity<A, Ob, T, Or> extends Equatable {
     T Function(Object? json)? fromJsonT,
     Or Function(Object? json)? fromJsonOr,
   ]) =>
-      _$EnrichedActivityFromJson<A, Ob, T, Or>(
+      _$GenericEnrichedActivityFromJson<A, Ob, T, Or>(
         Serializer.moveKeysToRoot(json, topLevelFields)!,
         fromJsonA ??
             (jsonA) => (A == User)
@@ -176,7 +178,7 @@ class GenericEnrichedActivity<A, Ob, T, Or> extends Equatable {
 
   /// Map of custom user extraData
   @JsonKey(includeIfNull: false)
-  final Map<String, Object>? extraData;
+  final Map<String, Object?>? extraData;
 
   GenericEnrichedActivity<A, Ob, T, Or> copyWith({
     A? actor,
@@ -263,6 +265,7 @@ class GenericEnrichedActivity<A, Ob, T, Or> extends Equatable {
     Object? Function(Or value) toJsonOr,
   ) =>
       Serializer.moveKeysToMapInPlace(
-          _$EnrichedActivityToJson(this, toJsonA, toJsonOb, toJsonT, toJsonOr),
+          _$GenericEnrichedActivityToJson(
+              this, toJsonA, toJsonOb, toJsonT, toJsonOr),
           topLevelFields);
 }

packages/stream_feed/lib/src/core/models/enriched_activity.g.dart

@@ -1,12 +1,14 @@
 import 'package:equatable/equatable.dart';
 import 'package:json_annotation/json_annotation.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 part 'follow.g.dart';
 
 /// {@template follow}
 /// Model for the follower of a feed
 /// {@endtemplate}
 @JsonSerializable()
+@DateTimeUTCConverter()
 class Follow extends Equatable {
   /// Builds a [Follow]
   const Follow({

packages/stream_feed/lib/src/core/models/follow.dart

@@ -1,11 +1,14 @@
 import 'package:equatable/equatable.dart';
 import 'package:stream_feed/src/core/util/extension.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 /// A model that wraps [foreignID] and [time]
 class ForeignIdTimePair extends Equatable {
   /// Builds a [ForeignIdTimePair].
   const ForeignIdTimePair(this.foreignID, this.time);
 
+  static const _converter = DateTimeUTCConverter();
+
   /// The foreign id of an activity
   final String foreignID;
 
@@ -19,7 +22,7 @@ class ForeignIdTimePair extends Equatable {
       final pair = it as List;
       checkArgument(pair.length == 2, 'Invalid foreignIdTime pair');
       final foreignId = pair[0] as String;
-      final time = DateTime.parse(pair[1] as String);
+      final time = _converter.fromJson(pair[1] as String);
       return ForeignIdTimePair(foreignId, time);
     }).toList(growable: false);
   }

packages/stream_feed/lib/src/core/models/follow.g.dart

@@ -1,10 +1,12 @@
 import 'package:equatable/equatable.dart';
 import 'package:json_annotation/json_annotation.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 part 'group.g.dart';
 
 /// An aggregated group type.
 @JsonSerializable(createToJson: true, genericArgumentFactories: true)
+@DateTimeUTCConverter()
 class Group<T> extends Equatable {
   /// [Group] constructor
   const Group({

packages/stream_feed/lib/src/core/models/foreign_id_time_pair.dart

@@ -16,6 +16,7 @@ export 'following.dart';
 export 'foreign_id_time_pair.dart';
 export 'group.dart';
 export 'lookup_attribute.dart';
+export 'notification_feed_meta.dart';
 export 'open_graph_data.dart';
 export 'reaction.dart';
 export 'realtime_message.dart';

packages/stream_feed/lib/src/core/models/group.dart

@@ -0,0 +1,26 @@
+import 'package:equatable/equatable.dart';
+import 'package:json_annotation/json_annotation.dart';
+
+part 'notification_feed_meta.g.dart';
+
+@JsonSerializable(createToJson: true)
+class NotificationFeedMeta extends Equatable {
+  const NotificationFeedMeta({
+    required this.unreadCount,
+    required this.unseenCount,
+  });
+
+  factory NotificationFeedMeta.fromJson(Map json) =>
+      _$NotificationFeedMetaFromJson(json);
+
+  Map<String, dynamic> toJson() => _$NotificationFeedMetaToJson(this);
+
+  @JsonKey(name: 'unread')
+  final int unreadCount;
+
+  @JsonKey(name: 'unseen')
+  final int unseenCount;
+
+  @override
+  List<Object?> get props => [unreadCount, unseenCount];
+}

packages/stream_feed/lib/src/core/models/index.dart

@@ -3,6 +3,7 @@ import 'package:json_annotation/json_annotation.dart';
 import 'package:stream_feed/src/core/models/feed_id.dart';
 import 'package:stream_feed/src/core/models/user.dart';
 import 'package:stream_feed/src/core/util/serializer.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 import 'package:stream_feed/stream_feed.dart';
 
 part 'reaction.g.dart';
@@ -15,6 +16,7 @@ part 'reaction.g.dart';
 /// Reactions are automatically returned to feeds' activities at read time
 /// when the reactions parameters are used.
 @JsonSerializable()
+@DateTimeUTCConverter()
 class Reaction extends Equatable {
   /// Builds a [Reaction].
   const Reaction({

packages/stream_feed/lib/src/core/models/notification_feed_meta.dart

@@ -4,6 +4,7 @@ import 'package:json_annotation/json_annotation.dart';
 import 'package:stream_feed/src/core/models/feed_id.dart';
 
 import 'package:stream_feed/src/core/models/foreign_id_time_pair.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 import 'package:stream_feed/stream_feed.dart';
 
 part 'realtime_message.g.dart';
@@ -23,6 +24,7 @@ part 'realtime_message.g.dart';
 /// The only thing you don’t get is the enriched reactions like `own_reaction`
 /// or `latest_reactions`
 @JsonSerializable(genericArgumentFactories: true)
+@DateTimeUTCConverter()
 class RealtimeMessage<A, Ob, T, Or> extends Equatable {
   /// Builds a [RealtimeMessage].
   const RealtimeMessage({

packages/stream_feed/lib/src/core/models/notification_feed_meta.g.dart

@@ -1,6 +1,7 @@
 import 'package:equatable/equatable.dart';
 import 'package:json_annotation/json_annotation.dart';
 import 'package:stream_feed/src/core/util/serializer.dart';
+import 'package:stream_feed/src/core/util/utc_converter.dart';
 
 part 'user.g.dart';
 
@@ -11,6 +12,7 @@ part 'user.g.dart';
 /// When stored in activities, users are automatically enriched by Stream.
 /// {@endtemplate}
 @JsonSerializable()
+@DateTimeUTCConverter()
 class User extends Equatable {
   /// Builds a [User].
   const User({

packages/stream_feed/lib/src/core/models/reaction.dart

@@ -0,0 +1,24 @@
+import 'package:intl/intl.dart';
+import 'package:json_annotation/json_annotation.dart';
+
+class DateTimeUTCConverter implements JsonConverter<DateTime, String> {
+  const DateTimeUTCConverter();
+  static final DateFormat FORMAT = DateFormat('yyyy-MM-ddTHH:mm:ssZ');
+
+  @override
+  DateTime fromJson(String json) => FORMAT.parse(json, true);
+
+  @override
+  String toJson(DateTime json) => formatDateWithOffset(json);
+}
+
+String formatDateWithOffset(DateTime date) {
+  String twoDigits(int n) => n >= 10 ? '$n' : '0$n';
+
+  final hours = twoDigits(date.timeZoneOffset.inHours.abs());
+  final minutes = twoDigits(date.timeZoneOffset.inMinutes.remainder(60));
+  final sign = date.timeZoneOffset.inHours > 0 ? '+' : '-';
+  final formattedDate = DateFormat('yyyy-MM-ddTHH:mm:ss').format(date);
+
+  return '$formattedDate$sign$hours:$minutes';
+}

packages/stream_feed/lib/src/core/models/realtime_message.dart

@@ -1,3 +1,3 @@
 /// Current package version
 /// Used in [HttpClient] to build the `x-stream-client` header
-const String packageVersion = '0.4.0';
+const String packageVersion = '0.4.0+1';

packages/stream_feed/lib/src/core/models/user.dart

@@ -1,6 +1,6 @@
 name: stream_feed
 description: Stream Feed official Dart SDK. Build your own feed experience using Dart and Flutter. 
-version: 0.4.0
+version: 0.4.0+1
 repository: https://github.com/GetStream/stream-feed-flutter
 issue_tracker: https://github.com/GetStream/stream-feed-flutter/issues
 homepage: https://getstream.io/
@@ -13,6 +13,7 @@ dependencies:
   equatable: ^2.0.0
   faye_dart: ^0.1.0
   http_parser: ^4.0.0
+  intl: ^0.17.0
   jose: ^0.3.2
   json_annotation: ^4.0.1
   logging: ^1.0.1