bump version to 1.0.3

Author: thisisabhash

CHANGELOG.md

@@ -1,6 +1,9 @@
 # Changelog
 
 
+## 1.0.3 - (2025-07-02)
+
+
 ## 1.0.2 - (2025-06-10)
 
 ## 1.0.1 (2024-09-27)

Sources/AWSAppSyncApolloExtensions/Utilities/PackageInfo.swift

@@ -21,7 +21,7 @@ import AppKit
 
 class PackageInfo {
 
-    private static let version = "1.0.2"
+    private static let version = "1.0.3"
 
     @MainActor
     private static var os: (name: String, version: String) = {

Sources/AWSAppSyncApolloExtensions/Websocket/AppSyncWebSocketClient.swift

@@ -17,10 +17,24 @@ public class AppSyncWebSocketClient: NSObject, ApolloWebSocket.WebSocketClient,
 
     // MARK: - ApolloWebSocket.WebSocketClient
 
-    public var request: URLRequest
     public var delegate: ApolloWebSocket.WebSocketClientDelegate?
     public var callbackQueue: DispatchQueue
 
+    private let requestLock = NSLock()
+    private var _request: URLRequest
+    public var request: URLRequest {
+        get {
+            requestLock.lock()
+            defer { requestLock.unlock() }
+            return _request
+        }
+        set {
+            requestLock.lock()
+            defer { requestLock.unlock() }
+            _request = newValue
+        }
+    }
+
     // MARK: - Public
 
     public var publisher: AnyPublisher<AppSyncWebSocketEvent, Never> {
@@ -71,7 +85,7 @@ public class AppSyncWebSocketClient: NSObject, ApolloWebSocket.WebSocketClient,
         callbackQueue: DispatchQueue,
         authorizer: AppSyncAuthorizer
     ) {
-        self.request = URLRequest(url: appSyncRealTimeEndpoint(endpointURL))
+        self._request = URLRequest(url: appSyncRealTimeEndpoint(endpointURL))
         self.delegate = delegate
         self.callbackQueue = callbackQueue
         self.authorizer = authorizer

Tests/AWSAppSyncApolloExtensionsTests/Websocket/AppSyncWebSocketClientTests.swift

@@ -119,6 +119,37 @@ final class AppSyncWebSocketClientTests: XCTestCase {
         await fulfillment(of: [messageReceivedExpectation], timeout: 5)
     }
 
+    func testConcurrentURLRequestAccess() async {
+        let endpoint = URL(string: "https://abc.appsync-api.us-east-1.amazonaws.com/graphql")!
+        
+        let websocket = AppSyncWebSocketClient(
+            endpointURL: endpoint,
+            authorizer: APIKeyAuthorizer(apiKey: "apiKey"))
+        
+        let raceConditionExpectation = expectation(description: "Race condition test")
+        raceConditionExpectation.expectedFulfillmentCount = 2
+        
+        let iterations = 1000
+        
+        // Thread 1: Continuous reading
+        DispatchQueue.global(qos: .userInitiated).async {
+            for _ in 0..<iterations {
+                _ = websocket.request.value(forHTTPHeaderField: "test-header")
+            }
+            raceConditionExpectation.fulfill()
+        }
+        
+        // Thread 2: Continuous writing
+        DispatchQueue.global(qos: .userInitiated).async {
+            for i in 0..<iterations {
+                websocket.request.setValue("value-\(i)", forHTTPHeaderField: "test-header")
+            }
+            raceConditionExpectation.fulfill()
+        }
+        
+        await fulfillment(of: [raceConditionExpectation], timeout: 5)
+    }
+
     private func verifyConnected(
            _ webSocketClient: AppSyncWebSocketClient,
            autoConnectOnNetworkStatusChange: Bool = false,