Migrated Code From ALMessage to KMCoreMessage

Author: AbhijeetRanjan308

Example/Tests/KommunicateTests.swift

@@ -39,7 +39,7 @@ class KommunicateTests: XCTestCase {
         override func getLatestMessages(_: Bool, withCompletionHandler completion: ((NSMutableArray?, Error?) -> Void)!) {
             let messageList: NSMutableArray = []
             for _ in 0 ..< KommunicateClientMock.messageCount {
-                let message = ALMessage()
+                let message = KMCoreMessage()
                 messageList.add(message)
             }
             completion(messageList, nil)

Sources/Kommunicate/Classes/KMConversationListViewController.swift

@@ -33,7 +33,7 @@ public class KMConversationListViewController: ALKBaseViewController, Localizabl
     var searchBar: KMCustomSearchBar!
     lazy var resultVC = ALKSearchResultViewController(configuration: configuration)
 
-    public var dbService = ALMessageDBService()
+    public var dbService = KMCoreMessageDBService()
     public var viewModel = ALKConversationListViewModel()
 
     var isSingleThreadedEnabled = KMCoreSettings.getIsSingleThreadedEnabled()
@@ -273,7 +273,7 @@ public class KMConversationListViewController: ALKBaseViewController, Localizabl
     }
 
     @objc func addMessages(notification: NSNotification) {
-        guard let msgArray = notification.object as? [ALMessage] else { return }
+        guard let msgArray = notification.object as? [KMCoreMessage] else { return }
         print("new notification received: ", msgArray.first?.message ?? "")
         guard let list = notification.object as? [Any], !list.isEmpty else { return }
         viewModel.addMessages(messages: list)
@@ -305,7 +305,7 @@ public class KMConversationListViewController: ALKBaseViewController, Localizabl
             contactId = object
         }
 
-        let message = ALMessage()
+        let message = KMCoreMessage()
         message.contactIds = contactId
         message.groupId = groupId
         let info = notification.userInfo
@@ -353,12 +353,12 @@ public class KMConversationListViewController: ALKBaseViewController, Localizabl
     }
 
     @objc func conversationDeleted(notification: NSNotification) {
-        guard let conversation = notification.object as? ALMessage else { return }
+        guard let conversation = notification.object as? KMCoreMessage else { return }
         deleteConversation(conversation: conversation)
     }
 
-    private func deleteConversation(conversation: ALMessage) {
-        ALMessageService().deleteMessageThread(nil, orChannelKey: conversation.groupId, withCompletion: {
+    private func deleteConversation(conversation: KMCoreMessage) {
+        KMCoreMessageService().deleteMessageThread(nil, orChannelKey: conversation.groupId, withCompletion: {
             _, error in
             guard error == nil else {
                 print("Failed to delete the conversation: \(error.debugDescription)")
@@ -466,7 +466,7 @@ public class KMConversationListViewController: ALKBaseViewController, Localizabl
         createConversationAndLaunch()
     }
 
-    func sync(message: ALMessage) {
+    func sync(message: KMCoreMessage) {
         if let viewController = conversationViewController,
            ALPushAssist().topViewController is KMConversationViewController,
            viewController.viewModel != nil,
@@ -638,7 +638,7 @@ public class KMConversationListViewController: ALKBaseViewController, Localizabl
     }
 }
 
-extension KMConversationListViewController: ALMessagesDelegate {
+extension KMConversationListViewController: KMCoreMessagesDelegate {
     public func getMessagesArray(_ messagesArray: NSMutableArray!) {
         guard let messages = messagesArray as? [Any], !messages.isEmpty else {
             viewModel.delegate?.listUpdated()
@@ -705,7 +705,7 @@ extension KMConversationListViewController: ALMQTTConversationDelegate {
         }
     }
 
-    public func isNewMessageForActiveThread(alMessage: ALMessage, vm: ALKConversationViewModel) -> Bool {
+    public func isNewMessageForActiveThread(alMessage: KMCoreMessage, vm: ALKConversationViewModel) -> Bool {
         let isGroupMessage = alMessage.groupId != nil && alMessage.groupId == vm.channelKey
         let isOneToOneMessage = alMessage.groupId == nil && vm.channelKey == nil && alMessage.contactId == vm.contactId
         if isGroupMessage || isOneToOneMessage {
@@ -714,14 +714,14 @@ extension KMConversationListViewController: ALMQTTConversationDelegate {
         return false
     }
 
-    func isMessageSentByLoggedInUser(alMessage: ALMessage) -> Bool {
+    func isMessageSentByLoggedInUser(alMessage: KMCoreMessage) -> Bool {
         if alMessage.isSentMessage() {
             return true
         }
         return false
     }
 
-    open func syncCall(_ alMessage: ALMessage!, andMessageList _: NSMutableArray!) {
+    open func syncCall(_ alMessage: KMCoreMessage!, andMessageList _: NSMutableArray!) {
         print("sync call: ", alMessage.message ?? "empty")
         guard let message = alMessage else { return }
         let viewController = navigationController?.visibleViewController as? KMConversationViewController
@@ -825,7 +825,7 @@ extension KMConversationListViewController: ALKConversationListTableViewDelegate
         viewModel.userBlockNotification(userId: userId, isBlocked: isBlocked)
     }
 
-    public func muteNotification(conversation: ALMessage, isMuted: Bool) {
+    public func muteNotification(conversation: KMCoreMessage, isMuted: Bool) {
         viewModel.muteNotification(conversation: conversation, isMuted: isMuted)
     }
 

Sources/Kommunicate/Classes/KMConversationViewController.swift

@@ -20,10 +20,10 @@ open class KMConversationViewController: ALKConversationViewController, KMUpdate
     private var kmBusinessHoursDataArray: [KMBusinessHoursViewModel]?
     let kmBotService = KMBotService()
     private var assigneeUserId: String?
-    var messageArray = [ALMessage]()
+    var messageArray = [KMCoreMessage]()
     var timer = Timer()
     var count = 0
-    var currentMessage = ALMessage()
+    var currentMessage = KMCoreMessage()
     var delayInterval = 0
     private var isWaitingQueueFetching: Bool = false
 
@@ -193,7 +193,7 @@ open class KMConversationViewController: ALKConversationViewController, KMUpdate
     }
 
     open override func addMessagesToList(_ messageList: [Any]) {
-       guard var messages = messageList as? [ALMessage] else { return }
+       guard var messages = messageList as? [KMCoreMessage] else { return }
 
         if KMConversationScreenConfiguration.showTypingIndicatorWhileFetchingResponse {
             updateTyingStatus(status: false, userId: "")
@@ -385,7 +385,7 @@ open class KMConversationViewController: ALKConversationViewController, KMUpdate
     // This method is used to delay the bot message as well as to show typing indicator
     func showDelayAndTypingIndicatorForMessage() {
         if count >= messageArray.count {
-           currentMessage = ALMessage()
+           currentMessage = KMCoreMessage()
            return
          }
 
@@ -740,7 +740,7 @@ open class KMConversationViewController: ALKConversationViewController, KMUpdate
         subscribeChannelToMqtt()
         viewModel.prepareController()
         self.updatePlaceholder()
-        ALMessageService.syncMessages()
+        KMCoreMessageService.syncMessages()
         syncAutoSuggestionMessage(message: viewModel?.lastMessage)
     }
 

Sources/Kommunicate/Classes/KMPushNotificationHelper.swift

@@ -55,7 +55,7 @@ public class KMPushNotificationHelper {
     ///
     /// - Parameter message: message of notification
     /// - Returns: `NotificationData` containing information about groupId
-    public func notificationData(message: ALMessage) -> NotificationData {
+    public func notificationData(message: KMCoreMessage) -> NotificationData {
         return NotificationData(groupId: message.channelKey)
     }
 

Sources/Kommunicate/Classes/Kommunicate.swift

@@ -1091,9 +1091,9 @@ open class Kommunicate: NSObject, Localizable {
                 completion(noConversationError)
                 return
             }
-            let alMessage = message.toALMessage()
+            let alMessage = message.toKMCoreMessage()
             alMessage.groupId = key
-            ALMessageService.sharedInstance().sendMessages(alMessage) { _, error in
+            KMCoreMessageService.sharedInstance().sendMessages(alMessage) { _, error in
                 guard error == nil else {
                     completion(error)
                     return

Sources/Kommunicate/Classes/Models/KMMessageBuilder.swift

@@ -41,8 +41,8 @@ public class KMMessageBuilder: NSObject {
 }
 
 extension KMMessage {
-    func toALMessage() -> ALMessage {
-        let alMessage = ALMessage()
+    func toKMCoreMessage() -> KMCoreMessage {
+        let alMessage = KMCoreMessage()
         alMessage.to = nil
         alMessage.contactIds = nil
         alMessage.message = text