Add all pushes

lib/src/model/channel_presence.dart

@@ -13,6 +13,7 @@ import 'package:meta/meta.dart';
 sealed class CentrifugeChannelPresence extends CentrifugeChannelPush {
   /// {@macro channel_presence}
   const CentrifugeChannelPresence({
+    required super.timestamp,
     required super.channel,
     required this.info,
   });
@@ -31,6 +32,7 @@ sealed class CentrifugeChannelPresence extends CentrifugeChannelPush {
 final class CentrifugeJoin extends CentrifugeChannelPresence {
   /// {@macro channel_presence}
   const CentrifugeJoin({
+    required super.timestamp,
     required super.channel,
     required super.info,
   });
@@ -49,6 +51,7 @@ final class CentrifugeJoin extends CentrifugeChannelPresence {
 final class CentrifugeLeave extends CentrifugeChannelPresence {
   /// {@macro channel_presence}
   const CentrifugeLeave({
+    required super.timestamp,
     required super.channel,
     required super.info,
   });

lib/src/model/channel_push.dart

@@ -6,6 +6,7 @@ import 'package:centrifuge_dart/src/model/event.dart';
 abstract base class CentrifugeChannelPush extends CentrifugeEvent {
   /// {@template centrifuge_channel_event}
   const CentrifugeChannelPush({
+    required super.timestamp,
     required this.channel,
   });
 

lib/src/model/connect.dart

@@ -0,0 +1,54 @@
+import 'package:centrifuge_dart/src/model/channel_push.dart';
+
+/// {@template connect}
+/// Connect push from Centrifugo server.
+/// {@endtemplate}
+final class CentrifugeConnect extends CentrifugeChannelPush {
+  /// {@macro connect}
+  const CentrifugeConnect({
+    required super.timestamp,
+    required super.channel,
+    required this.client,
+    required this.version,
+    required this.data,
+    this.expires,
+    this.ttl,
+    this.pingInterval,
+    this.sendPong,
+    this.session,
+    this.node,
+  });
+
+  @override
+  String get type => 'connect';
+
+  /// Unique client connection ID server issued to this connection
+  final String client;
+
+  /// Server version
+  final String version;
+
+  /// Whether a server will expire connection at some point
+  final bool? expires;
+
+  /// Time when connection will be expired
+  final DateTime? ttl;
+
+  /// Client must periodically (once in 25 secs, configurable) send
+  /// ping messages to server. If pong has not beed received in 5 secs
+  /// (configurable) then client must disconnect from server
+  /// and try to reconnect with backoff strategy.
+  final Duration? pingInterval;
+
+  /// Whether to send asynchronous message when pong received.
+  final bool? sendPong;
+
+  /// Session ID.
+  final String? session;
+
+  /// Server node ID.
+  final String? node;
+
+  /// Payload of connected push.
+  final List<int> data;
+}

lib/src/model/disconnect.dart

@@ -0,0 +1,27 @@
+import 'package:centrifuge_dart/src/model/channel_push.dart';
+
+/// {@template disconnect}
+/// Disconnect push from Centrifugo server.
+/// {@endtemplate}
+final class CentrifugeDisconnect extends CentrifugeChannelPush {
+  /// {@macro disconnect}
+  const CentrifugeDisconnect({
+    required super.timestamp,
+    required super.channel,
+    required this.code,
+    required this.reason,
+    required this.reconnect,
+  });
+
+  @override
+  String get type => 'disconnect';
+
+  /// Code of disconnect.
+  final int code;
+
+  /// Reason of disconnect.
+  final String reason;
+
+  /// Reconnect flag.
+  final bool reconnect;
+}

lib/src/model/event.dart

@@ -6,8 +6,13 @@ import 'package:meta/meta.dart';
 @immutable
 abstract base class CentrifugeEvent {
   /// {@template centrifuge_event}
-  const CentrifugeEvent();
+  const CentrifugeEvent({
+    required this.timestamp,
+  });
 
   /// Event type.
   abstract final String type;
+
+  /// Timestamp of event
+  final DateTime timestamp;
 }

lib/src/model/message.dart

@@ -0,0 +1,19 @@
+import 'package:centrifuge_dart/src/model/channel_push.dart';
+
+/// {@template message}
+/// Message push from Centrifugo server.
+/// {@endtemplate}
+final class CentrifugeMessage extends CentrifugeChannelPush {
+  /// {@macro message}
+  const CentrifugeMessage({
+    required super.timestamp,
+    required super.channel,
+    required this.data,
+  });
+
+  @override
+  String get type => 'message';
+
+  /// Payload of message.
+  final List<int> data;
+}

lib/src/model/publication.dart

@@ -11,6 +11,7 @@ import 'package:meta/meta.dart';
 final class CentrifugePublication extends CentrifugeChannelPush {
   /// {@macro publication}
   const CentrifugePublication({
+    required super.timestamp,
     required super.channel,
     required this.data,
     this.offset,

lib/src/model/refresh.dart

@@ -1,5 +1,28 @@
+import 'package:centrifuge_dart/src/model/channel_push.dart';
 import 'package:meta/meta.dart';
 
+/// {@template refresh}
+/// Refresh push from Centrifugo server.
+/// {@endtemplate}
+final class CentrifugeRefresh extends CentrifugeChannelPush {
+  /// {@macro refresh}
+  const CentrifugeRefresh({
+    required super.timestamp,
+    required super.channel,
+    required this.expires,
+    this.ttl,
+  });
+
+  @override
+  String get type => 'refresh';
+
+  /// Whether a server will expire connection at some point
+  final bool expires;
+
+  /// Time when connection will be expired
+  final DateTime? ttl;
+}
+
 /// {@nodoc}
 @internal
 @immutable

lib/src/model/subscribe.dart

@@ -0,0 +1,32 @@
+import 'package:centrifuge_dart/src/model/channel_push.dart';
+import 'package:centrifuge_dart/src/model/stream_position.dart';
+
+/// {@template subscribe}
+/// Subscribe push from Centrifugo server.
+/// {@endtemplate}
+final class CentrifugeSubscribe extends CentrifugeChannelPush {
+  /// {@macro subscribe}
+  const CentrifugeSubscribe({
+    required super.timestamp,
+    required super.channel,
+    required this.positioned,
+    required this.recoverable,
+    required this.data,
+    required this.streamPosition,
+  });
+
+  @override
+  String get type => 'subscribe';
+
+  /// Whether subscription is positioned.
+  final bool positioned;
+
+  /// Whether subscription is recoverable.
+  final bool recoverable;
+
+  /// Data attached to subscription.
+  final List<int> data;
+
+  /// Stream position.
+  final CentrifugeStreamPosition? streamPosition;
+}

lib/src/model/unsubscribe.dart

@@ -0,0 +1,23 @@
+import 'package:centrifuge_dart/src/model/channel_push.dart';
+
+/// {@template unsubscribe}
+/// Unsubscribe push from Centrifugo server.
+/// {@endtemplate}
+final class CentrifugeUnsubscribe extends CentrifugeChannelPush {
+  /// {@macro unsubscribe}
+  const CentrifugeUnsubscribe({
+    required super.timestamp,
+    required super.channel,
+    required this.code,
+    required this.reason,
+  });
+
+  @override
+  String get type => 'unsubscribe';
+
+  /// Code of unsubscribe.
+  final int code;
+
+  /// Reason of unsubscribe.
+  final String reason;
+}