mirror of
https://github.com/status-im/react-native.git
synced 2025-01-10 09:35:48 +00:00
b00c77af80
Summary:The 200ms timeout was causing resource issues and causing a lot of overhead when you're not running the devtools, since it will basically create a new socket every 200ms. Also clean up the way we do logging so it's completely compiled out in prod, and standardize all the names we use for threading to lowercase react. Reviewed By: frantic Differential Revision: D3115975 fb-gh-sync-id: e6e51c0621d8e9fc4eadb864acd678b8b5d322a1 fbshipit-source-id: e6e51c0621d8e9fc4eadb864acd678b8b5d322a1
144 lines
3.5 KiB
Objective-C
144 lines
3.5 KiB
Objective-C
/**
|
|
* Copyright (c) 2015-present, Facebook, Inc.
|
|
* All rights reserved.
|
|
*
|
|
* This source code is licensed under the BSD-style license found in the
|
|
* LICENSE file in the root directory of this source tree. An additional grant
|
|
* of patent rights can be found in the PATENTS file in the same directory.
|
|
*/
|
|
|
|
#import "RCTDefines.h"
|
|
|
|
#if RCT_DEV // Only supported in dev mode
|
|
|
|
#import "RCTWebSocketManager.h"
|
|
|
|
#import "RCTConvert.h"
|
|
#import "RCTLog.h"
|
|
#import "RCTUtils.h"
|
|
#import "RCTSRWebSocket.h"
|
|
|
|
#pragma mark - RCTWebSocketObserver
|
|
|
|
@interface RCTWebSocketObserver : NSObject <RCTSRWebSocketDelegate>
|
|
|
|
@property (nonatomic, strong) RCTSRWebSocket *socket;
|
|
@property (nonatomic, weak) id<RCTWebSocketProxyDelegate> delegate;
|
|
@property (nonatomic, strong) dispatch_semaphore_t socketOpenSemaphore;
|
|
|
|
- (instancetype)initWithURL:(NSURL *)url delegate:(id<RCTWebSocketProxyDelegate>)delegate;
|
|
|
|
@end
|
|
|
|
@implementation RCTWebSocketObserver
|
|
|
|
- (instancetype)initWithURL:(NSURL *)url delegate:(id<RCTWebSocketProxyDelegate>)delegate
|
|
{
|
|
if ((self = [self init])) {
|
|
_socket = [[RCTSRWebSocket alloc] initWithURL:url];
|
|
_socket.delegate = self;
|
|
|
|
_delegate = delegate;
|
|
}
|
|
return self;
|
|
}
|
|
|
|
- (void)start
|
|
{
|
|
_socketOpenSemaphore = dispatch_semaphore_create(0);
|
|
[_socket open];
|
|
dispatch_semaphore_wait(_socketOpenSemaphore, dispatch_time(DISPATCH_TIME_NOW, NSEC_PER_SEC * 2));
|
|
}
|
|
|
|
- (void)stop
|
|
{
|
|
_socket.delegate = nil;
|
|
[_socket closeWithCode:1000 reason:@"Invalidated"];
|
|
_socket = nil;
|
|
}
|
|
|
|
- (void)webSocket:(RCTSRWebSocket *)webSocket didReceiveMessage:(id)message
|
|
{
|
|
if (_delegate) {
|
|
NSError *error = nil;
|
|
NSDictionary<NSString *, id> *msg = RCTJSONParse(message, &error);
|
|
|
|
if (!error) {
|
|
[_delegate socketProxy:[RCTWebSocketManager sharedInstance] didReceiveMessage:msg];
|
|
} else {
|
|
RCTLogError(@"WebSocketManager failed to parse message with error %@\n<message>\n%@\n</message>", error, message);
|
|
}
|
|
}
|
|
}
|
|
|
|
- (void)webSocketDidOpen:(RCTSRWebSocket *)webSocket
|
|
{
|
|
dispatch_semaphore_signal(_socketOpenSemaphore);
|
|
}
|
|
|
|
- (void)webSocket:(RCTSRWebSocket *)webSocket didFailWithError:(NSError *)error
|
|
{
|
|
dispatch_semaphore_signal(_socketOpenSemaphore);
|
|
dispatch_async(dispatch_get_main_queue(), ^{
|
|
// Give the setUp method an opportunity to report an error first
|
|
RCTLogError(@"WebSocket connection failed with error %@", error);
|
|
});
|
|
}
|
|
|
|
@end
|
|
|
|
#pragma mark - RCTWebSocketManager
|
|
|
|
@interface RCTWebSocketManager()
|
|
|
|
@property (nonatomic, strong) NSMutableDictionary *sockets;
|
|
@property (nonatomic, strong) dispatch_queue_t queue;
|
|
|
|
@end
|
|
|
|
@implementation RCTWebSocketManager
|
|
|
|
+ (instancetype)sharedInstance
|
|
{
|
|
static RCTWebSocketManager *sharedInstance = nil;
|
|
static dispatch_once_t onceToken;
|
|
|
|
dispatch_once(&onceToken, ^{
|
|
sharedInstance = [self new];
|
|
});
|
|
|
|
return sharedInstance;
|
|
}
|
|
|
|
- (void)setDelegate:(id<RCTWebSocketProxyDelegate>)delegate forURL:(NSURL *)url
|
|
{
|
|
NSString *key = [url absoluteString];
|
|
RCTWebSocketObserver *observer = _sockets[key];
|
|
|
|
if (observer) {
|
|
if (!delegate) {
|
|
[observer stop];
|
|
[_sockets removeObjectForKey:key];
|
|
} else {
|
|
observer.delegate = delegate;
|
|
}
|
|
} else {
|
|
RCTWebSocketObserver *newObserver = [[RCTWebSocketObserver alloc] initWithURL:url delegate:delegate];
|
|
[newObserver start];
|
|
_sockets[key] = newObserver;
|
|
}
|
|
}
|
|
|
|
- (instancetype)init
|
|
{
|
|
if ((self = [super init])) {
|
|
_sockets = [NSMutableDictionary new];
|
|
_queue = dispatch_queue_create("com.facebook.react.WebSocketManager", DISPATCH_QUEUE_SERIAL);
|
|
}
|
|
return self;
|
|
}
|
|
|
|
@end
|
|
|
|
#endif
|