#import "RNWonderPush.h"
#import <WonderPush/WonderPush.h>

// Singleton delegate to handle WonderPush events before RNWonderPush module is initialized
@interface RNWonderPushDelegate : NSObject <WonderPushDelegate>
+ (instancetype)sharedInstance;
@property (nonatomic, weak) RNWonderPush *reactModule;
@property (nonatomic, strong) NSMutableArray *queuedReceivedNotifications;
@property (nonatomic, strong) NSMutableArray *queuedOpenedNotifications;
@property (nonatomic, strong) NSMutableArray *queuedUrlForDeeplink;
@property (nonatomic, strong) NSMutableDictionary<NSString *, void (^)(NSURL * _Nullable)> *urlCallbacks;
@property (nonatomic, strong) NSLock *urlCallbacksLock;
@property (nonatomic, strong) NSString *initialURL;
@property (nonatomic, assign) BOOL getInitialURLCalled;
- (void)flushDelegateEvents;
@end

// Singleton delegate implementation
@implementation RNWonderPushDelegate

+ (instancetype)sharedInstance {
    static RNWonderPushDelegate *sharedInstance = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        sharedInstance = [[self alloc] init];
    });
    return sharedInstance;
}

- (instancetype)init {
    if (self = [super init]) {
        _queuedReceivedNotifications = [NSMutableArray array];
        _queuedOpenedNotifications = [NSMutableArray array];
        _queuedUrlForDeeplink = [NSMutableArray array];
        _urlCallbacks = [NSMutableDictionary dictionary];
        _urlCallbacksLock = [[NSLock alloc] init];
        _initialURL = nil;
        _getInitialURLCalled = NO;
    }
    return self;
}

// Notification event emission methods (called by WonderPush delegate)
- (void)onNotificationReceived:(NSDictionary *)notification {
  if (self.reactModule) {
    NSDictionary *eventData = @{@"notification": notification};
    [self.reactModule emitOnNotificationReceived:eventData];
  } else {
    @synchronized(self) {
      [self.queuedReceivedNotifications addObject:notification];
    }
  }
}

- (void)onNotificationOpened:(NSDictionary *)notification withButton:(NSInteger)buttonIndex {
  // Capture the initial URL if getInitialURL hasn't been called yet
  @synchronized(self) {
    if (!self.getInitialURLCalled && !self.initialURL) {
      NSString *targetUrl = nil;

      if (buttonIndex == -1) {
        // No button clicked, get the main targetUrl
        targetUrl = notification[@"_wp"][@"targetUrl"];
      } else {
        // Button clicked, get the button's targetUrl
        NSArray *buttons = notification[@"_wp"][@"alert"][@"buttons"];
        if (buttons && [buttons isKindOfClass:[NSArray class]] && buttonIndex >= 0 && buttonIndex < buttons.count) {
          NSDictionary *button = buttons[buttonIndex];
          if ([button isKindOfClass:[NSDictionary class]]) {
            targetUrl = button[@"targetUrl"];
          }
        }
      }

      if (targetUrl && [targetUrl isKindOfClass:[NSString class]] && targetUrl.length > 0) {
        self.initialURL = targetUrl;
      }
    }
  }

  if (self.reactModule) {
    NSDictionary *eventData = @{
      @"notification": notification,
      @"buttonIndex": @(buttonIndex)
    };
    [self.reactModule emitOnNotificationOpened:eventData];
  } else {
    @synchronized(self) {
      [self.queuedOpenedNotifications addObject:@{
        @"notification": notification,
        @"buttonIndex": @(buttonIndex)
      }];
    }
  }
}

- (void)flushDelegateEvents {
  @synchronized(self) {
    // Flush queued URL for deeplink events
    // Those are the most time sensitive
    for (NSDictionary *eventData in self.queuedUrlForDeeplink) {
      [self.reactModule emitOnUrlForDeeplink:eventData];
    }
    [self.queuedUrlForDeeplink removeAllObjects];

    // Flush received notifications
    for (NSDictionary *notification in self.queuedReceivedNotifications) {
      NSDictionary *eventData = @{@"notification": notification};
      [self.reactModule emitOnNotificationReceived:eventData];
    }
    [self.queuedReceivedNotifications removeAllObjects];

    // Flush opened notifications
    for (NSDictionary *queuedItem in self.queuedOpenedNotifications) {
      NSDictionary *notification = queuedItem[@"notification"];
      NSInteger buttonIndex = [queuedItem[@"buttonIndex"] integerValue];
      NSDictionary *eventData = @{
        @"notification": notification,
        @"buttonIndex": @(buttonIndex)
      };
      [self.reactModule emitOnNotificationOpened:eventData];
    }
    [self.queuedOpenedNotifications removeAllObjects];
  }
}

// WonderPushDelegate method for URL deep link handling
- (void)wonderPushWillOpenURL:(NSURL *)url withCompletionHandler:(void (^)(NSURL * _Nullable))completionHandler {
  // Generate a unique callback ID
  NSString *callbackId = [[NSUUID UUID] UUIDString];

  // Store the completion handler
  [self.urlCallbacksLock lock];
  self.urlCallbacks[callbackId] = completionHandler;
  [self.urlCallbacksLock unlock];

  // Prepare event data
  NSDictionary *eventData = @{
    @"url": url.absoluteString ?: @"",
    @"callbackId": callbackId
  };

  // Send event to JavaScript if module is ready, otherwise queue it
  if (self.reactModule) {
    [self.reactModule emitOnUrlForDeeplink:eventData];
  } else {
    @synchronized(self) {
      [self.queuedUrlForDeeplink addObject:eventData];
    }
  }

  // Set a timeout to prevent waiting for too long.
  // We do not want to wait for too long because if the JavaScript code never sets a delegate, flushDelegateEvents will never run.
  // Maybe we could store whether we had a delegate in the previous run and wait for a lower duration and still allow longer app startup duration if we know it's probably worth it.
  dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2.0 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
    [self.urlCallbacksLock lock];
    void (^callback)(NSURL * _Nullable) = self.urlCallbacks[callbackId];
    if (callback) {
      // Callback wasn't called in time, use original URL
      [self.urlCallbacks removeObjectForKey:callbackId];
      [self.urlCallbacksLock unlock];
      NSLog(@"[RNWonderPushDelegate] urlForDeeplink callback timed out, using original URL");
      callback(url);
    } else {
      [self.urlCallbacksLock unlock];
    }
  });
}

- (void)invokeUrlCallback:(NSString *)callbackId withUrl:(NSString * _Nullable)urlString {
  [self.urlCallbacksLock lock];
  void (^callback)(NSURL * _Nullable) = self.urlCallbacks[callbackId];
  if (callback) {
    [self.urlCallbacks removeObjectForKey:callbackId];
    [self.urlCallbacksLock unlock];

    NSURL *url = nil;
    if (urlString && urlString.length > 0) {
      url = [NSURL URLWithString:urlString];
    }
    callback(url);
  } else {
    [self.urlCallbacksLock unlock];
  }
}

@end

@implementation RNWonderPush

RCT_EXPORT_MODULE()

+ (void)initialize {
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        [WonderPush setIntegrator:@"react-native-wonderpush-3.0.2"];
        [WonderPush setDelegate:[RNWonderPushDelegate sharedInstance]];
    });
}

- (instancetype)init {
    if (self = [super init]) {
        // Register this module with the singleton delegate
        [RNWonderPushDelegate sharedInstance].reactModule = self;
    }
    return self;
}

- (std::shared_ptr<facebook::react::TurboModule>)getTurboModule:
    (const facebook::react::ObjCTurboModule::InitParams &)params
{
    return std::make_shared<facebook::react::NativeWonderPushSpecJSI>(params);
}

// Initialization
- (void)setLogging:(BOOL)enable resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setLogging:enable];
    resolve(nil);
}

- (void)initialize:(NSString *)clientId clientSecret:(NSString *)clientSecret resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setClientId:clientId secret:clientSecret];
    resolve(nil);
}

- (void)initializeAndRememberCredentials:(NSString *)clientId clientSecret:(NSString *)clientSecret resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setAndRememberClientId:clientId secret:clientSecret];
    resolve(nil);
}

- (void)getRememberedClientId:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *clientId = [WonderPush getRememberedClientId];
    resolve(clientId);
}

- (void)isInitialized:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    BOOL initialized = [WonderPush isInitialized];
    resolve(@(initialized));
}

// Subscribing users
- (void)subscribeToNotifications:(BOOL)fallbackToSettings resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush subscribeToNotifications];
    resolve(nil);
}

- (void)unsubscribeFromNotifications:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush unsubscribeFromNotifications];
    resolve(nil);
}

- (void)isSubscribedToNotifications:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    BOOL subscribed = [WonderPush isSubscribedToNotifications];
    resolve(@(subscribed));
}

// Segmentation
- (void)trackEvent:(NSString *)type attributes:(NSDictionary *)attributes resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush trackEvent:type attributes:attributes];
    resolve(nil);
}

// Tags
- (void)addTag:(NSArray<NSString *> *)tags resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush addTags:tags];
    resolve(nil);
}

- (void)removeTag:(NSArray<NSString *> *)tags resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush removeTags:tags];
    resolve(nil);
}

- (void)removeAllTags:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush removeAllTags];
    resolve(nil);
}

- (void)hasTag:(NSString *)tag resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    BOOL hasTag = [WonderPush hasTag:tag];
    resolve(@(hasTag));
}

- (void)getTags:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSArray *tags = [[WonderPush getTags] array];
    resolve(tags ?: @[]);
}

// Properties
- (void)getPropertyValue:(NSString *)property resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    id value = [WonderPush getPropertyValue:property];
    resolve(value);
}

- (void)getPropertyValues:(NSString *)property resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSArray *values = [WonderPush getPropertyValues:property];
    resolve(values ?: @[]);
}

- (void)addProperty:(NSString *)str property:(NSArray *)property resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush addProperty:str value:property];
    resolve(nil);
}

- (void)removeProperty:(NSString *)str property:(NSArray *)property resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush removeProperty:str value:property];
    resolve(nil);
}

- (void)setProperty:(NSString *)str property:(NSArray *)property resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setProperty:str value:property];
    resolve(nil);
}

- (void)unsetProperty:(NSString *)property resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush unsetProperty:property];
    resolve(nil);
}

- (void)putProperties:(NSDictionary *)properties resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush putProperties:properties];
    resolve(nil);
}

- (void)getProperties:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSDictionary *properties = [WonderPush getProperties];
    resolve(properties ?: @{});
}

// Localization
- (void)getCountry:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *country = [WonderPush country];
    resolve(country);
}

- (void)setCountry:(NSString *)country resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setCountry:country];
    resolve(nil);
}

- (void)getCurrency:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *currency = [WonderPush currency];
    resolve(currency);
}

- (void)setCurrency:(NSString *)currency resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setCurrency:currency];
    resolve(nil);
}

- (void)getLocale:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *locale = [WonderPush locale];
    resolve(locale);
}

- (void)setLocale:(NSString *)locale resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setLocale:locale];
    resolve(nil);
}

- (void)getTimeZone:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *timeZone = [WonderPush timeZone];
    resolve(timeZone);
}

- (void)setTimeZone:(NSString *)timeZone resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setTimeZone:timeZone];
    resolve(nil);
}

// User IDs
- (void)getUserId:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *userId = [WonderPush userId];
    resolve(userId);
}

- (void)setUserId:(NSString *)userId resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setUserId:userId];
    resolve(nil);
}

// Installation info
- (void)getDeviceId:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *deviceId = [WonderPush deviceId];
    resolve(deviceId);
}

- (void)getInstallationId:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *installationId = [WonderPush installationId];
    resolve(installationId);
}

- (void)getPushToken:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *pushToken = [WonderPush pushToken];
    resolve(pushToken);
}

- (void)getAccessToken:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    NSString *accessToken = [WonderPush accessToken];
    resolve(accessToken);
}

// Privacy
- (void)setRequiresUserConsent:(BOOL)isConsent resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setRequiresUserConsent:isConsent];
    resolve(nil);
}

- (void)getUserConsent:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    BOOL consent = [WonderPush getUserConsent];
    resolve(@(consent));
}

- (void)setUserConsent:(BOOL)isConsent resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setUserConsent:isConsent];
    resolve(nil);
}

- (void)disableGeolocation:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush disableGeolocation];
    resolve(nil);
}

- (void)enableGeolocation:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush enableGeolocation];
    resolve(nil);
}

- (void)setGeolocation:(double)lat lon:(double)lon resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush setGeolocation:[[CLLocation alloc] initWithLatitude:lat longitude:lon]];
    resolve(nil);
}

- (void)clearEventsHistory:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush clearEventsHistory];
    resolve(nil);
}

- (void)clearPreferences:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush clearPreferences];
    resolve(nil);
}

- (void)clearAllData:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush clearAllData];
    resolve(nil);
}

- (void)downloadAllData:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [WonderPush downloadAllData:^(NSData * _Nullable data, NSError * _Nullable error) {
        if (error) {
            reject(@"DOWNLOAD_ERROR", [NSString stringWithFormat:@"Failed to download data: %@", error.localizedDescription], error);
        } else if (data) {
            NSString *jsonString = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
            resolve(jsonString ?: [NSNull null]);
        } else {
            resolve([NSNull null]);
        }
    }];
}

// Event emission
- (void)flushDelegateEvents:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    [[RNWonderPushDelegate sharedInstance] flushDelegateEvents];
    resolve(nil);
}

// Deep linking
- (void)getInitialURL:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    RNWonderPushDelegate *delegate = [RNWonderPushDelegate sharedInstance];
    @synchronized(delegate) {
        delegate.getInitialURLCalled = YES;
        resolve(delegate.initialURL);
    }
}

// Delegate callback for URL deep link handling
- (void)urlForDeeplinkCallback:(NSString *)callbackId url:(NSString * _Nullable)url {
    [[RNWonderPushDelegate sharedInstance] invokeUrlCallback:callbackId withUrl:url];
}

// User Preferences - Notification Channels (iOS no-op implementations)
- (void)getDefaultChannelId:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS always returns "default"
    resolve(@"default");
}

- (void)setDefaultChannelId:(NSString *)channelId resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

- (void)getChannelGroup:(NSString *)groupId resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS always returns null
    resolve([NSNull null]);
}

- (void)getChannel:(NSString *)channelId resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS always returns null
    resolve([NSNull null]);
}

- (void)setChannelGroups:(NSArray *)channelGroups resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

- (void)setChannels:(NSArray *)channels resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

- (void)putChannelGroup:(NSDictionary *)channelGroup resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

- (void)putChannel:(NSDictionary *)channel resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

- (void)removeChannelGroup:(NSString *)groupId resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

- (void)removeChannel:(NSString *)channelId resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject {
    // iOS no-op
    resolve(nil);
}

@end