NewsBlur/clients/ios/Classes/offline/OfflineSyncUnreads.m

//
//  OfflineSyncUnreads.m
//  NewsBlur
//
//  Created by Samuel Clay on 7/15/13.
//  Copyright (c) 2013 NewsBlur. All rights reserved.
//

#import "OfflineSyncUnreads.h"
#import "NewsBlurAppDelegate.h"
#import "NewsBlurViewController.h"
#import "FMResultSet.h"
#import "FMDatabase.h"
#import "AFJSONRequestOperation.h"

@implementation OfflineSyncUnreads

@synthesize appDelegate;
@synthesize request;

- (void)main {
    appDelegate = [NewsBlurAppDelegate sharedAppDelegate];
    
    NSLog(@"Syncing Unreads...");
    dispatch_async(dispatch_get_main_queue(), ^{
        [appDelegate.feedsViewController showSyncingNotifier];
    });

    NSURL *url = [NSURL URLWithString:[NSString
                                       stringWithFormat:@"%@/reader/unread_story_hashes?include_timestamps=true",
                                       NEWSBLUR_URL]];
    request = [AFJSONRequestOperation
               JSONRequestOperationWithRequest:[NSURLRequest requestWithURL:url]
               success:^(NSURLRequest *request, NSHTTPURLResponse *response, id JSON) {
                   [self storeUnreadHashes:JSON];
               } failure:^(NSURLRequest *request, NSHTTPURLResponse *response, NSError *error, id JSON) {
                   NSLog(@"Failed fetch all story hashes.");                                           
               }];
    request.successCallbackQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,
                                                             (unsigned long)NULL);
    [request start];
    [request waitUntilFinished];
}

- (void)storeUnreadHashes:(NSDictionary *)results {
    if (self.isCancelled) {
        NSLog(@"Canceled storing unread hashes");
        [request cancel];
        return;
    }
    
    [appDelegate.database inTransaction:^(FMDatabase *db, BOOL *rollback) {
        NSLog(@"Storing unread story hashes...");
        [db executeUpdate:@"DROP TABLE unread_hashes"];
        [appDelegate setupDatabase:db];
        NSDictionary *hashes = [results objectForKey:@"unread_feed_story_hashes"];
        for (NSString *feed in [hashes allKeys]) {
            NSArray *story_hashes = [hashes objectForKey:feed];
            for (NSArray *story_hash_tuple in story_hashes) {
                [db executeUpdate:@"INSERT into unread_hashes"
                 "(story_feed_id, story_hash, story_timestamp) VALUES "
                 "(?, ?, ?)",
                 feed,
                 [story_hash_tuple objectAtIndex:0],
                 [story_hash_tuple objectAtIndex:1]
                 ];
            }
        }
        
    }];
    [appDelegate.database inTransaction:^(FMDatabase *db, BOOL *rollback) {
        // Once all unread hashes are in, only keep under preference for offline limit
        NSInteger offlineLimit = [[NSUserDefaults standardUserDefaults] integerForKey:@"offline_store_limit"];
        NSString *order;
        NSString *orderComp;
        if ([[[NSUserDefaults standardUserDefaults] objectForKey:@"default_order"] isEqualToString:@"oldest"]) {
            order = @"ASC";
            orderComp = @">";
        } else {
            order = @"DESC";
            orderComp = @"<";
        }
        FMResultSet *cursor = [db executeQuery:[NSString stringWithFormat:@"SELECT story_timestamp FROM unread_hashes ORDER BY story_timestamp %@ LIMIT 1 OFFSET %ld", order, (long)offlineLimit]];
        int offlineLimitTimestamp = 0;
        while ([cursor next]) {
            offlineLimitTimestamp = [cursor intForColumn:@"story_timestamp"];
            break;
        }
        NSLog(@"Deleting stories over limit: %ld - %d", (long)offlineLimit, offlineLimitTimestamp);
        [db executeUpdate:[NSString stringWithFormat:@"DELETE FROM unread_hashes WHERE story_timestamp %@ %d", orderComp, offlineLimitTimestamp]];
        [db executeUpdate:[NSString stringWithFormat:@"DELETE FROM stories WHERE story_timestamp %@ %d", orderComp, offlineLimitTimestamp]];
    }];
    
    appDelegate.totalUnfetchedStoryCount = 0;
    appDelegate.remainingUnfetchedStoryCount = 0;
    appDelegate.latestFetchedStoryDate = 0;
    appDelegate.totalUncachedImagesCount = 0;
    appDelegate.remainingUncachedImagesCount = 0;
    
    NSLog(@"Done syncing Unreads...");
    [appDelegate startOfflineFetchStories];
}

@end