NCManageDatabase.swift 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945
  1. //
  2. // NCManageDatabase.swift
  3. // Crypto Cloud Technology Nextcloud
  4. //
  5. // Created by Marino Faggiana on 06/05/17.
  6. // Copyright © 2017 TWS. All rights reserved.
  7. //
  8. // Author Marino Faggiana <m.faggiana@twsweb.it>
  9. //
  10. // This program is free software: you can redistribute it and/or modify
  11. // it under the terms of the GNU General Public License as published by
  12. // the Free Software Foundation, either version 3 of the License, or
  13. // (at your option) any later version.
  14. //
  15. // This program is distributed in the hope that it will be useful,
  16. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  18. // GNU General Public License for more details.
  19. //
  20. // You should have received a copy of the GNU General Public License
  21. // along with this program. If not, see <http://www.gnu.org/licenses/>.
  22. //
  23. import RealmSwift
  24. class NCManageDatabase: NSObject {
  25. static let sharedInstance: NCManageDatabase = {
  26. let instance = NCManageDatabase()
  27. return instance
  28. }()
  29. override init() {
  30. let dirGroup = FileManager.default.containerURL(forSecurityApplicationGroupIdentifier: NCBrandOptions.sharedInstance.capabilitiesGroups)
  31. var config = Realm.Configuration()
  32. config.fileURL = dirGroup?.appendingPathComponent("\(appDatabaseNextcloud)/\(k_databaseDefault)")
  33. Realm.Configuration.defaultConfiguration = config
  34. }
  35. //MARK: -
  36. //MARK: Utility Database
  37. func clearTable(_ table : Object.Type, account: String?) {
  38. let results : Results<Object>
  39. let realm = try! Realm()
  40. if (account != nil) {
  41. results = realm.objects(table).filter("account = %@", account!)
  42. } else {
  43. results = realm.objects(table)
  44. }
  45. try! realm.write {
  46. realm.delete(results)
  47. }
  48. }
  49. func removeDB() {
  50. let realmURL = Realm.Configuration.defaultConfiguration.fileURL!
  51. let realmURLs = [
  52. realmURL,
  53. realmURL.appendingPathExtension("lock"),
  54. realmURL.appendingPathExtension("note"),
  55. realmURL.appendingPathExtension("management")
  56. ]
  57. for URL in realmURLs {
  58. do {
  59. try FileManager.default.removeItem(at: URL)
  60. } catch {
  61. // handle error
  62. }
  63. }
  64. }
  65. //MARK: -
  66. //MARK: Table Account
  67. func addAccount(_ account: String, url: String, user: String, password: String) {
  68. let realm = try! Realm()
  69. try! realm.write {
  70. let addAccount = tableAccount()
  71. addAccount.account = account
  72. // Brand
  73. if NCBrandOptions.sharedInstance.use_default_automatic_upload {
  74. addAccount.cameraUpload = true
  75. addAccount.cameraUploadPhoto = true
  76. addAccount.cameraUploadVideo = true
  77. addAccount.cameraUploadWWAnVideo = true
  78. }
  79. addAccount.password = password
  80. addAccount.url = url
  81. addAccount.user = user
  82. }
  83. }
  84. func setAccountPassword(_ account: String, password: String) {
  85. let realm = try! Realm()
  86. let results = realm.objects(tableAccount.self).filter("account = %@", account)
  87. if (results.count > 0) {
  88. try! realm.write {
  89. results[0].password = password
  90. }
  91. }
  92. }
  93. func deleteAccount(_ account: String) {
  94. let realm = try! Realm()
  95. let results = realm.objects(tableAccount.self).filter("account = %@", account)
  96. if (results.count > 0) {
  97. try! realm.write {
  98. realm.delete(results)
  99. }
  100. }
  101. }
  102. func getAccountActive() -> tableAccount? {
  103. let realm = try! Realm()
  104. let results = realm.objects(tableAccount.self).filter("active = true")
  105. if (results.count > 0) {
  106. return results[0]
  107. } else {
  108. return nil
  109. }
  110. }
  111. func getAccounts(_ account: String?) -> [tableAccount] {
  112. let realm = try! Realm()
  113. let results : Results<tableAccount>
  114. if account == nil {
  115. results = realm.objects(tableAccount.self).sorted(byKeyPath: "account", ascending: true)
  116. } else {
  117. results = realm.objects(tableAccount.self).filter("account = %@", account!).sorted(byKeyPath: "account", ascending: true)
  118. }
  119. return Array(results)
  120. }
  121. func getAccountsCameraUploadFolderName(_ activeUrl : String?) -> String {
  122. let realm = try! Realm()
  123. let results = realm.objects(tableAccount.self).filter("active = true")
  124. if (results.count > 0) {
  125. if results[0].cameraUploadFolderName.characters.count > 0 {
  126. if activeUrl == nil {
  127. return results[0].cameraUploadFolderName
  128. } else {
  129. return results[0].cameraUploadFolderPath
  130. }
  131. } else {
  132. if activeUrl == nil {
  133. return k_folderDefaultCameraUpload
  134. } else {
  135. return CCUtility.getHomeServerUrlActiveUrl(activeUrl!)
  136. }
  137. }
  138. }
  139. return ""
  140. }
  141. func getAccountsCameraUploadFolderPath(_ activeUrl : String) -> String {
  142. let cameraFolderName = self.getAccountsCameraUploadFolderName(nil)
  143. let cameraFolderPath = self.getAccountsCameraUploadFolderName(activeUrl)
  144. let folderPhotos = CCUtility.stringAppendServerUrl(cameraFolderPath, addFileName: cameraFolderName)!
  145. return folderPhotos
  146. }
  147. func setAccountActive(_ account: String) -> tableAccount {
  148. let realm = try! Realm()
  149. var activeAccount = tableAccount()
  150. let results = realm.objects(tableAccount.self)
  151. try! realm.write {
  152. for result in results {
  153. if result.account == account {
  154. result.active = true
  155. activeAccount = result
  156. } else {
  157. result.active = false
  158. }
  159. }
  160. }
  161. return activeAccount
  162. }
  163. func setAccountCameraStateFiled(field: String, state: Bool) {
  164. let realm = try! Realm()
  165. let results = realm.objects(tableAccount.self).filter("active = true")
  166. if (results.count > 0) {
  167. try! realm.write {
  168. switch field {
  169. case "cameraUpload":
  170. results[0].cameraUpload = state
  171. case "cameraUploadBackground":
  172. results[0].cameraUploadBackground = state
  173. case "cameraUploadCreateSubfolder":
  174. results[0].cameraUploadCreateSubfolder = state
  175. case "cameraUploadFull":
  176. results[0].cameraUploadFull = state
  177. case "cameraUploadPhoto":
  178. results[0].cameraUploadPhoto = state
  179. case "cameraUploadVideo":
  180. results[0].cameraUploadVideo = state
  181. case "cameraUploadWWAnPhoto":
  182. results[0].cameraUploadWWAnPhoto = state
  183. case "cameraUploadWWAnVideo":
  184. results[0].cameraUploadWWAnVideo = state
  185. default:
  186. print("No founfd field")
  187. }
  188. }
  189. }
  190. }
  191. func setAccountsCameraUploadDateAssetType(assetMediaType: PHAssetMediaType, assetDate: NSDate) {
  192. let realm = try! Realm()
  193. let results = realm.objects(tableAccount.self).filter("active = true")
  194. try! realm.write {
  195. if (assetMediaType == PHAssetMediaType.image && results.count > 0) {
  196. results[0].cameraUploadDatePhoto = assetDate
  197. }
  198. if (assetMediaType == PHAssetMediaType.video && results.count > 0) {
  199. results[0].cameraUploadDateVideo = assetDate
  200. }
  201. }
  202. }
  203. func setAccountsCameraUploadFolderName(folderName: String?) {
  204. let realm = try! Realm()
  205. var folderName : String? = folderName
  206. if folderName == nil {
  207. folderName = self.getAccountsCameraUploadFolderName(nil)
  208. }
  209. let results = realm.objects(tableAccount.self).filter("active = true")
  210. if (results.count > 0) {
  211. try! realm.write {
  212. results[0].cameraUploadFolderName = folderName!
  213. }
  214. }
  215. }
  216. func setAccountsCameraUploadFolderPath(pathName: String?, activeUrl: String) {
  217. let realm = try! Realm()
  218. var pathName : String? = pathName
  219. if pathName == nil {
  220. pathName = self.getAccountsCameraUploadFolderPath(activeUrl)
  221. }
  222. let results = realm.objects(tableAccount.self).filter("active = true")
  223. if (results.count > 0) {
  224. try! realm.write {
  225. results[0].cameraUploadFolderPath = pathName!
  226. }
  227. }
  228. }
  229. func setAccountsUserProfile(_ account: String, userProfile: OCUserProfile) {
  230. let realm = try! Realm()
  231. let results = realm.objects(tableAccount.self).filter("account = %@", account)
  232. if (results.count > 0) {
  233. try! realm.write {
  234. results[0].enabled = userProfile.enabled
  235. results[0].address = userProfile.address
  236. results[0].displayName = userProfile.displayName
  237. results[0].email = userProfile.email
  238. results[0].phone = userProfile.phone
  239. results[0].twitter = userProfile.twitter
  240. results[0].webpage = results[0].webpage
  241. results[0].quota = userProfile.quota
  242. results[0].quotaFree = userProfile.quotaFree
  243. results[0].quotaRelative = userProfile.quotaRelative
  244. results[0].quotaTotal = userProfile.quotaTotal
  245. results[0].quotaUsed = userProfile.quotaUsed
  246. }
  247. }
  248. }
  249. //MARK: -
  250. //MARK: Table Activity
  251. func getActivityWithPredicate(_ predicate: NSPredicate) -> [tableActivity] {
  252. let realm = try! Realm()
  253. let results = realm.objects(tableActivity.self).filter(predicate).sorted(byKeyPath: "date", ascending: false)
  254. return Array(results)
  255. }
  256. func addActivityServer(_ listOfActivity: [OCActivity], account: String) {
  257. let realm = try! Realm()
  258. try! realm.write {
  259. for activity in listOfActivity {
  260. let results = realm.objects(tableActivity.self).filter("idActivity = %d", activity.idActivity)
  261. if (results.count > 0) {
  262. continue
  263. }
  264. // Add new Activity
  265. let addActivity = tableActivity()
  266. addActivity.account = account
  267. if activity.date != nil {
  268. addActivity.date = activity.date! as NSDate
  269. }
  270. addActivity.idActivity = Double(activity.idActivity)
  271. addActivity.link = activity.link
  272. addActivity.note = activity.subject
  273. addActivity.type = k_activityTypeInfo
  274. realm.add(addActivity)
  275. }
  276. }
  277. }
  278. func addActivityClient(_ file: String, fileID: String, action: String, selector: String, note: String, type: String, verbose: Bool, account: String?, activeUrl: String?) {
  279. var noteReplacing : String = ""
  280. if (activeUrl != nil) {
  281. noteReplacing = note.replacingOccurrences(of: "\(activeUrl!)\(webDAV)", with: "")
  282. }
  283. noteReplacing = note.replacingOccurrences(of: "\(k_domain_session_queue).", with: "")
  284. let realm = try! Realm()
  285. try! realm.write {
  286. // Add new Activity
  287. let addActivity = tableActivity()
  288. if (account != nil) {
  289. addActivity.account = account!
  290. }
  291. addActivity.action = action
  292. addActivity.file = file
  293. addActivity.fileID = fileID
  294. addActivity.note = noteReplacing
  295. addActivity.selector = selector
  296. addActivity.type = type
  297. addActivity.verbose = verbose
  298. realm.add(addActivity)
  299. }
  300. }
  301. //MARK: -
  302. //MARK: Table Automatic Upload
  303. func addAutomaticUpload(_ metadataNet: CCMetadataNet, account: String) -> Bool {
  304. let realm = try! Realm()
  305. let results = realm.objects(tableAutomaticUpload.self).filter("account = %@ AND assetLocalIdentifier = %@", account, metadataNet.assetLocalIdentifier)
  306. if (results.count > 0) {
  307. return false
  308. }
  309. try! realm.write {
  310. // Add new AutomaticUpload
  311. let addAutomaticUpload = tableAutomaticUpload()
  312. addAutomaticUpload.account = account
  313. addAutomaticUpload.assetLocalIdentifier = metadataNet.assetLocalIdentifier
  314. addAutomaticUpload.fileName = metadataNet.fileName
  315. addAutomaticUpload.selector = metadataNet.selector
  316. if (metadataNet.selectorPost != nil) {
  317. addAutomaticUpload.selectorPost = metadataNet.selectorPost
  318. }
  319. addAutomaticUpload.serverUrl = metadataNet.serverUrl
  320. addAutomaticUpload.session = metadataNet.session
  321. addAutomaticUpload.priority = metadataNet.priority
  322. realm.add(addAutomaticUpload)
  323. }
  324. return true
  325. }
  326. func getAutomaticUploadForAccount(_ account: String, selector: String) -> CCMetadataNet? {
  327. let realm = try! Realm()
  328. let results = realm.objects(tableAutomaticUpload.self).filter("account = %@ AND selector = %@ AND lock == false", account, selector)
  329. if (results.count == 0) {
  330. return nil
  331. }
  332. let metadataNet = CCMetadataNet()
  333. metadataNet.action = actionUploadAsset
  334. metadataNet.assetLocalIdentifier = results[0].assetLocalIdentifier
  335. metadataNet.fileName = results[0].fileName
  336. metadataNet.priority = results[0].priority
  337. metadataNet.selector = results[0].selector
  338. metadataNet.selectorPost = results[0].selectorPost
  339. metadataNet.serverUrl = results[0].serverUrl
  340. metadataNet.session = results[0].session
  341. metadataNet.taskStatus = Int(k_taskStatusResume)
  342. // Lock
  343. try! realm.write {
  344. results[0].lock = true
  345. }
  346. return metadataNet
  347. }
  348. func getLockAutomaticUploadForAccount(_ account: String) -> [tableAutomaticUpload] {
  349. let realm = try! Realm()
  350. let results = realm.objects(tableAutomaticUpload.self).filter("account = %@ AND lock = true", account)
  351. return Array(results)
  352. }
  353. func unlockAutomaticUploadForAccount(_ account: String, assetLocalIdentifier: String) {
  354. let realm = try! Realm()
  355. let results = realm.objects(tableAutomaticUpload.self).filter("account = %@ AND assetLocalIdentifier = %@", account, assetLocalIdentifier)
  356. if (results.count > 0) {
  357. // UnLock
  358. try! realm.write {
  359. results[0].lock = false
  360. }
  361. }
  362. }
  363. func deleteAutomaticUploadForAccount(_ account: String, assetLocalIdentifier: String) {
  364. let realm = try! Realm()
  365. let results = realm.objects(tableAutomaticUpload.self).filter("account = %@ AND assetLocalIdentifier = %@", account, assetLocalIdentifier)
  366. if (results.count > 0) {
  367. try! realm.write {
  368. realm.delete(results)
  369. }
  370. }
  371. }
  372. func countAutomaticUploadForAccount(_ account: String, session: String?) -> Int {
  373. let realm = try! Realm()
  374. let results : Results<tableAutomaticUpload>
  375. if (session == nil) {
  376. results = realm.objects(tableAutomaticUpload.self).filter("account = %@", account)
  377. } else {
  378. results = realm.objects(tableAutomaticUpload.self).filter("account = %@ AND session = %@", account, session!)
  379. }
  380. return results.count
  381. }
  382. //MARK: -
  383. //MARK: Table Capabilities
  384. func addCapabilities(_ capabilities: OCCapabilities, account: String) {
  385. let realm = try! Realm()
  386. let results = realm.objects(tableCapabilities.self).filter("account = %@", account)
  387. try! realm.write {
  388. var resultCapabilities = tableCapabilities()
  389. if (results.count > 0) {
  390. resultCapabilities = results[0]
  391. }
  392. resultCapabilities.account = account
  393. resultCapabilities.themingBackground = capabilities.themingBackground
  394. resultCapabilities.themingColor = capabilities.themingColor
  395. resultCapabilities.themingLogo = capabilities.themingLogo
  396. resultCapabilities.themingName = capabilities.themingName
  397. resultCapabilities.themingSlogan = capabilities.themingSlogan
  398. resultCapabilities.themingUrl = capabilities.themingUrl
  399. resultCapabilities.versionMajor = capabilities.versionMajor
  400. resultCapabilities.versionMinor = capabilities.versionMinor
  401. resultCapabilities.versionMicro = capabilities.versionMicro
  402. resultCapabilities.versionString = capabilities.versionString
  403. if (results.count == 0) {
  404. realm.add(resultCapabilities)
  405. }
  406. }
  407. }
  408. func getCapabilitesForAccount(_ account: String) -> tableCapabilities? {
  409. let realm = try! Realm()
  410. let results = realm.objects(tableCapabilities.self).filter("account = %@", account)
  411. if (results.count > 0) {
  412. return results[0]
  413. } else {
  414. return nil
  415. }
  416. }
  417. func getServerVersionAccount(_ account: String) -> Int {
  418. let realm = try! Realm()
  419. let results = realm.objects(tableCapabilities.self).filter("account = %@", account)
  420. if (results.count > 0) {
  421. return results[0].versionMajor
  422. } else {
  423. return 0
  424. }
  425. }
  426. //MARK: -
  427. //MARK: Table Certificates
  428. func addCertificates(_ certificateLocation: String) {
  429. let realm = try! Realm()
  430. try! realm.write {
  431. let addCertificates = tableCertificates()
  432. addCertificates.certificateLocation = certificateLocation
  433. realm.add(addCertificates)
  434. }
  435. }
  436. func getCertificatesLocation(_ localCertificatesFolder: String) -> [String] {
  437. let realm = try! Realm()
  438. let results = realm.objects(tableCertificates.self)
  439. var arraycertificatePath = [String]()
  440. for result in results {
  441. arraycertificatePath.append("\(localCertificatesFolder)\(result.certificateLocation)")
  442. }
  443. return arraycertificatePath
  444. }
  445. //MARK: -
  446. //MARK: Table External Sites
  447. func addExternalSites(_ externalSites: OCExternalSites, account: String) {
  448. let realm = try! Realm()
  449. try! realm.write {
  450. let addExternalSite = tableExternalSites()
  451. addExternalSite.account = account
  452. addExternalSite.idExternalSite = externalSites.idExternalSite
  453. addExternalSite.icon = externalSites.icon
  454. addExternalSite.lang = externalSites.lang
  455. addExternalSite.name = externalSites.name
  456. addExternalSite.url = externalSites.url
  457. addExternalSite.type = externalSites.type
  458. realm.add(addExternalSite)
  459. }
  460. }
  461. func deleteExternalSitesForAccount(_ account: String) {
  462. let realm = try! Realm()
  463. let results = realm.objects(tableExternalSites.self).filter("account = %@", account)
  464. try! realm.write {
  465. realm.delete(results)
  466. }
  467. }
  468. func getAllExternalSitesWithPredicate(_ predicate: NSPredicate) -> [tableExternalSites] {
  469. let realm = try! Realm()
  470. let results = realm.objects(tableExternalSites.self).filter(predicate).sorted(byKeyPath: "idExternalSite", ascending: true)
  471. return Array(results)
  472. }
  473. //MARK: -
  474. //MARK: Table GPS
  475. func addGeocoderLocation(_ location: String, placemarkAdministrativeArea: String, placemarkCountry: String, placemarkLocality: String, placemarkPostalCode: String, placemarkThoroughfare: String, latitude: String, longitude: String) {
  476. let realm = try! Realm()
  477. // Verify if exists
  478. let results = realm.objects(tableGPS.self).filter("latitude = %@ AND longitude = %@", latitude, longitude)
  479. if (results.count > 0) {
  480. return
  481. }
  482. try! realm.write {
  483. // Add new GPS
  484. let addGPS = tableGPS()
  485. addGPS.location = location
  486. addGPS.placemarkAdministrativeArea = placemarkAdministrativeArea
  487. addGPS.placemarkCountry = placemarkCountry
  488. addGPS.placemarkLocality = placemarkLocality
  489. addGPS.placemarkPostalCode = placemarkPostalCode
  490. addGPS.placemarkThoroughfare = placemarkThoroughfare
  491. addGPS.latitude = latitude
  492. addGPS.longitude = longitude
  493. realm.add(addGPS)
  494. }
  495. }
  496. func getLocationFromGeoLatitude(_ latitude: String, longitude: String) -> String? {
  497. let realm = try! Realm()
  498. let results = realm.objects(tableGPS.self).filter("latitude = %@ AND longitude = %@", latitude, longitude)
  499. if (results.count == 0) {
  500. return nil
  501. } else {
  502. return results[0].location
  503. }
  504. }
  505. //MARK: -
  506. //MARK: Table Share
  507. func addShareLink(_ share: String, fileName: String, serverUrl: String, account: String) -> [String:String] {
  508. let realm = try! Realm()
  509. // Verify if exists
  510. let results = realm.objects(tableShare.self).filter("account = %@ AND fileName = %@ AND serverUrl = %@", account, fileName, serverUrl)
  511. if (results.count > 0) {
  512. try! realm.write {
  513. results[0].shareLink = share;
  514. }
  515. } else {
  516. // Add new record
  517. try! realm.write {
  518. let addShare = tableShare()
  519. addShare.account = account
  520. addShare.fileName = fileName
  521. addShare.serverUrl = serverUrl
  522. addShare.shareLink = share
  523. realm.add(addShare)
  524. }
  525. }
  526. return ["\(serverUrl)\(fileName)" : share]
  527. }
  528. func addShareUserAndGroup(_ share: String, fileName: String, serverUrl: String, account: String) -> [String:String] {
  529. let realm = try! Realm()
  530. // Verify if exists
  531. let results = realm.objects(tableShare.self).filter("account = %@ AND fileName = %@ AND serverUrl = %@", account, fileName, serverUrl)
  532. if (results.count > 0) {
  533. try! realm.write {
  534. results[0].shareUserAndGroup = share;
  535. }
  536. } else {
  537. // Add new record
  538. try! realm.write {
  539. let addShare = tableShare()
  540. addShare.account = account
  541. addShare.fileName = fileName
  542. addShare.serverUrl = serverUrl
  543. addShare.shareUserAndGroup = share
  544. realm.add(addShare)
  545. }
  546. }
  547. return ["\(serverUrl)\(fileName)" : share]
  548. }
  549. func unShare(_ share: String, fileName: String, serverUrl: String, sharesLink: [String:String], sharesUserAndGroup: [String:String], account: String) -> [Any] {
  550. var sharesLink = sharesLink
  551. var sharesUserAndGroup = sharesUserAndGroup
  552. let realm = try! Realm()
  553. let results = realm.objects(tableShare.self).filter("account = %@ AND (shareLink CONTAINS %@ OR shareUserAndGroup CONTAINS %@)", account, share, share)
  554. if (results.count > 0) {
  555. let result = results[0]
  556. realm.beginWrite()
  557. if (result.shareLink.contains(share)) {
  558. result.shareLink = ""
  559. }
  560. if (result.shareUserAndGroup.contains(share)) {
  561. var shares : [String] = result.shareUserAndGroup.components(separatedBy: ",")
  562. if let index = shares.index(of:share) {
  563. shares.remove(at: index)
  564. }
  565. result.shareUserAndGroup = shares.joined(separator: ",")
  566. }
  567. if (result.shareLink.characters.count > 0) {
  568. sharesLink.updateValue(result.shareLink, forKey:"\(serverUrl)\(fileName)")
  569. } else {
  570. sharesLink.removeValue(forKey: "\(serverUrl)\(fileName)")
  571. }
  572. if (result.shareUserAndGroup.characters.count > 0) {
  573. sharesUserAndGroup.updateValue(result.shareUserAndGroup, forKey:"\(serverUrl)\(fileName)")
  574. } else {
  575. sharesUserAndGroup.removeValue(forKey: "\(serverUrl)\(fileName)")
  576. }
  577. if (result.shareLink.characters.count == 0 && result.shareUserAndGroup.characters.count == 0) {
  578. realm.delete(result)
  579. }
  580. try! realm.commitWrite()
  581. }
  582. return [sharesLink, sharesUserAndGroup]
  583. }
  584. func removeShareActiveAccount(_ account: String) {
  585. let realm = try! Realm()
  586. let results = realm.objects(tableShare.self).filter("account = %@", account)
  587. try! realm.write {
  588. realm.delete(results)
  589. }
  590. }
  591. func updateShare(_ items: [String:OCSharedDto], account: String, activeUrl: String) -> [Any] {
  592. var sharesLink = [String:String]()
  593. var sharesUserAndGroup = [String:String]()
  594. self.removeShareActiveAccount(account)
  595. var itemsLink = [OCSharedDto]()
  596. var itemsUsersAndGroups = [OCSharedDto]()
  597. for (_, itemOCSharedDto) in items {
  598. if (itemOCSharedDto.shareType == Int(shareTypeLink.rawValue)) {
  599. itemsLink.append(itemOCSharedDto)
  600. }
  601. if (itemOCSharedDto.shareWith.characters.count > 0 && (itemOCSharedDto.shareType == Int(shareTypeUser.rawValue) || itemOCSharedDto.shareType == Int(shareTypeGroup.rawValue) || itemOCSharedDto.shareType == Int(shareTypeRemote.rawValue) )) {
  602. itemsUsersAndGroups.append(itemOCSharedDto)
  603. }
  604. }
  605. // Manage sharesLink
  606. for itemOCSharedDto in itemsLink {
  607. let fullPath = CCUtility.getHomeServerUrlActiveUrl(activeUrl) + "\(itemOCSharedDto.path!)"
  608. let fileName = NSString(string: fullPath).lastPathComponent
  609. var serverUrl = NSString(string: fullPath).substring(to: (fullPath.characters.count - fileName.characters.count - 1))
  610. if serverUrl.hasSuffix("/") {
  611. serverUrl = NSString(string: serverUrl).substring(to: (serverUrl.characters.count - 1))
  612. }
  613. if itemOCSharedDto.idRemoteShared > 0 {
  614. let sharesLinkReturn = self.addShareLink("\(itemOCSharedDto.idRemoteShared)", fileName: fileName, serverUrl: serverUrl, account: account)
  615. for (key,value) in sharesLinkReturn {
  616. sharesLink.updateValue(value, forKey:key)
  617. }
  618. }
  619. }
  620. // Manage sharesUserAndGroup
  621. var paths = [String:[String]]()
  622. for itemOCSharedDto in itemsUsersAndGroups {
  623. if paths[itemOCSharedDto.path] != nil {
  624. var share : [String] = paths[itemOCSharedDto.path]!
  625. share.append("\(itemOCSharedDto.idRemoteShared)")
  626. paths[itemOCSharedDto.path] = share
  627. } else {
  628. paths[itemOCSharedDto.path] = ["\(itemOCSharedDto.idRemoteShared)"]
  629. }
  630. }
  631. for (path, idsRemoteSharedArray) in paths {
  632. let idsRemoteShared = idsRemoteSharedArray.joined(separator: ",")
  633. print("[LOG] share \(String(describing: idsRemoteShared))")
  634. let fullPath = CCUtility.getHomeServerUrlActiveUrl(activeUrl) + "\(path)"
  635. let fileName = NSString(string: fullPath).lastPathComponent
  636. var serverUrl = NSString(string: fullPath).substring(to: (fullPath.characters.count - fileName.characters.count - 1))
  637. if serverUrl.hasSuffix("/") {
  638. serverUrl = NSString(string: serverUrl).substring(to: (serverUrl.characters.count - 1))
  639. }
  640. let sharesUserAndGroupReturn = self.addShareUserAndGroup(idsRemoteShared, fileName: fileName, serverUrl: serverUrl, account: account)
  641. for (key,value) in sharesUserAndGroupReturn {
  642. sharesUserAndGroup.updateValue(value, forKey:key)
  643. }
  644. }
  645. return [sharesLink, sharesUserAndGroup]
  646. }
  647. func getSharesAccount(_ account: String) -> [Any] {
  648. var sharesLink = [String:String]()
  649. var sharesUserAndGroup = [String:String]()
  650. let realm = try! Realm()
  651. let results = realm.objects(tableShare.self).filter("account = %@", account)
  652. for resultShare in results {
  653. if (resultShare.shareLink.characters.count > 0) {
  654. sharesLink = [resultShare.shareLink: "\(resultShare.serverUrl)\(resultShare.fileName)"]
  655. }
  656. if (resultShare.shareUserAndGroup.characters.count > 0) {
  657. sharesUserAndGroup = [resultShare.shareUserAndGroup: "\(resultShare.serverUrl)\(resultShare.fileName)"]
  658. }
  659. }
  660. return [sharesLink, sharesUserAndGroup]
  661. }
  662. //MARK: -
  663. }