Added conflict icon to folders containing files with conflicts
[pub/Android/ownCloud.git] / src / com / owncloud / android / datamodel / FileDataStorageManager.java
1 /**
2 * ownCloud Android client application
3 *
4 * Copyright (C) 2012 Bartek Przybylski
5 * Copyright (C) 2015 ownCloud Inc.
6 *
7 * This program is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2,
9 * as published by the Free Software Foundation.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program. If not, see <http://www.gnu.org/licenses/>.
18 *
19 */
20
21 package com.owncloud.android.datamodel;
22
23 import java.io.File;
24 import java.util.ArrayList;
25 import java.util.Collection;
26 import java.util.Collections;
27 import java.util.HashSet;
28 import java.util.Iterator;
29 import java.util.List;
30 import java.util.Set;
31 import java.util.Vector;
32
33 import android.accounts.Account;
34 import android.content.ContentProviderClient;
35 import android.content.ContentProviderOperation;
36 import android.content.ContentProviderResult;
37 import android.content.ContentResolver;
38 import android.content.ContentUris;
39 import android.content.ContentValues;
40 import android.content.Intent;
41 import android.content.OperationApplicationException;
42 import android.database.Cursor;
43 import android.net.Uri;
44 import android.os.RemoteException;
45 import android.provider.MediaStore;
46
47 import com.owncloud.android.MainApp;
48 import com.owncloud.android.db.ProviderMeta.ProviderTableMeta;
49 import com.owncloud.android.lib.common.utils.Log_OC;
50 import com.owncloud.android.lib.resources.files.FileUtils;
51 import com.owncloud.android.lib.resources.shares.OCShare;
52 import com.owncloud.android.lib.resources.shares.ShareType;
53 import com.owncloud.android.utils.FileStorageUtils;
54
55 import java.io.FileInputStream;
56 import java.io.FileOutputStream;
57 import java.io.IOException;
58 import java.io.InputStream;
59 import java.io.OutputStream;
60
61 public class FileDataStorageManager {
62
63 public static final int ROOT_PARENT_ID = 0;
64
65 private ContentResolver mContentResolver;
66 private ContentProviderClient mContentProviderClient;
67 private Account mAccount;
68
69 private static String TAG = FileDataStorageManager.class.getSimpleName();
70
71
72 public FileDataStorageManager(Account account, ContentResolver cr) {
73 mContentProviderClient = null;
74 mContentResolver = cr;
75 mAccount = account;
76 }
77
78 public FileDataStorageManager(Account account, ContentProviderClient cp) {
79 mContentProviderClient = cp;
80 mContentResolver = null;
81 mAccount = account;
82 }
83
84
85 public void setAccount(Account account) {
86 mAccount = account;
87 }
88
89 public Account getAccount() {
90 return mAccount;
91 }
92
93 public void setContentResolver(ContentResolver cr) {
94 mContentResolver = cr;
95 }
96
97 public ContentResolver getContentResolver() {
98 return mContentResolver;
99 }
100
101 public void setContentProviderClient(ContentProviderClient cp) {
102 mContentProviderClient = cp;
103 }
104
105 public ContentProviderClient getContentProviderClient() {
106 return mContentProviderClient;
107 }
108
109
110 public OCFile getFileByPath(String path) {
111 Cursor c = getCursorForValue(ProviderTableMeta.FILE_PATH, path);
112 OCFile file = null;
113 if (c.moveToFirst()) {
114 file = createFileInstance(c);
115 }
116 c.close();
117 if (file == null && OCFile.ROOT_PATH.equals(path)) {
118 return createRootDir(); // root should always exist
119 }
120 return file;
121 }
122
123
124 public OCFile getFileById(long id) {
125 Cursor c = getCursorForValue(ProviderTableMeta._ID, String.valueOf(id));
126 OCFile file = null;
127 if (c.moveToFirst()) {
128 file = createFileInstance(c);
129 }
130 c.close();
131 return file;
132 }
133
134 public OCFile getFileByLocalPath(String path) {
135 Cursor c = getCursorForValue(ProviderTableMeta.FILE_STORAGE_PATH, path);
136 OCFile file = null;
137 if (c.moveToFirst()) {
138 file = createFileInstance(c);
139 }
140 c.close();
141 return file;
142 }
143
144 public boolean fileExists(long id) {
145 return fileExists(ProviderTableMeta._ID, String.valueOf(id));
146 }
147
148 public boolean fileExists(String path) {
149 return fileExists(ProviderTableMeta.FILE_PATH, path);
150 }
151
152
153 public Vector<OCFile> getFolderContent(OCFile f/*, boolean onlyOnDevice*/) {
154 if (f != null && f.isFolder() && f.getFileId() != -1) {
155 // TODO Enable when "On Device" is recovered ?
156 return getFolderContent(f.getFileId()/*, onlyOnDevice*/);
157
158 } else {
159 return new Vector<OCFile>();
160 }
161 }
162
163
164 public Vector<OCFile> getFolderImages(OCFile folder/*, boolean onlyOnDevice*/) {
165 Vector<OCFile> ret = new Vector<OCFile>();
166 if (folder != null) {
167 // TODO better implementation, filtering in the access to database instead of here
168 // TODO Enable when "On Device" is recovered ?
169 Vector<OCFile> tmp = getFolderContent(folder/*, onlyOnDevice*/);
170 OCFile current = null;
171 for (int i=0; i<tmp.size(); i++) {
172 current = tmp.get(i);
173 if (current.isImage()) {
174 ret.add(current);
175 }
176 }
177 }
178 return ret;
179 }
180
181 public boolean saveFile(OCFile file) {
182 boolean overriden = false;
183 ContentValues cv = new ContentValues();
184 cv.put(ProviderTableMeta.FILE_MODIFIED, file.getModificationTimestamp());
185 cv.put(
186 ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA,
187 file.getModificationTimestampAtLastSyncForData()
188 );
189 cv.put(ProviderTableMeta.FILE_CREATION, file.getCreationTimestamp());
190 cv.put(ProviderTableMeta.FILE_CONTENT_LENGTH, file.getFileLength());
191 cv.put(ProviderTableMeta.FILE_CONTENT_TYPE, file.getMimetype());
192 cv.put(ProviderTableMeta.FILE_NAME, file.getFileName());
193 //if (file.getParentId() != DataStorageManager.ROOT_PARENT_ID)
194 cv.put(ProviderTableMeta.FILE_PARENT, file.getParentId());
195 cv.put(ProviderTableMeta.FILE_PATH, file.getRemotePath());
196 if (!file.isFolder())
197 cv.put(ProviderTableMeta.FILE_STORAGE_PATH, file.getStoragePath());
198 cv.put(ProviderTableMeta.FILE_ACCOUNT_OWNER, mAccount.name);
199 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE, file.getLastSyncDateForProperties());
200 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA, file.getLastSyncDateForData());
201 cv.put(ProviderTableMeta.FILE_KEEP_IN_SYNC, file.isFavorite() ? 1 : 0);
202 cv.put(ProviderTableMeta.FILE_ETAG, file.getEtag());
203 cv.put(ProviderTableMeta.FILE_SHARE_BY_LINK, file.isShareByLink() ? 1 : 0);
204 cv.put(ProviderTableMeta.FILE_PUBLIC_LINK, file.getPublicLink());
205 cv.put(ProviderTableMeta.FILE_PERMISSIONS, file.getPermissions());
206 cv.put(ProviderTableMeta.FILE_REMOTE_ID, file.getRemoteId());
207 cv.put(ProviderTableMeta.FILE_UPDATE_THUMBNAIL, file.needsUpdateThumbnail());
208 cv.put(ProviderTableMeta.FILE_IS_DOWNLOADING, file.isDownloading());
209 cv.put(ProviderTableMeta.FILE_IN_CONFLICT, file.isInConflict());
210
211 boolean sameRemotePath = fileExists(file.getRemotePath());
212 if (sameRemotePath || fileExists(file.getFileId())) { // for renamed files; no more delete and create
213
214 OCFile oldFile = null;
215 if (sameRemotePath) {
216 oldFile = getFileByPath(file.getRemotePath());
217 file.setFileId(oldFile.getFileId());
218 } else {
219 oldFile = getFileById(file.getFileId());
220 }
221
222 overriden = true;
223 if (getContentResolver() != null) {
224 getContentResolver().update(ProviderTableMeta.CONTENT_URI, cv,
225 ProviderTableMeta._ID + "=?",
226 new String[]{String.valueOf(file.getFileId())});
227 } else {
228 try {
229 getContentProviderClient().update(ProviderTableMeta.CONTENT_URI,
230 cv, ProviderTableMeta._ID + "=?",
231 new String[]{String.valueOf(file.getFileId())});
232 } catch (RemoteException e) {
233 Log_OC.e(TAG,
234 "Fail to insert insert file to database "
235 + e.getMessage());
236 }
237 }
238 } else {
239 Uri result_uri = null;
240 if (getContentResolver() != null) {
241 result_uri = getContentResolver().insert(
242 ProviderTableMeta.CONTENT_URI_FILE, cv);
243 } else {
244 try {
245 result_uri = getContentProviderClient().insert(
246 ProviderTableMeta.CONTENT_URI_FILE, cv);
247 } catch (RemoteException e) {
248 Log_OC.e(TAG,
249 "Fail to insert insert file to database "
250 + e.getMessage());
251 }
252 }
253 if (result_uri != null) {
254 long new_id = Long.parseLong(result_uri.getPathSegments()
255 .get(1));
256 file.setFileId(new_id);
257 }
258 }
259
260 // if (file.isFolder()) {
261 // updateFolderSize(file.getFileId());
262 // } else {
263 // updateFolderSize(file.getParentId());
264 // }
265
266 return overriden;
267 }
268
269
270 /**
271 * Inserts or updates the list of files contained in a given folder.
272 * <p/>
273 * CALLER IS THE RESPONSIBLE FOR GRANTING RIGHT UPDATE OF INFORMATION, NOT THIS METHOD.
274 * HERE ONLY DATA CONSISTENCY SHOULD BE GRANTED
275 *
276 * @param folder
277 * @param updatedFiles
278 * @param filesToRemove
279 */
280 public void saveFolder(
281 OCFile folder, Collection<OCFile> updatedFiles, Collection<OCFile> filesToRemove
282 ) {
283
284 Log_OC.d(TAG, "Saving folder " + folder.getRemotePath() + " with " + updatedFiles.size()
285 + " children and " + filesToRemove.size() + " files to remove");
286
287 ArrayList<ContentProviderOperation> operations =
288 new ArrayList<ContentProviderOperation>(updatedFiles.size());
289
290 // prepare operations to insert or update files to save in the given folder
291 for (OCFile file : updatedFiles) {
292 ContentValues cv = new ContentValues();
293 cv.put(ProviderTableMeta.FILE_MODIFIED, file.getModificationTimestamp());
294 cv.put(
295 ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA,
296 file.getModificationTimestampAtLastSyncForData()
297 );
298 cv.put(ProviderTableMeta.FILE_CREATION, file.getCreationTimestamp());
299 cv.put(ProviderTableMeta.FILE_CONTENT_LENGTH, file.getFileLength());
300 cv.put(ProviderTableMeta.FILE_CONTENT_TYPE, file.getMimetype());
301 cv.put(ProviderTableMeta.FILE_NAME, file.getFileName());
302 //cv.put(ProviderTableMeta.FILE_PARENT, file.getParentId());
303 cv.put(ProviderTableMeta.FILE_PARENT, folder.getFileId());
304 cv.put(ProviderTableMeta.FILE_PATH, file.getRemotePath());
305 if (!file.isFolder()) {
306 cv.put(ProviderTableMeta.FILE_STORAGE_PATH, file.getStoragePath());
307 }
308 cv.put(ProviderTableMeta.FILE_ACCOUNT_OWNER, mAccount.name);
309 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE, file.getLastSyncDateForProperties());
310 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA, file.getLastSyncDateForData());
311 cv.put(ProviderTableMeta.FILE_KEEP_IN_SYNC, file.isFavorite() ? 1 : 0);
312 cv.put(ProviderTableMeta.FILE_ETAG, file.getEtag());
313 cv.put(ProviderTableMeta.FILE_SHARE_BY_LINK, file.isShareByLink() ? 1 : 0);
314 cv.put(ProviderTableMeta.FILE_PUBLIC_LINK, file.getPublicLink());
315 cv.put(ProviderTableMeta.FILE_PERMISSIONS, file.getPermissions());
316 cv.put(ProviderTableMeta.FILE_REMOTE_ID, file.getRemoteId());
317 cv.put(ProviderTableMeta.FILE_UPDATE_THUMBNAIL, file.needsUpdateThumbnail());
318 cv.put(ProviderTableMeta.FILE_IS_DOWNLOADING, file.isDownloading());
319 cv.put(ProviderTableMeta.FILE_IN_CONFLICT, file.isInConflict());
320
321 boolean existsByPath = fileExists(file.getRemotePath());
322 if (existsByPath || fileExists(file.getFileId())) {
323 // updating an existing file
324 operations.add(ContentProviderOperation.newUpdate(ProviderTableMeta.CONTENT_URI).
325 withValues(cv).
326 withSelection(ProviderTableMeta._ID + "=?",
327 new String[]{String.valueOf(file.getFileId())})
328 .build());
329
330 } else {
331 // adding a new file
332 operations.add(ContentProviderOperation.newInsert(ProviderTableMeta.CONTENT_URI).
333 withValues(cv).build());
334 }
335 }
336
337 // prepare operations to remove files in the given folder
338 String where = ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?" + " AND " +
339 ProviderTableMeta.FILE_PATH + "=?";
340 String [] whereArgs = null;
341 for (OCFile file : filesToRemove) {
342 if (file.getParentId() == folder.getFileId()) {
343 whereArgs = new String[]{mAccount.name, file.getRemotePath()};
344 //Uri.withAppendedPath(ProviderTableMeta.CONTENT_URI_FILE, "" + file.getFileId());
345 if (file.isFolder()) {
346 operations.add(ContentProviderOperation.newDelete(
347 ContentUris.withAppendedId(
348 ProviderTableMeta.CONTENT_URI_DIR, file.getFileId()
349 )
350 ).withSelection(where, whereArgs).build());
351
352 File localFolder =
353 new File(FileStorageUtils.getDefaultSavePathFor(mAccount.name, file));
354 if (localFolder.exists()) {
355 removeLocalFolder(localFolder);
356 }
357 } else {
358 operations.add(ContentProviderOperation.newDelete(
359 ContentUris.withAppendedId(
360 ProviderTableMeta.CONTENT_URI_FILE, file.getFileId()
361 )
362 ).withSelection(where, whereArgs).build());
363
364 if (file.isDown()) {
365 String path = file.getStoragePath();
366 new File(path).delete();
367 triggerMediaScan(path); // notify MediaScanner about removed file
368 }
369 }
370 }
371 }
372
373 // update metadata of folder
374 ContentValues cv = new ContentValues();
375 cv.put(ProviderTableMeta.FILE_MODIFIED, folder.getModificationTimestamp());
376 cv.put(
377 ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA,
378 folder.getModificationTimestampAtLastSyncForData()
379 );
380 cv.put(ProviderTableMeta.FILE_CREATION, folder.getCreationTimestamp());
381 cv.put(ProviderTableMeta.FILE_CONTENT_LENGTH, 0);
382 cv.put(ProviderTableMeta.FILE_CONTENT_TYPE, folder.getMimetype());
383 cv.put(ProviderTableMeta.FILE_NAME, folder.getFileName());
384 cv.put(ProviderTableMeta.FILE_PARENT, folder.getParentId());
385 cv.put(ProviderTableMeta.FILE_PATH, folder.getRemotePath());
386 cv.put(ProviderTableMeta.FILE_ACCOUNT_OWNER, mAccount.name);
387 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE, folder.getLastSyncDateForProperties());
388 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA, folder.getLastSyncDateForData());
389 cv.put(ProviderTableMeta.FILE_KEEP_IN_SYNC, folder.isFavorite() ? 1 : 0);
390 cv.put(ProviderTableMeta.FILE_ETAG, folder.getEtag());
391 cv.put(ProviderTableMeta.FILE_SHARE_BY_LINK, folder.isShareByLink() ? 1 : 0);
392 cv.put(ProviderTableMeta.FILE_PUBLIC_LINK, folder.getPublicLink());
393 cv.put(ProviderTableMeta.FILE_PERMISSIONS, folder.getPermissions());
394 cv.put(ProviderTableMeta.FILE_REMOTE_ID, folder.getRemoteId());
395
396 operations.add(ContentProviderOperation.newUpdate(ProviderTableMeta.CONTENT_URI).
397 withValues(cv).
398 withSelection(ProviderTableMeta._ID + "=?",
399 new String[]{String.valueOf(folder.getFileId())})
400 .build());
401
402 // apply operations in batch
403 ContentProviderResult[] results = null;
404 Log_OC.d(TAG, "Sending " + operations.size() + " operations to FileContentProvider");
405 try {
406 if (getContentResolver() != null) {
407 results = getContentResolver().applyBatch(MainApp.getAuthority(), operations);
408
409 } else {
410 results = getContentProviderClient().applyBatch(operations);
411 }
412
413 } catch (OperationApplicationException e) {
414 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
415
416 } catch (RemoteException e) {
417 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
418 }
419
420 // update new id in file objects for insertions
421 if (results != null) {
422 long newId;
423 Iterator<OCFile> filesIt = updatedFiles.iterator();
424 OCFile file = null;
425 for (int i = 0; i < results.length; i++) {
426 if (filesIt.hasNext()) {
427 file = filesIt.next();
428 } else {
429 file = null;
430 }
431 if (results[i].uri != null) {
432 newId = Long.parseLong(results[i].uri.getPathSegments().get(1));
433 //updatedFiles.get(i).setFileId(newId);
434 if (file != null) {
435 file.setFileId(newId);
436 }
437 }
438 }
439 }
440
441 //updateFolderSize(folder.getFileId());
442
443 }
444
445
446 // /**
447 // *
448 // * @param id
449 // */
450 // private void updateFolderSize(long id) {
451 // if (id > FileDataStorageManager.ROOT_PARENT_ID) {
452 // Log_OC.d(TAG, "Updating size of " + id);
453 // if (getContentResolver() != null) {
454 // getContentResolver().update(ProviderTableMeta.CONTENT_URI_DIR,
455 // new ContentValues(),
456 // won't be used, but cannot be null; crashes in KLP
457 // ProviderTableMeta._ID + "=?",
458 // new String[] { String.valueOf(id) });
459 // } else {
460 // try {
461 // getContentProviderClient().update(ProviderTableMeta.CONTENT_URI_DIR,
462 // new ContentValues(),
463 // won't be used, but cannot be null; crashes in KLP
464 // ProviderTableMeta._ID + "=?",
465 // new String[] { String.valueOf(id) });
466 //
467 // } catch (RemoteException e) {
468 // Log_OC.e(
469 // TAG, "Exception in update of folder size through compatibility patch " + e.getMessage());
470 // }
471 // }
472 // } else {
473 // Log_OC.e(TAG, "not updating size for folder " + id);
474 // }
475 // }
476
477
478 public boolean removeFile(OCFile file, boolean removeDBData, boolean removeLocalCopy) {
479 boolean success = true;
480 if (file != null) {
481 if (file.isFolder()) {
482 success = removeFolder(file, removeDBData, removeLocalCopy);
483
484 } else {
485 if (removeDBData) {
486 //Uri file_uri = Uri.withAppendedPath(ProviderTableMeta.CONTENT_URI_FILE, ""+file.getFileId());
487 Uri file_uri = ContentUris.withAppendedId(ProviderTableMeta.CONTENT_URI_FILE, file.getFileId());
488 String where = ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?" + " AND " + ProviderTableMeta.FILE_PATH + "=?";
489 String[] whereArgs = new String[]{mAccount.name, file.getRemotePath()};
490 int deleted = 0;
491 if (getContentProviderClient() != null) {
492 try {
493 deleted = getContentProviderClient().delete(file_uri, where, whereArgs);
494 } catch (RemoteException e) {
495 e.printStackTrace();
496 }
497 } else {
498 deleted = getContentResolver().delete(file_uri, where, whereArgs);
499 }
500 success &= (deleted > 0);
501 }
502 String localPath = file.getStoragePath();
503 if (removeLocalCopy && file.isDown() && localPath != null && success) {
504 success = new File(localPath).delete();
505 if (success) {
506 deleteFileInMediaScan(localPath);
507 }
508 if (!removeDBData && success) {
509 // maybe unnecessary, but should be checked TODO remove if unnecessary
510 file.setStoragePath(null);
511 saveFile(file);
512 }
513 }
514 }
515 }
516 return success;
517 }
518
519
520 public boolean removeFolder(OCFile folder, boolean removeDBData, boolean removeLocalContent) {
521 boolean success = true;
522 if (folder != null && folder.isFolder()) {
523 if (removeDBData && folder.getFileId() != -1) {
524 success = removeFolderInDb(folder);
525 }
526 if (removeLocalContent && success) {
527 success = removeLocalFolder(folder);
528 }
529 }
530 return success;
531 }
532
533 private boolean removeFolderInDb(OCFile folder) {
534 Uri folder_uri = Uri.withAppendedPath(ProviderTableMeta.CONTENT_URI_DIR, "" +
535 folder.getFileId()); // URI for recursive deletion
536 String where = ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?" + " AND " +
537 ProviderTableMeta.FILE_PATH + "=?";
538 String [] whereArgs = new String[]{mAccount.name, folder.getRemotePath()};
539 int deleted = 0;
540 if (getContentProviderClient() != null) {
541 try {
542 deleted = getContentProviderClient().delete(folder_uri, where, whereArgs);
543 } catch (RemoteException e) {
544 e.printStackTrace();
545 }
546 } else {
547 deleted = getContentResolver().delete(folder_uri, where, whereArgs);
548 }
549 return deleted > 0;
550 }
551
552 private boolean removeLocalFolder(OCFile folder) {
553 boolean success = true;
554 String localFolderPath = FileStorageUtils.getDefaultSavePathFor(mAccount.name, folder);
555 File localFolder = new File(localFolderPath);
556 if (localFolder.exists()) {
557 // stage 1: remove the local files already registered in the files database
558 // TODO Enable when "On Device" is recovered ?
559 Vector<OCFile> files = getFolderContent(folder.getFileId()/*, false*/);
560 if (files != null) {
561 for (OCFile file : files) {
562 if (file.isFolder()) {
563 success &= removeLocalFolder(file);
564 } else {
565 if (file.isDown()) {
566 File localFile = new File(file.getStoragePath());
567 success &= localFile.delete();
568 if (success) {
569 // notify MediaScanner about removed file
570 deleteFileInMediaScan(file.getStoragePath());
571 file.setStoragePath(null);
572 saveFile(file);
573 }
574 }
575 }
576 }
577 }
578
579 // stage 2: remove the folder itself and any local file inside out of sync;
580 // for instance, after clearing the app cache or reinstalling
581 success &= removeLocalFolder(localFolder);
582 }
583 return success;
584 }
585
586 private boolean removeLocalFolder(File localFolder) {
587 boolean success = true;
588 File[] localFiles = localFolder.listFiles();
589 if (localFiles != null) {
590 for (File localFile : localFiles) {
591 if (localFile.isDirectory()) {
592 success &= removeLocalFolder(localFile);
593 } else {
594 String path = localFile.getAbsolutePath();
595 success &= localFile.delete();
596 }
597 }
598 }
599 success &= localFolder.delete();
600 return success;
601 }
602
603
604 /**
605 * Updates database and file system for a file or folder that was moved to a different location.
606 *
607 * TODO explore better (faster) implementations
608 * TODO throw exceptions up !
609 */
610 public void moveLocalFile(OCFile file, String targetPath, String targetParentPath) {
611
612 if (file != null && file.fileExists() && !OCFile.ROOT_PATH.equals(file.getFileName())) {
613
614 OCFile targetParent = getFileByPath(targetParentPath);
615 if (targetParent == null) {
616 throw new IllegalStateException("Parent folder of the target path does not exist!!");
617 }
618
619 /// 1. get all the descendants of the moved element in a single QUERY
620 Cursor c = null;
621 if (getContentProviderClient() != null) {
622 try {
623 c = getContentProviderClient().query(
624 ProviderTableMeta.CONTENT_URI,
625 null,
626 ProviderTableMeta.FILE_ACCOUNT_OWNER + "=? AND " +
627 ProviderTableMeta.FILE_PATH + " LIKE ? ",
628 new String[]{
629 mAccount.name,
630 file.getRemotePath() + "%"
631 },
632 ProviderTableMeta.FILE_PATH + " ASC "
633 );
634 } catch (RemoteException e) {
635 Log_OC.e(TAG, e.getMessage());
636 }
637
638 } else {
639 c = getContentResolver().query(
640 ProviderTableMeta.CONTENT_URI,
641 null,
642 ProviderTableMeta.FILE_ACCOUNT_OWNER + "=? AND " +
643 ProviderTableMeta.FILE_PATH + " LIKE ? ",
644 new String[]{
645 mAccount.name,
646 file.getRemotePath() + "%"
647 },
648 ProviderTableMeta.FILE_PATH + " ASC "
649 );
650 }
651
652 /// 2. prepare a batch of update operations to change all the descendants
653 ArrayList<ContentProviderOperation> operations =
654 new ArrayList<ContentProviderOperation>(c.getCount());
655 String defaultSavePath = FileStorageUtils.getSavePath(mAccount.name);
656 List<String> originalPathsToTriggerMediaScan = new ArrayList<String>();
657 List<String> newPathsToTriggerMediaScan = new ArrayList<String>();
658 if (c.moveToFirst()) {
659 int lengthOfOldPath = file.getRemotePath().length();
660 int lengthOfOldStoragePath = defaultSavePath.length() + lengthOfOldPath;
661 do {
662 ContentValues cv = new ContentValues(); // keep construction in the loop
663 OCFile child = createFileInstance(c);
664 cv.put(
665 ProviderTableMeta.FILE_PATH,
666 targetPath + child.getRemotePath().substring(lengthOfOldPath)
667 );
668 if (child.getStoragePath() != null &&
669 child.getStoragePath().startsWith(defaultSavePath)) {
670 // update link to downloaded content - but local move is not done here!
671 String targetLocalPath = defaultSavePath + targetPath +
672 child.getStoragePath().substring(lengthOfOldStoragePath);
673
674 cv.put(ProviderTableMeta.FILE_STORAGE_PATH, targetLocalPath);
675
676 originalPathsToTriggerMediaScan.add(child.getStoragePath());
677 newPathsToTriggerMediaScan.add(targetLocalPath);
678
679 }
680 if (child.getRemotePath().equals(file.getRemotePath())) {
681 cv.put(
682 ProviderTableMeta.FILE_PARENT,
683 targetParent.getFileId()
684 );
685 }
686 operations.add(
687 ContentProviderOperation.newUpdate(ProviderTableMeta.CONTENT_URI).
688 withValues(cv).
689 withSelection(
690 ProviderTableMeta._ID + "=?",
691 new String[]{String.valueOf(child.getFileId())}
692 )
693 .build());
694
695 } while (c.moveToNext());
696 }
697 c.close();
698
699 /// 3. apply updates in batch
700 try {
701 if (getContentResolver() != null) {
702 getContentResolver().applyBatch(MainApp.getAuthority(), operations);
703
704 } else {
705 getContentProviderClient().applyBatch(operations);
706 }
707
708 } catch (Exception e) {
709 Log_OC.e(TAG, "Fail to update " + file.getFileId() + " and descendants in database", e);
710 }
711
712 /// 4. move in local file system
713 String originalLocalPath = FileStorageUtils.getDefaultSavePathFor(mAccount.name, file);
714 String targetLocalPath = defaultSavePath + targetPath;
715 File localFile = new File(originalLocalPath);
716 boolean renamed = false;
717 if (localFile.exists()) {
718 File targetFile = new File(targetLocalPath);
719 File targetFolder = targetFile.getParentFile();
720 if (!targetFolder.exists()) {
721 targetFolder.mkdirs();
722 }
723 renamed = localFile.renameTo(targetFile);
724 }
725
726 if (renamed) {
727 Iterator<String> it = originalPathsToTriggerMediaScan.iterator();
728 while (it.hasNext()) {
729 // Notify MediaScanner about removed file
730 deleteFileInMediaScan(it.next());
731 }
732 it = newPathsToTriggerMediaScan.iterator();
733 while (it.hasNext()) {
734 // Notify MediaScanner about new file/folder
735 triggerMediaScan(it.next());
736 }
737 }
738 }
739
740 }
741
742 public void copyLocalFile(OCFile file, String targetPath) {
743
744 if (file != null && file.fileExists() && !OCFile.ROOT_PATH.equals(file.getFileName())) {
745 String localPath = FileStorageUtils.getDefaultSavePathFor(mAccount.name, file);
746 File localFile = new File(localPath);
747 boolean copied = false;
748 String defaultSavePath = FileStorageUtils.getSavePath(mAccount.name);
749 if (localFile.exists()) {
750 File targetFile = new File(defaultSavePath + targetPath);
751 File targetFolder = targetFile.getParentFile();
752 if (!targetFolder.exists()) {
753 targetFolder.mkdirs();
754 }
755 copied = copyFile(localFile, targetFile);
756 }
757 Log_OC.d(TAG, "Local file COPIED : " + copied);
758 }
759 }
760
761 private boolean copyFile(File src, File target) {
762 boolean ret = true;
763
764 InputStream in = null;
765 OutputStream out = null;
766
767 try {
768 in = new FileInputStream(src);
769 out = new FileOutputStream(target);
770 byte[] buf = new byte[1024];
771 int len;
772 while ((len = in.read(buf)) > 0) {
773 out.write(buf, 0, len);
774 }
775 } catch (IOException ex) {
776 ret = false;
777 } finally {
778 if (in != null) try {
779 in.close();
780 } catch (IOException e) {
781 e.printStackTrace(System.err);
782 }
783 if (out != null) try {
784 out.close();
785 } catch (IOException e) {
786 e.printStackTrace(System.err);
787 }
788 }
789
790 return ret;
791 }
792
793
794 private Vector<OCFile> getFolderContent(long parentId/*, boolean onlyOnDevice*/) {
795
796 Vector<OCFile> ret = new Vector<OCFile>();
797
798 Uri req_uri = Uri.withAppendedPath(
799 ProviderTableMeta.CONTENT_URI_DIR,
800 String.valueOf(parentId));
801 Cursor c = null;
802
803 if (getContentProviderClient() != null) {
804 try {
805 c = getContentProviderClient().query(req_uri, null,
806 ProviderTableMeta.FILE_PARENT + "=?",
807 new String[]{String.valueOf(parentId)}, null);
808 } catch (RemoteException e) {
809 Log_OC.e(TAG, e.getMessage());
810 return ret;
811 }
812 } else {
813 c = getContentResolver().query(req_uri, null,
814 ProviderTableMeta.FILE_PARENT + "=?",
815 new String[]{String.valueOf(parentId)}, null);
816 }
817
818 if (c.moveToFirst()) {
819 do {
820 OCFile child = createFileInstance(c);
821 // TODO Enable when "On Device" is recovered ?
822 // if (child.isFolder() || !onlyOnDevice || onlyOnDevice && child.isDown()){
823 ret.add(child);
824 // }
825 } while (c.moveToNext());
826 }
827
828 c.close();
829
830 Collections.sort(ret);
831
832 return ret;
833 }
834
835
836 private OCFile createRootDir() {
837 OCFile file = new OCFile(OCFile.ROOT_PATH);
838 file.setMimetype("DIR");
839 file.setParentId(FileDataStorageManager.ROOT_PARENT_ID);
840 saveFile(file);
841 return file;
842 }
843
844 private boolean fileExists(String cmp_key, String value) {
845 Cursor c;
846 if (getContentResolver() != null) {
847 c = getContentResolver()
848 .query(ProviderTableMeta.CONTENT_URI,
849 null,
850 cmp_key + "=? AND "
851 + ProviderTableMeta.FILE_ACCOUNT_OWNER
852 + "=?",
853 new String[]{value, mAccount.name}, null);
854 } else {
855 try {
856 c = getContentProviderClient().query(
857 ProviderTableMeta.CONTENT_URI,
858 null,
859 cmp_key + "=? AND "
860 + ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?",
861 new String[]{value, mAccount.name}, null);
862 } catch (RemoteException e) {
863 Log_OC.e(TAG,
864 "Couldn't determine file existance, assuming non existance: "
865 + e.getMessage());
866 return false;
867 }
868 }
869 boolean retval = c.moveToFirst();
870 c.close();
871 return retval;
872 }
873
874 private Cursor getCursorForValue(String key, String value) {
875 Cursor c = null;
876 if (getContentResolver() != null) {
877 c = getContentResolver()
878 .query(ProviderTableMeta.CONTENT_URI,
879 null,
880 key + "=? AND "
881 + ProviderTableMeta.FILE_ACCOUNT_OWNER
882 + "=?",
883 new String[]{value, mAccount.name}, null);
884 } else {
885 try {
886 c = getContentProviderClient().query(
887 ProviderTableMeta.CONTENT_URI,
888 null,
889 key + "=? AND " + ProviderTableMeta.FILE_ACCOUNT_OWNER
890 + "=?", new String[]{value, mAccount.name},
891 null);
892 } catch (RemoteException e) {
893 Log_OC.e(TAG, "Could not get file details: " + e.getMessage());
894 c = null;
895 }
896 }
897 return c;
898 }
899
900
901 private OCFile createFileInstance(Cursor c) {
902 OCFile file = null;
903 if (c != null) {
904 file = new OCFile(c.getString(c
905 .getColumnIndex(ProviderTableMeta.FILE_PATH)));
906 file.setFileId(c.getLong(c.getColumnIndex(ProviderTableMeta._ID)));
907 file.setParentId(c.getLong(c
908 .getColumnIndex(ProviderTableMeta.FILE_PARENT)));
909 file.setMimetype(c.getString(c
910 .getColumnIndex(ProviderTableMeta.FILE_CONTENT_TYPE)));
911 if (!file.isFolder()) {
912 file.setStoragePath(c.getString(c
913 .getColumnIndex(ProviderTableMeta.FILE_STORAGE_PATH)));
914 if (file.getStoragePath() == null) {
915 // try to find existing file and bind it with current account;
916 // with the current update of SynchronizeFolderOperation, this won't be
917 // necessary anymore after a full synchronization of the account
918 File f = new File(FileStorageUtils.getDefaultSavePathFor(mAccount.name, file));
919 if (f.exists()) {
920 file.setStoragePath(f.getAbsolutePath());
921 file.setLastSyncDateForData(f.lastModified());
922 }
923 }
924 }
925 file.setFileLength(c.getLong(c
926 .getColumnIndex(ProviderTableMeta.FILE_CONTENT_LENGTH)));
927 file.setCreationTimestamp(c.getLong(c
928 .getColumnIndex(ProviderTableMeta.FILE_CREATION)));
929 file.setModificationTimestamp(c.getLong(c
930 .getColumnIndex(ProviderTableMeta.FILE_MODIFIED)));
931 file.setModificationTimestampAtLastSyncForData(c.getLong(c
932 .getColumnIndex(ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA)));
933 file.setLastSyncDateForProperties(c.getLong(c
934 .getColumnIndex(ProviderTableMeta.FILE_LAST_SYNC_DATE)));
935 file.setLastSyncDateForData(c.getLong(c.
936 getColumnIndex(ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA)));
937 file.setFavorite(c.getInt(
938 c.getColumnIndex(ProviderTableMeta.FILE_KEEP_IN_SYNC)) == 1 ? true : false);
939 file.setEtag(c.getString(c.getColumnIndex(ProviderTableMeta.FILE_ETAG)));
940 file.setShareByLink(c.getInt(
941 c.getColumnIndex(ProviderTableMeta.FILE_SHARE_BY_LINK)) == 1 ? true : false);
942 file.setPublicLink(c.getString(c.getColumnIndex(ProviderTableMeta.FILE_PUBLIC_LINK)));
943 file.setPermissions(c.getString(c.getColumnIndex(ProviderTableMeta.FILE_PERMISSIONS)));
944 file.setRemoteId(c.getString(c.getColumnIndex(ProviderTableMeta.FILE_REMOTE_ID)));
945 file.setNeedsUpdateThumbnail(c.getInt(
946 c.getColumnIndex(ProviderTableMeta.FILE_UPDATE_THUMBNAIL)) == 1 ? true : false);
947 file.setDownloading(c.getInt(
948 c.getColumnIndex(ProviderTableMeta.FILE_IS_DOWNLOADING)) == 1 ? true : false);
949 file.setInConflict(c.getInt(
950 c.getColumnIndex(ProviderTableMeta.FILE_IN_CONFLICT)) == 1 ? true : false);
951
952 }
953 return file;
954 }
955
956 /**
957 * Returns if the file/folder is shared by link or not
958 *
959 * @param path Path of the file/folder
960 * @return
961 */
962 public boolean isShareByLink(String path) {
963 Cursor c = getCursorForValue(ProviderTableMeta.FILE_STORAGE_PATH, path);
964 OCFile file = null;
965 if (c.moveToFirst()) {
966 file = createFileInstance(c);
967 }
968 c.close();
969 return file.isShareByLink();
970 }
971
972 /**
973 * Returns the public link of the file/folder
974 *
975 * @param path Path of the file/folder
976 * @return
977 */
978 public String getPublicLink(String path) {
979 Cursor c = getCursorForValue(ProviderTableMeta.FILE_STORAGE_PATH, path);
980 OCFile file = null;
981 if (c.moveToFirst()) {
982 file = createFileInstance(c);
983 }
984 c.close();
985 return file.getPublicLink();
986 }
987
988
989 // Methods for Shares
990 public boolean saveShare(OCShare share) {
991 boolean overriden = false;
992 ContentValues cv = new ContentValues();
993 cv.put(ProviderTableMeta.OCSHARES_FILE_SOURCE, share.getFileSource());
994 cv.put(ProviderTableMeta.OCSHARES_ITEM_SOURCE, share.getItemSource());
995 cv.put(ProviderTableMeta.OCSHARES_SHARE_TYPE, share.getShareType().getValue());
996 cv.put(ProviderTableMeta.OCSHARES_SHARE_WITH, share.getShareWith());
997 cv.put(ProviderTableMeta.OCSHARES_PATH, share.getPath());
998 cv.put(ProviderTableMeta.OCSHARES_PERMISSIONS, share.getPermissions());
999 cv.put(ProviderTableMeta.OCSHARES_SHARED_DATE, share.getSharedDate());
1000 cv.put(ProviderTableMeta.OCSHARES_EXPIRATION_DATE, share.getExpirationDate());
1001 cv.put(ProviderTableMeta.OCSHARES_TOKEN, share.getToken());
1002 cv.put(
1003 ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME,
1004 share.getSharedWithDisplayName()
1005 );
1006 cv.put(ProviderTableMeta.OCSHARES_IS_DIRECTORY, share.isFolder() ? 1 : 0);
1007 cv.put(ProviderTableMeta.OCSHARES_USER_ID, share.getUserId());
1008 cv.put(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED, share.getIdRemoteShared());
1009 cv.put(ProviderTableMeta.OCSHARES_ACCOUNT_OWNER, mAccount.name);
1010
1011 if (shareExists(share.getIdRemoteShared())) { // for renamed files; no more delete and create
1012 overriden = true;
1013 if (getContentResolver() != null) {
1014 getContentResolver().update(ProviderTableMeta.CONTENT_URI_SHARE, cv,
1015 ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED + "=?",
1016 new String[]{String.valueOf(share.getIdRemoteShared())});
1017 } else {
1018 try {
1019 getContentProviderClient().update(ProviderTableMeta.CONTENT_URI_SHARE,
1020 cv, ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED + "=?",
1021 new String[]{String.valueOf(share.getIdRemoteShared())});
1022 } catch (RemoteException e) {
1023 Log_OC.e(TAG,
1024 "Fail to insert insert file to database "
1025 + e.getMessage());
1026 }
1027 }
1028 } else {
1029 Uri result_uri = null;
1030 if (getContentResolver() != null) {
1031 result_uri = getContentResolver().insert(
1032 ProviderTableMeta.CONTENT_URI_SHARE, cv);
1033 } else {
1034 try {
1035 result_uri = getContentProviderClient().insert(
1036 ProviderTableMeta.CONTENT_URI_SHARE, cv);
1037 } catch (RemoteException e) {
1038 Log_OC.e(TAG,
1039 "Fail to insert insert file to database "
1040 + e.getMessage());
1041 }
1042 }
1043 if (result_uri != null) {
1044 long new_id = Long.parseLong(result_uri.getPathSegments()
1045 .get(1));
1046 share.setId(new_id);
1047 }
1048 }
1049
1050 return overriden;
1051 }
1052
1053
1054 public OCShare getFirstShareByPathAndType(String path, ShareType type) {
1055 Cursor c = null;
1056 if (getContentResolver() != null) {
1057 c = getContentResolver().query(
1058 ProviderTableMeta.CONTENT_URI_SHARE,
1059 null,
1060 ProviderTableMeta.OCSHARES_PATH + "=? AND "
1061 + ProviderTableMeta.OCSHARES_SHARE_TYPE + "=? AND "
1062 + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?",
1063 new String[]{path, Integer.toString(type.getValue()), mAccount.name},
1064 null);
1065 } else {
1066 try {
1067 c = getContentProviderClient().query(
1068 ProviderTableMeta.CONTENT_URI_SHARE,
1069 null,
1070 ProviderTableMeta.OCSHARES_PATH + "=? AND "
1071 + ProviderTableMeta.OCSHARES_SHARE_TYPE + "=? AND "
1072 + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?",
1073 new String[]{path, Integer.toString(type.getValue()), mAccount.name},
1074 null);
1075
1076 } catch (RemoteException e) {
1077 Log_OC.e(TAG, "Could not get file details: " + e.getMessage());
1078 c = null;
1079 }
1080 }
1081 OCShare share = null;
1082 if (c.moveToFirst()) {
1083 share = createShareInstance(c);
1084 }
1085 c.close();
1086 return share;
1087 }
1088
1089 private OCShare createShareInstance(Cursor c) {
1090 OCShare share = null;
1091 if (c != null) {
1092 share = new OCShare(c.getString(c
1093 .getColumnIndex(ProviderTableMeta.OCSHARES_PATH)));
1094 share.setId(c.getLong(c.getColumnIndex(ProviderTableMeta._ID)));
1095 share.setFileSource(c.getLong(c
1096 .getColumnIndex(ProviderTableMeta.OCSHARES_ITEM_SOURCE)));
1097 share.setShareType(ShareType.fromValue(c.getInt(c
1098 .getColumnIndex(ProviderTableMeta.OCSHARES_SHARE_TYPE))));
1099 share.setPermissions(c.getInt(c
1100 .getColumnIndex(ProviderTableMeta.OCSHARES_PERMISSIONS)));
1101 share.setSharedDate(c.getLong(c
1102 .getColumnIndex(ProviderTableMeta.OCSHARES_SHARED_DATE)));
1103 share.setExpirationDate(c.getLong(c
1104 .getColumnIndex(ProviderTableMeta.OCSHARES_EXPIRATION_DATE)));
1105 share.setToken(c.getString(c
1106 .getColumnIndex(ProviderTableMeta.OCSHARES_TOKEN)));
1107 share.setSharedWithDisplayName(c.getString(c
1108 .getColumnIndex(ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME)));
1109 share.setIsFolder(c.getInt(
1110 c.getColumnIndex(ProviderTableMeta.OCSHARES_IS_DIRECTORY)) == 1);
1111 share.setUserId(c.getLong(c.getColumnIndex(ProviderTableMeta.OCSHARES_USER_ID)));
1112 share.setIdRemoteShared(c.getLong(c.getColumnIndex(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED)));
1113 }
1114 return share;
1115 }
1116
1117 private boolean shareExists(String cmp_key, String value) {
1118 Cursor c;
1119 if (getContentResolver() != null) {
1120 c = getContentResolver()
1121 .query(ProviderTableMeta.CONTENT_URI_SHARE,
1122 null,
1123 cmp_key + "=? AND "
1124 + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER
1125 + "=?",
1126 new String[]{value, mAccount.name}, null);
1127 } else {
1128 try {
1129 c = getContentProviderClient().query(
1130 ProviderTableMeta.CONTENT_URI_SHARE,
1131 null,
1132 cmp_key + "=? AND "
1133 + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?",
1134 new String[]{value, mAccount.name}, null);
1135 } catch (RemoteException e) {
1136 Log_OC.e(TAG,
1137 "Couldn't determine file existance, assuming non existance: "
1138 + e.getMessage());
1139 return false;
1140 }
1141 }
1142 boolean retval = c.moveToFirst();
1143 c.close();
1144 return retval;
1145 }
1146
1147 private boolean shareExists(long remoteId) {
1148 return shareExists(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED, String.valueOf(remoteId));
1149 }
1150
1151 private void cleanSharedFiles() {
1152 ContentValues cv = new ContentValues();
1153 cv.put(ProviderTableMeta.FILE_SHARE_BY_LINK, false);
1154 cv.put(ProviderTableMeta.FILE_PUBLIC_LINK, "");
1155 String where = ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?";
1156 String[] whereArgs = new String[]{mAccount.name};
1157
1158 if (getContentResolver() != null) {
1159 getContentResolver().update(ProviderTableMeta.CONTENT_URI, cv, where, whereArgs);
1160
1161 } else {
1162 try {
1163 getContentProviderClient().update(ProviderTableMeta.CONTENT_URI, cv, where, whereArgs);
1164 } catch (RemoteException e) {
1165 Log_OC.e(TAG, "Exception in cleanSharedFiles" + e.getMessage());
1166 }
1167 }
1168 }
1169
1170 private void cleanSharedFilesInFolder(OCFile folder) {
1171 ContentValues cv = new ContentValues();
1172 cv.put(ProviderTableMeta.FILE_SHARE_BY_LINK, false);
1173 cv.put(ProviderTableMeta.FILE_PUBLIC_LINK, "");
1174 String where = ProviderTableMeta.FILE_ACCOUNT_OWNER + "=? AND " +
1175 ProviderTableMeta.FILE_PARENT + "=?";
1176 String [] whereArgs = new String[] { mAccount.name , String.valueOf(folder.getFileId()) };
1177
1178 if (getContentResolver() != null) {
1179 getContentResolver().update(ProviderTableMeta.CONTENT_URI, cv, where, whereArgs);
1180
1181 } else {
1182 try {
1183 getContentProviderClient().update(ProviderTableMeta.CONTENT_URI, cv, where, whereArgs);
1184 } catch (RemoteException e) {
1185 Log_OC.e(TAG, "Exception in cleanSharedFilesInFolder " + e.getMessage());
1186 }
1187 }
1188 }
1189
1190 private void cleanShares() {
1191 String where = ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?";
1192 String[] whereArgs = new String[]{mAccount.name};
1193
1194 if (getContentResolver() != null) {
1195 getContentResolver().delete(ProviderTableMeta.CONTENT_URI_SHARE, where, whereArgs);
1196
1197 } else {
1198 try {
1199 getContentProviderClient().delete(ProviderTableMeta.CONTENT_URI_SHARE, where, whereArgs);
1200 } catch (RemoteException e) {
1201 Log_OC.e(TAG, "Exception in cleanShares" + e.getMessage());
1202 }
1203 }
1204 }
1205
1206 public void saveShares(Collection<OCShare> shares) {
1207 cleanShares();
1208 if (shares != null) {
1209 ArrayList<ContentProviderOperation> operations =
1210 new ArrayList<ContentProviderOperation>(shares.size());
1211
1212 // prepare operations to insert or update files to save in the given folder
1213 for (OCShare share : shares) {
1214 ContentValues cv = new ContentValues();
1215 cv.put(ProviderTableMeta.OCSHARES_FILE_SOURCE, share.getFileSource());
1216 cv.put(ProviderTableMeta.OCSHARES_ITEM_SOURCE, share.getItemSource());
1217 cv.put(ProviderTableMeta.OCSHARES_SHARE_TYPE, share.getShareType().getValue());
1218 cv.put(ProviderTableMeta.OCSHARES_SHARE_WITH, share.getShareWith());
1219 cv.put(ProviderTableMeta.OCSHARES_PATH, share.getPath());
1220 cv.put(ProviderTableMeta.OCSHARES_PERMISSIONS, share.getPermissions());
1221 cv.put(ProviderTableMeta.OCSHARES_SHARED_DATE, share.getSharedDate());
1222 cv.put(ProviderTableMeta.OCSHARES_EXPIRATION_DATE, share.getExpirationDate());
1223 cv.put(ProviderTableMeta.OCSHARES_TOKEN, share.getToken());
1224 cv.put(
1225 ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME,
1226 share.getSharedWithDisplayName()
1227 );
1228 cv.put(ProviderTableMeta.OCSHARES_IS_DIRECTORY, share.isFolder() ? 1 : 0);
1229 cv.put(ProviderTableMeta.OCSHARES_USER_ID, share.getUserId());
1230 cv.put(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED, share.getIdRemoteShared());
1231 cv.put(ProviderTableMeta.OCSHARES_ACCOUNT_OWNER, mAccount.name);
1232
1233 if (shareExists(share.getIdRemoteShared())) {
1234 // updating an existing file
1235 operations.add(
1236 ContentProviderOperation.newUpdate(ProviderTableMeta.CONTENT_URI_SHARE).
1237 withValues(cv).
1238 withSelection(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED + "=?",
1239 new String[]{String.valueOf(share.getIdRemoteShared())})
1240 .build());
1241 } else {
1242 // adding a new file
1243 operations.add(
1244 ContentProviderOperation.newInsert(ProviderTableMeta.CONTENT_URI_SHARE).
1245 withValues(cv).
1246 build()
1247 );
1248 }
1249 }
1250
1251 // apply operations in batch
1252 if (operations.size() > 0) {
1253 @SuppressWarnings("unused")
1254 ContentProviderResult[] results = null;
1255 Log_OC.d(TAG, "Sending " + operations.size() +
1256 " operations to FileContentProvider");
1257 try {
1258 if (getContentResolver() != null) {
1259 results = getContentResolver().applyBatch(MainApp.getAuthority(), operations);
1260 } else {
1261 results = getContentProviderClient().applyBatch(operations);
1262 }
1263
1264 } catch (OperationApplicationException e) {
1265 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1266
1267 } catch (RemoteException e) {
1268 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1269 }
1270 }
1271 }
1272
1273 }
1274
1275 public void updateSharedFiles(Collection<OCFile> sharedFiles) {
1276 cleanSharedFiles();
1277
1278 if (sharedFiles != null) {
1279 ArrayList<ContentProviderOperation> operations =
1280 new ArrayList<ContentProviderOperation>(sharedFiles.size());
1281
1282 // prepare operations to insert or update files to save in the given folder
1283 for (OCFile file : sharedFiles) {
1284 ContentValues cv = new ContentValues();
1285 cv.put(ProviderTableMeta.FILE_MODIFIED, file.getModificationTimestamp());
1286 cv.put(
1287 ProviderTableMeta.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA,
1288 file.getModificationTimestampAtLastSyncForData()
1289 );
1290 cv.put(ProviderTableMeta.FILE_CREATION, file.getCreationTimestamp());
1291 cv.put(ProviderTableMeta.FILE_CONTENT_LENGTH, file.getFileLength());
1292 cv.put(ProviderTableMeta.FILE_CONTENT_TYPE, file.getMimetype());
1293 cv.put(ProviderTableMeta.FILE_NAME, file.getFileName());
1294 cv.put(ProviderTableMeta.FILE_PARENT, file.getParentId());
1295 cv.put(ProviderTableMeta.FILE_PATH, file.getRemotePath());
1296 if (!file.isFolder()) {
1297 cv.put(ProviderTableMeta.FILE_STORAGE_PATH, file.getStoragePath());
1298 }
1299 cv.put(ProviderTableMeta.FILE_ACCOUNT_OWNER, mAccount.name);
1300 cv.put(ProviderTableMeta.FILE_LAST_SYNC_DATE, file.getLastSyncDateForProperties());
1301 cv.put(
1302 ProviderTableMeta.FILE_LAST_SYNC_DATE_FOR_DATA,
1303 file.getLastSyncDateForData()
1304 );
1305 cv.put(ProviderTableMeta.FILE_KEEP_IN_SYNC, file.isFavorite() ? 1 : 0);
1306 cv.put(ProviderTableMeta.FILE_ETAG, file.getEtag());
1307 cv.put(ProviderTableMeta.FILE_SHARE_BY_LINK, file.isShareByLink() ? 1 : 0);
1308 cv.put(ProviderTableMeta.FILE_PUBLIC_LINK, file.getPublicLink());
1309 cv.put(ProviderTableMeta.FILE_PERMISSIONS, file.getPermissions());
1310 cv.put(ProviderTableMeta.FILE_REMOTE_ID, file.getRemoteId());
1311 cv.put(
1312 ProviderTableMeta.FILE_UPDATE_THUMBNAIL,
1313 file.needsUpdateThumbnail() ? 1 : 0
1314 );
1315 cv.put(
1316 ProviderTableMeta.FILE_IS_DOWNLOADING,
1317 file.isDownloading() ? 1 : 0
1318 );
1319 cv.put(
1320 ProviderTableMeta.FILE_IN_CONFLICT,
1321 file.isInConflict() ? 1 : 0
1322 );
1323
1324 boolean existsByPath = fileExists(file.getRemotePath());
1325 if (existsByPath || fileExists(file.getFileId())) {
1326 // updating an existing file
1327 operations.add(
1328 ContentProviderOperation.newUpdate(ProviderTableMeta.CONTENT_URI).
1329 withValues(cv).
1330 withSelection(ProviderTableMeta._ID + "=?",
1331 new String[]{String.valueOf(file.getFileId())})
1332 .build());
1333
1334 } else {
1335 // adding a new file
1336 operations.add(
1337 ContentProviderOperation.newInsert(ProviderTableMeta.CONTENT_URI).
1338 withValues(cv).
1339 build()
1340 );
1341 }
1342 }
1343
1344 // apply operations in batch
1345 if (operations.size() > 0) {
1346 @SuppressWarnings("unused")
1347 ContentProviderResult[] results = null;
1348 Log_OC.d(TAG, "Sending " + operations.size() +
1349 " operations to FileContentProvider");
1350 try {
1351 if (getContentResolver() != null) {
1352 results = getContentResolver().applyBatch(MainApp.getAuthority(), operations);
1353 } else {
1354 results = getContentProviderClient().applyBatch(operations);
1355 }
1356
1357 } catch (OperationApplicationException e) {
1358 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1359
1360 } catch (RemoteException e) {
1361 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1362 }
1363 }
1364 }
1365
1366 }
1367
1368 public void removeShare(OCShare share) {
1369 Uri share_uri = ProviderTableMeta.CONTENT_URI_SHARE;
1370 String where = ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?" + " AND " +
1371 ProviderTableMeta.FILE_PATH + "=?";
1372 String [] whereArgs = new String[]{mAccount.name, share.getPath()};
1373 if (getContentProviderClient() != null) {
1374 try {
1375 getContentProviderClient().delete(share_uri, where, whereArgs);
1376 } catch (RemoteException e) {
1377 e.printStackTrace();
1378 }
1379 } else {
1380 getContentResolver().delete(share_uri, where, whereArgs);
1381 }
1382 }
1383
1384 public void saveSharesDB(ArrayList<OCShare> shares) {
1385 saveShares(shares);
1386
1387 ArrayList<OCFile> sharedFiles = new ArrayList<OCFile>();
1388
1389 for (OCShare share : shares) {
1390 // Get the path
1391 String path = share.getPath();
1392 if (share.isFolder()) {
1393 path = path + FileUtils.PATH_SEPARATOR;
1394 }
1395
1396 // Update OCFile with data from share: ShareByLink and publicLink
1397 OCFile file = getFileByPath(path);
1398 if (file != null) {
1399 if (share.getShareType().equals(ShareType.PUBLIC_LINK)) {
1400 file.setShareByLink(true);
1401 sharedFiles.add(file);
1402 }
1403 }
1404 }
1405
1406 updateSharedFiles(sharedFiles);
1407 }
1408
1409
1410 public void saveSharesInFolder(ArrayList<OCShare> shares, OCFile folder) {
1411 cleanSharedFilesInFolder(folder);
1412 ArrayList<ContentProviderOperation> operations = new ArrayList<ContentProviderOperation>();
1413 operations = prepareRemoveSharesInFolder(folder, operations);
1414
1415 if (shares != null) {
1416 // prepare operations to insert or update files to save in the given folder
1417 for (OCShare share : shares) {
1418 ContentValues cv = new ContentValues();
1419 cv.put(ProviderTableMeta.OCSHARES_FILE_SOURCE, share.getFileSource());
1420 cv.put(ProviderTableMeta.OCSHARES_ITEM_SOURCE, share.getItemSource());
1421 cv.put(ProviderTableMeta.OCSHARES_SHARE_TYPE, share.getShareType().getValue());
1422 cv.put(ProviderTableMeta.OCSHARES_SHARE_WITH, share.getShareWith());
1423 cv.put(ProviderTableMeta.OCSHARES_PATH, share.getPath());
1424 cv.put(ProviderTableMeta.OCSHARES_PERMISSIONS, share.getPermissions());
1425 cv.put(ProviderTableMeta.OCSHARES_SHARED_DATE, share.getSharedDate());
1426 cv.put(ProviderTableMeta.OCSHARES_EXPIRATION_DATE, share.getExpirationDate());
1427 cv.put(ProviderTableMeta.OCSHARES_TOKEN, share.getToken());
1428 cv.put(
1429 ProviderTableMeta.OCSHARES_SHARE_WITH_DISPLAY_NAME,
1430 share.getSharedWithDisplayName()
1431 );
1432 cv.put(ProviderTableMeta.OCSHARES_IS_DIRECTORY, share.isFolder() ? 1 : 0);
1433 cv.put(ProviderTableMeta.OCSHARES_USER_ID, share.getUserId());
1434 cv.put(ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED, share.getIdRemoteShared());
1435 cv.put(ProviderTableMeta.OCSHARES_ACCOUNT_OWNER, mAccount.name);
1436
1437 /*
1438 if (shareExists(share.getIdRemoteShared())) {
1439 // updating an existing share resource
1440 operations.add(
1441 ContentProviderOperation.newUpdate(ProviderTableMeta.CONTENT_URI_SHARE).
1442 withValues(cv).
1443 withSelection( ProviderTableMeta.OCSHARES_ID_REMOTE_SHARED + "=?",
1444 new String[] { String.valueOf(share.getIdRemoteShared()) })
1445 .build());
1446
1447 } else {
1448 */
1449 // adding a new share resource
1450 operations.add(
1451 ContentProviderOperation.newInsert(ProviderTableMeta.CONTENT_URI_SHARE).
1452 withValues(cv).
1453 build()
1454 );
1455 //}
1456 }
1457 }
1458
1459 // apply operations in batch
1460 if (operations.size() > 0) {
1461 @SuppressWarnings("unused")
1462 ContentProviderResult[] results = null;
1463 Log_OC.d(TAG, "Sending " + operations.size() + " operations to FileContentProvider");
1464 try {
1465 if (getContentResolver() != null) {
1466 results = getContentResolver().applyBatch(MainApp.getAuthority(), operations);
1467
1468 } else {
1469 results = getContentProviderClient().applyBatch(operations);
1470 }
1471
1472 } catch (OperationApplicationException e) {
1473 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1474
1475 } catch (RemoteException e) {
1476 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1477 }
1478 }
1479 //}
1480
1481 }
1482
1483 private ArrayList<ContentProviderOperation> prepareRemoveSharesInFolder(
1484 OCFile folder, ArrayList<ContentProviderOperation> preparedOperations) {
1485 if (folder != null) {
1486 String where = ProviderTableMeta.OCSHARES_PATH + "=?" + " AND "
1487 + ProviderTableMeta.OCSHARES_ACCOUNT_OWNER + "=?";
1488 String [] whereArgs = new String[]{ "", mAccount.name };
1489
1490 // TODO Enable when "On Device" is recovered ?
1491 Vector<OCFile> files = getFolderContent(folder /*, false*/);
1492
1493 for (OCFile file : files) {
1494 whereArgs[0] = file.getRemotePath();
1495 preparedOperations.add(
1496 ContentProviderOperation.newDelete(ProviderTableMeta.CONTENT_URI_SHARE).
1497 withSelection(where, whereArgs).
1498 build()
1499 );
1500 }
1501 }
1502 return preparedOperations;
1503
1504 /*
1505 if (operations.size() > 0) {
1506 try {
1507 if (getContentResolver() != null) {
1508 getContentResolver().applyBatch(MainApp.getAuthority(), operations);
1509
1510 } else {
1511 getContentProviderClient().applyBatch(operations);
1512 }
1513
1514 } catch (OperationApplicationException e) {
1515 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1516
1517 } catch (RemoteException e) {
1518 Log_OC.e(TAG, "Exception in batch of operations " + e.getMessage());
1519 }
1520 }
1521 */
1522
1523 /*
1524 if (getContentResolver() != null) {
1525
1526 getContentResolver().delete(ProviderTableMeta.CONTENT_URI_SHARE,
1527 where,
1528 whereArgs);
1529 } else {
1530 try {
1531 getContentProviderClient().delete( ProviderTableMeta.CONTENT_URI_SHARE,
1532 where,
1533 whereArgs);
1534
1535 } catch (RemoteException e) {
1536 Log_OC.e(TAG, "Exception deleting shares in a folder " + e.getMessage());
1537 }
1538 }
1539 */
1540 //}
1541 }
1542
1543 public void triggerMediaScan(String path) {
1544 Intent intent = new Intent(Intent.ACTION_MEDIA_SCANNER_SCAN_FILE);
1545 intent.setData(Uri.fromFile(new File(path)));
1546 MainApp.getAppContext().sendBroadcast(intent);
1547 }
1548
1549 public void deleteFileInMediaScan(String path) {
1550
1551 String mimetypeString = FileStorageUtils.getMimeTypeFromName(path);
1552 ContentResolver contentResolver = getContentResolver();
1553
1554 if (contentResolver != null) {
1555 if (mimetypeString.startsWith("image/")) {
1556 // Images
1557 contentResolver.delete(MediaStore.Images.Media.EXTERNAL_CONTENT_URI,
1558 MediaStore.Images.Media.DATA + "=?", new String[]{path});
1559 } else if (mimetypeString.startsWith("audio/")) {
1560 // Audio
1561 contentResolver.delete(MediaStore.Audio.Media.EXTERNAL_CONTENT_URI,
1562 MediaStore.Audio.Media.DATA + "=?", new String[]{path});
1563 } else if (mimetypeString.startsWith("video/")) {
1564 // Video
1565 contentResolver.delete(MediaStore.Video.Media.EXTERNAL_CONTENT_URI,
1566 MediaStore.Video.Media.DATA + "=?", new String[]{path});
1567 }
1568 } else {
1569 ContentProviderClient contentProviderClient = getContentProviderClient();
1570 try {
1571 if (mimetypeString.startsWith("image/")) {
1572 // Images
1573 contentProviderClient.delete(MediaStore.Images.Media.EXTERNAL_CONTENT_URI,
1574 MediaStore.Images.Media.DATA + "=?", new String[]{path});
1575 } else if (mimetypeString.startsWith("audio/")) {
1576 // Audio
1577 contentProviderClient.delete(MediaStore.Audio.Media.EXTERNAL_CONTENT_URI,
1578 MediaStore.Audio.Media.DATA + "=?", new String[]{path});
1579 } else if (mimetypeString.startsWith("video/")) {
1580 // Video
1581 contentProviderClient.delete(MediaStore.Video.Media.EXTERNAL_CONTENT_URI,
1582 MediaStore.Video.Media.DATA + "=?", new String[]{path});
1583 }
1584 } catch (RemoteException e) {
1585 Log_OC.e(TAG, "Exception deleting media file in MediaStore " + e.getMessage());
1586 }
1587 }
1588
1589 }
1590
1591 public void saveConflict(OCFile file, boolean inConflict) {
1592 ContentValues cv = new ContentValues();
1593 cv.put(ProviderTableMeta.FILE_IN_CONFLICT, inConflict);
1594 int updated = 0;
1595 if (getContentResolver() != null) {
1596 updated = getContentResolver().update(
1597 ProviderTableMeta.CONTENT_URI_FILE,
1598 cv,
1599 ProviderTableMeta._ID + "=?",
1600 new String[] { String.valueOf(file.getFileId())}
1601 );
1602 } else {
1603 try {
1604 updated = getContentProviderClient().update(
1605 ProviderTableMeta.CONTENT_URI_FILE,
1606 cv,
1607 ProviderTableMeta._ID + "=?",
1608 new String[]{String.valueOf(file.getFileId())}
1609 );
1610 } catch (RemoteException e) {
1611 Log_OC.e(TAG, "Failed saving conflict in database " + e.getMessage());
1612 }
1613 }
1614
1615 Log_OC.d(TAG, "Number of files updated with CONFLICT: " + updated);
1616
1617 if (updated > 0) {
1618 if (inConflict) {
1619 /// set conflict in all ancestor folders
1620
1621 long parentId = file.getParentId();
1622 Set<String> ancestorIds = new HashSet<String>();
1623 while (parentId != FileDataStorageManager.ROOT_PARENT_ID) {
1624 ancestorIds.add(Long.toString(parentId));
1625 parentId = getFileById(parentId).getParentId();
1626 }
1627
1628 if (ancestorIds.size() > 0) {
1629 StringBuffer whereBuffer = new StringBuffer();
1630 whereBuffer.append(ProviderTableMeta._ID).append(" IN (");
1631 for (int i = 0; i < ancestorIds.size() - 1; i++) {
1632 whereBuffer.append("?,");
1633 }
1634 whereBuffer.append("?");
1635 whereBuffer.append(")");
1636
1637 if (getContentResolver() != null) {
1638 updated = getContentResolver().update(
1639 ProviderTableMeta.CONTENT_URI_FILE,
1640 cv,
1641 whereBuffer.toString(),
1642 ancestorIds.toArray(new String[]{})
1643 );
1644 } else {
1645 try {
1646 updated = getContentProviderClient().update(
1647 ProviderTableMeta.CONTENT_URI_FILE,
1648 cv,
1649 whereBuffer.toString(),
1650 ancestorIds.toArray(new String[]{})
1651 );
1652 } catch (RemoteException e) {
1653 Log_OC.e(TAG, "Failed saving conflict in database " + e.getMessage());
1654 }
1655 }
1656 } // else file is ROOT folder, no parent to set in conflict
1657
1658 } else {
1659 /// TODO update conflict in ancestor folders
1660 // (not directly unset; maybe there are more conflicts below them)
1661 }
1662 }
1663
1664 Log_OC.d(TAG, "Number of parents updated with CONFLICT: " + updated);
1665
1666 }
1667 }