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 "FMResultSet.h"
#import "FMDatabase.h"
#import "NewsBlur-Swift.h"

@implementation OfflineSyncUnreads

@synthesize appDelegate;

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

    __block NSCondition *lock = [NSCondition new];
    [lock lock];

    NSString *urlString = [NSString stringWithFormat:@"%@/reader/unread_story_hashes?include_timestamps=true",
                           self.appDelegate.url];
    AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
    manager.responseSerializer = [AFJSONResponseSerializer serializer];
    manager.completionQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND, 0);
    [manager GET:urlString parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
        NSLog(@"Syncing stories success");
        [self storeUnreadHashes:responseObject];
        [lock signal];
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
        NSLog(@"Failed fetch all story hashes: %@", error);
        [lock signal];
    }];
    
    [lock waitUntilDate:[NSDate dateWithTimeIntervalSinceNow:30]];
    [lock unlock];

    NSLog(@"Finished syncing stories");
}

- (void)storeUnreadHashes:(NSDictionary *)results {
    if (self.isCancelled) {
//        NSLog(@"Canceled storing unread hashes");
//        [request cancel];
        return;
    }
    
    [self.appDelegate.database inTransaction:^(FMDatabase *db, BOOL *rollback) {
//        NSLog(@"Storing unread story hashes...");
        [db executeUpdate:@"DROP TABLE unread_hashes"];
        [self.appDelegate setupDatabase:db force:NO];
        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]
                 ];
            }
        }
    }];
    [self.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 = @"<";
        }
        NSString *lastStorySql = [NSString stringWithFormat:
                                  @"SELECT story_timestamp FROM unread_hashes "
                                  "ORDER BY story_timestamp %@ LIMIT 1 OFFSET %ld",
                                  order, (long)offlineLimit];
        FMResultSet *cursor = [db executeQuery:lastStorySql];
        int offlineLimitTimestamp = 0;
        while ([cursor next]) {
            offlineLimitTimestamp = [cursor intForColumn:@"story_timestamp"];
            break;
        }
        [cursor close];
        
        if (offlineLimitTimestamp) {
//            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]];
            [db executeUpdate:[NSString stringWithFormat:@"DELETE FROM text WHERE story_timestamp %@ %d", orderComp, offlineLimitTimestamp]];
//            [db executeUpdate:[NSString stringWithFormat:@"DELETE FROM story_scrolls WHERE story_timestamp %@ %d", orderComp, offlineLimitTimestamp]]; // Don't cleanup story scrolls just yet
        }
    }];
    
    self.appDelegate.totalUnfetchedStoryCount = 0;
    self.appDelegate.remainingUnfetchedStoryCount = 0;
    self.appDelegate.latestFetchedStoryDate = 0;
    self.appDelegate.totalUncachedImagesCount = 0;
    self.appDelegate.remainingUncachedImagesCount = 0;
    
//    NSLog(@"Done syncing Unreads...");
    [self.appDelegate startOfflineFetchStories];
}

@end