//
//  TextileApi.m
//  Textile
//
//  Created by Aaron Sutula on 2/28/19.
//  Copyright © 2019 Textile. All rights reserved.
//

#import "TextileApi.h"
#import "Messenger.h"
#import "RequestsHandler.h"
#import "Callback.h"
#import "TTELifecycleManager.h"
#import "TTEAppStateLifecycleManager.h"

NSString *const TEXTILE_BACKGROUND_SESSION_ID = @"textile";

@interface Textile()

@property (nonatomic, strong) Messenger *messenger;

@property (nonatomic, strong) AccountApi *account;
@property (nonatomic, strong) CafesApi *cafes;
@property (nonatomic, strong) CommentsApi *comments;
@property (nonatomic, strong) ContactsApi *contacts;
@property (nonatomic, strong) FeedApi *feed;
@property (nonatomic, strong) FilesApi *files;
@property (nonatomic, strong) FlagsApi *flags;
@property (nonatomic, strong) IgnoresApi *ignores;
@property (nonatomic, strong) InvitesApi *invites;
@property (nonatomic, strong) IpfsApi *ipfs;
@property (nonatomic, strong) LikesApi *likes;
@property (nonatomic, strong) LogsApi *logs;
@property (nonatomic, strong) MessagesApi *messages;
@property (nonatomic, strong) NotificationsApi *notifications;
@property (nonatomic, strong) ProfileApi *profile;
@property (nonatomic, strong) SchemasApi *schemas;
@property (nonatomic, strong) ThreadsApi *threads;

@property (nonatomic, strong) RequestsHandler *requestsHandler;

@property (nonatomic, strong) id<TTELifecycleManager> lifecycleManager;

+ (BOOL)migrateRepo:(NSString *)repoPath error:(NSError **)error;

@end

@implementation Textile

#pragma mark Public

+ (NSString *)newWallet:(long)wordCount error:(NSError * _Nullable __autoreleasing *)error {
  NSString *recoveryPhrase = MobileNewWallet(wordCount, error);
  return recoveryPhrase;
}

+ (MobileWalletAccount *)walletAccountAt:(NSString *)phrase index:(NSInteger)index password:(NSString *)password error:(NSError * _Nullable __autoreleasing *)error {
  NSData *data = MobileWalletAccountAt(phrase, index, password, error);
  if (*error) {
    return nil;
  }
  MobileWalletAccount *account = [[MobileWalletAccount alloc] initWithData:data error:error];
  if (*error) {
    return nil;
  }
  return account;
}

+ (BOOL)isInitialized:(NSString *)repoPath {
  return MobileRepoExists(repoPath);
}

+ (BOOL)initialize:(NSString *)repoPath seed:(NSString *)seed debug:(BOOL)debug logToDisk:(BOOL)logToDisk error:(NSError * _Nullable __autoreleasing *)error {
  MobileInitConfig *config = [[MobileInitConfig alloc] init];
  config.seed = seed;
  config.repoPath = repoPath;
  config.logToDisk = logToDisk;
  config.debug = debug;
  return MobileInitRepo(config, error);
}

+ (NSString *)initializeCreatingNewWalletAndAccount:(NSString *)repoPath debug:(BOOL)debug logToDisk:(BOOL)logToDisk error:(NSError * _Nullable __autoreleasing *)error {
  NSString *recoveryPhrase = [Textile newWallet:12 error:error];
  if (!recoveryPhrase) {
    return nil;
  }
  MobileWalletAccount *account = [Textile walletAccountAt:recoveryPhrase index:0 password:@"" error:error];
  if (!account) {
    return nil;
  }
  BOOL initialized = [Textile initialize:repoPath seed:account.seed debug:debug logToDisk:logToDisk error:error];
  if (!initialized) {
    return nil;
  }
  return recoveryPhrase;
}

+ (BOOL)launch:(NSString *)repoPath debug:(BOOL)debug error:(NSError * _Nullable __autoreleasing *)error {
  RequestsHandler *requestsHandler = [[RequestsHandler alloc] initWithTextile:Textile.instance];
  Messenger *messenger = [[Messenger alloc] initWithTextile:Textile.instance];

  Textile.instance.requestsHandler = requestsHandler;
  Textile.instance.messenger = messenger;

  MobileRunConfig *config = [[MobileRunConfig alloc] init];
  config.repoPath = repoPath;
  config.debug = debug;
  config.cafeOutboxHandler = requestsHandler;

  MobileMobile *node = MobileNewTextile(config, messenger, error);
  if (node) {
    Textile.instance.node = node;
    [Textile.instance createNodeDependants];
    dispatch_async(dispatch_get_main_queue(), ^{
      [Textile.instance forLater];
    });
    return YES;
  } else {
    return NO;
  }
}

+ (Textile *)instance {
  static Textile *instnace = nil;
  static dispatch_once_t onceToken;
  dispatch_once(&onceToken, ^{
    instnace = [[self alloc] init];
  });
  return instnace;
}

- (NSString *)version {
  return [self.node version];
}

- (NSString *)gitSummary {
  return [self.node gitSummary];
}

- (Summary *)summary:(NSError * _Nullable __autoreleasing *)error {
  NSData *data = [self.node summary:error];
  if (*error) {
    return nil;
  }
  return [[Summary alloc] initWithData:data error:error];
}

- (BOOL)start:(NSError *__autoreleasing  _Nullable *)error {
  return [self.lifecycleManager start:error];
}

- (void)stopWithCompletion:(void (^)(BOOL, NSError * _Nullable))completion {
  [self.lifecycleManager stopWithCompletion:completion];
}

- (void)destroyWithCompletion:(void (^)(BOOL, NSError * _Nullable))completion {
  [self stopWithCompletion:^(BOOL success, NSError * _Nullable error) {
    if (success) {
      self.delegate = nil;
      self.node = nil;
      self.messenger = nil;
      self.lifecycleManager = nil;
      self.requestsHandler = nil;

      self.account = nil;
      self.cafes = nil;
      self.comments = nil;
      self.contacts = nil;
      self.feed = nil;
      self.files = nil;
      self.flags = nil;
      self.ignores = nil;
      self.invites = nil;
      self.ipfs = nil;
      self.likes = nil;
      self.logs = nil;
      self.messages = nil;
      self.notifications = nil;
      self.profile = nil;
      self.schemas = nil;
      self.threads = nil;
    }
    if (completion) {
      completion(success, error);
    }
  }];
}

#pragma mark Private

+ (BOOL)migrateRepo:(NSString *)repoPath error:(NSError *__autoreleasing *)error {
  MobileMigrateConfig *config = [[MobileMigrateConfig alloc] init];
  config.repoPath = repoPath;
  return MobileMigrateRepo(config, error);
}

- (void)createNodeDependants {
  self.account = [[AccountApi alloc] initWithNode:self.node];
  self.cafes = [[CafesApi alloc] initWithNode:self.node];
  self.comments = [[CommentsApi alloc] initWithNode:self.node];
  self.contacts = [[ContactsApi alloc] initWithNode:self.node];
  self.feed = [[FeedApi alloc] initWithNode:self.node];
  self.files = [[FilesApi alloc] initWithNode:self.node];
  self.flags = [[FlagsApi alloc] initWithNode:self.node];
  self.ignores = [[IgnoresApi alloc] initWithNode:self.node];
  self.invites = [[InvitesApi alloc] initWithNode:self.node];
  self.ipfs = [[IpfsApi alloc] initWithNode:self.node];
  self.likes = [[LikesApi alloc] initWithNode:self.node];
  self.logs = [[LogsApi alloc] initWithNode:self.node];
  self.messages = [[MessagesApi alloc] initWithNode:self.node];
  self.notifications = [[NotificationsApi alloc] initWithNode:self.node];
  self.profile = [[ProfileApi alloc] initWithNode:self.node];
  self.schemas = [[SchemasApi alloc] initWithNode:self.node];
  self.threads = [[ThreadsApi alloc] initWithNode:self.node];
}

- (void)forLater {
  // depending on the context, we can change the the implementation that gets assigned here.
  self.lifecycleManager = [[TTEAppStateLifecycleManager alloc] initWithTextile:self];

  // start creates the NSURLSession, we want to be sure the client has had
  // time to registe a delegate before the NSURLSession is created.
  [self.requestsHandler start];
}

@end