// Copyright 2015-present 650 Industries. All rights reserved.

/**
 * This file is compiled without ARC - the memory needs to be managed by hand.
 */

#import <EXDevLauncher/RCTPackagerConnection+EXDevLauncherPackagerConnectionInterceptor.h>
#import <EXDevLauncher/EXDevLauncherController.h>

#import <React/RCTReconnectingWebSocket.h>

#import <objc/runtime.h>
#import <mutex>

#if RCT_DEV

static RCTReconnectingWebSocket *createSocketForURL(NSURL * url)
{
  NSURLComponents *const components = [NSURLComponents new];
  components.host = [url host];
  NSString *scheme = [url scheme];
  components.scheme = ([scheme isEqualToString:@"https"] || [scheme isEqualToString:@"exps"]) ? @"https" : @"http";
  components.port =  [url port];
  components.path = @"/message";
  components.queryItems = @[[NSURLQueryItem queryItemWithName:@"role" value:@"ios"]];
  static dispatch_queue_t queue;
  static dispatch_once_t onceToken;
  dispatch_once(&onceToken, ^{
    queue = dispatch_queue_create("com.facebook.RCTPackagerConnectionQueue", DISPATCH_QUEUE_SERIAL);
  });

  RCTReconnectingWebSocket *webSocket = [[RCTReconnectingWebSocket alloc] initWithURL:components.URL queue:queue];
  [components release];
  return [webSocket autorelease]; // adds to ARC
}

@implementation RCTPackagerConnection (EXDevLauncherPackagerConnectionInterceptor)

/**
 * Sets the WebSocket URL.
 */
- (void)setSocketConnectionURL:(NSURL *)url
{
  // Mutex isn't an objective-c object - [self valueForKey:@"_mutex"] will fail.
  // The other solution requires `object_getInstanceVariable` which doesn't work with ARC.
  // That's the only solution to get private variables that comes from cpp.
  Ivar mutexVar = object_getInstanceVariable(self, "_mutex", NULL);
  ptrdiff_t mutexOffset = ivar_getOffset(mutexVar);
  unsigned char* selfPtr = (unsigned char *)(__bridge void*)self;
  std::mutex *mutex = (std::mutex *)(selfPtr + mutexOffset);
  
  RCTReconnectingWebSocket *oldSocket = (RCTReconnectingWebSocket *)[self valueForKey:@"_socket"];

  std::lock_guard<std::mutex> l(*mutex);
  if (oldSocket == nil) {
    return; // already stopped
  }

  [self setValue:@NO forKey:@"_socketConnected"];

  oldSocket.delegate = nil;
  [oldSocket stop];
  
  RCTReconnectingWebSocket *newSocket = createSocketForURL(url);
  newSocket.delegate = (id<RCTReconnectingWebSocketDelegate>)self;
  [newSocket start];

  [self setValue:newSocket forKey:@"_socket"];

  static dispatch_once_t onceToken;
  dispatch_once(&onceToken, ^{
    [[NSNotificationCenter defaultCenter] addObserverForName:@"RCTTriggerReloadCommandNotification"
                                                      object:nil
                                                       queue:[NSOperationQueue mainQueue]
                                                  usingBlock:^(NSNotification *_Nonnull __unused note) {
      dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.1 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        NSURL *bundleUrl = [EXDevLauncherController sharedInstance].sourceUrl;
        if (bundleUrl && ![bundleUrl.scheme isEqualToString:@"file"]) {
          [self setSocketConnectionURL:bundleUrl];
        }
      });
    }];
  });
}

@end

#endif