chore: create inline UIView that checks if there are inline messages …

…in local queue

Part of: https://linear.app/customerio/issue/MBL-310/create-a-uikit-uiview-that-displays-an-inline-in-app-message-sent-from

Create a new public UIView that customers can add to their app's UI to display inline Views. This commit does not display messages yet. It only checks if there is an in-app message available to display inline with the equal elementId.

Testing:
Automated tests added in the commit. Some boilerplate code was added to allow mocking some dependencies and testing functions that were previously not very testable.

Reviewer notes:
This commit only handles the use case of inline Views being able to display inline messages after a fetch has already completed in the SDK. Future changes will handle when an inline View is visible and a fetch completes.

commit-id:60639329

Sources/MessagingInApp/Gist/Gist.swift

@@ -1,8 +1,13 @@
+import CioInternalCommon
 import Foundation
 import UIKit
 
-public class Gist: GistDelegate {
-    var messageQueueManager = MessageQueueManager()
+protocol GistInstance: AutoMockable {
+    func showMessage(_ message: Message, position: MessagePosition) -> Bool
+}
+
+public class Gist: GistInstance, GistDelegate {
+    var messageQueueManager: MessageQueueManager = DIGraphShared.shared.messageQueueManager
     var shownMessageQueueIds: Set<String> = []
     private var messageManagers: [MessageManager] = []
     public var siteId: String = ""
@@ -56,7 +61,7 @@ public class Gist: GistDelegate {
 
     // MARK: Message Actions
 
-    public func showMessage(_ message: Message, position: MessagePosition = .center) -> Bool {
+    func showMessage(_ message: Message, position: MessagePosition) -> Bool {
         if let messageManager = getModalMessageManager() {
             Logger.instance.info(message: "Message cannot be displayed, \(messageManager.currentMessage.messageId) is being displayed.")
         } else {
@@ -67,6 +72,10 @@ public class Gist: GistDelegate {
         return false
     }
 
+    public func showMessage(_ message: Message) -> Bool {
+        showMessage(message, position: .center)
+    }
+
     public func getMessageView(_ message: Message) -> GistView {
         let messageManager = createMessageManager(siteId: siteId, message: message)
         return messageManager.getMessageView()
@@ -146,4 +155,21 @@ public class Gist: GistDelegate {
     func removeMessageManager(instanceId: String) {
         messageManagers.removeAll(where: { $0.currentMessage.instanceId == instanceId })
     }
+
+    // Inline messages
+
+    func getInlineMessages(forElementId elementId: String) -> [Message] {
+        messageQueueManager.getInlineMessages(forElementId: elementId)
+    }
+}
+
+// Convenient way for other modules to access instance as well as being able to mock instance in tests.
+extension DIGraphShared {
+    var gist: GistInstance {
+        if let override: GistInstance = getOverriddenInstance() {
+            return override
+        }
+
+        return Gist.shared
+    }
 }

Sources/MessagingInApp/Gist/Managers/MessageQueueManager.swift

@@ -1,13 +1,34 @@
+import CioInternalCommon
 import Foundation
 import UIKit
 
-class MessageQueueManager {
+protocol MessageQueueManager: AutoMockable {
+    var interval: Double { get set }
+    func setup()
+    // sourcery:Name=setupSkipQueueCheck
+    // sourcery:DuplicateMethod=setup
+    func setup(skipQueueCheck: Bool)
+    func fetchUserMessagesFromLocalStore()
+    func removeMessageFromLocalStore(message: Message)
+    func clearUserMessagesFromLocalStore()
+    func getInlineMessages(forElementId elementId: String) -> [Message]
+}
+
+// sourcery: InjectRegisterShared = "MessageQueueManager"
+class MessageQueueManagerImpl: MessageQueueManager {
     var interval: Double = 600
     private var queueTimer: Timer?
     // The local message store is used to keep messages that can't be displayed because the route rule doesnt match.
-    private var localMessageStore: [String: Message] = [:]
+    var localMessageStore: [String: Message] = [:]
+    private var gist: GistInstance {
+        DIGraphShared.shared.gist
+    }
+
+    func setup() {
+        setup(skipQueueCheck: false)
+    }
 
-    func setup(skipQueueCheck: Bool = false) {
+    func setup(skipQueueCheck: Bool) {
         queueTimer?.invalidate()
         queueTimer = nil
 
@@ -59,7 +80,11 @@ class MessageQueueManager {
         localMessageStore.removeValue(forKey: queueId)
     }
 
-    private func addMessageToLocalStore(message: Message) {
+    func getInlineMessages(forElementId elementId: String) -> [Message] {
+        localMessageStore.filter { $0.value.elementId == elementId }.map(\.value)
+    }
+
+    func addMessageToLocalStore(message: Message) {
         guard let queueId = message.queueId else {
             return
         }
@@ -72,21 +97,16 @@ class MessageQueueManager {
             Logger.instance.info(message: "Checking Gist queue service")
             if let userToken = UserManager().getUserToken() {
                 QueueManager(siteId: Gist.shared.siteId, dataCenter: Gist.shared.dataCenter)
-                    .fetchUserQueue(userToken: userToken, completionHandler: { response in
+                    .fetchUserQueue(userToken: userToken, completionHandler: { [weak self] response in
                         switch response {
                         case .success(nil):
                             Logger.instance.info(message: "No changes to remote queue")
                         case .success(let responses):
                             guard let responses else {
                                 return
                             }
-                            // To prevent us from showing expired / revoked messages, clear user messages from local queue.
-                            self.clearUserMessagesFromLocalStore()
-                            Logger.instance.info(message: "Gist queue service found \(responses.count) new messages")
-                            for queueMessage in responses {
-                                let message = queueMessage.toMessage()
-                                self.handleMessage(message: message)
-                            }
+
+                            self?.processFetchedMessages(responses.map { $0.toMessage() })
                         case .failure(let error):
                             Logger.instance.error(message: "Error fetching messages from Gist queue service. \(error.localizedDescription)")
                         }
@@ -99,6 +119,15 @@ class MessageQueueManager {
         }
     }
 
+    func processFetchedMessages(_ fetchedMessages: [Message]) {
+        // To prevent us from showing expired / revoked messages, clear user messages from local queue.
+        clearUserMessagesFromLocalStore()
+        Logger.instance.info(message: "Gist queue service found \(fetchedMessages.count) new messages")
+        for message in fetchedMessages {
+            handleMessage(message: message)
+        }
+    }
+
     private func handleMessage(message: Message) {
         // Skip shown messages
         if let queueId = message.queueId, Gist.shared.shownMessageQueueIds.contains(queueId) {
@@ -123,12 +152,22 @@ class MessageQueueManager {
             }
         }
 
-        if let elementId = message.gistProperties.elementId {
-            Logger.instance.info(message: "Embedding message with Element Id \(elementId)")
-            Gist.shared.embedMessage(message: message, elementId: elementId)
+        if message.isInlineMessage {
+            // If message has an element id, it's meant to be shown inline.
+            // Inline Views show inline messages by getting messages stored in the local queue on device.
+            // So, add the message to the local store and when inline Views are constructed, they will check the store.
+
+            addMessageToLocalStore(message: message)
+
+            // In a future PR, we will want to notify all currently visible inline Views that new messages are available in local store.
+            //
+            // At that time, we may decide we do not need these lines anymore. Keeping them in until we implement this notify piece.
+            //            Logger.instance.info(message: "Found a message meant to be shown inline. Element Id \(elementId)")
+            //            Gist.shared.embedMessage(message: message, elementId: elementId)
+
             return
         } else {
-            _ = Gist.shared.showMessage(message, position: position)
+            _ = gist.showMessage(message, position: position)
         }
     }
 }

Sources/MessagingInApp/Gist/Managers/Models/Message.swift

@@ -18,7 +18,7 @@ public class GistProperties {
 
 public class Message {
     public private(set) var instanceId = UUID().uuidString.lowercased()
-    public let queueId: String?
+    public let queueId: String? // uniquely identifies an in-app message in the backend system
     public let priority: Int?
     public let messageId: String
     public private(set) var gistProperties: GistProperties
@@ -92,3 +92,18 @@ public class Message {
         return engineRoute
     }
 }
+
+// Convenient functions for Inline message feature
+extension Message {
+    var elementId: String? {
+        gistProperties.elementId
+    }
+
+    var isInlineMessage: Bool {
+        elementId != nil
+    }
+
+    var isModalMessage: Bool {
+        !isInlineMessage
+    }
+}

Sources/MessagingInApp/Views/InAppMessageView.swift

@@ -0,0 +1,69 @@
+import CioInternalCommon
+import Foundation
+import UIKit
+
+/**
+ View that can be added to a customer's app UI to display inline in-app messages.
+
+ Usage:
+ 1. Create an instance of this View and add it to the customer's app UI.
+ ```
+ // you can construct an instance with code:
+ let inAppMessageView = InAppMessageView(elementId: "elementId")
+ view.addSubView(inAppMessageView)
+
+ // Or, if you use Storyboards:
+ @IBOutlet weak var inAppMessageView: InAppMessageView!
+ inAppMessageView.elementId = "elementId"
+ ```
+ 2. Position and set size of the View in app's UI. The View will adjust it's height automatically, but all other constraints are the responsibilty of app developer. You can set a height constraint if you want autolayout warnings to go away but know that the View will ignore this set height.
+ */
+public class InAppMessageView: UIView {
+    private var localMessageQueue: MessageQueueManager {
+        DIGraphShared.shared.messageQueueManager
+    }
+
+    // Can set in the constructor or can set later (like if you use Storyboards)
+    public var elementId: String? {
+        didSet {
+            checkIfMessageAvailableToDisplay()
+        }
+    }
+
+    public init(elementId: String) {
+        super.init(frame: .zero)
+        self.elementId = elementId
+
+        // Setup the View and display a message, if one available. Since an elementId has been set.
+        setupView()
+        checkIfMessageAvailableToDisplay()
+    }
+
+    // This is called when the View is created from a Storyboard.
+    required init?(coder: NSCoder) {
+        super.init(coder: coder)
+
+        setupView()
+        // An element id will not be set yet. No need to check for messages to display.
+    }
+
+    private func setupView() {}
+
+    private func checkIfMessageAvailableToDisplay() {
+        // In a future PR, we will remove the asyncAfter(). this is only for testing in sample apps because when app opens, the local queue is empty. so wait to check messages until first fetch is done.
+//        DispatchQueue.main.asyncAfter(deadline: .now() + 5) { [self] in
+        guard let elementId = elementId else {
+            return
+        }
+
+        let queueOfMessagesForGivenElementId = localMessageQueue.getInlineMessages(forElementId: elementId)
+        guard let messageToDisplay = queueOfMessagesForGivenElementId.first else {
+            return // no messages to display, exit early. In the future we will dismiss the View.
+        }
+
+        displayInAppMessage(messageToDisplay)
+        //      }
+    }
+
+    private func displayInAppMessage(_ message: Message) {}
+}

Sources/MessagingInApp/autogenerated/AutoDependencyInjection.generated.swift

@@ -57,6 +57,9 @@ extension DIGraphShared {
         _ = inAppProvider
         countDependenciesResolved += 1
 
+        _ = messageQueueManager
+        countDependenciesResolved += 1
+
         return countDependenciesResolved
     }
 
@@ -70,6 +73,16 @@ extension DIGraphShared {
     private var newInAppProvider: InAppProvider {
         GistInAppProvider()
     }
+
+    // MessageQueueManager
+    var messageQueueManager: MessageQueueManager {
+        getOverriddenInstance() ??
+            newMessageQueueManager
+    }
+
+    private var newMessageQueueManager: MessageQueueManager {
+        MessageQueueManagerImpl()
+    }
 }
 
 // swiftlint:enable all