[RTDB] Use NSURLSessionWebSocket instead of SocketRocket where possible (#12894)

Co-authored-by: Nick Cooke <36927374+ncooke3@users.noreply.github.com>

Author: paulb777

FirebaseDatabase/CHANGELOG.md

@@ -1,3 +1,7 @@
+# Unreleased
+- [changed] Update internal socket implementation to use `NSURLSessionWebSocket` where
+  available. (#12883)
+
 # 10.25.0
 - [changed] Removed usages of user defaults API to eliminate required reason impact.
 

FirebaseDatabase/Sources/Realtime/FWebSocketConnection.h

@@ -23,7 +23,8 @@
 @protocol FWebSocketDelegate;
 
 #if !TARGET_OS_WATCH
-@interface FWebSocketConnection : NSObject <FSRWebSocketDelegate>
+@interface FWebSocketConnection
+    : NSObject <FSRWebSocketDelegate, NSURLSessionWebSocketDelegate>
 #else
 @interface FWebSocketConnection : NSObject <NSURLSessionWebSocketDelegate>
 #endif // else !TARGET_OS_WATCH

FirebaseDatabase/Sources/Realtime/FWebSocketConnection.m

@@ -26,16 +26,17 @@
 #import "FirebaseDatabase/Sources/Realtime/FWebSocketConnection.h"
 #import "FirebaseDatabase/Sources/Utilities/FStringUtilities.h"
 
-#if TARGET_OS_IOS || TARGET_OS_TV ||                                           \
-    (defined(TARGET_OS_VISION) && TARGET_OS_VISION)
+#if TARGET_OS_IOS || TARGET_OS_TV || TARGET_OS_VISION
 #import <UIKit/UIKit.h>
-#endif // TARGET_OS_IOS || TARGET_OS_TV || (defined(TARGET_OS_VISION) &&
-       // TARGET_OS_VISION)
 
-#if TARGET_OS_WATCH
-#import <Network/Network.h>
+#elif TARGET_OS_WATCH
 #import <WatchKit/WatchKit.h>
-#endif // TARGET_OS_WATCH
+
+#elif TARGET_OS_OSX
+#import <AppKit/NSApplication.h>
+#endif
+
+#import <Network/Network.h>
 
 static NSString *const kAppCheckTokenHeader = @"X-Firebase-AppCheck";
 static NSString *const kUserAgentHeader = @"User-Agent";
@@ -52,9 +53,10 @@ - (void)shutdown;
 - (void)onClosed;
 - (void)closeIfNeverConnected;
 
-#if TARGET_OS_WATCH
-@property(nonatomic, strong) NSURLSessionWebSocketTask *webSocketTask;
-#else
+@property(nonatomic, strong)
+    NSURLSessionWebSocketTask *webSocketTask API_AVAILABLE(
+        macos(10.15), ios(13.0), watchos(6.0), tvos(13.0));
+#if !TARGET_OS_WATCH
 @property(nonatomic, strong) FSRWebSocket *webSocket;
 #endif // TARGET_OS_WATCH
 @property(nonatomic, strong) NSNumber *connectionId;
@@ -100,40 +102,56 @@ - (instancetype)initWith:(FRepoInfo *)repoInfo
                                                      userAgent:userAgent
                                                    googleAppID:googleAppID
                                                  appCheckToken:appCheckToken];
-#if TARGET_OS_WATCH
-        // Regular NSURLSession websocket.
-        NSOperationQueue *opQueue = [[NSOperationQueue alloc] init];
-        opQueue.underlyingQueue = queue;
-        NSURLSession *session = [NSURLSession
-            sessionWithConfiguration:[NSURLSessionConfiguration
-                                         defaultSessionConfiguration]
-                            delegate:self
-                       delegateQueue:opQueue];
-        NSURLSessionWebSocketTask *task =
-            [session webSocketTaskWithRequest:req];
-        self.webSocketTask = task;
-
-        if (@available(watchOS 7.0, *)) {
-            [[NSNotificationCenter defaultCenter]
-                addObserverForName:WKApplicationWillResignActiveNotification
-                            object:nil
-                             queue:opQueue
-                        usingBlock:^(NSNotification *_Nonnull note) {
-                          FFLog(@"I-RDB083015",
-                                @"Received watchOS background notification, "
-                                @"closing web socket.");
-                          [self onClosed];
-                        }];
+
+        if (@available(iOS 13.0, macOS 10.15, macCatalyst 13.1, tvOS 13.0,
+                       watchOS 6.0, *)) {
+            // Regular NSURLSession websocket.
+            NSOperationQueue *opQueue = [[NSOperationQueue alloc] init];
+            opQueue.underlyingQueue = queue;
+            NSURLSession *session = [NSURLSession
+                sessionWithConfiguration:[NSURLSessionConfiguration
+                                             defaultSessionConfiguration]
+                                delegate:self
+                           delegateQueue:opQueue];
+            NSURLSessionWebSocketTask *task =
+                [session webSocketTaskWithRequest:req];
+            self.webSocketTask = task;
+
+#if TARGET_OS_IOS || TARGET_OS_TV || TARGET_OS_VISION || TARGET_OS_MACCATALYST
+            NSString *resignName = UIApplicationWillResignActiveNotification;
+#elif TARGET_OS_OSX
+            NSString *resignName = NSApplicationWillResignActiveNotification;
+#elif TARGET_OS_WATCH
+            NSString *resignName = WKApplicationWillResignActiveNotification;
+#elif
+#error("missing platform")
+#endif
+            if (@available(watchOS 7.0, *)) {
+                [[NSNotificationCenter defaultCenter]
+                    addObserverForName:resignName
+                                object:nil
+                                 queue:opQueue
+                            usingBlock:^(NSNotification *_Nonnull note) {
+                              FFLog(@"I-RDB083015",
+                                    @"Received notification that application "
+                                    @"will resign, "
+                                    @"closing web socket.");
+                              [self onClosed];
+                            }];
+            }
+        }
+#if !TARGET_OS_WATCH
+        else {
+            // TODO(mmaksym): Remove googleAppID and userAgent from FSRWebSocket
+            // as they are passed via NSURLRequest.
+            self.webSocket =
+                [[FSRWebSocket alloc] initWithURLRequest:req
+                                                   queue:queue
+                                             googleAppID:googleAppID
+                                            andUserAgent:userAgent];
+            [self.webSocket setDelegateDispatchQueue:queue];
+            self.webSocket.delegate = self;
         }
-#else
-        // TODO(mmaksym): Remove googleAppID and userAgent from FSRWebSocket as
-        // they are passed via NSURLRequest.
-        self.webSocket = [[FSRWebSocket alloc] initWithURLRequest:req
-                                                            queue:queue
-                                                      googleAppID:googleAppID
-                                                     andUserAgent:userAgent];
-        [self.webSocket setDelegateDispatchQueue:queue];
-        self.webSocket.delegate = self;
 #endif // TARGET_OS_WATCH
     }
     return self;
@@ -195,13 +213,17 @@ - (void)open {
     assert(delegate);
     everConnected = NO;
     // TODO Assert url
-#if TARGET_OS_WATCH
-    [self.webSocketTask resume];
-    // We need to request data from the web socket in order for it to start
-    // sending data.
-    [self receiveWebSocketData];
-#else
-    [self.webSocket open];
+    if (@available(iOS 13.0, macOS 10.15, macCatalyst 13.1, tvOS 13.0,
+                   watchOS 6.0, *)) {
+        [self.webSocketTask resume];
+        // We need to request data from the web socket in order for it to start
+        // sending data.
+        [self receiveWebSocketData];
+    }
+#if !TARGET_OS_WATCH
+    else {
+        [self.webSocket open];
+    }
 #endif // TARGET_OS_WATCH
     dispatch_time_t when = dispatch_time(
         DISPATCH_TIME_NOW, kWebsocketConnectTimeout * NSEC_PER_SEC);
@@ -214,12 +236,16 @@ - (void)close {
     FFLog(@"I-RDB083003", @"(wsc:%@) FWebSocketConnection is being closed.",
           self.connectionId);
     isClosed = YES;
-#if TARGET_OS_WATCH
-    [self.webSocketTask
-        cancelWithCloseCode:NSURLSessionWebSocketCloseCodeNormalClosure
-                     reason:nil];
-#else
-    [self.webSocket close];
+    if (@available(iOS 13.0, macOS 10.15, macCatalyst 13.1, tvOS 13.0,
+                   watchOS 6.0, *)) {
+        [self.webSocketTask
+            cancelWithCloseCode:NSURLSessionWebSocketCloseCodeNormalClosure
+                         reason:nil];
+    }
+#if !TARGET_OS_WATCH
+    else {
+        [self.webSocket close];
+    }
 #endif // TARGET_OS_WATCH
 }
 
@@ -322,25 +348,27 @@ - (void)handleIncomingFrame:(NSString *)message {
 }
 
 #pragma mark -
-#pragma mark URLSessionWebSocketDelegate watchOS implementation
-#if TARGET_OS_WATCH
+#pragma mark URLSessionWebSocketDelegate implementation
 
 - (void)URLSession:(NSURLSession *)session
           webSocketTask:(NSURLSessionWebSocketTask *)webSocketTask
-    didOpenWithProtocol:(NSString *)protocol {
+    didOpenWithProtocol:(NSString *)protocol
+    API_AVAILABLE(macos(10.15), ios(13.0), watchos(6.0), tvos(13.0)) {
     [self webSocketDidOpen];
 }
 
 - (void)URLSession:(NSURLSession *)session
        webSocketTask:(NSURLSessionWebSocketTask *)webSocketTask
     didCloseWithCode:(NSURLSessionWebSocketCloseCode)closeCode
-              reason:(NSData *)reason {
+              reason:(NSData *)reason
+    API_AVAILABLE(macos(10.15), ios(13.0), watchos(6.0), tvos(13.0)) {
     FFLog(@"I-RDB083011", @"(wsc:%@) didCloseWithCode: %ld %@",
           self.connectionId, (long)closeCode, reason);
     [self onClosed];
 }
 
-- (void)receiveWebSocketData {
+- (void)receiveWebSocketData API_AVAILABLE(macos(10.15), ios(13.0),
+                                           watchos(6.0), tvos(13.0)) {
     __weak __auto_type weakSelf = self;
     [self.webSocketTask receiveMessageWithCompletionHandler:^(
                             NSURLSessionWebSocketMessage *_Nullable message,
@@ -364,7 +392,7 @@ - (void)receiveWebSocketData {
     }];
 }
 
-#else
+#if !TARGET_OS_WATCH
 
 #pragma mark SRWebSocketDelegate implementation
 
@@ -387,7 +415,7 @@ - (void)webSocket:(FSRWebSocket *)webSocket
     [self onClosed];
 }
 
-#endif // TARGET_OS_WATCH
+#endif // !TARGET_OS_WATCH
 
 // Common to both SRWebSocketDelegate and URLSessionWebSocketDelegate.
 
@@ -413,21 +441,26 @@ - (void)webSocketDidOpen {
 
 /** Sends a string through the open web socket. */
 - (void)sendStringToWebSocket:(NSString *)string {
-#if TARGET_OS_WATCH
-    // Use built-in URLSessionWebSocket functionality.
-    [self.webSocketTask sendMessage:[[NSURLSessionWebSocketMessage alloc]
-                                        initWithString:string]
-                  completionHandler:^(NSError *_Nullable error) {
-                    if (error) {
-                        FFWarn(@"I-RDB083016",
-                               @"Error sending web socket data: %@.", error);
-                        return;
-                    }
-                  }];
-#else
-    // Use existing SocketRocket implementation.
-    [self.webSocket send:string];
-#endif // TARGET_OS_WATCH
+    if (@available(iOS 13.0, macOS 10.15, macCatalyst 13.1, tvOS 13.0,
+                   watchOS 6.0, *)) {
+        // Use built-in URLSessionWebSocket functionality.
+        [self.webSocketTask
+                  sendMessage:[[NSURLSessionWebSocketMessage alloc]
+                                  initWithString:string]
+            completionHandler:^(NSError *_Nullable error) {
+              if (error) {
+                  FFWarn(@"I-RDB083016", @"Error sending web socket data: %@.",
+                         error);
+                  return;
+              }
+            }];
+    }
+#if !TARGET_OS_WATCH
+    else {
+        // Use existing SocketRocket implementation.
+        [self.webSocket send:string];
+    }
+#endif // !TARGET_OS_WATCH
 }
 
 /**
@@ -446,12 +479,17 @@ - (void)closeIfNeverConnected {
     if (!everConnected) {
         FFLog(@"I-RDB083012", @"(wsc:%@) Websocket timed out on connect",
               self.connectionId);
-#if TARGET_OS_WATCH
-        [self.webSocketTask
-            cancelWithCloseCode:NSURLSessionWebSocketCloseCodeNoStatusReceived
-                         reason:nil];
-#else
-        [self.webSocket close];
+        if (@available(iOS 13.0, macOS 10.15, macCatalyst 13.1, tvOS 13.0,
+                       watchOS 6.0, *)) {
+            [self.webSocketTask
+                cancelWithCloseCode:
+                    NSURLSessionWebSocketCloseCodeNoStatusReceived
+                             reason:nil];
+        }
+#if !TARGET_OS_WATCH
+        else {
+            [self.webSocket close];
+        }
 #endif // TARGET_OS_WATCH
     }
 }
@@ -468,9 +506,11 @@ - (void)onClosed {
         FFLog(@"I-RDB083013", @"Websocket is closing itself");
         [self shutdown];
     }
-#if TARGET_OS_WATCH
-    self.webSocketTask = nil;
-#else
+    if (@available(iOS 13.0, macOS 10.15, macCatalyst 13.1, tvOS 13.0,
+                   watchOS 6.0, *)) {
+        self.webSocketTask = nil;
+    }
+#if !TARGET_OS_WATCH
     self.webSocket = nil;
 #endif // TARGET_OS_WATCH
     if (keepAlive.isValid) {

FirebaseDatabase/Tests/Integration/FData.m

@@ -2197,7 +2197,9 @@ - (void)testUpdateDoesntAffectPriorityRemotely {
   }];
 }
 
-- (void)testUpdateReplacesChildrenAndIsNotRecursive {
+// TODO: On arm hardware Macs, the following test hangs with the emulator, but passes with a real
+// project.
+- (void)SKIPtestUpdateReplacesChildrenAndIsNotRecursive {
   FTupleFirebase *refs = [FTestHelpers getRandomNodePair];
   FIRDatabaseReference *reader = refs.one;
   FIRDatabaseReference *writer = refs.two;

FirebaseDatabase/Tests/Integration/FIRDatabaseQueryTests.m

@@ -4419,7 +4419,9 @@ - (void)testGetUpdatesPersistenceCacheWhenEnabled {
   }
 }
 
-- (void)testGetSkipsPersistenceCacheWhenOnline {
+// TODO: On arm hardware Macs, the following test hangs with the emulator, but passes with a real
+// project.
+- (void)SKIPtestGetSkipsPersistenceCacheWhenOnline {
   FIRDatabase* db = [self databaseForURL:self.databaseURL name:[[NSUUID UUID] UUIDString]];
   FIRDatabase* db2 = [self databaseForURL:self.databaseURL name:[[NSUUID UUID] UUIDString]];