Feature/platform message encoding

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

@@ -1,17 +1,20 @@
 package io.ably.flutter.plugin;
 
+import java.io.ByteArrayOutputStream;
 import java.nio.ByteBuffer;
 import java.util.function.Consumer;
 
 import io.ably.lib.rest.Auth;
 import io.ably.lib.rest.Auth.TokenDetails;
 import io.ably.lib.types.ClientOptions;
 import io.ably.lib.types.Param;
+import io.ably.lib.types.ErrorInfo;
 import io.flutter.plugin.common.StandardMessageCodec;
 
 public class AblyMessageCodec extends StandardMessageCodec {
     private static final byte _valueClientOptions = (byte)128;
     private static final byte _valueTokenDetails = (byte)129;
+    private static final byte _errorInfo = (byte)144;
     private static final byte _valueAblyMessage = (byte)255;
 
     @Override
@@ -110,4 +113,26 @@ private Object readTokenDetails(final ByteBuffer buffer) {
 
         return o;
     }
+
+
+    //HANDLING WRITE
+
+    @Override
+    protected void writeValue(ByteArrayOutputStream stream, Object value) {
+        if(value instanceof ErrorInfo){
+            stream.write(_errorInfo);
+            writeErrorInfo(stream, (ErrorInfo) value);
+            return;
+        }
+        super.writeValue(stream, value);
+    }
+
+    private void writeErrorInfo(ByteArrayOutputStream stream, ErrorInfo e){
+        writeValue(stream, e.code);
+        writeValue(stream, e.message);
+        writeValue(stream, e.statusCode);
+        writeValue(stream, e.href);
+        writeValue(stream, null); //requestId - not available in ably-java
+        writeValue(stream, null); //cause - not available in ably-java
+    }
 }

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

@@ -165,7 +165,7 @@ public void onSuccess() {
 
                 @Override
                 public void onError(ErrorInfo reason) {
-                    result.error(Integer.toString(reason.code), "Unable to publish message to Ably server; err = " + reason.message, null);
+                    result.error(Integer.toString(reason.code), "Unable to publish message to Ably server; err = " + reason.message, reason);
                 }
             });
         });

example/lib/main.dart

@@ -116,9 +116,13 @@ class _MyAppState extends State<MyApp> {
     String name = "Hello";
     dynamic data = "Flutter";
     print('publishing messages... name "$name", message "$data"');
-    await rest.channels.get('test').publish(name, data);
-    await rest.channels.get('test').publish(name);
-    await rest.channels.get('test').publish();
+    try {
+      await rest.channels.get('test').publish(name, data);
+      await rest.channels.get('test').publish(name);
+      await rest.channels.get('test').publish();
+    } on ably.AblyException catch(e) {
+      print(e.errorInfo);
+    }
     print('Message published');
   }
 

ios/Classes/AblyFlutterPlugin.m

@@ -4,7 +4,7 @@
 //   @import Ably;
 #import "Ably.h"
 
-#import "AblyFlutterReaderWriter.h"
+#import "codec/AblyFlutterReaderWriter.h"
 #import "AblyFlutterMessage.h"
 #import "AblyFlutter.h"
 #import "AblyFlutterSurfaceRealtime.h"
@@ -65,7 +65,7 @@ -(nullable AblyFlutter *)ablyWithHandle:(NSNumber *)handle;
                     FlutterError
                     errorWithCode:[NSString stringWithFormat: @"%ld", (long)error.code]
                     message:[NSString stringWithFormat:@"Unable to publish message to Ably server; err = %@", [error message]]
-                    details:nil
+                    details:error
                     ]);
         }else{
             result(nil);

ios/Classes/codec/AblyFlutterReader.h

@@ -0,0 +1,17 @@
+@import Foundation;
+@import Flutter;
+
+NS_ASSUME_NONNULL_BEGIN
+
+@interface AblyFlutterReader : FlutterStandardReader
+@end
+
+NS_ASSUME_NONNULL_END
+
+
+typedef NS_ENUM(UInt8, _Value) {
+    _valueClientOptions = 128,
+    _valueTokenDetails = 129,
+    _ValueErrorInfo = 144,
+    _valueAblyMessage = 255,
+};

ios/Classes/AblyFlutterReader.m → ios/Classes/codec/AblyFlutterReader.m

@@ -16,12 +16,6 @@ static ARTLogLevel _logLevel(NSNumber *const number) {
 
 @implementation AblyFlutterReader
 
-typedef NS_ENUM(UInt8, _Value) {
-    _valueClientOptions = 128,
-    _valueTokenDetails = 129,
-    _valueAblyMessage = 255,
-};
-
 -(id)readValueOfType:(const UInt8)type {
     switch ((_Value)type) {
         case _valueClientOptions:

ios/Classes/AblyFlutterReaderWriter.m → ios/Classes/codec/AblyFlutterReaderWriter.m

@@ -1,10 +1,15 @@
 #import "AblyFlutterReaderWriter.h"
 #import "AblyFlutterReader.h"
+#import "AblyFlutterWriter.h"
 
 @implementation AblyFlutterReaderWriter
 
 -(FlutterStandardReader *)readerWithData:(NSData *const)data {
     return [[AblyFlutterReader alloc] initWithData:data];
 }
 
+- (FlutterStandardWriter*)writerWithData:(NSMutableData*)data {
+    return [[AblyFlutterWriter alloc] initWithData:data];
+}
+
 @end

ios/Classes/AblyFlutterReader.h → ios/Classes/codec/AblyFlutterWriter.h

@@ -3,7 +3,7 @@
 
 NS_ASSUME_NONNULL_BEGIN
 
-@interface AblyFlutterReader : FlutterStandardReader
+@interface AblyFlutterWriter : FlutterStandardWriter
 @end
 
 NS_ASSUME_NONNULL_END

ios/Classes/codec/AblyFlutterWriter.m

@@ -0,0 +1,28 @@
+#import "AblyFlutterWriter.h"
+#import "Ably.h"
+#import "AblyFlutterMessage.h"
+#import "AblyFlutterReader.h"
+
+
+@implementation AblyFlutterWriter
+
+- (void)writeValue:(id)value {
+    if([value isKindOfClass:[ARTErrorInfo class]]){
+        [self writeByte:_ValueErrorInfo];
+        [self writeErrorInfo: value];
+        return;
+    }
+
+    [super writeValue:value];
+}
+
+- (void) writeErrorInfo:(ARTErrorInfo *) e{
+    [self writeValue: nil];    //code - not available in ably-cocoa
+    [self writeValue: [e message]];
+    [self writeValue: @([e statusCode])];
+    [self writeValue: nil]; //href - not available in ably-cocoa
+    [self writeValue: nil]; //requestId - not available in ably-java
+    [self writeValue: nil]; //cause - not available in ably-java
+}
+
+@end