Release 0.3.0

- AI Answer Assist Feature updated to 2.0.0
- AI Translate Feature updated to 2.0.0
- AI Rephrase Feature updated to 2.0.0
- some tweaks and improvements

Author: IlliaChemolosov

Package.resolved

@@ -17,9 +17,9 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/QuickBlox/ios-quickblox-sdk", .upToNextMajor(from: "2.19.0")),
-        .package(url: "https://github.com/QuickBlox/ios-ai-answer-assistant.git", .upToNextMajor(from: "1.0.0")),
-        .package(url: "https://github.com/QuickBlox/ios-ai-translate.git", .upToNextMajor(from: "1.0.0")),
-        .package(url: "https://github.com/QuickBlox/ios-ai-rephrase", .upToNextMajor(from: "1.0.0"))
+        .package(url: "https://github.com/QuickBlox/ios-ai-answer-assistant.git", .upToNextMajor(from: "2.0.0")),
+        .package(url: "https://github.com/QuickBlox/ios-ai-translate.git", .upToNextMajor(from: "2.0.0")),
+        .package(url: "https://github.com/QuickBlox/ios-ai-rephrase.git", .upToNextMajor(from: "2.0.0"))
     ],
     targets: [
         .target(

Package.swift

@@ -11,7 +11,7 @@ public enum RemoteEvent {
     case create(_ dialogId: String, byUser: Bool, message: RemoteMessageDTO)
     case update(_ dialogId: String)
     case leave(_ dialogId: String, byUser: Bool)
-    case removed(_ dialogId: String)
+    case removed(_ dialogId: String, byUser: Bool)
     case newMessage(_ message: RemoteMessageDTO)
     case history(_ messages: RemoteMessagesDTO)
     case read( _ messageID: String, dialogID: String)
@@ -34,7 +34,11 @@ public enum RemoteEvent {
                     self = .leave(message.dialogId, byUser: message.isOwnedByCurrentUser)
                 }
             case .removed:
-                self = .removed(message.dialogId)
+                if message.isOwnedByCurrentUser {
+                    self = .update(message.dialogId)
+                } else {
+                    self = .removed(message.dialogId, byUser: message.isOwnedByCurrentUser)
+                }
             case .message:
                 self = .newMessage(message)
             case .read:

Sources/QuickBloxData/Event/RemoteEvent.swift

@@ -15,7 +15,7 @@ public enum RemoteDataSourceException: Error, Equatable {
     case unauthorised(_ description: String = "")
 
     /// Would be thrown when sending the wrong format of data, missing required fields, or providing incorrect values.
-    case incorrectData(description: String = "")
+    case incorrectData(_ description: String = "")
 
     /// Would be thrown when there are no necessary permissions to access the requested resource.
     case restrictedAccess(description: String = "")

Sources/QuickBloxData/Exception/RemoteDataSourceException.swift

@@ -40,7 +40,7 @@ extension Error {
         case .unauthorised( let info):
             return RepositoryException.unauthorised( info)
         case .incorrectData(description: let info):
-            return RepositoryException.incorrectData(description: info)
+            return RepositoryException.incorrectData(info)
         case .restrictedAccess(description: let info):
             return RepositoryException.restrictedAccess(description: info)
         case .connectionFailed(description: let info):
@@ -53,7 +53,7 @@ extension Error {
         case .unexpected(let info):
             return RepositoryException.unexpected(info)
         case .incorrectData(description: let info):
-            return RepositoryException.incorrectData(description: info)
+            return RepositoryException.incorrectData(info)
         }
     }
 }

Sources/QuickBloxData/Mapper/Error+RepositoryException.swift

@@ -33,8 +33,8 @@ extension DialogsRepository: DialogsRepositoryProtocol {
                     case .update(withDialogId: let dialogId): return .update(dialogId)
                     case .leave( let dialogId, let isCurrentUser):
                         return .leave(dialogId, byUser: isCurrentUser)
-                    case .removed(let dialogId):
-                        return .removed(dialogId)
+                    case .removed(let dialogId, let isCurrentUser):
+                        return .removed(dialogId, byUser: isCurrentUser)
                     case .newMessage(let message):
                         return .newMessage(Message(message))
                     case .history(let dto):
@@ -65,6 +65,13 @@ extension DialogsRepository: DialogsRepositoryProtocol {
         }
     }
 
+    public var localDialogUpdatePublisher: AnyPublisher<String, Never> {
+        get async {
+            await local.dialogUpdatePublisher
+                .eraseToAnyPublisher()
+        }
+    }
+    
     public func create(dialogInRemote entity: Dialog) async throws -> Dialog {
         do {
             let data = try await remote.create(dialog: RemoteDialogDTO(entity))
@@ -227,6 +234,8 @@ private extension RemoteDialogDTO {
         lastMessageUserId = value.lastMessage.userId
         unreadMessagesCount = value.unreadMessagesCount
         isOwnedByCurrentUser = value.isOwnedByCurrentUser
+        toAddIds = value.pushIDs
+        toDeleteIds = value.pullIDs
     }
 }
 

Sources/QuickBloxData/Repository/DialogsRepository.swift

@@ -31,6 +31,9 @@ public struct Dialog: DialogEntity {
     public var unreadMessagesCount: Int
     public var decrementCounter: Bool = false
 
+    public var pushIDs: [String] = []
+    public var pullIDs: [String] = []
+    
     public init(id: String = "",
                 type: DialogType,
                 name: String = "",

Sources/QuickBloxData/Source/Entity/Dialog.swift

@@ -23,7 +23,6 @@ public struct Message: MessageEntity {
     /// > Note: Returns an empty string by default
     public var text: String = ""
     public var translatedText: String = ""
-    
     public var userId: String = ""
     public var isOwnedByCurrentUser = false
     public var isRead: Bool = false

Sources/QuickBloxData/Source/Entity/Message.swift

@@ -17,13 +17,20 @@ import QuickBloxLog
 actor LocalDataSource: LocalDataSourceProtocol {
     //MARK: Properties
     private var dialogs = CurrentValueSubject<[LocalDialogDTO], Never>([])
+    private var updatedDialog = CurrentValueSubject<String, Never>("")
     private var users: [String: LocalUserDTO] = [:]
 
     var dialogsPublisher: AnyPublisher<[LocalDialogDTO], Never> {
         get async {
             dialogs.eraseToAnyPublisher()
         }
     }
+    
+    var dialogUpdatePublisher: AnyPublisher<String, Never> {
+        get async {
+            updatedDialog.eraseToAnyPublisher()
+        }
+    }
 }
 
 //MARK: Clear
@@ -44,6 +51,7 @@ extension LocalDataSource {
         var value = dialogs.value
         value.insertElement(dto, withSorting: .orderedDescending)
         dialogs.value = value
+        updatedDialog.value = dto.id
     }
 
     func get(dialog dto: LocalDialogDTO) async throws -> LocalDialogDTO {
@@ -141,6 +149,8 @@ extension LocalDataSource {
         } else {
             dialogs.value[index] = dialog
         }
+        
+        updatedDialog.value = dto.id
     }
 
     func getAllDialogs() async throws -> LocalDialogsDTO {

Sources/QuickBloxData/Source/Local/LocalDataSource.swift

@@ -13,6 +13,7 @@ import Combine
 public protocol LocalDataSourceProtocol: ClearLocalDataSourceProtocol {
     //MARK: Dialogs
     var dialogsPublisher: AnyPublisher<[LocalDialogDTO], Never>  { get async }
+    var dialogUpdatePublisher: AnyPublisher<String, Never>  { get async }
 
     /// Store a dialog session or conversation to a local storage.
     ///