space-ios/iOSClient/Synchronization/CCSynchronization.m

//
//  CCSynchronization.m
//  Crypto Cloud Technology Nextcloud
//
//  Created by Marino Faggiana on 19/10/16.
//  Copyright (c) 2016 TWS. All rights reserved.
//
//  Author Marino Faggiana <m.faggiana@twsweb.it>
//
//  This program is free software: you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  (at your option) any later version.
//
//  This program is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program.  If not, see <http://www.gnu.org/licenses/>.
//

#import "CCSynchronization.h"

#import "AppDelegate.h"
#import "CCCoreData.h"
#import "CCMain.h"

@interface CCSynchronization ()
{
    // local
}
@end

@implementation CCSynchronization

+ (CCSynchronization *)sharedSynchronization {
    static CCSynchronization *sharedSynchronization;
    @synchronized(self)
    {
        if (!sharedSynchronization) {
            
            sharedSynchronization = [[CCSynchronization alloc] init];
        }
        return sharedSynchronization;
    }
}

#pragma --------------------------------------------------------------------------------------------
#pragma mark ===== Synchronized =====
#pragma --------------------------------------------------------------------------------------------

- (void)synchronizationFolders
{
    if ([app.activeAccount length] == 0)
        return;

    NSArray *directories = [CCCoreData getSynchronizedDirectoryActiveAccount:app.activeAccount];
    
    for (TableDirectory *directory in directories) {
        
        CCMetadataNet *metadataNet = [[CCMetadataNet alloc] initWithAccount:app.activeAccount];
        
        metadataNet.action = actionReadFolder;
        metadataNet.date = [NSDate date];
        metadataNet.directoryID = directory.directoryID;
        metadataNet.priority = NSOperationQueuePriorityVeryLow;
        metadataNet.selector = selectorSynchronizedFolder;
        metadataNet.serverUrl = directory.serverUrl;
        
        [app addNetworkingOperationQueue:app.netQueue delegate:self metadataNet:metadataNet oneByOne:YES];
    }
}

//
// Add - Remove Folder for sync
//
- (void)synchronizationFolder:(NSString *)serverUrl
{
    BOOL synchronized = [CCCoreData isSynchronizedDirectory:serverUrl activeAccount:app.activeAccount];
    NSString *directoryID = [CCCoreData getDirectoryIDFromServerUrl:serverUrl activeAccount:app.activeAccount];
    
    if (synchronized) {
        
        [CCCoreData setSynchronizedDirectory:serverUrl synchronized:NO activeAccount:app.activeAccount];
        
    } else {
        
        [CCCoreData setSynchronizedDirectory:serverUrl synchronized:YES activeAccount:app.activeAccount];
        
        CCMetadataNet *metadataNet = [[CCMetadataNet alloc] initWithAccount:app.activeAccount];
        
        metadataNet.action = actionReadFolder;
        metadataNet.directoryID = directoryID;
        metadataNet.priority = NSOperationQueuePriorityVeryHigh;
        metadataNet.selector = selectorReadFolder;
        metadataNet.serverUrl = serverUrl;
        
        [app addNetworkingOperationQueue:app.netQueue delegate:self metadataNet:metadataNet oneByOne:YES];
    }
}

#pragma --------------------------------------------------------------------------------------------
#pragma mark ===== Read Folder Synchronize =====
#pragma --------------------------------------------------------------------------------------------

- (void)readFolderFailure:(CCMetadataNet *)metadataNet message:(NSString *)message errorCode:(NSInteger)errorCode
{
    // verify active user
    TableAccount *recordAccount = [CCCoreData getActiveAccount];
    
    // Folder not present, remove it
    if (errorCode == 404 && [recordAccount.account isEqualToString:metadataNet.account])
        [CCCoreData deleteDirectoryAndSubDirectory:metadataNet.serverUrl activeAccount:app.activeAccount];
}

// MULTI THREAD
- (void)readFolderSuccess:(CCMetadataNet *)metadataNet permissions:(NSString *)permissions rev:(NSString *)rev metadatas:(NSArray *)metadatas
{
    TableAccount *recordAccount = [CCCoreData getActiveAccount];
    
    __block NSMutableArray *metadatasForSynchronized = [[NSMutableArray alloc] init];
    
    if ([recordAccount.account isEqualToString:metadataNet.account] == NO && [metadataNet.selector isEqualToString:selectorSynchronizedFolder])
        return;
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_HIGH, 0), ^{
        
        NSArray *recordsInSessions = [CCCoreData getTableMetadataWithPredicate:[NSPredicate predicateWithFormat:@"(account == %@) AND (directoryID == %@) AND (session != NULL) AND (session != '')", app.activeAccount, metadataNet.directoryID] context:nil];
        
        // ----- Test metadata not present (DELETE) -----
        
        NSMutableArray *metadatasNotPresents = [[NSMutableArray alloc] init];
        NSArray *metadatasInDB = [CCCoreData getTableMetadataWithPredicate:[NSPredicate predicateWithFormat:@"(account == %@) AND (directoryID == %@)", app.activeAccount, metadataNet.directoryID] context:nil];
        
        for (CCMetadata *metadataDB in metadatasInDB) {
            
            BOOL fileIDFound = NO;
            
            for (CCMetadata *metadata in metadatas) {
                
                if ([metadataDB.fileID isEqualToString:metadata.fileID]) {
                    fileIDFound = YES;
                    break;
                }
            }
            
            if (!fileIDFound)
                [metadatasNotPresents addObject:metadataDB];
        }
        
        dispatch_async(dispatch_get_main_queue(), ^{
            
            // delete metadata not present
            for (CCMetadata *metadata in metadatasNotPresents)
                [CCCoreData deleteFile:metadata serverUrl:metadataNet.serverUrl directoryUser:app.directoryUser typeCloud:app.typeCloud activeAccount:app.activeAccount];
            
            [app.activeMain getDataSourceWithReloadTableView:metadataNet.directoryID fileID:nil selector:nil];
            
        });
        
        // ----- Search metadata for test change metadata (MODIFY) -----
        
        for (CCMetadata *metadata in metadatas) {
            
            // no dir
            if (metadata.directory)
                continue;
            
            NSInteger typeFilename = [CCUtility getTypeFileName:metadata.fileName];
            
            // reject crypto
            if (typeFilename == metadataTypeFilenameCrypto) continue;
            
            // Verify if the plist is complited
            if (typeFilename == metadataTypeFilenamePlist) {
                
                BOOL isCryptoComplete = NO;
                NSString *fileNameCrypto = [CCUtility trasformedFileNamePlistInCrypto:metadata.fileName];
                
                for (CCMetadata *completeMetadata in metadatas) {
                    
                    if (completeMetadata.cryptated == NO) continue;
                    else  if ([completeMetadata.fileName isEqualToString:fileNameCrypto]) {
                        isCryptoComplete = YES;
                        break;
                    }
                }
                if (isCryptoComplete == NO) continue;
            }
        
            // Error password
            if (metadata.errorPasscode)
                continue;
            
            // Plist not download
            if (metadata.cryptated && [metadata.title length] == 0)
                continue;
            
            // It's in session
            BOOL recordInSession = NO;
            for (TableMetadata *record in recordsInSessions) {
                if ([record.fileID isEqualToString:metadata.fileID]) {
                    recordInSession = YES;
                    break;
                }
            }
            if (recordInSession)
                continue;
            
            // Ohhhh INSERT
            [metadatasForSynchronized addObject:metadata];
        }
        
        if ([metadatasForSynchronized count] > 0)
            [self verifyChangeMedatas:metadatasForSynchronized serverUrl:metadataNet.serverUrl directoryID:metadataNet.directoryID account:metadataNet.account synchronization:YES];
    });
}

// MULTI THREAD
- (void)verifyChangeMedatas:(NSArray *)allRecordMetadatas serverUrl:(NSString *)serverUrl directoryID:(NSString *)directoryID account:(NSString *)account synchronization:(BOOL)synchronization
{
    NSMutableArray *metadatas = [[NSMutableArray alloc] init];
    TableAccount *recordAccount = [CCCoreData getActiveAccount];
    
    for (CCMetadata *metadata in allRecordMetadatas) {
        
        BOOL changeRev = NO;
        
        // no dir
        if (metadata.directory)
            continue;
        
        TableLocalFile *record = [TableLocalFile MR_findFirstWithPredicate:[NSPredicate predicateWithFormat:@"(account == %@) AND (fileID == %@)", app.activeAccount, metadata.fileID]];
        
        if (synchronization) {
            
            if (![record.rev isEqualToString:metadata.rev ])
                changeRev = YES;
            
        } else {
            
            if (record && ![record.rev isEqualToString:metadata.rev ])
                changeRev = YES;
        }
        
        if (changeRev && [recordAccount.account isEqualToString:account]) {
            
            if ([metadata.type isEqualToString:metadataType_file]) {
                
                // remove file and ico
                [[NSFileManager defaultManager] removeItemAtPath:[NSString stringWithFormat:@"%@/%@", app.directoryUser, metadata.fileID] error:nil];
                [[NSFileManager defaultManager] removeItemAtPath:[NSString stringWithFormat:@"%@/%@.ico", app.directoryUser, metadata.fileID] error:nil];
            }
            
            if ([metadata.type isEqualToString:metadataType_model]) {
                
                // remove model
                [[NSFileManager defaultManager] removeItemAtPath:[NSString stringWithFormat:@"%@/%@", app.directoryUser, metadata.fileName] error:nil];
            }
            
            [metadatas addObject:metadata];
        }
    }
    
    dispatch_async(dispatch_get_main_queue(), ^{
        if ([metadatas count])
            [self synchronizedMetadatas:metadatas serverUrl:serverUrl directoryID:directoryID synchronization:synchronization];
    });
}

// MAIN THREAD
- (void)synchronizedMetadatas:(NSArray *)metadatas serverUrl:(NSString *)serverUrl directoryID:(NSString *)directoryID synchronization:(BOOL)synchronization
{
    // HUD
    if ([metadatas count] > 50 && synchronization) {
        if (!_hud) _hud = [[CCHud alloc] initWithView:[[[UIApplication sharedApplication] delegate] window]];
        [_hud visibleHudTitle:NSLocalizedString(@"_create_synchronization_", nil) mode:MBProgressHUDModeIndeterminate color:nil];
    }
    
    // select type of session
    NSString *session;
    if ([CCUtility getSynchronizationsOnlyWiFi] && synchronization) session = download_session_wwan;
    else session = download_session;
    
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, 0.01 * NSEC_PER_SEC), dispatch_get_main_queue(), ^(void) {
        
        for (CCMetadata *metadata in metadatas) {
        
            NSString *selector, *selectorPost;
            BOOL downloadData, downloadPlist;
        
            // it's a favorite ?
            BOOL isFavorite = [CCCoreData isFavorite:metadata.fileID activeAccount:app.activeAccount];
        
            if (isFavorite)
                selectorPost = selectorAddFavorite;
        
            if ([metadata.type isEqualToString:metadataType_file]) {
                downloadData = YES;
                selector = selectorDownloadSynchronized;
            }
        
            if ([metadata.type isEqualToString:metadataType_model]) {
                downloadPlist = YES;
                selector = selectorLoadPlist;
            }
        
            [CCCoreData addMetadata:metadata activeAccount:app.activeAccount activeUrl:serverUrl typeCloud:app.typeCloud overwrite:NO context:nil];
        
            CCMetadataNet *metadataNet = [[CCMetadataNet alloc] initWithAccount:app.activeAccount];
            
            metadataNet.action = actionDownloadFile;
            metadataNet.metadata = metadata;
            metadataNet.downloadData = downloadData;
            metadataNet.downloadPlist = downloadPlist;
            metadataNet.selector = selector;
            metadataNet.selectorPost = selectorPost;
            metadataNet.serverUrl = serverUrl;
            metadataNet.session = session;
            metadataNet.taskStatus = taskStatusResume;

            if ([session containsString:@"wwan"])
                [app addNetworkingOperationQueue:app.netQueueDownloadWWan delegate:app.activeMain metadataNet:metadataNet oneByOne:YES];
            else
                [app addNetworkingOperationQueue:app.netQueueDownload delegate:app.activeMain metadataNet:metadataNet oneByOne:YES];
                        
        }
    
        [app.activeMain getDataSourceWithReloadTableView:directoryID fileID:nil selector:nil];
        
        [_hud hideHud];
    });
}

@end