Add appSessionID to PaywallEventsManager

Sources/Events/StoredEvent.swift

@@ -18,16 +18,18 @@ struct StoredEvent {
 
     private(set) var encodedEvent: AnyEncodable
     private(set) var userID: String
+    private(set) var appSessionID: UUID
     private(set) var feature: Feature
 
-    init?<T: Encodable>(event: T, userID: String, feature: Feature) {
+    init?<T: Encodable>(event: T, userID: String, appSessionID: UUID, feature: Feature) {
         guard let data = try? JSONEncoder.default.encode(value: event),
               let dictionary = try? JSONSerialization.jsonObject(with: data) as? [String: Any] else {
             return nil
         }
 
         self.encodedEvent = AnyEncodable(dictionary)
         self.userID = userID
+        self.appSessionID = appSessionID
         self.feature = feature
     }
 
@@ -49,6 +51,7 @@ extension StoredEvent: Codable {
 
         case encodedEvent = "event"
         case userID = "userId"
+        case appSessionID = "appSessionID"
         case feature
 
     }
@@ -64,6 +67,19 @@ extension StoredEvent: Codable {
         } else {
             self.feature = .paywalls
         }
+        if let appSessionID = try container.decodeIfPresent(UUID.self, forKey: .appSessionID) {
+            self.appSessionID = appSessionID
+        } else {
+            // Backward compatibility for PaywallEvents from before we started storing the user session ID
+            // Just use the paywall event's session ID
+            // Or generate a new one in the worst case
+            if let eventData = encodedEvent.value as? [String: Any],
+               let paywallEvent: PaywallEvent = try JSONDecoder.default.decode(dictionary: eventData) {
+                self.appSessionID = paywallEvent.data.sessionIdentifier
+            } else {
+                self.appSessionID = UUID()
+            }
+        }
     }
 
 }

Sources/Paywalls/Events/PaywallEventsManager.swift

@@ -23,6 +23,8 @@ protocol PaywallEventsManagerType {
     @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
     func flushEvents(count: Int) async throws -> Int
 
+    func resetAppSessionID() async
+
 }
 
 @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
@@ -31,6 +33,7 @@ actor PaywallEventsManager: PaywallEventsManagerType {
     private let internalAPI: InternalAPI
     private let userProvider: CurrentUserProvider
     private let store: PaywallEventStoreType
+    private var appSessionID: UUID
 
     private var flushInProgress = false
 
@@ -42,11 +45,17 @@ actor PaywallEventsManager: PaywallEventsManagerType {
         self.internalAPI = internalAPI
         self.userProvider = userProvider
         self.store = store
+        self.appSessionID = UUID()
+    }
+
+    func resetAppSessionID() {
+        self.appSessionID = UUID()
     }
 
     func track(paywallEvent: PaywallEvent) async {
         guard let event: StoredEvent = .init(event: AnyEncodable(paywallEvent),
                                              userID: self.userProvider.currentAppUserID,
+                                             appSessionID: self.appSessionID,
                                              feature: .paywalls) else {
             Logger.error(Strings.paywalls.event_cannot_serialize)
             return

Sources/Purchasing/Purchases/Purchases.swift

@@ -820,6 +820,10 @@ public extension Purchases {
             self.systemInfo.isApplicationBackgrounded { isAppBackgrounded in
                 self.updateOfferingsCache(isAppBackgrounded: isAppBackgrounded)
             }
+
+            Task {
+                await self.paywallEventsManager?.resetAppSessionID()
+            }
         }
     }
 
@@ -853,6 +857,10 @@ public extension Purchases {
                 return
             }
 
+            Task {
+                await self.paywallEventsManager?.resetAppSessionID()
+            }
+
             self.updateAllCaches {
                 completion?($0.value, $0.error)
             }