Messages update and delete with versions.

Author: maratal

Ably.xcodeproj/project.pbxproj

@@ -153,6 +153,34 @@ - (void)publish:(NSArray<ARTMessage *> *)messages callback:(nullable ARTCallback
     [self internalPostMessages:messagesWithDataEncoded callback:callback];
 }
 
+- (void)updateMessage:(ARTMessage *)message
+            operation:(nullable ARTMessageOperation *)operation
+               params:(nullable NSDictionary<NSString *, ARTStringifiable *> *)params
+     wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents
+             callback:(nullable ARTCallback)callback {
+    NSAssert(false, @"-[%@ %@] should always be overriden.", self.class, NSStringFromSelector(_cmd));
+}
+
+- (void)deleteMessage:(ARTMessage *)message
+            operation:(nullable ARTMessageOperation *)operation
+               params:(nullable NSDictionary<NSString *, ARTStringifiable *> *)params
+     wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents
+             callback:(nullable ARTCallback)callback {
+    NSAssert(false, @"-[%@ %@] should always be overriden.", self.class, NSStringFromSelector(_cmd));
+}
+
+- (void)getMessageWithSerial:(NSString *)serial
+            wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents
+                    callback:(ARTMessageErrorCallback)callback {
+    NSAssert(false, @"-[%@ %@] should always be overriden.", self.class, NSStringFromSelector(_cmd));
+}
+
+- (void)getMessageVersionsWithSerial:(NSString *)serial
+                    wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents
+                            callback:(ARTPaginatedMessagesCallback)callback {
+    NSAssert(false, @"-[%@ %@] should always be overriden.", self.class, NSStringFromSelector(_cmd));
+}
+
 - (BOOL)exceedMaxSize:(NSArray<ARTBaseMessage *> *)messages {
     NSInteger size = 0;
     for (ARTMessage *message in messages) {

Source/ARTChannel.m

@@ -0,0 +1,55 @@
+#import "ARTMessageOperation.h"
+#import "ARTMessageOperation+Private.h"
+
+@implementation ARTMessageOperation
+
+- (instancetype)initWithClientId:(NSString *)clientId descriptionText:(NSString *)descriptionText metadata:(NSDictionary<NSString *, NSString *> *)metadata {
+    self = [super init];
+    if (self) {
+        _clientId = clientId;
+        _descriptionText = descriptionText;
+        _metadata = metadata;
+    }
+    return self;
+}
+
+- (id)copyWithZone:(NSZone *)zone {
+    ARTMessageOperation *operation = [[[self class] allocWithZone:zone] init];
+    operation->_clientId = self.clientId;
+    operation->_descriptionText = self.descriptionText;
+    operation->_metadata = self.metadata;
+    return operation;
+}
+
+- (NSString *)description {
+    NSMutableString *description = [NSMutableString stringWithFormat:@"<%@: %p> {\n", self.class, self];
+    [description appendFormat:@" clientId: %@,\n", self.clientId];
+    [description appendFormat:@" descriptionText: %@,\n", self.descriptionText];
+    [description appendFormat:@" metadata: %@\n", self.metadata];
+    [description appendFormat:@"}"];
+    return description;
+}
+
+- (void)writeToDictionary:(NSMutableDictionary<NSString *, id> *)dictionary {
+    if (self.clientId) {
+        dictionary[@"clientId"] = self.clientId;
+    }
+    if (self.descriptionText) {
+        dictionary[@"description"] = self.descriptionText;
+    }
+    if (self.metadata) {
+        dictionary[@"metadata"] = self.metadata;
+    }
+}
+
++ (nullable instancetype)createFromDictionary:(nonnull NSDictionary *)dictionary {
+    NSAssert(false, @"Not implemented");
+    return nil;
+}
+
+- (nullable instancetype)initWithDictionary:(nonnull NSDictionary *)dictionary {
+    NSAssert(false, @"Not implemented");
+    return nil;
+}
+
+@end

Source/ARTMessageOperation.m

@@ -144,6 +144,22 @@ - (void)publish:(NSArray<ARTMessage *> *)messages callback:(nullable ARTCallback
     [_internal publish:messages callback:callback];
 }
 
+- (void)updateMessage:(ARTMessage *)message operation:(nullable ARTMessageOperation *)operation params:(nullable NSDictionary<NSString *, ARTStringifiable *> *)params callback:(nullable ARTCallback)callback {
+    [_internal updateMessage:message operation:operation params:params wrapperSDKAgents:nil callback:callback];
+}
+
+- (void)deleteMessage:(ARTMessage *)message operation:(nullable ARTMessageOperation *)operation params:(nullable NSDictionary<NSString *, ARTStringifiable *> *)params callback:(nullable ARTCallback)callback {
+    [_internal deleteMessage:message operation:operation params:params wrapperSDKAgents:nil callback:callback];
+}
+
+- (void)getMessageWithSerial:(NSString *)serial callback:(ARTMessageErrorCallback)callback {
+    [_internal getMessageWithSerial:serial wrapperSDKAgents:nil callback:callback];
+}
+
+- (void)getMessageVersionsWithSerial:(NSString *)serial callback:(ARTPaginatedMessagesCallback)callback {
+    [_internal getMessageVersionsWithSerial:serial wrapperSDKAgents:nil callback:callback];
+}
+
 - (void)history:(ARTPaginatedMessagesCallback)callback {
     [_internal historyWithWrapperSDKAgents:nil completion:callback];
 }
@@ -451,6 +467,30 @@ - (void)sendObjectWithObjectMessages:(NSArray<id<APObjectMessageProtocol>> *)obj
  }
 #endif
 
+- (void)updateMessage:(ARTMessage *)message
+            operation:(nullable ARTMessageOperation *)operation
+               params:(nullable NSDictionary<NSString *, ARTStringifiable *> *)params
+     wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents
+             callback:(nullable ARTCallback)callback {
+    [self.restChannel updateMessage:message operation:operation params:params wrapperSDKAgents:wrapperSDKAgents callback:callback];
+}
+
+- (void)deleteMessage:(ARTMessage *)message
+            operation:(nullable ARTMessageOperation *)operation
+               params:(nullable NSDictionary<NSString *, ARTStringifiable *> *)params
+     wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents
+             callback:(nullable ARTCallback)callback {
+    [self.restChannel deleteMessage:message operation:operation params:params wrapperSDKAgents:wrapperSDKAgents callback:callback];
+}
+
+- (void)getMessageWithSerial:(NSString *)serial wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents callback:(ARTMessageErrorCallback)callback {
+    [self.restChannel getMessageWithSerial:serial wrapperSDKAgents:wrapperSDKAgents callback:callback];
+}
+
+- (void)getMessageVersionsWithSerial:(NSString *)serial wrapperSDKAgents:(nullable NSStringDictionary *)wrapperSDKAgents callback:(ARTPaginatedMessagesCallback)callback {
+    [self.restChannel getMessageVersionsWithSerial:serial wrapperSDKAgents:wrapperSDKAgents callback:callback];
+}
+
 - (void)publishProtocolMessage:(ARTProtocolMessage *)pm callback:(ARTStatusCallback)cb {
     switch (self.state_nosync) {
         case ARTRealtimeChannelSuspended: