Add user id analytics

Author: ertembiyik

…/Sources/Kit/Managers/KnockManager.swift Bluerage/Sources/Kit/AuthObserver.swiftBluerage/Sources/Kit/Managers/KnockManager.swift renamed to Bluerage/Sources/Kit/AuthObserver.swift Bluerage/Sources/Kit/Managers/KnockManager.swift renamed to Bluerage/Sources/Kit/AuthObserver.swift

@@ -2,36 +2,53 @@ import Foundation
 import FactoryKit
 import Combine
 import Knock
+import PostHog
 import OSLog
+import Sentry
+import Queue
 
-final class KnockManager {
+final class AuthObserver {
 
     @Injected(\.authSession) private var authSession
 
+    @Injected(\.knock) private var knock
+
+    @Injected(\.postHog) private var postHog
+
+    private let queue = AsyncQueue()
+
     private var connection: AnyCancellable?
 
     func start() {
         self.connection?.cancel()
         self.connection = nil
 
         self.connection = self.authSession.authStatePublisher
-            .sink { authState in
-                Task {
+            .sink { [weak self] authState in
+                self?.queue.addOperation { [ weak self] in
+                    guard let self else {
+                        return
+                    }
+
                     if case .authenticated(let id) = authState {
                         await Knock.shared.signIn(userId: id, userToken: nil)
+
+                        self.postHog.identify(id, userProperties: nil)
+
+                        SentrySDK.setUser(User(userId: id))
                     } else if case .unauthenticated = authState {
                         do {
                             try await Knock.shared.signOut()
                         } catch {
                             Logger.knockManager.error("Error signing out of knock")
                         }
+
+                        self.postHog.reset()
+
+                        SentrySDK.setUser(nil)
                     }
                 }
-            }
-    }
 
-    func setup(publishableKey: String, pushChannelId: String?, options: Knock.KnockStartupOptions? = nil) async throws {
-        try await Knock.shared.setup(publishableKey: publishableKey, pushChannelId: pushChannelId, options: options)
+            }
     }
-
 }

…pendencies/KnockManager+Dependancy.swift …/Kit/Dependencies/Knock+Dependancy.swiftBluerage/Sources/Kit/Dependencies/KnockManager+Dependancy.swift renamed to Bluerage/Sources/Kit/Dependencies/Knock+Dependancy.swift Bluerage/Sources/Kit/Dependencies/KnockManager+Dependancy.swift renamed to Bluerage/Sources/Kit/Dependencies/Knock+Dependancy.swift

@@ -4,9 +4,9 @@ import FactoryKit
 
 extension Container {
 
-    var knockManager: Factory<KnockManager> {
+    var knock: Factory<Knock> {
         self {
-            return KnockManager()
+            return Knock.shared
         }.shared
     }
 

Bluerage/Sources/UI/AppDelegate.swift

@@ -17,7 +17,9 @@ final class AppDelegate: KnockAppDelegate {
 
     @Injected(\.authSession) private var authSession
 
-    @Injected(\.knockManager) private var knockManager
+    @Injected(\.knock) private var knock
+
+    private let authObserver = AuthObserver()
 
     override func application(_ application: UIApplication,
                      didFinishLaunchingWithOptions launchOptions: [UIApplication.LaunchOptionsKey: Any]? = nil) -> Bool {
@@ -29,6 +31,8 @@ final class AppDelegate: KnockAppDelegate {
 
         self.setUpPostHog()
 
+        self.setUpAuthObserver()
+
         self.setUpAuthSession()
 
         self.setUpNuke()
@@ -52,6 +56,10 @@ final class AppDelegate: KnockAppDelegate {
         return [options]
     }
 
+    private func setUpAuthObserver() {
+        self.authObserver.start()
+    }
+
     private func setUpClerk() {
         self.clerk.configure(publishableKey: self.env.CLERK_PUBLISHABLE_KEY)
 
@@ -78,11 +86,9 @@ final class AppDelegate: KnockAppDelegate {
     }
 
     private func setUpKnock() {
-        self.knockManager.start()
-
         Task {
             do {
-                try await self.knockManager.setup(publishableKey: self.env.KNOCK_PUBLISHABLE_KEY,
+                try await self.knock.setup(publishableKey: self.env.KNOCK_PUBLISHABLE_KEY,
                                            pushChannelId: self.env.KNOCK_CHANNEL_ID)
             } catch {
                 Logger.knockManager.error("Error setting up remote notifications: \(error.localizedDescription, privacy: .public)")

Project.swift

@@ -22,8 +22,6 @@ let project = Project(
                     "UIAppFonts": [
                         "InstrumentSerif-Regular.ttf"
                     ],
-                    "CADisableMinimumFrameDurationOnPhone": true,
-                    "PHPhotoLibraryPreventAutomaticLimitedAccessAlert": true,
                     "CFBundleDisplayName": "$(BUNDLE_DISPLAY_NAME)",
                     "CFBundleName": "$(BUNDLE_NAME)",
                     "POSTHOG_API_KEY": "$(POSTHOG_API_KEY)",
@@ -84,6 +82,7 @@ let project = Project(
                 .external(name: "SwiftUIIntrospect"),
                 .external(name: "Get"),
                 .external(name: "Knock"),
+                .external(name: "Queue")
             ],
             settings: .settings(
                 base: .init()

Tuist/Package.resolved

@@ -28,6 +28,7 @@ let package = Package(
         .package(url: "https://github.com/hmlongco/Navigator", from: "1.2.2"),
         .package(url: "https://github.com/siteline/swiftui-introspect", from: "26.0.0"),
         .package(url: "https://github.com/kean/Get", from: "2.2.1"),
-        .package(url: "https://github.com/knocklabs/knock-swift.git", from: "1.2.4")
+        .package(url: "https://github.com/knocklabs/knock-swift", from: "1.2.4"),
+        .package(url: "https://github.com/mattmassicotte/Queue", from: "0.2.2")
     ]
 )