Fix realtime connection fields

android/src/main/java/io/ably/flutter/plugin/AblyMethodCallHandler.java

@@ -112,6 +112,12 @@ public AblyMethodCallHandler(final MethodChannel methodChannel,
     _map.put(PlatformConstants.PlatformMethod.restAuthGetClientId,
             (methodCall, result) -> authMethodHandler.clientId(methodCall, result, AuthMethodHandler.Type.Rest));
 
+    // Connection specific handlers
+    _map.put(PlatformConstants.PlatformMethod.connectionId, this::connectionId);
+    _map.put(PlatformConstants.PlatformMethod.connectionKey, this::connectionKey);
+    _map.put(PlatformConstants.PlatformMethod.connectionRecoveryKey, this::connectionRecoveryKey);
+    _map.put(PlatformConstants.PlatformMethod.connectionErrorReason, this::connectionErrorReason);
+
     // Push Notifications
     _map.put(PlatformConstants.PlatformMethod.pushActivate, this::pushActivate);
     _map.put(PlatformConstants.PlatformMethod.pushDeactivate, this::pushDeactivate);
@@ -559,6 +565,30 @@ private void restTime(@NonNull MethodCall methodCall, @NonNull MethodChannel.Res
         time(result, instanceStore.getRest(ablyMessage.handle));
     }
 
+  private void connectionId(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+    final AblyFlutterMessage ablyMessage = (AblyFlutterMessage) methodCall.arguments;
+    AblyRealtime realtime = instanceStore.getRealtime(ablyMessage.handle);
+    result.success(realtime.connection.id);
+  }
+
+  private void connectionKey(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+    final AblyFlutterMessage ablyMessage = (AblyFlutterMessage) methodCall.arguments;
+    AblyRealtime realtime = instanceStore.getRealtime(ablyMessage.handle);
+    result.success(realtime.connection.key);
+  }
+
+  private void connectionRecoveryKey(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+    final AblyFlutterMessage ablyMessage = (AblyFlutterMessage) methodCall.arguments;
+    AblyRealtime realtime = instanceStore.getRealtime(ablyMessage.handle);
+    result.success(realtime.connection.recoveryKey);
+  }
+
+  private void connectionErrorReason(@NonNull MethodCall methodCall, @NonNull MethodChannel.Result result) {
+    final AblyFlutterMessage ablyMessage = (AblyFlutterMessage) methodCall.arguments;
+    AblyRealtime realtime = instanceStore.getRealtime(ablyMessage.handle);
+    result.success(realtime.connection.reason);
+  }
+
     private void time(@NonNull MethodChannel.Result result, AblyBase client) {
         Callback<Long> callback = new Callback<Long>() {
             @Override

android/src/main/java/io/ably/flutter/plugin/generated/PlatformConstants.java

@@ -77,6 +77,12 @@ static final public class PlatformMethod {
         public static final String realtimeAuthCreateTokenRequest = "realtimeAuthCreateTokenRequest";
         public static final String realtimeAuthRequestToken = "realtimeAuthRequestToken";
         public static final String realtimeAuthGetClientId = "realtimeAuthGetClientId";
+
+        public static final String connectionId = "connectionId";
+        public static final String connectionKey = "connectionKey";
+        public static final String connectionRecoveryKey = "connectionRecoveryKey";
+        public static final String connectionErrorReason = "connectionErrorReason";
+
         public static final String pushActivate = "pushActivate";
         public static final String pushDeactivate = "pushDeactivate";
         public static final String pushReset = "pushReset";

ios/Classes/AblyFlutter.m

@@ -586,7 +586,6 @@ -(void)reset;
 
 static const FlutterHandler _restTime = ^void(AblyFlutter *const ably, FlutterMethodCall *const call, const FlutterResult result) {
     AblyFlutterMessage *const ablyMessage = call.arguments;
-
     AblyInstanceStore *const instanceStore = [ably instanceStore];
     ARTRest *const rest = [instanceStore restFrom:ablyMessage.handle];
 
@@ -599,6 +598,38 @@ -(void)reset;
     }];
 };
 
+static const FlutterHandler _connectionId = ^void(AblyFlutter *const ably, FlutterMethodCall *const call, const FlutterResult result) {
+    AblyFlutterMessage *const ablyMessage = call.arguments;
+    AblyInstanceStore *const instanceStore = [ably instanceStore];
+    ARTRealtime *const realtime = [instanceStore realtimeFrom:ablyMessage.handle];
+    NSString *const connectionId = [realtime.connection id];
+    result(connectionId);
+};
+
+static const FlutterHandler _connectionKey = ^void(AblyFlutter *const ably, FlutterMethodCall *const call, const FlutterResult result) {
+    AblyFlutterMessage *const ablyMessage = call.arguments;
+    AblyInstanceStore *const instanceStore = [ably instanceStore];
+    ARTRealtime *const realtime = [instanceStore realtimeFrom:ablyMessage.handle];
+    NSString *const connectionKey = [realtime.connection key];
+    result(connectionKey);
+};
+
+static const FlutterHandler _connectionErrorReason = ^void(AblyFlutter *const ably, FlutterMethodCall *const call, const FlutterResult result) {
+    AblyFlutterMessage *const ablyMessage = call.arguments;
+    AblyInstanceStore *const instanceStore = [ably instanceStore];
+    ARTRealtime *const realtime = [instanceStore realtimeFrom:ablyMessage.handle];
+    ARTErrorInfo* connectionError = [realtime.connection errorReason];
+    result(connectionError);
+};
+
+static const FlutterHandler _connectionRecoveryKey = ^void(AblyFlutter *const ably, FlutterMethodCall *const call, const FlutterResult result) {
+    AblyFlutterMessage *const ablyMessage = call.arguments;
+    AblyInstanceStore *const instanceStore = [ably instanceStore];
+    ARTRealtime *const realtime = [instanceStore realtimeFrom:ablyMessage.handle];
+    NSString *const connectionRecoveryKey = [realtime.connection recoveryKey];
+    result(connectionRecoveryKey);
+};
+
 static const FlutterHandler _getNextPage = ^void(AblyFlutter *const ably, FlutterMethodCall *const call, const FlutterResult result) {
     AblyFlutterMessage *const ablyMessage = call.arguments;
 
@@ -741,6 +772,11 @@ -(instancetype)initWithChannel:(FlutterMethodChannel *const)channel
         AblyPlatformMethod_releaseRealtimeChannel: _releaseRealtimeChannel,
         AblyPlatformMethod_realtimeTime:_realtimeTime,
         AblyPlatformMethod_restTime:_restTime,
+        // Connection fields
+        AblyPlatformMethod_connectionId:_connectionId,
+        AblyPlatformMethod_connectionKey:_connectionKey,
+        AblyPlatformMethod_connectionRecoveryKey:_connectionRecoveryKey,
+        AblyPlatformMethod_connectionErrorReason:_connectionErrorReason,
         // Push Notifications
         AblyPlatformMethod_pushActivate: PushHandlers.activate,
         AblyPlatformMethod_pushRequestPermission: PushHandlers.requestPermission,

ios/Classes/codec/AblyPlatformConstants.h

@@ -75,6 +75,12 @@ extern NSString *const AblyPlatformMethod_realtimeAuthAuthorize;
 extern NSString *const AblyPlatformMethod_realtimeAuthCreateTokenRequest;
 extern NSString *const AblyPlatformMethod_realtimeAuthRequestToken;
 extern NSString *const AblyPlatformMethod_realtimeAuthGetClientId;
+
+extern NSString *const AblyPlatformMethod_connectionId;
+extern NSString *const AblyPlatformMethod_connectionKey;
+extern NSString *const AblyPlatformMethod_connectionRecoveryKey;
+extern NSString *const AblyPlatformMethod_connectionErrorReason;
+
 extern NSString *const AblyPlatformMethod_pushActivate;
 extern NSString *const AblyPlatformMethod_pushDeactivate;
 extern NSString *const AblyPlatformMethod_pushReset;

ios/Classes/codec/AblyPlatformConstants.m

@@ -44,6 +44,12 @@
 NSString *const AblyPlatformMethod_realtimeAuthCreateTokenRequest= @"realtimeAuthCreateTokenRequest";
 NSString *const AblyPlatformMethod_realtimeAuthRequestToken= @"realtimeAuthRequestToken";
 NSString *const AblyPlatformMethod_realtimeAuthGetClientId= @"realtimeAuthGetClientId";
+
+NSString *const AblyPlatformMethod_connectionId = @"connectionId";
+NSString *const AblyPlatformMethod_connectionKey = @"connectionKey";
+NSString *const AblyPlatformMethod_connectionRecoveryKey = @"connectionRecoveryKey";
+NSString *const AblyPlatformMethod_connectionErrorReason = @"connectionErrorReason";
+
 NSString *const AblyPlatformMethod_pushActivate= @"pushActivate";
 NSString *const AblyPlatformMethod_pushDeactivate= @"pushDeactivate";
 NSString *const AblyPlatformMethod_pushReset= @"pushReset";

lib/src/generated/platform_constants.dart

@@ -76,6 +76,12 @@ class PlatformMethod {
       'realtimeAuthCreateTokenRequest';
   static const String realtimeAuthRequestToken = 'realtimeAuthRequestToken';
   static const String realtimeAuthGetClientId = 'realtimeAuthGetClientId';
+
+  static const String connectionId = 'connectionId';
+  static const String connectionKey = 'connectionKey';
+  static const String connectionRecoveryKey = 'connectionRecoveryKey';
+  static const String connectionErrorReason = 'connectionErrorReason';
+
   static const String pushActivate = 'pushActivate';
   static const String pushDeactivate = 'pushDeactivate';
   static const String pushReset = 'pushReset';

lib/src/platform/src/realtime/connection.dart

@@ -37,7 +37,8 @@ class Connection extends PlatformObject {
 
   /// A unique public identifier for this connection, used to identify this
   /// member.
-  String? id;
+  Future<String?> get id async =>
+      invoke<String?>(PlatformMethod.connectionId);
 
   /// A unique private connection key used to recover or resume a connection,
   /// assigned by Ably.
@@ -48,14 +49,16 @@ class Connection extends PlatformObject {
   /// to publish on behalf of this client. See the
   /// [publishing over REST on behalf of a realtime client docs](https://ably.com/docs/rest/channels#publish-on-behalf)
   /// for more info.
-  String? key;
+  Future<String?> get key async =>
+      invoke<String?>(PlatformMethod.connectionKey);
 
   /// The recovery key string can be used by another client to recover this
   /// connection's state in the recover client options property.
   ///
   /// See [connection state recover options](https://ably.com/docs/realtime/connection#connection-state-recover-options)
   /// for more information.
-  String? recoveryKey;
+  Future<String?> get recoveryKey async =>
+      invoke<String?>(PlatformMethod.connectionRecoveryKey);
 
   /// The serial number of the last message to be received on this connection,
   /// used automatically by the library when recovering or resuming a