// // CCSynchronization.m // Crypto Cloud Technology Nextcloud // // Created by Marino Faggiana on 19/10/16. // Copyright (c) 2016 TWS. All rights reserved. // // Author Marino Faggiana // // 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 . // #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