2 * ownCloud Android client application
4 * Copyright (C) 2012 Bartek Przybylski
5 * Copyright (C) 2015 ownCloud Inc.
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.
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.
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/>.
21 package com
.owncloud
.android
.datamodel
;
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
;
31 import java
.util
.Vector
;
33 import android
.accounts
.Account
;
34 import android
.content
.ContentProvider
;
35 import android
.content
.ContentProviderClient
;
36 import android
.content
.ContentProviderOperation
;
37 import android
.content
.ContentProviderResult
;
38 import android
.content
.ContentResolver
;
39 import android
.content
.ContentUris
;
40 import android
.content
.ContentValues
;
41 import android
.content
.Intent
;
42 import android
.content
.OperationApplicationException
;
43 import android
.database
.Cursor
;
44 import android
.net
.Uri
;
45 import android
.os
.RemoteException
;
46 import android
.provider
.MediaStore
;
48 import com
.owncloud
.android
.MainApp
;
49 import com
.owncloud
.android
.db
.ProviderMeta
.ProviderTableMeta
;
50 import com
.owncloud
.android
.lib
.common
.utils
.Log_OC
;
51 import com
.owncloud
.android
.lib
.resources
.files
.FileUtils
;
52 import com
.owncloud
.android
.lib
.resources
.shares
.OCShare
;
53 import com
.owncloud
.android
.lib
.resources
.shares
.ShareType
;
54 import com
.owncloud
.android
.utils
.FileStorageUtils
;
56 import java
.io
.FileInputStream
;
57 import java
.io
.FileOutputStream
;
58 import java
.io
.IOException
;
59 import java
.io
.InputStream
;
60 import java
.io
.OutputStream
;
62 public class FileDataStorageManager
{
64 public static final int ROOT_PARENT_ID
= 0;
66 private ContentResolver mContentResolver
;
67 private ContentProviderClient mContentProviderClient
;
68 private Account mAccount
;
70 private static String TAG
= FileDataStorageManager
.class.getSimpleName();
73 public FileDataStorageManager(Account account
, ContentResolver cr
) {
74 mContentProviderClient
= null
;
75 mContentResolver
= cr
;
79 public FileDataStorageManager(Account account
, ContentProviderClient cp
) {
80 mContentProviderClient
= cp
;
81 mContentResolver
= null
;
86 public void setAccount(Account account
) {
90 public Account
getAccount() {
94 public ContentResolver
getContentResolver() {
95 return mContentResolver
;
98 public ContentProviderClient
getContentProviderClient() {
99 return mContentProviderClient
;
103 public OCFile
getFileByPath(String path
) {
104 Cursor c
= getCursorForValue(ProviderTableMeta
.FILE_PATH
, path
);
106 if (c
.moveToFirst()) {
107 file
= createFileInstance(c
);
110 if (file
== null
&& OCFile
.ROOT_PATH
.equals(path
)) {
111 return createRootDir(); // root should always exist
117 public OCFile
getFileById(long id
) {
118 Cursor c
= getCursorForValue(ProviderTableMeta
._ID
, String
.valueOf(id
));
120 if (c
.moveToFirst()) {
121 file
= createFileInstance(c
);
127 public OCFile
getFileByLocalPath(String path
) {
128 Cursor c
= getCursorForValue(ProviderTableMeta
.FILE_STORAGE_PATH
, path
);
130 if (c
.moveToFirst()) {
131 file
= createFileInstance(c
);
137 public boolean fileExists(long id
) {
138 return fileExists(ProviderTableMeta
._ID
, String
.valueOf(id
));
141 public boolean fileExists(String path
) {
142 return fileExists(ProviderTableMeta
.FILE_PATH
, path
);
146 public Vector
<OCFile
> getFolderContent(OCFile f
/*, boolean onlyOnDevice*/) {
147 if (f
!= null
&& f
.isFolder() && f
.getFileId() != -1) {
148 // TODO Enable when "On Device" is recovered ?
149 return getFolderContent(f
.getFileId()/*, onlyOnDevice*/);
152 return new Vector
<OCFile
>();
157 public Vector
<OCFile
> getFolderImages(OCFile folder
/*, boolean onlyOnDevice*/) {
158 Vector
<OCFile
> ret
= new Vector
<OCFile
>();
159 if (folder
!= null
) {
160 // TODO better implementation, filtering in the access to database instead of here
161 // TODO Enable when "On Device" is recovered ?
162 Vector
<OCFile
> tmp
= getFolderContent(folder
/*, onlyOnDevice*/);
163 OCFile current
= null
;
164 for (int i
=0; i
<tmp
.size(); i
++) {
165 current
= tmp
.get(i
);
166 if (current
.isImage()) {
174 public boolean saveFile(OCFile file
) {
175 boolean overriden
= false
;
176 ContentValues cv
= new ContentValues();
177 cv
.put(ProviderTableMeta
.FILE_MODIFIED
, file
.getModificationTimestamp());
179 ProviderTableMeta
.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA
,
180 file
.getModificationTimestampAtLastSyncForData()
182 cv
.put(ProviderTableMeta
.FILE_CREATION
, file
.getCreationTimestamp());
183 cv
.put(ProviderTableMeta
.FILE_CONTENT_LENGTH
, file
.getFileLength());
184 cv
.put(ProviderTableMeta
.FILE_CONTENT_TYPE
, file
.getMimetype());
185 cv
.put(ProviderTableMeta
.FILE_NAME
, file
.getFileName());
186 cv
.put(ProviderTableMeta
.FILE_PARENT
, file
.getParentId());
187 cv
.put(ProviderTableMeta
.FILE_PATH
, file
.getRemotePath());
188 if (!file
.isFolder())
189 cv
.put(ProviderTableMeta
.FILE_STORAGE_PATH
, file
.getStoragePath());
190 cv
.put(ProviderTableMeta
.FILE_ACCOUNT_OWNER
, mAccount
.name
);
191 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE
, file
.getLastSyncDateForProperties());
192 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE_FOR_DATA
, file
.getLastSyncDateForData());
193 cv
.put(ProviderTableMeta
.FILE_KEEP_IN_SYNC
, file
.isFavorite() ?
1 : 0);
194 cv
.put(ProviderTableMeta
.FILE_ETAG
, file
.getEtag());
195 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_LINK
, file
.isSharedViaLink() ?
1 : 0);
196 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_USERS
, file
.isSharedViaUsers() ?
1 : 0);
197 cv
.put(ProviderTableMeta
.FILE_PUBLIC_LINK
, file
.getPublicLink());
198 cv
.put(ProviderTableMeta
.FILE_PERMISSIONS
, file
.getPermissions());
199 cv
.put(ProviderTableMeta
.FILE_REMOTE_ID
, file
.getRemoteId());
200 cv
.put(ProviderTableMeta
.FILE_UPDATE_THUMBNAIL
, file
.needsUpdateThumbnail());
201 cv
.put(ProviderTableMeta
.FILE_IS_DOWNLOADING
, file
.isDownloading());
202 cv
.put(ProviderTableMeta
.FILE_ETAG_IN_CONFLICT
, file
.getEtagInConflict());
204 boolean sameRemotePath
= fileExists(file
.getRemotePath());
205 if (sameRemotePath
|| fileExists(file
.getFileId())) { // for renamed files; no more delete and create
208 if (sameRemotePath
) {
209 oldFile
= getFileByPath(file
.getRemotePath());
210 file
.setFileId(oldFile
.getFileId());
212 oldFile
= getFileById(file
.getFileId());
216 if (getContentResolver() != null
) {
217 getContentResolver().update(ProviderTableMeta
.CONTENT_URI
, cv
,
218 ProviderTableMeta
._ID
+ "=?",
219 new String
[]{String
.valueOf(file
.getFileId())});
222 getContentProviderClient().update(ProviderTableMeta
.CONTENT_URI
,
223 cv
, ProviderTableMeta
._ID
+ "=?",
224 new String
[]{String
.valueOf(file
.getFileId())});
225 } catch (RemoteException e
) {
227 "Fail to insert insert file to database "
232 Uri result_uri
= null
;
233 if (getContentResolver() != null
) {
234 result_uri
= getContentResolver().insert(
235 ProviderTableMeta
.CONTENT_URI_FILE
, cv
);
238 result_uri
= getContentProviderClient().insert(
239 ProviderTableMeta
.CONTENT_URI_FILE
, cv
);
240 } catch (RemoteException e
) {
242 "Fail to insert insert file to database "
246 if (result_uri
!= null
) {
247 long new_id
= Long
.parseLong(result_uri
.getPathSegments()
249 file
.setFileId(new_id
);
258 * Inserts or updates the list of files contained in a given folder.
260 * CALLER IS THE RESPONSIBLE FOR GRANTING RIGHT UPDATE OF INFORMATION, NOT THIS METHOD.
261 * HERE ONLY DATA CONSISTENCY SHOULD BE GRANTED
264 * @param updatedFiles
265 * @param filesToRemove
267 public void saveFolder(
268 OCFile folder
, Collection
<OCFile
> updatedFiles
, Collection
<OCFile
> filesToRemove
271 Log_OC
.d(TAG
, "Saving folder " + folder
.getRemotePath() + " with " + updatedFiles
.size()
272 + " children and " + filesToRemove
.size() + " files to remove");
274 ArrayList
<ContentProviderOperation
> operations
=
275 new ArrayList
<ContentProviderOperation
>(updatedFiles
.size());
277 // prepare operations to insert or update files to save in the given folder
278 for (OCFile file
: updatedFiles
) {
279 ContentValues cv
= new ContentValues();
280 cv
.put(ProviderTableMeta
.FILE_MODIFIED
, file
.getModificationTimestamp());
282 ProviderTableMeta
.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA
,
283 file
.getModificationTimestampAtLastSyncForData()
285 cv
.put(ProviderTableMeta
.FILE_CREATION
, file
.getCreationTimestamp());
286 cv
.put(ProviderTableMeta
.FILE_CONTENT_LENGTH
, file
.getFileLength());
287 cv
.put(ProviderTableMeta
.FILE_CONTENT_TYPE
, file
.getMimetype());
288 cv
.put(ProviderTableMeta
.FILE_NAME
, file
.getFileName());
289 //cv.put(ProviderTableMeta.FILE_PARENT, file.getParentId());
290 cv
.put(ProviderTableMeta
.FILE_PARENT
, folder
.getFileId());
291 cv
.put(ProviderTableMeta
.FILE_PATH
, file
.getRemotePath());
292 if (!file
.isFolder()) {
293 cv
.put(ProviderTableMeta
.FILE_STORAGE_PATH
, file
.getStoragePath());
295 cv
.put(ProviderTableMeta
.FILE_ACCOUNT_OWNER
, mAccount
.name
);
296 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE
, file
.getLastSyncDateForProperties());
297 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE_FOR_DATA
, file
.getLastSyncDateForData());
298 cv
.put(ProviderTableMeta
.FILE_KEEP_IN_SYNC
, file
.isFavorite() ?
1 : 0);
299 cv
.put(ProviderTableMeta
.FILE_ETAG
, file
.getEtag());
300 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_LINK
, file
.isSharedViaLink() ?
1 : 0);
301 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_USERS
, file
.isSharedViaUsers() ?
1 : 0);
302 cv
.put(ProviderTableMeta
.FILE_PUBLIC_LINK
, file
.getPublicLink());
303 cv
.put(ProviderTableMeta
.FILE_PERMISSIONS
, file
.getPermissions());
304 cv
.put(ProviderTableMeta
.FILE_REMOTE_ID
, file
.getRemoteId());
305 cv
.put(ProviderTableMeta
.FILE_UPDATE_THUMBNAIL
, file
.needsUpdateThumbnail());
306 cv
.put(ProviderTableMeta
.FILE_IS_DOWNLOADING
, file
.isDownloading());
307 cv
.put(ProviderTableMeta
.FILE_ETAG_IN_CONFLICT
, file
.getEtagInConflict());
309 boolean existsByPath
= fileExists(file
.getRemotePath());
310 if (existsByPath
|| fileExists(file
.getFileId())) {
311 // updating an existing file
312 operations
.add(ContentProviderOperation
.newUpdate(ProviderTableMeta
.CONTENT_URI
).
314 withSelection(ProviderTableMeta
._ID
+ "=?",
315 new String
[]{String
.valueOf(file
.getFileId())})
320 operations
.add(ContentProviderOperation
.newInsert(ProviderTableMeta
.CONTENT_URI
).
321 withValues(cv
).build());
325 // prepare operations to remove files in the given folder
326 String where
= ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=?" + " AND " +
327 ProviderTableMeta
.FILE_PATH
+ "=?";
328 String
[] whereArgs
= null
;
329 for (OCFile file
: filesToRemove
) {
330 if (file
.getParentId() == folder
.getFileId()) {
331 whereArgs
= new String
[]{mAccount
.name
, file
.getRemotePath()};
332 if (file
.isFolder()) {
333 operations
.add(ContentProviderOperation
.newDelete(
334 ContentUris
.withAppendedId(
335 ProviderTableMeta
.CONTENT_URI_DIR
, file
.getFileId()
337 ).withSelection(where
, whereArgs
).build());
340 new File(FileStorageUtils
.getDefaultSavePathFor(mAccount
.name
, file
));
341 if (localFolder
.exists()) {
342 removeLocalFolder(localFolder
);
345 operations
.add(ContentProviderOperation
.newDelete(
346 ContentUris
.withAppendedId(
347 ProviderTableMeta
.CONTENT_URI_FILE
, file
.getFileId()
349 ).withSelection(where
, whereArgs
).build());
352 String path
= file
.getStoragePath();
353 new File(path
).delete();
354 triggerMediaScan(path
); // notify MediaScanner about removed file
360 // update metadata of folder
361 ContentValues cv
= new ContentValues();
362 cv
.put(ProviderTableMeta
.FILE_MODIFIED
, folder
.getModificationTimestamp());
364 ProviderTableMeta
.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA
,
365 folder
.getModificationTimestampAtLastSyncForData()
367 cv
.put(ProviderTableMeta
.FILE_CREATION
, folder
.getCreationTimestamp());
368 cv
.put(ProviderTableMeta
.FILE_CONTENT_LENGTH
, 0);
369 cv
.put(ProviderTableMeta
.FILE_CONTENT_TYPE
, folder
.getMimetype());
370 cv
.put(ProviderTableMeta
.FILE_NAME
, folder
.getFileName());
371 cv
.put(ProviderTableMeta
.FILE_PARENT
, folder
.getParentId());
372 cv
.put(ProviderTableMeta
.FILE_PATH
, folder
.getRemotePath());
373 cv
.put(ProviderTableMeta
.FILE_ACCOUNT_OWNER
, mAccount
.name
);
374 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE
, folder
.getLastSyncDateForProperties());
375 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE_FOR_DATA
, folder
.getLastSyncDateForData());
376 cv
.put(ProviderTableMeta
.FILE_KEEP_IN_SYNC
, folder
.isFavorite() ?
1 : 0);
377 cv
.put(ProviderTableMeta
.FILE_ETAG
, folder
.getEtag());
378 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_LINK
, folder
.isSharedViaLink() ?
1 : 0);
379 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_USERS
, folder
.isSharedViaUsers() ?
1 : 0);
380 cv
.put(ProviderTableMeta
.FILE_PUBLIC_LINK
, folder
.getPublicLink());
381 cv
.put(ProviderTableMeta
.FILE_PERMISSIONS
, folder
.getPermissions());
382 cv
.put(ProviderTableMeta
.FILE_REMOTE_ID
, folder
.getRemoteId());
384 operations
.add(ContentProviderOperation
.newUpdate(ProviderTableMeta
.CONTENT_URI
).
386 withSelection(ProviderTableMeta
._ID
+ "=?",
387 new String
[]{String
.valueOf(folder
.getFileId())})
390 // apply operations in batch
391 ContentProviderResult
[] results
= null
;
392 Log_OC
.d(TAG
, "Sending " + operations
.size() + " operations to FileContentProvider");
394 if (getContentResolver() != null
) {
395 results
= getContentResolver().applyBatch(MainApp
.getAuthority(), operations
);
398 results
= getContentProviderClient().applyBatch(operations
);
401 } catch (OperationApplicationException e
) {
402 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
404 } catch (RemoteException e
) {
405 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
408 // update new id in file objects for insertions
409 if (results
!= null
) {
411 Iterator
<OCFile
> filesIt
= updatedFiles
.iterator();
413 for (int i
= 0; i
< results
.length
; i
++) {
414 if (filesIt
.hasNext()) {
415 file
= filesIt
.next();
419 if (results
[i
].uri
!= null
) {
420 newId
= Long
.parseLong(results
[i
].uri
.getPathSegments().get(1));
421 //updatedFiles.get(i).setFileId(newId);
423 file
.setFileId(newId
);
432 public boolean removeFile(OCFile file
, boolean removeDBData
, boolean removeLocalCopy
) {
433 boolean success
= true
;
435 if (file
.isFolder()) {
436 success
= removeFolder(file
, removeDBData
, removeLocalCopy
);
440 //Uri file_uri = Uri.withAppendedPath(ProviderTableMeta.CONTENT_URI_FILE, ""+file.getFileId());
441 Uri file_uri
= ContentUris
.withAppendedId(ProviderTableMeta
.CONTENT_URI_FILE
, file
.getFileId());
442 String where
= ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=?" + " AND " + ProviderTableMeta
.FILE_PATH
+ "=?";
443 String
[] whereArgs
= new String
[]{mAccount
.name
, file
.getRemotePath()};
445 if (getContentProviderClient() != null
) {
447 deleted
= getContentProviderClient().delete(file_uri
, where
, whereArgs
);
448 } catch (RemoteException e
) {
452 deleted
= getContentResolver().delete(file_uri
, where
, whereArgs
);
454 success
&= (deleted
> 0);
456 String localPath
= file
.getStoragePath();
457 if (removeLocalCopy
&& file
.isDown() && localPath
!= null
&& success
) {
458 success
= new File(localPath
).delete();
460 deleteFileInMediaScan(localPath
);
462 if (!removeDBData
&& success
) {
463 // maybe unnecessary, but should be checked TODO remove if unnecessary
464 file
.setStoragePath(null
);
466 saveConflict(file
, null
);
475 public boolean removeFolder(OCFile folder
, boolean removeDBData
, boolean removeLocalContent
) {
476 boolean success
= true
;
477 if (folder
!= null
&& folder
.isFolder()) {
478 if (removeDBData
&& folder
.getFileId() != -1) {
479 success
= removeFolderInDb(folder
);
481 if (removeLocalContent
&& success
) {
482 success
= removeLocalFolder(folder
);
488 private boolean removeFolderInDb(OCFile folder
) {
489 Uri folder_uri
= Uri
.withAppendedPath(ProviderTableMeta
.CONTENT_URI_DIR
, "" +
490 folder
.getFileId()); // URI for recursive deletion
491 String where
= ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=?" + " AND " +
492 ProviderTableMeta
.FILE_PATH
+ "=?";
493 String
[] whereArgs
= new String
[]{mAccount
.name
, folder
.getRemotePath()};
495 if (getContentProviderClient() != null
) {
497 deleted
= getContentProviderClient().delete(folder_uri
, where
, whereArgs
);
498 } catch (RemoteException e
) {
502 deleted
= getContentResolver().delete(folder_uri
, where
, whereArgs
);
507 private boolean removeLocalFolder(OCFile folder
) {
508 boolean success
= true
;
509 String localFolderPath
= FileStorageUtils
.getDefaultSavePathFor(mAccount
.name
, folder
);
510 File localFolder
= new File(localFolderPath
);
511 if (localFolder
.exists()) {
512 // stage 1: remove the local files already registered in the files database
513 // TODO Enable when "On Device" is recovered ?
514 Vector
<OCFile
> files
= getFolderContent(folder
.getFileId()/*, false*/);
516 for (OCFile file
: files
) {
517 if (file
.isFolder()) {
518 success
&= removeLocalFolder(file
);
521 File localFile
= new File(file
.getStoragePath());
522 success
&= localFile
.delete();
524 // notify MediaScanner about removed file
525 deleteFileInMediaScan(file
.getStoragePath());
526 file
.setStoragePath(null
);
534 // stage 2: remove the folder itself and any local file inside out of sync;
535 // for instance, after clearing the app cache or reinstalling
536 success
&= removeLocalFolder(localFolder
);
541 private boolean removeLocalFolder(File localFolder
) {
542 boolean success
= true
;
543 File
[] localFiles
= localFolder
.listFiles();
544 if (localFiles
!= null
) {
545 for (File localFile
: localFiles
) {
546 if (localFile
.isDirectory()) {
547 success
&= removeLocalFolder(localFile
);
549 String path
= localFile
.getAbsolutePath();
550 success
&= localFile
.delete();
554 success
&= localFolder
.delete();
560 * Updates database and file system for a file or folder that was moved to a different location.
562 * TODO explore better (faster) implementations
563 * TODO throw exceptions up !
565 public void moveLocalFile(OCFile file
, String targetPath
, String targetParentPath
) {
567 if (file
!= null
&& file
.fileExists() && !OCFile
.ROOT_PATH
.equals(file
.getFileName())) {
569 OCFile targetParent
= getFileByPath(targetParentPath
);
570 if (targetParent
== null
) {
571 throw new IllegalStateException("Parent folder of the target path does not exist!!");
574 /// 1. get all the descendants of the moved element in a single QUERY
576 if (getContentProviderClient() != null
) {
578 c
= getContentProviderClient().query(
579 ProviderTableMeta
.CONTENT_URI
,
581 ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=? AND " +
582 ProviderTableMeta
.FILE_PATH
+ " LIKE ? ",
585 file
.getRemotePath() + "%"
587 ProviderTableMeta
.FILE_PATH
+ " ASC "
589 } catch (RemoteException e
) {
590 Log_OC
.e(TAG
, e
.getMessage());
594 c
= getContentResolver().query(
595 ProviderTableMeta
.CONTENT_URI
,
597 ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=? AND " +
598 ProviderTableMeta
.FILE_PATH
+ " LIKE ? ",
601 file
.getRemotePath() + "%"
603 ProviderTableMeta
.FILE_PATH
+ " ASC "
607 /// 2. prepare a batch of update operations to change all the descendants
608 ArrayList
<ContentProviderOperation
> operations
=
609 new ArrayList
<ContentProviderOperation
>(c
.getCount());
610 String defaultSavePath
= FileStorageUtils
.getSavePath(mAccount
.name
);
611 List
<String
> originalPathsToTriggerMediaScan
= new ArrayList
<String
>();
612 List
<String
> newPathsToTriggerMediaScan
= new ArrayList
<String
>();
613 if (c
.moveToFirst()) {
614 int lengthOfOldPath
= file
.getRemotePath().length();
615 int lengthOfOldStoragePath
= defaultSavePath
.length() + lengthOfOldPath
;
617 ContentValues cv
= new ContentValues(); // keep construction in the loop
618 OCFile child
= createFileInstance(c
);
620 ProviderTableMeta
.FILE_PATH
,
621 targetPath
+ child
.getRemotePath().substring(lengthOfOldPath
)
623 if (child
.getStoragePath() != null
&&
624 child
.getStoragePath().startsWith(defaultSavePath
)) {
625 // update link to downloaded content - but local move is not done here!
626 String targetLocalPath
= defaultSavePath
+ targetPath
+
627 child
.getStoragePath().substring(lengthOfOldStoragePath
);
629 cv
.put(ProviderTableMeta
.FILE_STORAGE_PATH
, targetLocalPath
);
631 originalPathsToTriggerMediaScan
.add(child
.getStoragePath());
632 newPathsToTriggerMediaScan
.add(targetLocalPath
);
635 if (child
.getRemotePath().equals(file
.getRemotePath())) {
637 ProviderTableMeta
.FILE_PARENT
,
638 targetParent
.getFileId()
642 ContentProviderOperation
.newUpdate(ProviderTableMeta
.CONTENT_URI
).
645 ProviderTableMeta
._ID
+ "=?",
646 new String
[]{String
.valueOf(child
.getFileId())}
650 } while (c
.moveToNext());
654 /// 3. apply updates in batch
656 if (getContentResolver() != null
) {
657 getContentResolver().applyBatch(MainApp
.getAuthority(), operations
);
660 getContentProviderClient().applyBatch(operations
);
663 } catch (Exception e
) {
664 Log_OC
.e(TAG
, "Fail to update " + file
.getFileId() + " and descendants in database", e
);
667 /// 4. move in local file system
668 String originalLocalPath
= FileStorageUtils
.getDefaultSavePathFor(mAccount
.name
, file
);
669 String targetLocalPath
= defaultSavePath
+ targetPath
;
670 File localFile
= new File(originalLocalPath
);
671 boolean renamed
= false
;
672 if (localFile
.exists()) {
673 File targetFile
= new File(targetLocalPath
);
674 File targetFolder
= targetFile
.getParentFile();
675 if (!targetFolder
.exists()) {
676 targetFolder
.mkdirs();
678 renamed
= localFile
.renameTo(targetFile
);
682 Iterator
<String
> it
= originalPathsToTriggerMediaScan
.iterator();
683 while (it
.hasNext()) {
684 // Notify MediaScanner about removed file
685 deleteFileInMediaScan(it
.next());
687 it
= newPathsToTriggerMediaScan
.iterator();
688 while (it
.hasNext()) {
689 // Notify MediaScanner about new file/folder
690 triggerMediaScan(it
.next());
697 public void copyLocalFile(OCFile file
, String targetPath
) {
699 if (file
!= null
&& file
.fileExists() && !OCFile
.ROOT_PATH
.equals(file
.getFileName())) {
700 String localPath
= FileStorageUtils
.getDefaultSavePathFor(mAccount
.name
, file
);
701 File localFile
= new File(localPath
);
702 boolean copied
= false
;
703 String defaultSavePath
= FileStorageUtils
.getSavePath(mAccount
.name
);
704 if (localFile
.exists()) {
705 File targetFile
= new File(defaultSavePath
+ targetPath
);
706 File targetFolder
= targetFile
.getParentFile();
707 if (!targetFolder
.exists()) {
708 targetFolder
.mkdirs();
710 copied
= copyFile(localFile
, targetFile
);
712 Log_OC
.d(TAG
, "Local file COPIED : " + copied
);
716 private boolean copyFile(File src
, File target
) {
719 InputStream
in = null
;
720 OutputStream out
= null
;
723 in = new FileInputStream(src
);
724 out
= new FileOutputStream(target
);
725 byte[] buf
= new byte[1024];
727 while ((len
= in.read(buf
)) > 0) {
728 out
.write(buf
, 0, len
);
730 } catch (IOException ex
) {
733 if (in != null
) try {
735 } catch (IOException e
) {
736 e
.printStackTrace(System
.err
);
738 if (out
!= null
) try {
740 } catch (IOException e
) {
741 e
.printStackTrace(System
.err
);
749 private Vector
<OCFile
> getFolderContent(long parentId
/*, boolean onlyOnDevice*/) {
751 Vector
<OCFile
> ret
= new Vector
<OCFile
>();
753 Uri req_uri
= Uri
.withAppendedPath(
754 ProviderTableMeta
.CONTENT_URI_DIR
,
755 String
.valueOf(parentId
));
758 if (getContentProviderClient() != null
) {
760 c
= getContentProviderClient().query(req_uri
, null
,
761 ProviderTableMeta
.FILE_PARENT
+ "=?",
762 new String
[]{String
.valueOf(parentId
)}, null
);
763 } catch (RemoteException e
) {
764 Log_OC
.e(TAG
, e
.getMessage());
768 c
= getContentResolver().query(req_uri
, null
,
769 ProviderTableMeta
.FILE_PARENT
+ "=?",
770 new String
[]{String
.valueOf(parentId
)}, null
);
773 if (c
.moveToFirst()) {
775 OCFile child
= createFileInstance(c
);
776 // TODO Enable when "On Device" is recovered ?
777 // if (child.isFolder() || !onlyOnDevice || onlyOnDevice && child.isDown()){
780 } while (c
.moveToNext());
785 Collections
.sort(ret
);
791 private OCFile
createRootDir() {
792 OCFile file
= new OCFile(OCFile
.ROOT_PATH
);
793 file
.setMimetype("DIR");
794 file
.setParentId(FileDataStorageManager
.ROOT_PARENT_ID
);
799 private boolean fileExists(String cmp_key
, String value
) {
801 if (getContentResolver() != null
) {
802 c
= getContentResolver()
803 .query(ProviderTableMeta
.CONTENT_URI
,
806 + ProviderTableMeta
.FILE_ACCOUNT_OWNER
808 new String
[]{value
, mAccount
.name
}, null
);
811 c
= getContentProviderClient().query(
812 ProviderTableMeta
.CONTENT_URI
,
815 + ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=?",
816 new String
[]{value
, mAccount
.name
}, null
);
817 } catch (RemoteException e
) {
819 "Couldn't determine file existance, assuming non existance: "
824 boolean retval
= c
.moveToFirst();
829 private Cursor
getCursorForValue(String key
, String value
) {
831 if (getContentResolver() != null
) {
832 c
= getContentResolver()
833 .query(ProviderTableMeta
.CONTENT_URI
,
836 + ProviderTableMeta
.FILE_ACCOUNT_OWNER
838 new String
[]{value
, mAccount
.name
}, null
);
841 c
= getContentProviderClient().query(
842 ProviderTableMeta
.CONTENT_URI
,
844 key
+ "=? AND " + ProviderTableMeta
.FILE_ACCOUNT_OWNER
845 + "=?", new String
[]{value
, mAccount
.name
},
847 } catch (RemoteException e
) {
848 Log_OC
.e(TAG
, "Could not get file details: " + e
.getMessage());
856 private OCFile
createFileInstance(Cursor c
) {
859 file
= new OCFile(c
.getString(c
860 .getColumnIndex(ProviderTableMeta
.FILE_PATH
)));
861 file
.setFileId(c
.getLong(c
.getColumnIndex(ProviderTableMeta
._ID
)));
862 file
.setParentId(c
.getLong(c
863 .getColumnIndex(ProviderTableMeta
.FILE_PARENT
)));
864 file
.setMimetype(c
.getString(c
865 .getColumnIndex(ProviderTableMeta
.FILE_CONTENT_TYPE
)));
866 if (!file
.isFolder()) {
867 file
.setStoragePath(c
.getString(c
868 .getColumnIndex(ProviderTableMeta
.FILE_STORAGE_PATH
)));
869 if (file
.getStoragePath() == null
) {
870 // try to find existing file and bind it with current account;
871 // with the current update of SynchronizeFolderOperation, this won't be
872 // necessary anymore after a full synchronization of the account
873 File f
= new File(FileStorageUtils
.getDefaultSavePathFor(mAccount
.name
, file
));
875 file
.setStoragePath(f
.getAbsolutePath());
876 file
.setLastSyncDateForData(f
.lastModified());
880 file
.setFileLength(c
.getLong(c
881 .getColumnIndex(ProviderTableMeta
.FILE_CONTENT_LENGTH
)));
882 file
.setCreationTimestamp(c
.getLong(c
883 .getColumnIndex(ProviderTableMeta
.FILE_CREATION
)));
884 file
.setModificationTimestamp(c
.getLong(c
885 .getColumnIndex(ProviderTableMeta
.FILE_MODIFIED
)));
886 file
.setModificationTimestampAtLastSyncForData(c
.getLong(c
887 .getColumnIndex(ProviderTableMeta
.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA
)));
888 file
.setLastSyncDateForProperties(c
.getLong(c
889 .getColumnIndex(ProviderTableMeta
.FILE_LAST_SYNC_DATE
)));
890 file
.setLastSyncDateForData(c
.getLong(c
.
891 getColumnIndex(ProviderTableMeta
.FILE_LAST_SYNC_DATE_FOR_DATA
)));
892 file
.setFavorite(c
.getInt(
893 c
.getColumnIndex(ProviderTableMeta
.FILE_KEEP_IN_SYNC
)) == 1 ? true
: false
);
894 file
.setEtag(c
.getString(c
.getColumnIndex(ProviderTableMeta
.FILE_ETAG
)));
895 file
.setShareViaLink(c
.getInt(
896 c
.getColumnIndex(ProviderTableMeta
.FILE_SHARED_VIA_LINK
)) == 1 ? true
: false
);
897 file
.setShareViaUsers(c
.getInt(
898 c
.getColumnIndex(ProviderTableMeta
.FILE_SHARED_VIA_USERS
)) == 1 ? true
: false
);
899 file
.setPublicLink(c
.getString(c
.getColumnIndex(ProviderTableMeta
.FILE_PUBLIC_LINK
)));
900 file
.setPermissions(c
.getString(c
.getColumnIndex(ProviderTableMeta
.FILE_PERMISSIONS
)));
901 file
.setRemoteId(c
.getString(c
.getColumnIndex(ProviderTableMeta
.FILE_REMOTE_ID
)));
902 file
.setNeedsUpdateThumbnail(c
.getInt(
903 c
.getColumnIndex(ProviderTableMeta
.FILE_UPDATE_THUMBNAIL
)) == 1 ? true
: false
);
904 file
.setDownloading(c
.getInt(
905 c
.getColumnIndex(ProviderTableMeta
.FILE_IS_DOWNLOADING
)) == 1 ? true
: false
);
906 file
.setEtagInConflict(c
.getString(c
.getColumnIndex(ProviderTableMeta
.FILE_ETAG_IN_CONFLICT
)));
912 // Methods for Shares
913 public boolean saveShare(OCShare share
) {
914 boolean overriden
= false
;
915 ContentValues cv
= new ContentValues();
916 cv
.put(ProviderTableMeta
.OCSHARES_FILE_SOURCE
, share
.getFileSource());
917 cv
.put(ProviderTableMeta
.OCSHARES_ITEM_SOURCE
, share
.getItemSource());
918 cv
.put(ProviderTableMeta
.OCSHARES_SHARE_TYPE
, share
.getShareType().getValue());
919 cv
.put(ProviderTableMeta
.OCSHARES_SHARE_WITH
, share
.getShareWith());
920 cv
.put(ProviderTableMeta
.OCSHARES_PATH
, share
.getPath());
921 cv
.put(ProviderTableMeta
.OCSHARES_PERMISSIONS
, share
.getPermissions());
922 cv
.put(ProviderTableMeta
.OCSHARES_SHARED_DATE
, share
.getSharedDate());
923 cv
.put(ProviderTableMeta
.OCSHARES_EXPIRATION_DATE
, share
.getExpirationDate());
924 cv
.put(ProviderTableMeta
.OCSHARES_TOKEN
, share
.getToken());
926 ProviderTableMeta
.OCSHARES_SHARE_WITH_DISPLAY_NAME
,
927 share
.getSharedWithDisplayName()
929 cv
.put(ProviderTableMeta
.OCSHARES_IS_DIRECTORY
, share
.isFolder() ?
1 : 0);
930 cv
.put(ProviderTableMeta
.OCSHARES_USER_ID
, share
.getUserId());
931 cv
.put(ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
, share
.getIdRemoteShared());
932 cv
.put(ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
, mAccount
.name
);
934 if (shareExists(share
.getIdRemoteShared())) { // for renamed files; no more delete and create
936 if (getContentResolver() != null
) {
937 getContentResolver().update(ProviderTableMeta
.CONTENT_URI_SHARE
, cv
,
938 ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
+ "=?",
939 new String
[]{String
.valueOf(share
.getIdRemoteShared())});
942 getContentProviderClient().update(ProviderTableMeta
.CONTENT_URI_SHARE
,
943 cv
, ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
+ "=?",
944 new String
[]{String
.valueOf(share
.getIdRemoteShared())});
945 } catch (RemoteException e
) {
947 "Fail to insert insert file to database "
952 Uri result_uri
= null
;
953 if (getContentResolver() != null
) {
954 result_uri
= getContentResolver().insert(
955 ProviderTableMeta
.CONTENT_URI_SHARE
, cv
);
958 result_uri
= getContentProviderClient().insert(
959 ProviderTableMeta
.CONTENT_URI_SHARE
, cv
);
960 } catch (RemoteException e
) {
962 "Fail to insert insert file to database "
966 if (result_uri
!= null
) {
967 long new_id
= Long
.parseLong(result_uri
.getPathSegments()
977 public OCShare
getFirstShareByPathAndType(String path
, ShareType type
, String shareWith
) {
980 String selection
= ProviderTableMeta
.OCSHARES_PATH
+ "=? AND "
981 + ProviderTableMeta
.OCSHARES_SHARE_TYPE
+ "=? AND "
982 + ProviderTableMeta
.OCSHARES_SHARE_WITH
+ "=? AND "
983 + ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
+ "=?" ;
985 String
[] selectionArgs
= new String
[]{path
, Integer
.toString(type
.getValue()),
986 shareWith
, mAccount
.name
};
988 if (getContentResolver() != null
) {
989 c
= getContentResolver().query(
990 ProviderTableMeta
.CONTENT_URI_SHARE
,
992 selection
, selectionArgs
,
996 c
= getContentProviderClient().query(
997 ProviderTableMeta
.CONTENT_URI_SHARE
,
999 selection
, selectionArgs
,
1002 } catch (RemoteException e
) {
1003 Log_OC
.e(TAG
, "Could not get file details: " + e
.getMessage());
1007 OCShare share
= null
;
1008 if (c
.moveToFirst()) {
1009 share
= createShareInstance(c
);
1015 private OCShare
createShareInstance(Cursor c
) {
1016 OCShare share
= null
;
1018 share
= new OCShare(c
.getString(c
1019 .getColumnIndex(ProviderTableMeta
.OCSHARES_PATH
)));
1020 share
.setId(c
.getLong(c
.getColumnIndex(ProviderTableMeta
._ID
)));
1021 share
.setFileSource(c
.getLong(c
1022 .getColumnIndex(ProviderTableMeta
.OCSHARES_ITEM_SOURCE
)));
1023 share
.setShareType(ShareType
.fromValue(c
.getInt(c
1024 .getColumnIndex(ProviderTableMeta
.OCSHARES_SHARE_TYPE
))));
1025 share
.setPermissions(c
.getInt(c
1026 .getColumnIndex(ProviderTableMeta
.OCSHARES_PERMISSIONS
)));
1027 share
.setSharedDate(c
.getLong(c
1028 .getColumnIndex(ProviderTableMeta
.OCSHARES_SHARED_DATE
)));
1029 share
.setExpirationDate(c
.getLong(c
1030 .getColumnIndex(ProviderTableMeta
.OCSHARES_EXPIRATION_DATE
)));
1031 share
.setToken(c
.getString(c
1032 .getColumnIndex(ProviderTableMeta
.OCSHARES_TOKEN
)));
1033 share
.setSharedWithDisplayName(c
.getString(c
1034 .getColumnIndex(ProviderTableMeta
.OCSHARES_SHARE_WITH_DISPLAY_NAME
)));
1035 share
.setIsFolder(c
.getInt(
1036 c
.getColumnIndex(ProviderTableMeta
.OCSHARES_IS_DIRECTORY
)) == 1);
1037 share
.setUserId(c
.getLong(c
.getColumnIndex(ProviderTableMeta
.OCSHARES_USER_ID
)));
1038 share
.setIdRemoteShared(c
.getLong(c
.getColumnIndex(ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
)));
1043 private boolean shareExists(String cmp_key
, String value
) {
1045 if (getContentResolver() != null
) {
1046 c
= getContentResolver()
1047 .query(ProviderTableMeta
.CONTENT_URI_SHARE
,
1050 + ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
1052 new String
[]{value
, mAccount
.name
}, null
);
1055 c
= getContentProviderClient().query(
1056 ProviderTableMeta
.CONTENT_URI_SHARE
,
1059 + ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
+ "=?",
1060 new String
[]{value
, mAccount
.name
}, null
);
1061 } catch (RemoteException e
) {
1063 "Couldn't determine file existance, assuming non existance: "
1068 boolean retval
= c
.moveToFirst();
1073 private boolean shareExists(long remoteId
) {
1074 return shareExists(ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
, String
.valueOf(remoteId
));
1077 private void resetShareFlagsInAllFiles() {
1078 ContentValues cv
= new ContentValues();
1079 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_LINK
, false
);
1080 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_USERS
, false
);
1081 cv
.put(ProviderTableMeta
.FILE_PUBLIC_LINK
, "");
1082 String where
= ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=?";
1083 String
[] whereArgs
= new String
[]{mAccount
.name
};
1085 if (getContentResolver() != null
) {
1086 getContentResolver().update(ProviderTableMeta
.CONTENT_URI
, cv
, where
, whereArgs
);
1090 getContentProviderClient().update(ProviderTableMeta
.CONTENT_URI
, cv
, where
, whereArgs
);
1091 } catch (RemoteException e
) {
1092 Log_OC
.e(TAG
, "Exception in resetShareFlagsInAllFiles" + e
.getMessage());
1097 private void resetShareFlagsInFolder(OCFile folder
) {
1098 ContentValues cv
= new ContentValues();
1099 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_LINK
, false
);
1100 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_USERS
, false
);
1101 cv
.put(ProviderTableMeta
.FILE_PUBLIC_LINK
, "");
1102 String where
= ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=? AND " +
1103 ProviderTableMeta
.FILE_PARENT
+ "=?";
1104 String
[] whereArgs
= new String
[] { mAccount
.name
, String
.valueOf(folder
.getFileId()) };
1106 if (getContentResolver() != null
) {
1107 getContentResolver().update(ProviderTableMeta
.CONTENT_URI
, cv
, where
, whereArgs
);
1111 getContentProviderClient().update(ProviderTableMeta
.CONTENT_URI
, cv
, where
, whereArgs
);
1112 } catch (RemoteException e
) {
1113 Log_OC
.e(TAG
, "Exception in resetShareFlagsInFolder " + e
.getMessage());
1118 private void cleanShares() {
1119 String where
= ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
+ "=?";
1120 String
[] whereArgs
= new String
[]{mAccount
.name
};
1122 if (getContentResolver() != null
) {
1123 getContentResolver().delete(ProviderTableMeta
.CONTENT_URI_SHARE
, where
, whereArgs
);
1127 getContentProviderClient().delete(ProviderTableMeta
.CONTENT_URI_SHARE
, where
, whereArgs
);
1128 } catch (RemoteException e
) {
1129 Log_OC
.e(TAG
, "Exception in cleanShares" + e
.getMessage());
1134 public void saveShares(Collection
<OCShare
> shares
) {
1136 if (shares
!= null
) {
1137 ArrayList
<ContentProviderOperation
> operations
=
1138 new ArrayList
<ContentProviderOperation
>(shares
.size());
1140 // prepare operations to insert or update files to save in the given folder
1141 for (OCShare share
: shares
) {
1142 ContentValues cv
= new ContentValues();
1143 cv
.put(ProviderTableMeta
.OCSHARES_FILE_SOURCE
, share
.getFileSource());
1144 cv
.put(ProviderTableMeta
.OCSHARES_ITEM_SOURCE
, share
.getItemSource());
1145 cv
.put(ProviderTableMeta
.OCSHARES_SHARE_TYPE
, share
.getShareType().getValue());
1146 cv
.put(ProviderTableMeta
.OCSHARES_SHARE_WITH
, share
.getShareWith());
1147 cv
.put(ProviderTableMeta
.OCSHARES_PATH
, share
.getPath());
1148 cv
.put(ProviderTableMeta
.OCSHARES_PERMISSIONS
, share
.getPermissions());
1149 cv
.put(ProviderTableMeta
.OCSHARES_SHARED_DATE
, share
.getSharedDate());
1150 cv
.put(ProviderTableMeta
.OCSHARES_EXPIRATION_DATE
, share
.getExpirationDate());
1151 cv
.put(ProviderTableMeta
.OCSHARES_TOKEN
, share
.getToken());
1153 ProviderTableMeta
.OCSHARES_SHARE_WITH_DISPLAY_NAME
,
1154 share
.getSharedWithDisplayName()
1156 cv
.put(ProviderTableMeta
.OCSHARES_IS_DIRECTORY
, share
.isFolder() ?
1 : 0);
1157 cv
.put(ProviderTableMeta
.OCSHARES_USER_ID
, share
.getUserId());
1158 cv
.put(ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
, share
.getIdRemoteShared());
1159 cv
.put(ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
, mAccount
.name
);
1161 if (shareExists(share
.getIdRemoteShared())) {
1162 // updating an existing file
1164 ContentProviderOperation
.newUpdate(ProviderTableMeta
.CONTENT_URI_SHARE
).
1166 withSelection(ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
+ "=?",
1167 new String
[]{String
.valueOf(share
.getIdRemoteShared())})
1170 // adding a new file
1172 ContentProviderOperation
.newInsert(ProviderTableMeta
.CONTENT_URI_SHARE
).
1179 // apply operations in batch
1180 if (operations
.size() > 0) {
1181 @SuppressWarnings("unused")
1182 ContentProviderResult
[] results
= null
;
1183 Log_OC
.d(TAG
, "Sending " + operations
.size() +
1184 " operations to FileContentProvider");
1186 if (getContentResolver() != null
) {
1187 results
= getContentResolver().applyBatch(MainApp
.getAuthority(), operations
);
1189 results
= getContentProviderClient().applyBatch(operations
);
1192 } catch (OperationApplicationException e
) {
1193 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
1195 } catch (RemoteException e
) {
1196 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
1203 public void updateSharedFiles(Collection
<OCFile
> sharedFiles
) {
1204 resetShareFlagsInAllFiles();
1206 if (sharedFiles
!= null
) {
1207 ArrayList
<ContentProviderOperation
> operations
=
1208 new ArrayList
<ContentProviderOperation
>(sharedFiles
.size());
1210 // prepare operations to insert or update files to save in the given folder
1211 for (OCFile file
: sharedFiles
) {
1212 ContentValues cv
= new ContentValues();
1213 cv
.put(ProviderTableMeta
.FILE_MODIFIED
, file
.getModificationTimestamp());
1215 ProviderTableMeta
.FILE_MODIFIED_AT_LAST_SYNC_FOR_DATA
,
1216 file
.getModificationTimestampAtLastSyncForData()
1218 cv
.put(ProviderTableMeta
.FILE_CREATION
, file
.getCreationTimestamp());
1219 cv
.put(ProviderTableMeta
.FILE_CONTENT_LENGTH
, file
.getFileLength());
1220 cv
.put(ProviderTableMeta
.FILE_CONTENT_TYPE
, file
.getMimetype());
1221 cv
.put(ProviderTableMeta
.FILE_NAME
, file
.getFileName());
1222 cv
.put(ProviderTableMeta
.FILE_PARENT
, file
.getParentId());
1223 cv
.put(ProviderTableMeta
.FILE_PATH
, file
.getRemotePath());
1224 if (!file
.isFolder()) {
1225 cv
.put(ProviderTableMeta
.FILE_STORAGE_PATH
, file
.getStoragePath());
1227 cv
.put(ProviderTableMeta
.FILE_ACCOUNT_OWNER
, mAccount
.name
);
1228 cv
.put(ProviderTableMeta
.FILE_LAST_SYNC_DATE
, file
.getLastSyncDateForProperties());
1230 ProviderTableMeta
.FILE_LAST_SYNC_DATE_FOR_DATA
,
1231 file
.getLastSyncDateForData()
1233 cv
.put(ProviderTableMeta
.FILE_KEEP_IN_SYNC
, file
.isFavorite() ?
1 : 0);
1234 cv
.put(ProviderTableMeta
.FILE_ETAG
, file
.getEtag());
1235 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_LINK
, file
.isSharedViaLink() ?
1 : 0);
1236 cv
.put(ProviderTableMeta
.FILE_SHARED_VIA_USERS
, file
.isSharedViaUsers() ?
1 : 0);
1237 cv
.put(ProviderTableMeta
.FILE_PUBLIC_LINK
, file
.getPublicLink());
1238 cv
.put(ProviderTableMeta
.FILE_PERMISSIONS
, file
.getPermissions());
1239 cv
.put(ProviderTableMeta
.FILE_REMOTE_ID
, file
.getRemoteId());
1241 ProviderTableMeta
.FILE_UPDATE_THUMBNAIL
,
1242 file
.needsUpdateThumbnail() ?
1 : 0
1245 ProviderTableMeta
.FILE_IS_DOWNLOADING
,
1246 file
.isDownloading() ?
1 : 0
1248 cv
.put(ProviderTableMeta
.FILE_ETAG_IN_CONFLICT
, file
.getEtagInConflict());
1250 boolean existsByPath
= fileExists(file
.getRemotePath());
1251 if (existsByPath
|| fileExists(file
.getFileId())) {
1252 // updating an existing file
1254 ContentProviderOperation
.newUpdate(ProviderTableMeta
.CONTENT_URI
).
1256 withSelection(ProviderTableMeta
._ID
+ "=?",
1257 new String
[]{String
.valueOf(file
.getFileId())})
1261 // adding a new file
1263 ContentProviderOperation
.newInsert(ProviderTableMeta
.CONTENT_URI
).
1270 // apply operations in batch
1271 if (operations
.size() > 0) {
1272 @SuppressWarnings("unused")
1273 ContentProviderResult
[] results
= null
;
1274 Log_OC
.d(TAG
, "Sending " + operations
.size() +
1275 " operations to FileContentProvider");
1277 if (getContentResolver() != null
) {
1278 results
= getContentResolver().applyBatch(MainApp
.getAuthority(), operations
);
1280 results
= getContentProviderClient().applyBatch(operations
);
1283 } catch (OperationApplicationException e
) {
1284 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
1286 } catch (RemoteException e
) {
1287 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
1294 public void removeShare(OCShare share
) {
1295 Uri share_uri
= ProviderTableMeta
.CONTENT_URI_SHARE
;
1296 String where
= ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
+ "=?" + " AND " +
1297 ProviderTableMeta
.FILE_PATH
+ "=?";
1298 String
[] whereArgs
= new String
[]{mAccount
.name
, share
.getPath()};
1299 if (getContentProviderClient() != null
) {
1301 getContentProviderClient().delete(share_uri
, where
, whereArgs
);
1302 } catch (RemoteException e
) {
1303 e
.printStackTrace();
1306 getContentResolver().delete(share_uri
, where
, whereArgs
);
1310 public void saveSharesDB(ArrayList
<OCShare
> shares
) {
1313 ArrayList
<OCFile
> sharedFiles
= new ArrayList
<OCFile
>();
1315 for (OCShare share
: shares
) {
1317 String path
= share
.getPath();
1318 if (share
.isFolder()) {
1319 path
= path
+ FileUtils
.PATH_SEPARATOR
;
1322 // Update OCFile with data from share: ShareByLink and publicLink
1323 OCFile file
= getFileByPath(path
);
1325 if (share
.getShareType().equals(ShareType
.PUBLIC_LINK
)) {
1326 file
.setShareViaLink(true
);
1327 sharedFiles
.add(file
);
1332 updateSharedFiles(sharedFiles
);
1336 public void saveSharesInFolder(ArrayList
<OCShare
> shares
, OCFile folder
) {
1337 resetShareFlagsInFolder(folder
);
1338 ArrayList
<ContentProviderOperation
> operations
= new ArrayList
<ContentProviderOperation
>();
1339 operations
= prepareRemoveSharesInFolder(folder
, operations
);
1341 if (shares
!= null
) {
1342 // prepare operations to insert or update files to save in the given folder
1343 for (OCShare share
: shares
) {
1344 ContentValues cv
= new ContentValues();
1345 cv
.put(ProviderTableMeta
.OCSHARES_FILE_SOURCE
, share
.getFileSource());
1346 cv
.put(ProviderTableMeta
.OCSHARES_ITEM_SOURCE
, share
.getItemSource());
1347 cv
.put(ProviderTableMeta
.OCSHARES_SHARE_TYPE
, share
.getShareType().getValue());
1348 cv
.put(ProviderTableMeta
.OCSHARES_SHARE_WITH
, share
.getShareWith());
1349 cv
.put(ProviderTableMeta
.OCSHARES_PATH
, share
.getPath());
1350 cv
.put(ProviderTableMeta
.OCSHARES_PERMISSIONS
, share
.getPermissions());
1351 cv
.put(ProviderTableMeta
.OCSHARES_SHARED_DATE
, share
.getSharedDate());
1352 cv
.put(ProviderTableMeta
.OCSHARES_EXPIRATION_DATE
, share
.getExpirationDate());
1353 cv
.put(ProviderTableMeta
.OCSHARES_TOKEN
, share
.getToken());
1355 ProviderTableMeta
.OCSHARES_SHARE_WITH_DISPLAY_NAME
,
1356 share
.getSharedWithDisplayName()
1358 cv
.put(ProviderTableMeta
.OCSHARES_IS_DIRECTORY
, share
.isFolder() ?
1 : 0);
1359 cv
.put(ProviderTableMeta
.OCSHARES_USER_ID
, share
.getUserId());
1360 cv
.put(ProviderTableMeta
.OCSHARES_ID_REMOTE_SHARED
, share
.getIdRemoteShared());
1361 cv
.put(ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
, mAccount
.name
);
1363 // adding a new share resource
1365 ContentProviderOperation
.newInsert(ProviderTableMeta
.CONTENT_URI_SHARE
).
1372 // apply operations in batch
1373 if (operations
.size() > 0) {
1374 Log_OC
.d(TAG
, "Sending " + operations
.size() + " operations to FileContentProvider");
1376 if (getContentResolver() != null
) {
1377 getContentResolver().applyBatch(MainApp
.getAuthority(), operations
);
1380 getContentProviderClient().applyBatch(operations
);
1383 } catch (OperationApplicationException e
) {
1384 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
1386 } catch (RemoteException e
) {
1387 Log_OC
.e(TAG
, "Exception in batch of operations " + e
.getMessage());
1393 private ArrayList
<ContentProviderOperation
> prepareRemoveSharesInFolder(
1394 OCFile folder
, ArrayList
<ContentProviderOperation
> preparedOperations
) {
1395 if (folder
!= null
) {
1396 String where
= ProviderTableMeta
.OCSHARES_PATH
+ "=?" + " AND "
1397 + ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
+ "=?";
1398 String
[] whereArgs
= new String
[]{ "", mAccount
.name
};
1400 // TODO Enable when "On Device" is recovered ?
1401 Vector
<OCFile
> files
= getFolderContent(folder
/*, false*/);
1403 for (OCFile file
: files
) {
1404 whereArgs
[0] = file
.getRemotePath();
1405 preparedOperations
.add(
1406 ContentProviderOperation
.newDelete(ProviderTableMeta
.CONTENT_URI_SHARE
).
1407 withSelection(where
, whereArgs
).
1412 return preparedOperations
;
1415 public ArrayList
<OCShare
> getSharesWithForAFile(String filePath
, String accountName
){
1417 String where
= ProviderTableMeta
.OCSHARES_PATH
+ "=?" + " AND "
1418 + ProviderTableMeta
.OCSHARES_ACCOUNT_OWNER
+ "=?"+ "AND"
1419 + " (" + ProviderTableMeta
.OCSHARES_SHARE_TYPE
+ "=? OR "
1420 + ProviderTableMeta
.OCSHARES_SHARE_TYPE
+ "=? ) ";
1421 String
[] whereArgs
= new String
[]{ filePath
, accountName
,
1422 Integer
.toString(ShareType
.USER
.getValue()),
1423 Integer
.toString(ShareType
.GROUP
.getValue()) };
1426 if (getContentResolver() != null
) {
1427 c
= getContentResolver().query(
1428 ProviderTableMeta
.CONTENT_URI_SHARE
,
1429 null
, where
, whereArgs
, null
);
1432 c
= getContentProviderClient().query(
1433 ProviderTableMeta
.CONTENT_URI_SHARE
,
1434 null
, where
, whereArgs
, null
);
1436 } catch (RemoteException e
) {
1437 Log_OC
.e(TAG
, "Could not get list of shares with: " + e
.getMessage());
1441 ArrayList
<OCShare
> shares
= new ArrayList
<OCShare
>();
1442 OCShare share
= null
;
1443 if (c
.moveToFirst()) {
1445 share
= createShareInstance(c
);
1448 } while (c
.moveToNext());
1455 public void triggerMediaScan(String path
) {
1456 Intent intent
= new Intent(Intent
.ACTION_MEDIA_SCANNER_SCAN_FILE
);
1457 intent
.setData(Uri
.fromFile(new File(path
)));
1458 MainApp
.getAppContext().sendBroadcast(intent
);
1461 public void deleteFileInMediaScan(String path
) {
1463 String mimetypeString
= FileStorageUtils
.getMimeTypeFromName(path
);
1464 ContentResolver contentResolver
= getContentResolver();
1466 if (contentResolver
!= null
) {
1467 if (mimetypeString
.startsWith("image/")) {
1469 contentResolver
.delete(MediaStore
.Images
.Media
.EXTERNAL_CONTENT_URI
,
1470 MediaStore
.Images
.Media
.DATA
+ "=?", new String
[]{path
});
1471 } else if (mimetypeString
.startsWith("audio/")) {
1473 contentResolver
.delete(MediaStore
.Audio
.Media
.EXTERNAL_CONTENT_URI
,
1474 MediaStore
.Audio
.Media
.DATA
+ "=?", new String
[]{path
});
1475 } else if (mimetypeString
.startsWith("video/")) {
1477 contentResolver
.delete(MediaStore
.Video
.Media
.EXTERNAL_CONTENT_URI
,
1478 MediaStore
.Video
.Media
.DATA
+ "=?", new String
[]{path
});
1481 ContentProviderClient contentProviderClient
= getContentProviderClient();
1483 if (mimetypeString
.startsWith("image/")) {
1485 contentProviderClient
.delete(MediaStore
.Images
.Media
.EXTERNAL_CONTENT_URI
,
1486 MediaStore
.Images
.Media
.DATA
+ "=?", new String
[]{path
});
1487 } else if (mimetypeString
.startsWith("audio/")) {
1489 contentProviderClient
.delete(MediaStore
.Audio
.Media
.EXTERNAL_CONTENT_URI
,
1490 MediaStore
.Audio
.Media
.DATA
+ "=?", new String
[]{path
});
1491 } else if (mimetypeString
.startsWith("video/")) {
1493 contentProviderClient
.delete(MediaStore
.Video
.Media
.EXTERNAL_CONTENT_URI
,
1494 MediaStore
.Video
.Media
.DATA
+ "=?", new String
[]{path
});
1496 } catch (RemoteException e
) {
1497 Log_OC
.e(TAG
, "Exception deleting media file in MediaStore " + e
.getMessage());
1503 public void saveConflict(OCFile file
, String etagInConflict
) {
1504 if (!file
.isDown()) {
1505 etagInConflict
= null
;
1507 ContentValues cv
= new ContentValues();
1508 cv
.put(ProviderTableMeta
.FILE_ETAG_IN_CONFLICT
, etagInConflict
);
1510 if (getContentResolver() != null
) {
1511 updated
= getContentResolver().update(
1512 ProviderTableMeta
.CONTENT_URI_FILE
,
1514 ProviderTableMeta
._ID
+ "=?",
1515 new String
[] { String
.valueOf(file
.getFileId())}
1519 updated
= getContentProviderClient().update(
1520 ProviderTableMeta
.CONTENT_URI_FILE
,
1522 ProviderTableMeta
._ID
+ "=?",
1523 new String
[]{String
.valueOf(file
.getFileId())}
1525 } catch (RemoteException e
) {
1526 Log_OC
.e(TAG
, "Failed saving conflict in database " + e
.getMessage());
1530 Log_OC
.d(TAG
, "Number of files updated with CONFLICT: " + updated
);
1533 if (etagInConflict
!= null
) {
1534 /// set conflict in all ancestor folders
1536 long parentId
= file
.getParentId();
1537 Set
<String
> ancestorIds
= new HashSet
<String
>();
1538 while (parentId
!= FileDataStorageManager
.ROOT_PARENT_ID
) {
1539 ancestorIds
.add(Long
.toString(parentId
));
1540 parentId
= getFileById(parentId
).getParentId();
1543 if (ancestorIds
.size() > 0) {
1544 StringBuffer whereBuffer
= new StringBuffer();
1545 whereBuffer
.append(ProviderTableMeta
._ID
).append(" IN (");
1546 for (int i
= 0; i
< ancestorIds
.size() - 1; i
++) {
1547 whereBuffer
.append("?,");
1549 whereBuffer
.append("?");
1550 whereBuffer
.append(")");
1552 if (getContentResolver() != null
) {
1553 updated
= getContentResolver().update(
1554 ProviderTableMeta
.CONTENT_URI_FILE
,
1556 whereBuffer
.toString(),
1557 ancestorIds
.toArray(new String
[]{})
1561 updated
= getContentProviderClient().update(
1562 ProviderTableMeta
.CONTENT_URI_FILE
,
1564 whereBuffer
.toString(),
1565 ancestorIds
.toArray(new String
[]{})
1567 } catch (RemoteException e
) {
1568 Log_OC
.e(TAG
, "Failed saving conflict in database " + e
.getMessage());
1571 } // else file is ROOT folder, no parent to set in conflict
1574 /// update conflict in ancestor folders
1575 // (not directly unset; maybe there are more conflicts below them)
1576 String parentPath
= file
.getRemotePath();
1577 if (parentPath
.endsWith(OCFile
.PATH_SEPARATOR
)) {
1578 parentPath
= parentPath
.substring(0, parentPath
.length() - 1);
1580 parentPath
= parentPath
.substring(0, parentPath
.lastIndexOf(OCFile
.PATH_SEPARATOR
) + 1);
1582 Log_OC
.d(TAG
, "checking parents to remove conflict; STARTING with " + parentPath
);
1583 while (parentPath
.length() > 0) {
1586 ProviderTableMeta
.FILE_ETAG_IN_CONFLICT
+ " IS NOT NULL AND " +
1587 ProviderTableMeta
.FILE_CONTENT_TYPE
+ " != 'DIR' AND " +
1588 ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ " = ? AND " +
1589 ProviderTableMeta
.FILE_PATH
+ " LIKE ?";
1590 Cursor descendentsInConflict
= getContentResolver().query(
1591 ProviderTableMeta
.CONTENT_URI_FILE
,
1592 new String
[]{ProviderTableMeta
._ID
},
1594 new String
[]{mAccount
.name
, parentPath
+ "%"},
1597 if (descendentsInConflict
== null
|| descendentsInConflict
.getCount() == 0) {
1598 Log_OC
.d(TAG
, "NO MORE conflicts in " + parentPath
);
1599 if (getContentResolver() != null
) {
1600 updated
= getContentResolver().update(
1601 ProviderTableMeta
.CONTENT_URI_FILE
,
1603 ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=? AND " +
1604 ProviderTableMeta
.FILE_PATH
+ "=?",
1605 new String
[]{mAccount
.name
, parentPath
}
1609 updated
= getContentProviderClient().update(
1610 ProviderTableMeta
.CONTENT_URI_FILE
,
1612 ProviderTableMeta
.FILE_ACCOUNT_OWNER
+ "=? AND " +
1613 ProviderTableMeta
.FILE_PATH
+ "=?"
1614 , new String
[]{mAccount
.name
, parentPath
}
1616 } catch (RemoteException e
) {
1617 Log_OC
.e(TAG
, "Failed saving conflict in database " + e
.getMessage());
1622 Log_OC
.d(TAG
, "STILL " + descendentsInConflict
.getCount() + " in " + parentPath
);
1625 if (descendentsInConflict
!= null
) {
1626 descendentsInConflict
.close();
1629 parentPath
= parentPath
.substring(0, parentPath
.length() - 1); // trim last /
1630 parentPath
= parentPath
.substring(0, parentPath
.lastIndexOf(OCFile
.PATH_SEPARATOR
) + 1);
1631 Log_OC
.d(TAG
, "checking parents to remove conflict; NEXT " + parentPath
);