#import "Pebble.h"

@implementation Pebble {
    NSMutableDictionary* watches;
    
    NSString* connectCallbackId;
    NSString* messageCallbackId;
}

- (void)pluginInitialize
{
    
    [[PBPebbleCentral defaultCentral] setDelegate:self];
    watches = [[NSMutableDictionary alloc] init];
    
}

-(void)setAppUUID:(CDVInvokedUrlCommand *)command
{
    NSString *uuidString = [command.arguments objectAtIndex:0];
    NSLog(@"PGPebble appUUID = %@", uuidString);
    
    NSUUID *uuid = [[NSUUID alloc] initWithUUIDString:uuidString];
    [PBPebbleCentral defaultCentral].appUUID = uuid;
    [[PBPebbleCentral defaultCentral] run];

    [self notifyCallback:command.callbackId isSuccess:true];
}

-(void)onConnect:(CDVInvokedUrlCommand *)command
{
    connectCallbackId = command.callbackId;
    
    NSArray *connected = [[PBPebbleCentral defaultCentral] connectedWatches];

    NSLog(@"%lu Pebble device(s) found at startup", (unsigned long)[connected count]);

    for (PBWatch* watch in connected) {
        [self watchConnected:watch];
    }
}

-(void)onAppMessageReceived:(CDVInvokedUrlCommand *)command
{
    messageCallbackId = command.callbackId;
}

-(void)launchApp:(CDVInvokedUrlCommand *)command
{
    if (![self checkWatchConnected]) return;
    
    NSLog(@"Pebble launchApp()");
    
    for (NSString* key in watches) {
        PBWatch* watch = [watches objectForKey:key];
        
        [watch appMessagesLaunch:^(PBWatch *watch, NSError *error) {
            
            [self notifyCallback:command.callbackId
                       isSuccess:!error
                      withReason:(error ? error.description : nil)];
            
        }];
    }
    
}

-(void)killApp:(CDVInvokedUrlCommand *)command
{
    if (![self checkWatchConnected]) return;
    
    NSLog(@"Pebble killApp()");
    
    for (NSString* key in watches) {
        PBWatch* watch = [watches objectForKey:key];
        
        [watch appMessagesKill:^(PBWatch *watch, NSError *error) {
            
            [self notifyCallback:command.callbackId
                       isSuccess:!error
                      withReason:(error ? error.description : nil)];
            
        }];
    }
}

-(void)sendAppMessage:(CDVInvokedUrlCommand *)command
{
    if (![self checkWatchConnected]) return;
    
    NSLog(@"Pebble sendMessage()");
    
    NSString *jsonStr = [command.arguments objectAtIndex:0];
    jsonStr = [jsonStr stringByReplacingOccurrencesOfString:@"\\\"" withString:@"\""];
    NSData *jsonData = [jsonStr dataUsingEncoding:NSUTF8StringEncoding];
    NSDictionary *result = [NSJSONSerialization JSONObjectWithData:jsonData options:0 error:nil];
    
    NSMutableDictionary* update = [NSMutableDictionary dictionaryWithCapacity:[result count]];
    NSNumberFormatter * f = [[NSNumberFormatter alloc] init];
    [f setNumberStyle:NSNumberFormatterDecimalStyle];
    
    for (NSString* key in result) {
        NSNumber * keyNum = [f numberFromString:key];
        [update setObject:[result objectForKey:key] forKey:keyNum];
    }
    
    NSLog(@"Pebble SDK will send update %@", update);
    
    for (NSString* key in watches) {
        PBWatch* watch = [watches objectForKey:key];
        
        [watch appMessagesPushUpdate:update onSent:^(PBWatch *watch, NSDictionary *update, NSError *error) {
            
            [self notifyCallback:command.callbackId
                       isSuccess:!error
                      withReason:(error ? error.description : nil)];
            
        }];
    }
}


#pragma mark utils

- (void) listenToWatch:(PBWatch*) watch
{
    [watch appMessagesAddReceiveUpdateHandler:^BOOL(PBWatch *watch, NSDictionary *update) {
        NSLog(@"Pebble: received message: %@", update);
        
        NSMutableDictionary* returnInfo = [[NSMutableDictionary alloc]
                                           initWithObjectsAndKeys: [watch name], @"watch", nil];
        
        for (NSNumber *key in update) {
            [returnInfo setObject:[update objectForKey:key] forKey:[key stringValue]];
        }
        
        [self notifyKeepCallback:messageCallbackId
                      withStatus:CDVCommandStatus_OK
                     andWithData:returnInfo];
        
        return YES;
    }];
}

- (void)notifyKeepCallback:(NSString*) callbackId
                withStatus:(CDVCommandStatus) status
               andWithData:(NSMutableDictionary*) data
{
    CDVPluginResult* result = [CDVPluginResult resultWithStatus: status messageAsDictionary:data];
    [result setKeepCallbackAsBool:YES];
    
    [self.commandDelegate sendPluginResult:result callbackId:callbackId];
}

- (void)notifyCallback:(NSString*) callbackId
             isSuccess:(BOOL)success
{
    [self notifyCallback:callbackId isSuccess:success withReason:nil];
}

- (void)notifyCallback:(NSString*) callbackId
             isSuccess:(BOOL)success
            withReason:(NSString*)reason
{
    CDVCommandStatus status = (success) ? CDVCommandStatus_OK : CDVCommandStatus_ERROR;
    CDVPluginResult *result;
    
    if(reason) {
        result = [CDVPluginResult resultWithStatus:status messageAsString:reason];
    } else {
        result = [CDVPluginResult resultWithStatus:status];
    }
    
    [self.commandDelegate sendPluginResult:result callbackId:callbackId];
}

-(BOOL)checkWatchConnected
{
    if ([watches count] == 0) {
        NSLog(@"Pebble: No watches connected.");
        
        return FALSE;
    }
    else {
        return TRUE;
    }
}

-(void)watchConnected:(PBWatch*) watch
{
    [watches setObject:watch forKey:[watch name]];
    
    NSLog(@"watchConnected");
    
    [self listenToWatch:watch];
    
    NSMutableDictionary* returnInfo = [[NSMutableDictionary alloc]
                                initWithObjectsAndKeys:[watch name],@"name", nil];
    
    [self notifyKeepCallback: connectCallbackId
                  withStatus: CDVCommandStatus_OK
                 andWithData: returnInfo];
}

-(void)watchDisconnected:(PBWatch*) watch
{
    [watches removeObjectForKey:[watch name]];
    
    NSMutableDictionary* returnInfo = [[NSMutableDictionary alloc]
                                       initWithObjectsAndKeys:[watch name],@"name", nil];
    
    [self notifyKeepCallback: connectCallbackId
                  withStatus: CDVCommandStatus_ERROR
                 andWithData: returnInfo];
}

#pragma mark delegate methods

- (void)pebbleCentral:(PBPebbleCentral*)central
      watchDidConnect:(PBWatch*)watch
                isNew:(BOOL)isNew
{
    NSLog(@"Pebble connected: %@", [watch name]);
    
    [self watchConnected:watch];
}


- (void)pebbleCentral:(PBPebbleCentral*)central
   watchDidDisconnect:(PBWatch*)watch
{
    NSLog(@"Pebble disconnected: %@", [watch name]);
    
    [self watchDisconnected:watch];
}

@end