/**
 * Copyright (c) 2015-present, Facebook, Inc.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 */

// TODO(macOS ISS#2323203)

#import "RCTPlatformDisplayLink.h"

#import <React/RCTAssert.h>
#import <React/RCTDefines.h>

#import <CoreVideo/CVDisplayLink.h>
#import <CoreVideo/CVHostTime.h>

#import <libkern/OSAtomic.h>

@interface RCTPlatformDisplayLink ()

@property (nonatomic, strong) NSRunLoop *runLoop;

@end

@implementation RCTPlatformDisplayLink
{
  CVDisplayLinkRef _displayLink;
  SEL _selector;
  __weak id _target;
  NSRunLoop *_runLoop;
  NSMutableArray<NSRunLoopMode> *_modes;
  OSSpinLock _lock; // OS_SPINLOCK_INIT == 0
}

+ (RCTPlatformDisplayLink *)displayLinkWithTarget:(id)target selector:(SEL)sel
{
  RCTPlatformDisplayLink *displayLink = [[self.class alloc] init];
  displayLink->_target = target;
  displayLink->_selector = sel;
  return displayLink;
}

static CVReturn RCTPlatformDisplayLinkCallBack(__unused CVDisplayLinkRef displayLink, __unused const CVTimeStamp* now, __unused const CVTimeStamp* outputTime, __unused CVOptionFlags flagsIn, __unused CVOptionFlags* flagsOut, void* displayLinkContext)
{
  @autoreleasepool {
    RCTPlatformDisplayLink *rctDisplayLink = (__bridge RCTPlatformDisplayLink*)displayLinkContext;

    // Lock and check for invalidation prior to calling out to the runloop
    OSSpinLockLock(&rctDisplayLink->_lock);
    if (rctDisplayLink->_runLoop != nil) {
      CFRunLoopRef cfRunLoop = [rctDisplayLink->_runLoop getCFRunLoop];
      CFRunLoopPerformBlock(cfRunLoop, kCFRunLoopDefaultMode, ^{
        [rctDisplayLink tick];
      });
      CFRunLoopWakeUp(cfRunLoop);
    }
    OSSpinLockUnlock(&rctDisplayLink->_lock);
  }
  return kCVReturnSuccess;
}

- (void)dealloc
{
  if (_displayLink != NULL) {
    CVDisplayLinkStop(_displayLink);
    CVDisplayLinkRelease(_displayLink);
  }
}

- (void)addToRunLoop:(NSRunLoop *)runloop forMode:(NSRunLoopMode)mode
{
  _runLoop = runloop;

  if (_displayLink != NULL) {
    [_modes addObject:mode];
    return;
  }

  _modes = @[mode].mutableCopy;
  CVReturn ret = CVDisplayLinkCreateWithActiveCGDisplays(&_displayLink);
  if (ret != kCVReturnSuccess) {
    ret = CVDisplayLinkCreateWithCGDisplay(CGMainDisplayID(), &_displayLink);
  }
  RCTAssert(ret == kCVReturnSuccess, @"Cannot create display link");
  CVDisplayLinkSetOutputCallback(_displayLink, &RCTPlatformDisplayLinkCallBack, (__bridge void *)(self));
  CVDisplayLinkStart(_displayLink);
}

- (void)removeFromRunLoop:(__unused NSRunLoop *)runloop forMode:(NSRunLoopMode)mode
{
  [_modes removeObject:mode];
  if (_modes.count == 0) {
    [self invalidate];
  }
}

- (void)invalidate
{
  if (_runLoop != nil) {
    OSSpinLockLock(&_lock);
    _runLoop = nil;
    _modes = nil;
    OSSpinLockUnlock(&_lock);

    // CVDisplayLinkStop attempts to acquire a mutex possibly held during the callback's invocation.
    // Stop the display link outside of the lock to avoid deadlocking here.
    if (_displayLink != NULL) {
      CVDisplayLinkStop(_displayLink);
    }
  }
}

- (void)setPaused:(BOOL)paused
{
  if (paused) {
    CVDisplayLinkStop(_displayLink);
  } else {
    CVDisplayLinkStart(_displayLink);
  }
}

- (BOOL)isPaused
{
  return !CVDisplayLinkIsRunning(_displayLink);
}

- (NSTimeInterval)timestamp
{
  CVTimeStamp now;
  now.version = 0;
  memset(&now, 0 , sizeof(now));
  CVDisplayLinkGetCurrentTime(_displayLink, &now);
  return (NSTimeInterval)now.hostTime / (NSTimeInterval)CVGetHostClockFrequency();
}

- (NSTimeInterval)duration
{
  NSTimeInterval duration = 0;
  const CVTime time = CVDisplayLinkGetNominalOutputVideoRefreshPeriod(_displayLink);
  if (!(time.flags & kCVTimeIsIndefinite)) {
    duration = (NSTimeInterval)time.timeValue / (NSTimeInterval)time.timeScale;
  }
  return duration;
}

#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Warc-performSelector-leaks"
- (void)tick
{
  if (_selector && [_target respondsToSelector:_selector]) {
    [_target performSelector:_selector withObject:self];
  }
}
#pragma clang diagnostic pop

@end