#import "RnTinyRbmq.h"

@interface RnTinyRbmq ()
    @property (nonatomic, readwrite) bool isConnected;
    @property (nonatomic, readwrite) NSDictionary *config;
    @property (nonatomic, readwrite) RMQConnection *connection;
    @property (nonatomic, readwrite) id<RMQChannel> channel;
    @property (nonatomic, readwrite) NSMutableArray *consumers;
@end

@implementation RnTinyRbmq

RCT_EXPORT_MODULE()

RCT_EXPORT_METHOD(initialize:(NSDictionary *) config) {
    self.config = config;
    self.consumers = [[NSMutableArray alloc] init];
}

RCT_EXPORT_METHOD(connect) {
    if (!self.isConnected) {
        RnTinyRbmqDelegateLogger *delegate = [[RnTinyRbmqDelegateLogger alloc] init];
        NSString *protocol = @"amqp";
        if ([self.config objectForKey:@"ssl"] != nil && [[self.config objectForKey:@"ssl"] boolValue]){
            protocol = @"amqps";
        }
        
        NSString *uri = [NSString stringWithFormat:@"%@://%@:%@@%@:%@/%@", protocol, self.config[@"username"], self.config[@"password"], self.config[@"host"], self.config[@"port"], self.config[@"virtualhost"]];
        
        self.connection = [[RMQConnection alloc] initWithUri:uri userProvidedConnectionName:NULL channelMax:@65535 frameMax:@(RMQFrameMax) heartbeat:@30 connectTimeout:@15 readTimeout:@30 writeTimeout:@30 syncTimeout:@10 delegate:delegate delegateQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0) recoverAfter:0 recoveryAttempts:0 recoverFromConnectionClose:false];
        
        [self.connection start:^{
            self.channel = [self.connection createChannel];
            self.isConnected = true;
            [RnTinyRbmqEventEmitter emitEventWithName:@"RnTinyRbmqEvent" body:@{@"name": @"connected"}];
        }];
    }
}

RCT_EXPORT_METHOD(basicConsume:(NSString *) queue) {
    if (self.isConnected) {
        RMQConsumer *consumer = [self.channel basicConsume:queue acknowledgementMode:(RMQBasicConsumeAcknowledgementModeAuto) handler:^(RMQMessage * _Nonnull message) {
            NSString *body = [[NSString alloc] initWithData:message.body encoding:NSUTF8StringEncoding];
                   
            [RnTinyRbmqEventEmitter emitEventWithName:@"RnTinyRbmqEvent"
                body:@{
                    @"name": @"message",
                    @"queue_name": queue,
                    @"message": body,
                    @"routing_key": message.routingKey,
                    @"exchange": message.exchangeName,
                    @"consumer_tag": message.consumerTag,
                    @"delivery_tag": message.deliveryTag
                }
            ];
        }];
        
        [consumer onCancellation:^{
            [RnTinyRbmqEventEmitter emitEventWithName:@"RnTinyRbmqEvent" body:@{@"name": @"error", @"type": @"consumer"}];
        }];
        
        [self.consumers addObject:consumer];
    }
}

RCT_EXPORT_METHOD(close) {
    if (self.isConnected) {
        for (RMQConsumer *cns in self.consumers) {
            [self.channel basicCancel:cns.tag];
        }
        [self.consumers removeAllObjects];
        
        [self.connection close];
        self.connection = nil;
        self.isConnected = false;
    }
}

@end