Paywalls: events unit and integration tests

- Added `PurchasesOrchestrator` tests for paywall data sent through post receipt
- Fixed and tested state issue with cached paywall data and failed purchases
- Added `Integration Tests` for tracking and flushing events
- Configured `Integration Tests` with a custom documents directory to ensure it's empty on every test invocation
- Changed deployment target on `Integration Tests` to iOS 16 to simplify code
- Setting `Purchases.logLevel` before configuring purchases on `Integration Tests`
- Added assertion to ensure `FileHandler` never runs on the main thread

RevenueCat.xcodeproj/project.pbxproj

@@ -4183,7 +4183,7 @@
 				CLANG_WARN_QUOTED_INCLUDE_IN_FRAMEWORK_HEADER = YES;
 				CODE_SIGN_STYLE = Automatic;
 				INFOPLIST_FILE = Tests/BackendIntegrationTests/Info.plist;
-				IPHONEOS_DEPLOYMENT_TARGET = 15.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 16.0;
 				LD_RUNPATH_SEARCH_PATHS = (
 					"$(inherited)",
 					"@executable_path/Frameworks",
@@ -4211,7 +4211,7 @@
 				CLANG_WARN_QUOTED_INCLUDE_IN_FRAMEWORK_HEADER = YES;
 				CODE_SIGN_STYLE = Automatic;
 				INFOPLIST_FILE = Tests/BackendIntegrationTests/Info.plist;
-				IPHONEOS_DEPLOYMENT_TARGET = 15.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 16.0;
 				LD_RUNPATH_SEARCH_PATHS = (
 					"$(inherited)",
 					"@executable_path/Frameworks",
@@ -4477,7 +4477,7 @@
 				CLANG_WARN_QUOTED_INCLUDE_IN_FRAMEWORK_HEADER = YES;
 				CODE_SIGN_STYLE = Automatic;
 				INFOPLIST_FILE = Tests/BackendIntegrationTests/Info.plist;
-				IPHONEOS_DEPLOYMENT_TARGET = 15.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 16.0;
 				LD_RUNPATH_SEARCH_PATHS = (
 					"$(inherited)",
 					"@executable_path/Frameworks",
@@ -4505,7 +4505,7 @@
 				CLANG_WARN_QUOTED_INCLUDE_IN_FRAMEWORK_HEADER = YES;
 				CODE_SIGN_STYLE = Automatic;
 				INFOPLIST_FILE = Tests/BackendIntegrationTests/Info.plist;
-				IPHONEOS_DEPLOYMENT_TARGET = 15.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 16.0;
 				LD_RUNPATH_SEARCH_PATHS = (
 					"$(inherited)",
 					"@executable_path/Frameworks",

Sources/Diagnostics/FileHandler.swift

@@ -56,6 +56,8 @@ actor FileHandler: FileHandlerType {
     /// - Note: this loads the entire file in memory
     /// For newer versions, consider using `readLines` instead.
     func readFile() throws -> Data {
+        RCTestAssertNotMainThread()
+
         try self.moveToBeginningOfFile()
 
         return self.fileHandle.availableData
@@ -64,13 +66,17 @@ actor FileHandler: FileHandlerType {
     /// Returns an async sequence for every line in the file
     @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
     func readLines() throws -> AsyncLineSequence<FileHandle.AsyncBytes> {
+        RCTestAssertNotMainThread()
+
         try self.moveToBeginningOfFile()
 
         return self.fileHandle.bytes.lines
     }
 
     /// Adds a line at the end of the file
     func append(line: String) {
+        RCTestAssertNotMainThread()
+
         self.fileHandle.seekToEndOfFile()
         self.fileHandle.write(line.asData)
         self.fileHandle.write(Self.lineBreakData)

Sources/Logging/Strings/PaywallsStrings.swift

@@ -33,7 +33,7 @@ enum PaywallsStrings {
     case event_flush_already_in_progress
     case event_flush_with_empty_store
     case event_flush_starting(count: Int)
-    case event_flush_failed(BackendError)
+    case event_flush_failed(Error)
 
 }
 
@@ -78,7 +78,7 @@ extension PaywallsStrings: LogMessage {
             return "Paywall event flush: posting \(count) events."
 
         case let .event_flush_failed(error):
-            return "Paywall event flushing failed, will retry. Error: \(error.localizedDescription)"
+            return "Paywall event flushing failed, will retry. Error: \((error as NSError).localizedDescription)"
         }
     }
 

Sources/Networking/InternalAPI.swift

@@ -56,11 +56,14 @@ class InternalAPI {
 
 extension InternalAPI {
 
+    /// - Throws: `BackendError`
     @available(iOS 15.0, macOS 12.0, tvOS 15.0, watchOS 8.0, *)
-    func postPaywallEvents(events: [PaywallStoredEvent]) async -> BackendError? {
-        return await Async.call { completion in
+    func postPaywallEvents(events: [PaywallStoredEvent]) async throws {
+        let error = await Async.call { completion in
             self.postPaywallEvents(events: events, completion: completion)
         }
+
+        if let error { throw error }
     }
 
 }

Sources/Paywalls/Events/PaywallEventStore.swift

@@ -85,11 +85,14 @@ internal actor PaywallEventStore: PaywallEventStoreType {
 @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
 extension PaywallEventStore {
 
-    static func createDefault() throws -> PaywallEventStore {
-        let url = try Self.documentsDirectory
+    static func createDefault(documentsDirectory: URL?) throws -> PaywallEventStore {
+        let documentsDirectory = try documentsDirectory ?? Self.documentsDirectory
+        let url = documentsDirectory
             .appendingPathComponent("revenuecat")
             .appendingPathComponent("paywall_event_store")
 
+        Logger.verbose(PaywallEventStoreStrings.initializing(url))
+
         return try .init(handler: FileHandler(url))
     }
 
@@ -116,6 +119,8 @@ extension PaywallEventStore {
 @available(iOS 15.0, macOS 12.0, tvOS 15.0, watchOS 8.0, *)
 private enum PaywallEventStoreStrings {
 
+    case initializing(URL)
+
     case storing_event(PaywallEvent)
 
     case error_storing_event(Error)
@@ -131,6 +136,9 @@ extension PaywallEventStoreStrings: LogMessage {
 
     var description: String {
         switch self {
+        case let .initializing(directory):
+            return "Initializing PaywallEventStore: \(directory.absoluteString)"
+
         case let .storing_event(event):
             return "Storing event: \(event.debugDescription)"
 

Sources/Paywalls/Events/PaywallEventsManager.swift

@@ -18,8 +18,10 @@ protocol PaywallEventsManagerType {
     @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
     func track(paywallEvent: PaywallEvent) async
 
+    /// - Throws: if posting events fails
+    /// - Returns: the number of events posted
     @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
-    func flushEvents(count: Int) async
+    func flushEvents(count: Int) async throws -> Int
 
 }
 
@@ -46,10 +48,10 @@ actor PaywallEventsManager: PaywallEventsManagerType {
         await self.store.store(.init(event: paywallEvent, userID: self.userProvider.currentAppUserID))
     }
 
-    func flushEvents(count: Int) async {
+    func flushEvents(count: Int) async throws -> Int {
         guard !self.flushInProgress else {
             Logger.debug(Strings.paywalls.event_flush_already_in_progress)
-            return
+            return 0
         }
         self.flushInProgress = true
         defer { self.flushInProgress = false }
@@ -58,21 +60,26 @@ actor PaywallEventsManager: PaywallEventsManagerType {
 
         guard !events.isEmpty else {
             Logger.verbose(Strings.paywalls.event_flush_with_empty_store)
-            return
+            return 0
         }
 
         Logger.verbose(Strings.paywalls.event_flush_starting(count: events.count))
 
-        let error = await self.internalAPI.postPaywallEvents(events: events)
+        do {
+            try await self.internalAPI.postPaywallEvents(events: events)
 
-        if let error {
+            await self.store.clear(count)
+
+            return events.count
+        } catch {
             Logger.error(Strings.paywalls.event_flush_failed(error))
 
-            if error.successfullySynced {
+            if let backendError = error as? BackendError,
+               backendError.successfullySynced {
                 await self.store.clear(count)
             }
-        } else {
-            await self.store.clear(count)
+
+            throw error
         }
     }
 

Sources/Purchasing/Purchases/Purchases.swift

@@ -260,6 +260,7 @@ public typealias StartPurchaseBlock = (@escaping PurchaseCompletedBlock) -> Void
     convenience init(apiKey: String,
                      appUserID: String?,
                      userDefaults: UserDefaults? = nil,
+                     documentsDirectory: URL? = nil,
                      observerMode: Bool = false,
                      platformInfo: PlatformInfo? = Purchases.platformInfo,
                      responseVerificationMode: Signing.ResponseVerificationMode,
@@ -359,7 +360,7 @@ public typealias StartPurchaseBlock = (@escaping PurchaseCompletedBlock) -> Void
                 paywallEventsManager = PaywallEventsManager(
                     internalAPI: backend.internalAPI,
                     userProvider: identityManager,
-                    store: try PaywallEventStore.createDefault()
+                    store: try PaywallEventStore.createDefault(documentsDirectory: documentsDirectory)
                 )
                 Logger.verbose(Strings.paywalls.event_manager_initialized)
             } else {
@@ -1266,6 +1267,7 @@ public extension Purchases {
         appUserID: String?,
         observerMode: Bool,
         userDefaults: UserDefaults?,
+        documentsDirectory: URL? = nil,
         platformInfo: PlatformInfo?,
         responseVerificationMode: Signing.ResponseVerificationMode,
         storeKit2Setting: StoreKit2Setting,
@@ -1277,6 +1279,7 @@ public extension Purchases {
             .init(apiKey: apiKey,
                   appUserID: appUserID,
                   userDefaults: userDefaults,
+                  documentsDirectory: documentsDirectory,
                   observerMode: observerMode,
                   platformInfo: platformInfo,
                   responseVerificationMode: responseVerificationMode,
@@ -1531,6 +1534,13 @@ internal extension Purchases {
         self.offeringsManager.invalidateCachedOfferings(appUserID: self.appUserID)
     }
 
+    /// - Throws: if posting events fails
+    /// - Returns: the number of events posted
+    @available(iOS 15.0, tvOS 15.0, macOS 12.0, watchOS 8.0, *)
+    func flushPaywallEvents(count: Int) async throws -> Int {
+        return try await self.paywallEventsManager?.flushEvents(count: count) ?? 0
+    }
+
 }
 
 #endif