#import "RNRudderSdkModuleImpl.h"
#import "RNRudderAnalytics.h"
#import "RSClient.h"
#import "RSConfig.h"
#import "RSLogger.h"
#import "RSMessageBuilder.h"
#import "RNApplicationLifeCycleManager.h"
#import "RNBackGroundModeManager.h"
#import "RNPreferenceManager.h"
#import "RNParamsConfigurator.h"
#import "RNUserSessionPlugin.h"

@implementation RNRudderSdkModuleImpl {
    RCTBridge *bridge;
    RNApplicationLifeCycleManager *applicationLifeCycleManager;
    RNBackGroundModeManager *backGroundModeManager;
    RNPreferenceManager *preferenceManager;
    RNParamsConfigurator *configParams;
    BOOL initialized;
    RNUserSessionPlugin *session;
}

- (instancetype)initWithBridge:(RCTBridge *)bridge {
  self = [super init];
  if (self) {
    self->bridge = bridge;
    self->initialized = NO;
  }
  return self;
}

- (void)setup:(NSDictionary*)config options:(NSDictionary*)options resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    self->configParams = [[RNParamsConfigurator alloc] initWithConfig:config];
    RSConfigBuilder *configBuilder = [self->configParams handleConfig];
    
    [RSLogger logDebug:@"setup: Initiating RNPreferenceManager"];
    self->preferenceManager = [RNPreferenceManager getInstance];
    [self->preferenceManager migrateAppInfoPreferencesWhenRNPrefDoesNotExist];
    
    [RSClient getInstance:self->configParams.writeKey config:[RNRudderAnalytics buildWithIntegrations:configBuilder] options:[self getRudderOptionsObject:options]];
    
    [RSLogger logDebug:@"setup: Initiating RNUserSessionPlugin"];
    self->session = [[RNUserSessionPlugin alloc] initWithAutomaticSessionTrackingStatus:self->configParams.autoSessionTracking withLifecycleEventsTrackingStatus:self->configParams.trackLifeCycleEvents withSessionTimeout:self->configParams.sessionTimeout];
    [self->session handleSessionTracking];
    
    [RSLogger logDebug:@"setup: Initiating RNBackGroundModeManager"];
    self->backGroundModeManager = [[RNBackGroundModeManager alloc] initWithEnableBackgroundMode:self->configParams.enableBackgroundMode];
    
    [RSLogger logDebug:@"setup: Initiating RNApplicationLifeCycleManager"];
    self->applicationLifeCycleManager = [[RNApplicationLifeCycleManager alloc] initWithTrackLifecycleEvents:self->configParams.trackLifeCycleEvents andBackGroundModeManager:self->backGroundModeManager withLaunchOptions:bridge.launchOptions withSessionPlugin:self->session];
    [self->applicationLifeCycleManager trackApplicationLifeCycle];
    
    if (self->configParams.recordScreenViews) {
      [RSLogger logDebug:@"setup: Enabling automatic recording of screen views"];
      [self->applicationLifeCycleManager prepareScreenRecorder];
    }
    self->initialized = YES;
  }
  else{
    [RSLogger logDebug:@"Rudder Client already initialized, Ignoring the new setup call"];
  }
  resolve(nil);
}

-(BOOL)isRudderClientInitializedAndReady {
  if (self->initialized == NO || [RSClient sharedInstance] == nil) {
    [RSLogger logWarn:@"Dropping the call as RudderClient is not initialized yet. Please use `await` keyword with the setup call"];
    return NO;
  }
  return YES;
}

- (void)track:(NSString*)event properties:(NSDictionary*)properties options:(NSDictionary*)options resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [self->session saveEventTimestamp];
  RSMessageBuilder* builder = [[RSMessageBuilder alloc] init];
  [builder setEventName:event];
  [builder setPropertyDict:properties];
  [builder setRSOption:[self getRudderOptionsObject:options]];
  
  [[RSClient sharedInstance] trackWithBuilder:builder];
  resolve(nil);
}

- (void)screen:(NSString*)event properties:(NSDictionary*)properties options:(NSDictionary*)options resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [self->session saveEventTimestamp];
  [[RSClient sharedInstance] screen:event properties:properties options:[self getRudderOptionsObject:options]];
  resolve(nil);
}

- (void)identify:(NSString*)userId traits:(NSDictionary*)traits options:(NSDictionary*)options resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [self->session saveEventTimestamp];
  if([userId isEqual:@""]) {
    [[RSClient sharedInstance] identify:nil traits:traits options:[self getRudderOptionsObject:options]];
    resolve(nil);
    return;
  }
  [[RSClient sharedInstance] identify:userId traits:traits options:[self getRudderOptionsObject:options]];
  resolve(nil);
}

- (void)alias:(NSString*)newId previousId:(NSString*)previousId options:(NSDictionary*)options resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  if([newId isEqual:@""]) {
    [RSLogger logWarn:@"Dropping the Alias call as newId can not be empty"];
    resolve(nil);
    return;
  }
  [self->session saveEventTimestamp];
  [[RSClient sharedInstance] alias:newId previousId:previousId options:[self getRudderOptionsObject:options]];
  resolve(nil);
}

- (void)group:(NSString*)groupId traits:(NSDictionary*)traits options:(NSDictionary*)options resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  if([groupId isEqual:@""]) {
    [RSLogger logWarn:@"Dropping the Group call as groupId can not be empty"];
    resolve(nil);
    return;
  }
  [self->session saveEventTimestamp];
  [[RSClient sharedInstance] group:groupId traits:traits options:[self getRudderOptionsObject:options]];
  resolve(nil);
}

- (void)putDeviceToken:(NSString*)token resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (token!=nil && [token length] != 0) {
    [RSClient putDeviceToken:token];
  }
  resolve(nil);
}

- (void)reset:(BOOL)clearAnonymousId resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [[RSClient sharedInstance] reset:clearAnonymousId];
  resolve(nil);
}

- (void)flush:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [[RSClient sharedInstance] flush];
  resolve(nil);
}

- (void)optOut:(BOOL)optOut resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [[RSClient sharedInstance] optOut:optOut];
  resolve(nil);
}

- (void)putAdvertisingId:(NSString*)id resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  [RSClient putAdvertisingId:id];
  resolve(nil);
}

- (void)clearAdvertisingId:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [[RSClient sharedInstance] clearAdvertisingId];
  resolve(nil);
}

- (void)putAnonymousId:(NSString*)id resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (id != nil && [id length] != 0) {
    [RSClient putAnonymousId:id];
  }
  resolve(nil);
}

- (void)registerCallback:(NSString *)name callback:(RCTResponseSenderBlock)callback {
    // we will trigger the callback directly because ios native sdk's deal with static references
  callback(@[]);
}

  // Migrated from Callbacks to Promise to support ES2016's async/await syntax on the RN Side
- (void)getRudderContext:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  NSDictionary* context = [[[RSClient sharedInstance] getContext] dict];
  resolve(context);
}

- (void)startSession:(NSString *)sessionId resolver:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [self->session enableManualSessionParams];
  if ([sessionId length] == 0) {
    [self->session startSession];
    [RSLogger logVerbose:@"setup: startSession: starting manual session"];
    resolve(nil);
    return;
  }
  [self->session startSession:[sessionId longLongValue]];
  [RSLogger logVerbose:[NSString stringWithFormat:@"setup: starting manual session with id: %lld", [sessionId longLongValue]]];
  resolve(nil);
}

- (void)endSession:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  [self->session endSession];
  [RSLogger logVerbose:@"setup: ending session"];
  resolve(nil);
}

- (void)getSessionId:(RCTPromiseResolveBlock)resolve rejecter:(RCTPromiseRejectBlock)reject {
  if (![self isRudderClientInitializedAndReady]) {
    resolve(nil);
    return;
  }
  NSNumber *sessionId = [self->session getSessionId];
  if (sessionId == nil) {
    resolve(nil);
    return;
  }
  resolve(sessionId);
}

-(RSOption*) getRudderOptionsObject:(NSDictionary *) optionsDict {
  RSOption * options = [[RSOption alloc]init];
  @try {
    optionsDict = [self removeExternalIdsIfExternalIdExists:optionsDict];
    for (NSString *key in optionsDict) {
      if ([key isEqualToString:@"externalId"]) {
        [self setExternalId:key withOptionsDict:optionsDict andOptions:options];
      } else if ([key isEqualToString:@"externalIds"]) {
        [self setExternalId:key withOptionsDict:optionsDict andOptions:options];
      } else if ([key isEqualToString:@"integrations"]) {
        [self setIntegrations:optionsDict andOptions:options];
      } else {
        [self setCustomContext:key withOptionsDict:optionsDict options:options];
      }
    }
  } @catch (NSException *exception) {
    [RSLogger logWarn:[NSString stringWithFormat:@"Error occurred while handling options object: %@", exception]];
  }
  return options;
}

// For legacy reason we are still supporting "externalIds". First priority is given to "externalId".
- (NSDictionary *)removeExternalIdsIfExternalIdExists:(NSDictionary *)optionsDict {
  if (optionsDict == nil) return nil;
  
  NSMutableDictionary *mutableOptionsDict = [optionsDict mutableCopy];
  if ([mutableOptionsDict objectForKey:@"externalId"] && [mutableOptionsDict objectForKey:@"externalIds"]) {
    [mutableOptionsDict removeObjectForKey:@"externalIds"];
  }
  
  return [mutableOptionsDict copy];
}

-(void) setExternalId:(NSString*) key withOptionsDict:(NSDictionary *) optionsDict andOptions:(RSOption *) options {
  if([optionsDict objectForKey:key]) {
    NSArray *externalIdsArray =  [optionsDict objectForKey:key];
    for(NSDictionary *externalId in externalIdsArray) {
      id type = [externalId objectForKey:@"type"];
      id idValue = [externalId objectForKey:@"id"];
      if (type != nil && idValue != nil) {
        [options putExternalId:type withId:idValue];
      }
    }
  }
}

-(void) setIntegrations:(NSDictionary *) optionsDict andOptions:(RSOption *) options {
  NSDictionary *integrationsDict = [optionsDict objectForKey:@"integrations"];
  for(NSString* key in integrationsDict) {
    id value = [integrationsDict objectForKey:key];
      // Checking for NSNumber class, as there is no bool class in objective-c
    if (value != nil && value != [NSNull null] && [value isKindOfClass:[NSNumber class]]) {
      [options putIntegration:key isEnabled:[[integrationsDict objectForKey:key] boolValue]];
    }
  }
}

-(void) setCustomContext:(NSString*) key withOptionsDict:(NSDictionary *) optionsDict options:(RSOption *) options {
  id value = optionsDict[key];
  if ([value isKindOfClass:[NSDictionary class]] && [(NSDictionary *)value count] > 0) {
    [options putCustomContext:value withKey:key];
  }
}

@end