refactor: add private access control to lock isolated values (#328)

* refactor: add private access control to lock isolated values

* chore: allow refactor prexi on commit

* chore: add readonly access to CallbackManager properties

Author: grdsdev

.github/workflows/conventional-commits-lint.js

@@ -16,6 +16,7 @@ const ALLOWED_CONVENTIONAL_COMMIT_PREFIXES = [
   "chore",
   "style",
   "test",
+  "refactor",
 ];
 
 const object = process.argv[2];
@@ -102,4 +103,4 @@ if (failed) {
   process.exit(1);
 }
 
-process.exit(0);
+process.exit(0);

Sources/PostgREST/PostgrestClient.swift

@@ -53,7 +53,7 @@ public final class PostgrestClient: Sendable {
     }
   }
 
-  let _configuration: LockIsolated<Configuration>
+  private let _configuration: LockIsolated<Configuration>
   public var configuration: Configuration { _configuration.value }
 
   /// Creates a PostgREST client with the specified configuration.

Sources/Realtime/V2/CallbackManager.swift

@@ -16,7 +16,15 @@ final class CallbackManager: @unchecked Sendable {
     var callbacks: [RealtimeCallback] = []
   }
 
-  let mutableState = LockIsolated(MutableState())
+  private let mutableState = LockIsolated(MutableState())
+
+  var serverChanges: [PostgresJoinConfig] {
+    mutableState.serverChanges
+  }
+
+  var callbacks: [RealtimeCallback] {
+    mutableState.callbacks
+  }
 
   @discardableResult
   func addBroadcastCallback(

Sources/Realtime/V2/WebSocketClient.swift

@@ -42,7 +42,7 @@ final class WebSocket: NSObject, URLSessionWebSocketDelegate, WebSocketClient, @
     var stream: SocketStream?
   }
 
-  let mutableState = LockIsolated(MutableState())
+  private let mutableState = LockIsolated(MutableState())
 
   init(config: RealtimeClientV2.Configuration) {
     realtimeURL = config.realtimeWebSocketURL

Sources/_Helpers/EventEmitter.swift

@@ -30,7 +30,7 @@ public final class ObservationToken: Sendable {
 package final class EventEmitter<Event: Sendable>: Sendable {
   public typealias Listener = @Sendable (Event) -> Void
 
-  let listeners = LockIsolated<[ObjectIdentifier: Listener]>([:])
+  private let listeners = LockIsolated<[ObjectIdentifier: Listener]>([:])
   public let lastEvent: LockIsolated<Event>
 
   let emitsLastEventWhenAttaching: Bool

Tests/RealtimeTests/CallbackManagerTests.swift

@@ -36,14 +36,14 @@ final class CallbackManagerTests: XCTestCase {
 
     XCTAssertEqual(callbackManager.addPresenceCallback { _ in }, 3)
 
-    XCTAssertEqual(callbackManager.mutableState.value.callbacks.count, 3)
+    XCTAssertEqual(callbackManager.callbacks.count, 3)
 
     callbackManager.removeCallback(id: 2)
     callbackManager.removeCallback(id: 3)
 
-    XCTAssertEqual(callbackManager.mutableState.value.callbacks.count, 1)
+    XCTAssertEqual(callbackManager.callbacks.count, 1)
     XCTAssertFalse(
-      callbackManager.mutableState.value.callbacks
+      callbackManager.callbacks
         .contains(where: { $0.id == 2 || $0.id == 3 })
     )
   }
@@ -62,7 +62,7 @@ final class CallbackManagerTests: XCTestCase {
 
     callbackManager.setServerChanges(changes: changes)
 
-    XCTAssertEqual(callbackManager.mutableState.value.serverChanges, changes)
+    XCTAssertEqual(callbackManager.serverChanges, changes)
   }
 
   func testTriggerPostgresChanges() {