chore: Identify API for MAUI refactor

Sources/LaunchDarklySessionReplay/API/LDReplay.swift

@@ -5,7 +5,9 @@ public final class LDReplay {
     public static var shared = LDReplay()
 
     /// Hook proxy for the C# / MAUI bridge. Set by the SessionReplay plugin during getHooks().
-    public var hookProxy: SessionReplayHookProxy?
+    public var hookProxy: SessionReplayHookProxy? {
+        client.map { SessionReplayHookProxy(sessionReplayService: $0) }
+    }
 
     var client: SessionReplayServicing?
 

Sources/LaunchDarklySessionReplay/Operations/InitializeSessionOperation.swift

@@ -189,7 +189,7 @@ extension SessionReplayAPIService {
             """,
             variables: InitializeSessionVariables(
                    sessionSecureId: sessionSecureId,
-                   organizationVerboseId:  context.sdkKey,
+                   organizationVerboseId: context.sdkKey,
                    enableStrictPrivacy: false,
                    privacySetting: "none",
                    enableRecordingNetworkContents: false,

Sources/LaunchDarklySessionReplay/SessionReplay.swift

@@ -2,8 +2,12 @@ import LaunchDarkly
 import Foundation
 import LaunchDarklyObservability
 import OSLog
+#if !LD_COCOAPODS
+    import Common
+#endif
 
 public final class SessionReplay: Plugin {
+    let sessionReplayHook = SessionReplayHook()
     let options: SessionReplayOptions
     var sessionReplayService: SessionReplayService?
     var observabilityContext: ObservabilityContext?
@@ -34,7 +38,7 @@ public final class SessionReplay: Plugin {
                                                                 metadata: metadata)
             LDReplay.shared.client = sessionReplayService
             self.sessionReplayService = sessionReplayService
-
+            sessionReplayHook.delegate = sessionReplayService
             if options.isEnabled {
                 start()
             }
@@ -44,8 +48,7 @@ public final class SessionReplay: Plugin {
     }
 
     public func getHooks(metadata: EnvironmentMetadata) -> [any Hook] {
-        LDReplay.shared.hookProxy = SessionReplayHookProxy(plugin: self)
-        return [SessionReplayHook(plugin: self)]
+        return [sessionReplayHook]
     }
 
     public func start() {

Sources/LaunchDarklySessionReplay/SessionReplayHook.swift

@@ -7,31 +7,31 @@ import LaunchDarklyObservability
     import Common
 #endif
 
+/// Hook protocol adapter for native Swift SDK usage.
+/// Extracts data from SDK types and delegates to SessionReplayHookExporter.
 final class SessionReplayHook: Hook {
-    private let plugin: SessionReplay
-
-    init(plugin: SessionReplay) {
-        self.plugin = plugin
+    weak var delegate: SessionReplayServicing?
+
+    init() {
     }
-    
+
     public func metadata() -> Metadata {
         return Metadata(name: "SessionReplay")
     }
-    
+
     public func afterIdentify(seriesContext: IdentifySeriesContext, seriesData: IdentifySeriesData, result: IdentifyResult) -> IdentifySeriesData {
-        guard case .complete = result else {
-            return seriesData
-        }
-
-        guard let options = plugin.observabilityContext?.options else {
+        guard case .complete = result, let delegate else {
             return seriesData
         }
-        let sessionAttributes = plugin.observabilityContext?.sessionAttributes
-        Task {
-            let identifyPayload = await IdentifyItemPayload(options: options, sessionAttributes: sessionAttributes, ldContext: seriesContext.context, timestamp: Date().timeIntervalSince1970)
-            await plugin.sessionReplayService?.scheduleIdentifySession(identifyPayload: identifyPayload)
-        }
-
+
+        var keys = [String: String]()
+        for (k, v) in seriesContext.context.contextKeys() { keys[k] = v }
+
+        delegate.afterIdentify(
+            contextKeys: keys,
+            canonicalKey: seriesContext.context.fullyQualifiedKey(),
+            completed: true
+        )
         return seriesData
     }
 }

Sources/LaunchDarklySessionReplay/SessionReplayHookProxy.swift

@@ -1,39 +1,29 @@
 import Foundation
 import LaunchDarklyObservability
+#if LD_COCOAPODS
+    import LaunchDarklyObservability
+#else
+    import Common
+#endif
 
 /// @objc adapter for the C# / MAUI bridge.
-/// Converts Foundation types (NSObject, NSDictionary) to Swift types
-/// and delegates to SessionReplay so the replay identify logic is accessible
-/// from the Xamarin.iOS binding.
+/// Converts Foundation types to Swift types
+/// and delegates to SessionReplayHookExporter.
 @objc(SessionReplayHookProxy)
 public final class SessionReplayHookProxy: NSObject {
-    private let plugin: SessionReplay
+    private let sessionReplayService: SessionReplayServicing
 
-    init(plugin: SessionReplay) {
-        self.plugin = plugin
+    init(sessionReplayService: SessionReplayServicing) {
+        self.sessionReplayService = sessionReplayService
         super.init()
     }
 
     @objc(afterIdentifyWithContextKeys:canonicalKey:completed:)
     public func afterIdentify(contextKeys: NSDictionary, canonicalKey: String, completed: Bool) {
-        guard completed else { return }
-        guard let options = plugin.observabilityContext?.options else { return }
-
         var keys = [String: String]()
         for (k, v) in contextKeys {
             if let key = k as? String, let val = v as? String { keys[key] = val }
         }
-
-        let sessionAttributes = plugin.observabilityContext?.sessionAttributes
-        Task {
-            let identifyPayload = IdentifyItemPayload(
-                options: options,
-                sessionAttributes: sessionAttributes,
-                contextKeys: keys,
-                canonicalKey: canonicalKey,
-                timestamp: Date().timeIntervalSince1970
-            )
-            await plugin.sessionReplayService?.scheduleIdentifySession(identifyPayload: identifyPayload)
-        }
+        sessionReplayService.afterIdentify(contextKeys: keys, canonicalKey: canonicalKey, completed: completed)
     }
 }

Sources/LaunchDarklySessionReplay/SessionReplayService.swift

@@ -8,7 +8,7 @@ import LaunchDarklyObservability
 import Common
 #endif
 
-protocol SessionReplayServicing {
+protocol SessionReplayServicing: AnyObject {
     @MainActor
     func start()
 
@@ -17,6 +17,8 @@ protocol SessionReplayServicing {
 
     @MainActor
     var isEnabled: Bool { get set }
+
+    func afterIdentify(contextKeys: [String: String], canonicalKey: String, completed: Bool)
 }
 
 struct SessionReplayContext {
@@ -48,6 +50,7 @@ final class SessionReplayService: SessionReplayServicing {
     var sessionReplayExporter: SessionReplayExporter
     let userInteractionManager: UserInteractionManager
     let log: OSLog
+    var observabilityContext: ObservabilityContext
 
     @MainActor
     var isEnabled = false {
@@ -69,6 +72,7 @@ final class SessionReplayService: SessionReplayServicing {
         guard let url = URL(string: observabilityContext.options.backendUrl) else {
             throw InstrumentationError.invalidGraphQLUrl
         }
+        self.observabilityContext = observabilityContext
         self.log = observabilityContext.options.log
         let graphQLClient = GraphQLClient(endpoint: url)
         let captureService = ImageCaptureService(options: sessonReplayOptions)
@@ -101,6 +105,20 @@ final class SessionReplayService: SessionReplayServicing {
         os_log("LaunchDarkly Session Replay started, version: %{public}@", log: log, type: .info, sdkVersion)
     }
 
+    func afterIdentify(contextKeys: [String: String], canonicalKey: String, completed: Bool) {
+        guard completed else { return }
+        Task {
+            let identifyPayload = IdentifyItemPayload(
+                options: observabilityContext.options,
+                sessionAttributes: observabilityContext.sessionAttributes,
+                contextKeys: contextKeys,
+                canonicalKey: canonicalKey,
+                timestamp: Date().timeIntervalSince1970
+            )
+            await scheduleIdentifySession(identifyPayload: identifyPayload)
+        }
+    }
+
     func scheduleIdentifySession(identifyPayload: IdentifyItemPayload) async {
         do {
             try await sessionReplayExporter.identifySession(identifyPayload: identifyPayload)

TestApp/Sources/AppDelegate.swift

@@ -22,11 +22,13 @@ final class AppDelegate: NSObject, UIApplicationDelegate {
                 )
             config.plugins = [
                 Observability(options: .init(
+                    isEnabled: true,
                     serviceName: "observability-ios-test-app",
                     otlpEndpoint: otlpEndpoint,
                     backendUrl: backendUrl,
                     resourceAttributes: ["test-options-attribute": .string("ios-test-app")],
                     sessionBackgroundTimeout: 3,
+                    crashReporting: .enabled
                    )),
                 SessionReplay(options: .init(
                     isEnabled: true,