|
@@ -2372,44 +2372,37 @@ class NCManageDatabase: NSObject {
|
|
|
return Array(results.map { tableQueueUpload.init(value:$0) })
|
|
|
}
|
|
|
|
|
|
- @objc func getQueueUpload(withPath: Bool) -> CCMetadataNet? {
|
|
|
+
|
|
|
+ @objc func getQueueUpload() -> CCMetadataNet? {
|
|
|
|
|
|
guard let tableAccount = self.getAccountActive() else {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
- var result: tableQueueUpload?
|
|
|
-
|
|
|
let realm = try! Realm()
|
|
|
realm.refresh()
|
|
|
|
|
|
- if withPath {
|
|
|
- result = realm.objects(tableQueueUpload.self).filter("account = %@ AND lock == false AND path != nil", tableAccount.account).sorted(byKeyPath: "date", ascending: true).first
|
|
|
- } else {
|
|
|
- result = realm.objects(tableQueueUpload.self).filter("account = %@ AND lock == false AND path == nil", tableAccount.account).sorted(byKeyPath: "date", ascending: true).first
|
|
|
- }
|
|
|
-
|
|
|
- if result == nil {
|
|
|
+ guard let result = realm.objects(tableQueueUpload.self).filter("account = %@ AND lock == false", tableAccount.account).sorted(byKeyPath: "date", ascending: true).first else {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
let metadataNet = CCMetadataNet()
|
|
|
|
|
|
- metadataNet.account = result!.account
|
|
|
- metadataNet.assetLocalIdentifier = result!.assetLocalIdentifier
|
|
|
- metadataNet.errorCode = result!.errorCode
|
|
|
- metadataNet.directoryID = self.getDirectoryID(result!.serverUrl)
|
|
|
- metadataNet.fileName = result!.fileName
|
|
|
- metadataNet.fileNameView = result!.fileNameView
|
|
|
- metadataNet.path = result!.path
|
|
|
- metadataNet.selector = result!.selector
|
|
|
- metadataNet.selectorPost = result!.selectorPost
|
|
|
- metadataNet.serverUrl = result!.serverUrl
|
|
|
- metadataNet.session = result!.session
|
|
|
- metadataNet.sessionError = result!.sessionError
|
|
|
- metadataNet.sessionID = result!.sessionID
|
|
|
- metadataNet.sessionTaskIdentifier = result!.sessionTaskIdentifier
|
|
|
- metadataNet.size = result!.size
|
|
|
+ metadataNet.account = result.account
|
|
|
+ metadataNet.assetLocalIdentifier = result.assetLocalIdentifier
|
|
|
+ metadataNet.errorCode = result.errorCode
|
|
|
+ metadataNet.directoryID = self.getDirectoryID(result.serverUrl)
|
|
|
+ metadataNet.fileName = result.fileName
|
|
|
+ metadataNet.fileNameView = result.fileNameView
|
|
|
+ metadataNet.path = result.path
|
|
|
+ metadataNet.selector = result.selector
|
|
|
+ metadataNet.selectorPost = result.selectorPost
|
|
|
+ metadataNet.serverUrl = result.serverUrl
|
|
|
+ metadataNet.session = result.session
|
|
|
+ metadataNet.sessionError = result.sessionError
|
|
|
+ metadataNet.sessionID = result.sessionID
|
|
|
+ metadataNet.sessionTaskIdentifier = result.sessionTaskIdentifier
|
|
|
+ metadataNet.size = result.size
|
|
|
metadataNet.taskStatus = Int(k_taskStatusResume)
|
|
|
|
|
|
return metadataNet
|
|
@@ -2429,51 +2422,43 @@ class NCManageDatabase: NSObject {
|
|
|
return Array(results.map { tableQueueUpload.init(value:$0) })
|
|
|
}
|
|
|
|
|
|
- @objc func lockQueueUpload(selector: String, withPath: Bool) -> CCMetadataNet? {
|
|
|
+ @objc func lockQueueUpload(selector: String) -> CCMetadataNet? {
|
|
|
|
|
|
guard let tableAccount = self.getAccountActive() else {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
- var result: tableQueueUpload?
|
|
|
-
|
|
|
let realm = try! Realm()
|
|
|
-
|
|
|
- if withPath {
|
|
|
- result = realm.objects(tableQueueUpload.self).filter("account = %@ AND selector = %@ AND lock == false AND path != nil", tableAccount.account, selector).sorted(byKeyPath: "date", ascending: true).first
|
|
|
- } else {
|
|
|
- result = realm.objects(tableQueueUpload.self).filter("account = %@ AND selector = %@ AND lock == false AND path == nil", tableAccount.account, selector).sorted(byKeyPath: "date", ascending: true).first
|
|
|
- }
|
|
|
-
|
|
|
- if result == nil {
|
|
|
+
|
|
|
+ guard let result = realm.objects(tableQueueUpload.self).filter("account = %@ AND selector = %@ AND lock == false", tableAccount.account, selector).sorted(byKeyPath: "date", ascending: true).first else {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
- let directoryID = self.getDirectoryID(result!.serverUrl)
|
|
|
+ let directoryID = self.getDirectoryID(result.serverUrl)
|
|
|
|
|
|
realm.beginWrite()
|
|
|
|
|
|
let metadataNet = CCMetadataNet()
|
|
|
|
|
|
- metadataNet.account = result!.account
|
|
|
- metadataNet.assetLocalIdentifier = result!.assetLocalIdentifier
|
|
|
+ metadataNet.account = result.account
|
|
|
+ metadataNet.assetLocalIdentifier = result.assetLocalIdentifier
|
|
|
metadataNet.directoryID = directoryID
|
|
|
- metadataNet.errorCode = result!.errorCode
|
|
|
- metadataNet.fileName = result!.fileName
|
|
|
- metadataNet.fileNameView = result!.fileNameView
|
|
|
- metadataNet.path = result!.path
|
|
|
- metadataNet.selector = result!.selector
|
|
|
- metadataNet.selectorPost = result!.selectorPost
|
|
|
- metadataNet.serverUrl = result!.serverUrl
|
|
|
- metadataNet.session = result!.session
|
|
|
- metadataNet.sessionError = result!.sessionError
|
|
|
- metadataNet.sessionID = result!.sessionID
|
|
|
- metadataNet.sessionTaskIdentifier = result!.sessionTaskIdentifier
|
|
|
- metadataNet.size = result!.size
|
|
|
+ metadataNet.errorCode = result.errorCode
|
|
|
+ metadataNet.fileName = result.fileName
|
|
|
+ metadataNet.fileNameView = result.fileNameView
|
|
|
+ metadataNet.path = result.path
|
|
|
+ metadataNet.selector = result.selector
|
|
|
+ metadataNet.selectorPost = result.selectorPost
|
|
|
+ metadataNet.serverUrl = result.serverUrl
|
|
|
+ metadataNet.session = result.session
|
|
|
+ metadataNet.sessionError = result.sessionError
|
|
|
+ metadataNet.sessionID = result.sessionID
|
|
|
+ metadataNet.sessionTaskIdentifier = result.sessionTaskIdentifier
|
|
|
+ metadataNet.size = result.size
|
|
|
metadataNet.taskStatus = Int(k_taskStatusResume)
|
|
|
|
|
|
// Lock
|
|
|
- result!.lock = true
|
|
|
+ result.lock = true
|
|
|
|
|
|
do {
|
|
|
try realm.commitWrite()
|
|
@@ -2510,28 +2495,6 @@ class NCManageDatabase: NSObject {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- @objc func unlockAllQueueUploadWithPath() {
|
|
|
-
|
|
|
- guard let tableAccount = self.getAccountActive() else {
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- let realm = try! Realm()
|
|
|
-
|
|
|
- do {
|
|
|
- try realm.write {
|
|
|
-
|
|
|
- let results = realm.objects(tableQueueUpload.self).filter("account = %@ AND path != nil", tableAccount.account)
|
|
|
-
|
|
|
- for result in results {
|
|
|
- result.lock = false;
|
|
|
- }
|
|
|
- }
|
|
|
- } catch let error {
|
|
|
- print("[LOG] Could not write to database: ", error)
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
@objc func deleteQueueUpload(assetLocalIdentifier: String, selector: String) {
|
|
|
|
|
|
guard let tableAccount = self.getAccountActive() else {
|