#import <React/RCTAssert.h>
#import <React/RCTConvert.h>
#import <React/RCTEventDispatcher.h>
#import <React/RCTLog.h>


#import "TcpSocketClient.h"
#import "TcpSockets.h"


// offset native ids by 5000
#define COUNTER_OFFSET 5000

@implementation TcpSockets {
    NSMutableDictionary<NSNumber *, TcpSocketClient *> *_clients;
    NSMutableDictionary<NSNumber *, NSDictionary *> *_pendingTLS;
    int _counter;
}

RCT_EXPORT_MODULE()

- (NSArray<NSString *> *)supportedEvents {
    return @[
        @"connect", @"listening", @"connection", @"secureConnection", @"data",
        @"close", @"error", @"written", @"end"
    ];
}

- (void)startObserving {
    // Does nothing
}

- (void)stopObserving {
    // Does nothing
}

- (void)dealloc {
    for (NSNumber *cId in _clients.allKeys) {
        [self destroyClient:cId];
    }
}

- (TcpSocketClient *)createSocket:(nonnull NSNumber *)cId {
    if (!cId) {
        RCTLogWarn(@"%@.createSocket called with nil id parameter.",
                   [self class]);
        return nil;
    }

    if (!_clients) {
        _clients = [NSMutableDictionary new];
    }

    if (_clients[cId]) {
        RCTLogWarn(@"%@.createSocket called twice with the same id.",
                   [self class]);
        return nil;
    }

    _clients[cId] = [TcpSocketClient socketClientWithId:cId andConfig:self];

    return _clients[cId];
}

RCT_EXPORT_METHOD(connect
                  : (nonnull NSNumber *)cId host
                  : (NSString *)host port
                  : (int)port withOptions
                  : (NSDictionary *)options) {
    TcpSocketClient *client = _clients[cId];
    if (!client) {
        client = [self createSocket:cId];
    }

    NSDictionary *tlsOptions = _pendingTLS[cId];

    NSError *error = nil;
    if (![client connect:host
                    port:port
             withOptions:options
              tlsOptions:tlsOptions
                   error:&error]) {
        [self onError:client withError:error];
        return;
    }
}

RCT_EXPORT_METHOD(write
                  : (nonnull NSNumber *)cId string
                  : (nonnull NSString *)base64String callback
                  : (nonnull NSNumber *)msgId) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    // iOS7+
    // TODO: use https://github.com/nicklockwood/Base64 for compatibility with
    // earlier iOS versions
    NSData *data = [[NSData alloc] initWithBase64EncodedString:base64String
                                                       options:0];
    [client writeData:data msgId:msgId];
}

RCT_EXPORT_METHOD(end : (nonnull NSNumber *)cId) { [self endClient:cId]; }

RCT_EXPORT_METHOD(destroy : (nonnull NSNumber *)cId) {
    [self destroyClient:cId];
}

RCT_EXPORT_METHOD(close : (nonnull NSNumber *)cId) { [self destroyClient:cId]; }

RCT_EXPORT_METHOD(listen
                  : (nonnull NSNumber *)cId withOptions
                  : (nonnull NSDictionary *)options) {
    TcpSocketClient *client = _clients[cId];
    if (!client) {
        client = [self createSocket:cId];
    }

    NSError *error = nil;
    if (![client listen:options error:&error]) {
        [self onError:client withError:error];
        return;
    }
}

RCT_EXPORT_METHOD(startTLS
                  : (nonnull NSNumber *)cId tlsOptions
                  : (nonnull NSDictionary *)tlsOptions) {
    TcpSocketClient *client = _clients[cId];
    if (!client) {
        if (!_pendingTLS) {
            _pendingTLS = [NSMutableDictionary new];
        }
        _pendingTLS[cId] = tlsOptions;
    } else {
        [client startTLS:tlsOptions];
    }
}

RCT_EXPORT_METHOD(setNoDelay
                  : (nonnull NSNumber *)cId noDelay
                  : (BOOL)noDelay) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    [client setNoDelay:noDelay];
}

RCT_EXPORT_METHOD(setKeepAlive
                  : (nonnull NSNumber *)cId enable
                  : (BOOL)enable initialDelay
                  : (int)initialDelay) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    [client setKeepAlive:enable initialDelay:initialDelay];
}

RCT_EXPORT_METHOD(pause : (nonnull NSNumber *)cId) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    [client pause];
}

RCT_EXPORT_METHOD(resume : (nonnull NSNumber *)cId) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    [client resume];
}

RCT_EXPORT_METHOD(hasIdentity:(nonnull NSDictionary *)aliases
                  resolver:(RCTPromiseResolveBlock)resolve
                  rejecter:(RCTPromiseRejectBlock)reject) {
    // Since this is a static check of the keychain, we don't need a client instance
    BOOL hasIdentity = [TcpSocketClient hasIdentity:aliases];
    resolve(@(hasIdentity));
}

RCT_EXPORT_METHOD(getPeerCertificate:(nonnull NSNumber *)cId
                  resolver:(RCTPromiseResolveBlock)resolve
                  rejecter:(RCTPromiseRejectBlock)reject) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client) {
        reject(@"NOT_FOUND", @"Client not found", nil);
        return;
    }
    
    NSDictionary *cert = [client getPeerCertificate];
    resolve(cert ?: [NSNull null]);
}

RCT_EXPORT_METHOD(getCertificate:(nonnull NSNumber *)cId
                  resolver:(RCTPromiseResolveBlock)resolve
                  rejecter:(RCTPromiseRejectBlock)reject) {
    TcpSocketClient *client = [self findClient:cId];
    if (!client) {
        reject(@"NOT_FOUND", @"Client not found", nil);
        return;
    }
    
    NSDictionary *cert = [client getCertificate];
    resolve(cert ?: [NSNull null]);
}

- (void)onWrittenData:(TcpSocketClient *)client msgId:(NSNumber *)msgId {
    [self sendEventWithName:@"written"
                       body:@{
                           @"id" : client.id,
                           @"msgId" : msgId,
                       }];
}

- (void)onConnect:(TcpSocketClient *)client {
    GCDAsyncSocket *socket = [client getSocket];
    [self sendEventWithName:@"connect"
                       body:@{
                           @"id" : client.id,
                           @"connection" : @{
                               @"localAddress" : [socket localHost],
                               @"localPort" :
                                   [NSNumber numberWithInt:[socket localPort]],
                               @"remoteAddress" : [socket connectedHost],
                               @"remotePort" : [NSNumber
                                   numberWithInt:[socket connectedPort]],
                               @"remoteFamily" : [socket isIPv4] ? @"IPv4"
                                                                 : @"IPv6"
                           }
                       }];
}

- (void)onListen:(TcpSocketClient *)server {
    GCDAsyncSocket *socket = [server getSocket];
    [self sendEventWithName:@"listening"
                       body:@{
                           @"id" : server.id,
                           @"connection" : @{
                               @"localAddress" : [socket localHost],
                               @"localPort" :
                                   [NSNumber numberWithInt:[socket localPort]],
                               @"localFamily" : [socket isIPv4] ? @"IPv4"
                                                                : @"IPv6"
                           }
                       }];
}

- (void)onConnection:(TcpSocketClient *)client toClient:(NSNumber *)clientID {
    [self onSocketConnection:client
                    toClient:clientID
              connectionType:@"connection"];
}

- (void)onSecureConnection:(TcpSocketClient *)client
                  toClient:(NSNumber *)clientID {
    [self onSocketConnection:client
                    toClient:clientID
              connectionType:@"secureConnection"];
}

- (void)addClient:(TcpSocketClient *)client {
    _clients[client.id] = client;
}

- (void)onSocketConnection:(TcpSocketClient *)client
                  toClient:(NSNumber *)clientID
            connectionType:(NSString *)connectionType {
    GCDAsyncSocket *socket = [client getSocket];

    [self sendEventWithName:connectionType
                       body:@{
                           @"id" : clientID,
                           @"info" : @{
                               @"id" : client.id,
                               @"connection" : @{
                                   @"localAddress" : [socket localHost],
                                   @"localPort" : [NSNumber
                                       numberWithInt:[socket localPort]],
                                   @"remoteAddress" : [socket connectedHost],
                                   @"remotePort" : [NSNumber
                                       numberWithInt:[socket connectedPort]],
                                   @"remoteFamily" : [socket isIPv4] ? @"IPv4"
                                                                     : @"IPv6"
                               }
                           }
                       }];
}

- (void)onData:(NSNumber *)clientID data:(NSData *)data {
    NSString *base64String = [data base64EncodedStringWithOptions:0];
    [self sendEventWithName:@"data"
                       body:@{
                           @"id" : clientID,
                           @"data" : base64String
                       }];
}

- (void)onEnd:(NSNumber *)clientID {
    [self sendEventWithName:@"end"
                       body:@{
                           @"id" : clientID
                       }];
}

- (void)onClose:(NSNumber *)clientID withError:(NSError *)err {
    TcpSocketClient *client = [self findClient:clientID];
    if (!client) {
        RCTLogWarn(@"onClose: unrecognized client id %@", clientID);
    }

    if (err) {
        [self onError:client withError:err];
    }

    [self sendEventWithName:@"close"
                       body:@{
                           @"id" : clientID,
                           @"hadError" : err == nil ? @NO : @YES
                       }];

    [_clients removeObjectForKey:clientID];
}

- (void)onError:(TcpSocketClient *)client withError:(NSError *)err {
    NSString *msg = err.localizedDescription ?: err.localizedFailureReason;
    [self sendEventWithName:@"error" body:@{@"id" : client.id, @"error" : msg}];
}

- (TcpSocketClient *)findClient:(nonnull NSNumber *)cId {
    TcpSocketClient *client = _clients[cId];
    if (!client) {
        NSString *msg =
            [NSString stringWithFormat:@"no client found with id %@", cId];
        [self sendEventWithName:@"error" body:@{@"id" : cId, @"error" : msg}];

        return nil;
    }

    return client;
}

- (void)endClient:(nonnull NSNumber *)cId {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    [client end];
}

- (void)destroyClient:(nonnull NSNumber *)cId {
    TcpSocketClient *client = [self findClient:cId];
    if (!client)
        return;

    [client destroy];
}

- (NSNumber *)getNextId {
    return @(_counter++ + COUNTER_OFFSET);
}

@end