756 lines
31 KiB
Java
756 lines
31 KiB
Java
/*
|
|
* ownCloud Android client application
|
|
*
|
|
* Copyright (C) 2012 Bartek Przybylski
|
|
* Copyright (C) 2012-2016 ownCloud Inc.
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License version 2,
|
|
* as published by the Free Software Foundation.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
package com.owncloud.android.files.services;
|
|
|
|
import android.accounts.Account;
|
|
import android.accounts.AccountManager;
|
|
import android.accounts.OnAccountsUpdateListener;
|
|
import android.app.Notification;
|
|
import android.app.NotificationManager;
|
|
import android.app.PendingIntent;
|
|
import android.app.Service;
|
|
import android.content.Intent;
|
|
import android.graphics.BitmapFactory;
|
|
import android.os.Binder;
|
|
import android.os.Handler;
|
|
import android.os.HandlerThread;
|
|
import android.os.IBinder;
|
|
import android.os.Looper;
|
|
import android.os.Message;
|
|
import android.os.Process;
|
|
import android.util.Pair;
|
|
|
|
import com.nextcloud.client.account.User;
|
|
import com.nextcloud.client.account.UserAccountManager;
|
|
import com.nextcloud.client.files.downloader.DownloadTask;
|
|
import com.owncloud.android.R;
|
|
import com.owncloud.android.authentication.AuthenticatorActivity;
|
|
import com.owncloud.android.datamodel.FileDataStorageManager;
|
|
import com.owncloud.android.datamodel.OCFile;
|
|
import com.owncloud.android.datamodel.UploadsStorageManager;
|
|
import com.owncloud.android.lib.common.OwnCloudAccount;
|
|
import com.owncloud.android.lib.common.OwnCloudClient;
|
|
import com.owncloud.android.lib.common.OwnCloudClientManagerFactory;
|
|
import com.owncloud.android.lib.common.network.OnDatatransferProgressListener;
|
|
import com.owncloud.android.lib.common.operations.RemoteOperationResult;
|
|
import com.owncloud.android.lib.common.operations.RemoteOperationResult.ResultCode;
|
|
import com.owncloud.android.lib.common.utils.Log_OC;
|
|
import com.owncloud.android.lib.resources.files.FileUtils;
|
|
import com.owncloud.android.operations.DownloadFileOperation;
|
|
import com.owncloud.android.providers.DocumentsStorageProvider;
|
|
import com.owncloud.android.ui.activity.ConflictsResolveActivity;
|
|
import com.owncloud.android.ui.activity.FileActivity;
|
|
import com.owncloud.android.ui.activity.FileDisplayActivity;
|
|
import com.owncloud.android.ui.dialog.SendShareDialog;
|
|
import com.owncloud.android.ui.fragment.OCFileListFragment;
|
|
import com.owncloud.android.ui.notifications.NotificationUtils;
|
|
import com.owncloud.android.ui.preview.PreviewImageActivity;
|
|
import com.owncloud.android.ui.preview.PreviewImageFragment;
|
|
import com.owncloud.android.utils.ErrorMessageAdapter;
|
|
import com.owncloud.android.utils.MimeTypeUtil;
|
|
import com.owncloud.android.utils.theme.ThemeColorUtils;
|
|
|
|
import java.io.File;
|
|
import java.security.SecureRandom;
|
|
import java.util.AbstractList;
|
|
import java.util.HashMap;
|
|
import java.util.Iterator;
|
|
import java.util.Map;
|
|
import java.util.Vector;
|
|
|
|
import javax.inject.Inject;
|
|
|
|
import androidx.core.app.NotificationCompat;
|
|
import androidx.localbroadcastmanager.content.LocalBroadcastManager;
|
|
import dagger.android.AndroidInjection;
|
|
import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
|
|
|
|
public class FileDownloader extends Service
|
|
implements OnDatatransferProgressListener, OnAccountsUpdateListener {
|
|
|
|
public static final String EXTRA_USER = "USER";
|
|
public static final String EXTRA_FILE = "FILE";
|
|
|
|
private static final String DOWNLOAD_ADDED_MESSAGE = "DOWNLOAD_ADDED";
|
|
private static final String DOWNLOAD_FINISH_MESSAGE = "DOWNLOAD_FINISH";
|
|
public static final String EXTRA_DOWNLOAD_RESULT = "RESULT";
|
|
public static final String EXTRA_REMOTE_PATH = "REMOTE_PATH";
|
|
public static final String EXTRA_LINKED_TO_PATH = "LINKED_TO";
|
|
public static final String ACCOUNT_NAME = "ACCOUNT_NAME";
|
|
|
|
private static final int FOREGROUND_SERVICE_ID = 412;
|
|
|
|
private static final String TAG = FileDownloader.class.getSimpleName();
|
|
|
|
private Looper mServiceLooper;
|
|
private ServiceHandler mServiceHandler;
|
|
private IBinder mBinder;
|
|
private OwnCloudClient mDownloadClient;
|
|
private Account mCurrentAccount;
|
|
private FileDataStorageManager mStorageManager;
|
|
|
|
private IndexedForest<DownloadFileOperation> mPendingDownloads = new IndexedForest<>();
|
|
|
|
private DownloadFileOperation mCurrentDownload;
|
|
|
|
private NotificationManager mNotificationManager;
|
|
private NotificationCompat.Builder mNotificationBuilder;
|
|
private int mLastPercent;
|
|
|
|
private Notification mNotification;
|
|
|
|
private long conflictUploadId;
|
|
|
|
public boolean mStartedDownload = false;
|
|
|
|
@Inject UserAccountManager accountManager;
|
|
@Inject UploadsStorageManager uploadsStorageManager;
|
|
@Inject LocalBroadcastManager localBroadcastManager;
|
|
|
|
public static String getDownloadAddedMessage() {
|
|
return FileDownloader.class.getName() + DOWNLOAD_ADDED_MESSAGE;
|
|
}
|
|
|
|
public static String getDownloadFinishMessage() {
|
|
return FileDownloader.class.getName() + DOWNLOAD_FINISH_MESSAGE;
|
|
}
|
|
|
|
/**
|
|
* Service initialization
|
|
*/
|
|
@Override
|
|
public void onCreate() {
|
|
super.onCreate();
|
|
AndroidInjection.inject(this);
|
|
Log_OC.d(TAG, "Creating service");
|
|
mNotificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
|
|
HandlerThread thread = new HandlerThread("FileDownloaderThread", Process.THREAD_PRIORITY_BACKGROUND);
|
|
thread.start();
|
|
mServiceLooper = thread.getLooper();
|
|
mServiceHandler = new ServiceHandler(mServiceLooper, this);
|
|
mBinder = new FileDownloaderBinder();
|
|
|
|
NotificationCompat.Builder builder = new NotificationCompat.Builder(this).setContentTitle(
|
|
getApplicationContext().getResources().getString(R.string.app_name))
|
|
.setContentText(getApplicationContext().getResources().getString(R.string.foreground_service_download))
|
|
.setSmallIcon(R.drawable.notification_icon)
|
|
.setLargeIcon(BitmapFactory.decodeResource(getResources(), R.drawable.notification_icon))
|
|
.setColor(ThemeColorUtils.primaryColor(getApplicationContext(), true));
|
|
|
|
if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.O) {
|
|
builder.setChannelId(NotificationUtils.NOTIFICATION_CHANNEL_DOWNLOAD);
|
|
}
|
|
|
|
mNotification = builder.build();
|
|
|
|
// add AccountsUpdatedListener
|
|
AccountManager am = AccountManager.get(getApplicationContext());
|
|
am.addOnAccountsUpdatedListener(this, null, false);
|
|
}
|
|
|
|
|
|
/**
|
|
* Service clean up
|
|
*/
|
|
@Override
|
|
public void onDestroy() {
|
|
Log_OC.v(TAG, "Destroying service");
|
|
mBinder = null;
|
|
mServiceHandler = null;
|
|
mServiceLooper.quit();
|
|
mServiceLooper = null;
|
|
mNotificationManager = null;
|
|
|
|
// remove AccountsUpdatedListener
|
|
AccountManager am = AccountManager.get(getApplicationContext());
|
|
am.removeOnAccountsUpdatedListener(this);
|
|
|
|
super.onDestroy();
|
|
}
|
|
|
|
|
|
/**
|
|
* Entry point to add one or several files to the queue of downloads.
|
|
*
|
|
* New downloads are added calling to startService(), resulting in a call to this method.
|
|
* This ensures the service will keep on working although the caller activity goes away.
|
|
*/
|
|
@Override
|
|
public int onStartCommand(Intent intent, int flags, int startId) {
|
|
Log_OC.d(TAG, "Starting command with id " + startId);
|
|
|
|
startForeground(FOREGROUND_SERVICE_ID, mNotification);
|
|
|
|
if (intent == null || !intent.hasExtra(EXTRA_USER) || !intent.hasExtra(EXTRA_FILE)) {
|
|
Log_OC.e(TAG, "Not enough information provided in intent");
|
|
return START_NOT_STICKY;
|
|
} else {
|
|
final User user = intent.getParcelableExtra(EXTRA_USER);
|
|
final OCFile file = intent.getParcelableExtra(EXTRA_FILE);
|
|
final String behaviour = intent.getStringExtra(OCFileListFragment.DOWNLOAD_BEHAVIOUR);
|
|
String activityName = intent.getStringExtra(SendShareDialog.ACTIVITY_NAME);
|
|
String packageName = intent.getStringExtra(SendShareDialog.PACKAGE_NAME);
|
|
conflictUploadId = intent.getLongExtra(ConflictsResolveActivity.EXTRA_CONFLICT_UPLOAD_ID, -1);
|
|
AbstractList<String> requestedDownloads = new Vector<String>();
|
|
try {
|
|
DownloadFileOperation newDownload = new DownloadFileOperation(user.toPlatformAccount(),
|
|
file,
|
|
behaviour,
|
|
activityName,
|
|
packageName,
|
|
getBaseContext());
|
|
newDownload.addDatatransferProgressListener(this);
|
|
newDownload.addDatatransferProgressListener((FileDownloaderBinder) mBinder);
|
|
Pair<String, String> putResult = mPendingDownloads.putIfAbsent(user.getAccountName(),
|
|
file.getRemotePath(),
|
|
newDownload);
|
|
if (putResult != null) {
|
|
String downloadKey = putResult.first;
|
|
requestedDownloads.add(downloadKey);
|
|
sendBroadcastNewDownload(newDownload, putResult.second);
|
|
} // else, file already in the queue of downloads; don't repeat the request
|
|
|
|
} catch (IllegalArgumentException e) {
|
|
Log_OC.e(TAG, "Not enough information provided in intent: " + e.getMessage());
|
|
return START_NOT_STICKY;
|
|
}
|
|
|
|
if (requestedDownloads.size() > 0) {
|
|
Message msg = mServiceHandler.obtainMessage();
|
|
msg.arg1 = startId;
|
|
msg.obj = requestedDownloads;
|
|
mServiceHandler.sendMessage(msg);
|
|
}
|
|
}
|
|
|
|
return START_NOT_STICKY;
|
|
}
|
|
|
|
/**
|
|
* Provides a binder object that clients can use to perform operations on the queue of downloads,
|
|
* excepting the addition of new files.
|
|
*
|
|
* Implemented to perform cancellation, pause and resume of existing downloads.
|
|
*/
|
|
@Override
|
|
public IBinder onBind(Intent intent) {
|
|
return mBinder;
|
|
}
|
|
|
|
|
|
/**
|
|
* Called when ALL the bound clients were onbound.
|
|
*/
|
|
@Override
|
|
public boolean onUnbind(Intent intent) {
|
|
((FileDownloaderBinder) mBinder).clearListeners();
|
|
return false; // not accepting rebinding (default behaviour)
|
|
}
|
|
|
|
@Override
|
|
public void onAccountsUpdated(Account[] accounts) {
|
|
//review the current download and cancel it if its account doesn't exist
|
|
if (mCurrentDownload != null && !accountManager.exists(mCurrentDownload.getAccount())) {
|
|
mCurrentDownload.cancel();
|
|
}
|
|
// The rest of downloads are cancelled when they try to start
|
|
}
|
|
|
|
|
|
/**
|
|
* Binder to let client components to perform operations on the queue of downloads.
|
|
* <p/>
|
|
* It provides by itself the available operations.
|
|
*/
|
|
public class FileDownloaderBinder extends Binder implements OnDatatransferProgressListener {
|
|
|
|
/**
|
|
* Map of listeners that will be reported about progress of downloads from a
|
|
* {@link FileDownloaderBinder}
|
|
* instance.
|
|
*/
|
|
private Map<Long, OnDatatransferProgressListener> mBoundListeners =
|
|
new HashMap<Long, OnDatatransferProgressListener>();
|
|
|
|
|
|
/**
|
|
* Cancels a pending or current download of a remote file.
|
|
*
|
|
* @param account ownCloud account where the remote file is stored.
|
|
* @param file A file in the queue of pending downloads
|
|
*/
|
|
public void cancel(Account account, OCFile file) {
|
|
Pair<DownloadFileOperation, String> removeResult =
|
|
mPendingDownloads.remove(account.name, file.getRemotePath());
|
|
DownloadFileOperation download = removeResult.first;
|
|
if (download != null) {
|
|
download.cancel();
|
|
} else {
|
|
if (mCurrentDownload != null && mCurrentAccount != null &&
|
|
mCurrentDownload.getRemotePath().startsWith(file.getRemotePath()) &&
|
|
account.name.equals(mCurrentAccount.name)) {
|
|
mCurrentDownload.cancel();
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Cancels all the downloads for an account
|
|
*
|
|
* @param account ownCloud account.
|
|
*/
|
|
public void cancel(Account account) {
|
|
Log_OC.d(TAG, "Account= " + account.name);
|
|
|
|
if (mCurrentDownload != null) {
|
|
Log_OC.d(TAG, "Current Download Account= " + mCurrentDownload.getAccount().name);
|
|
if (mCurrentDownload.getAccount().name.equals(account.name)) {
|
|
mCurrentDownload.cancel();
|
|
}
|
|
}
|
|
// Cancel pending downloads
|
|
cancelDownloadsForAccount(account);
|
|
}
|
|
|
|
public void clearListeners() {
|
|
mBoundListeners.clear();
|
|
}
|
|
|
|
|
|
/**
|
|
* Returns True when the file described by 'file' in the ownCloud account 'account'
|
|
* is downloading or waiting to download.
|
|
*
|
|
* If 'file' is a directory, returns 'true' if any of its descendant files is downloading or
|
|
* waiting to download.
|
|
*
|
|
* @param user user where the remote file is stored.
|
|
* @param file A file that could be in the queue of downloads.
|
|
*/
|
|
public boolean isDownloading(User user, OCFile file) {
|
|
return user != null && file != null && mPendingDownloads.contains(user.getAccountName(), file.getRemotePath());
|
|
}
|
|
|
|
|
|
/**
|
|
* Adds a listener interested in the progress of the download for a concrete file.
|
|
*
|
|
* @param listener Object to notify about progress of transfer.
|
|
* @param file {@link OCFile} of interest for listener.
|
|
*/
|
|
public void addDatatransferProgressListener(OnDatatransferProgressListener listener, OCFile file) {
|
|
if (file == null || listener == null) {
|
|
return;
|
|
}
|
|
mBoundListeners.put(file.getFileId(), listener);
|
|
}
|
|
|
|
|
|
/**
|
|
* Removes a listener interested in the progress of the download for a concrete file.
|
|
*
|
|
* @param listener Object to notify about progress of transfer.
|
|
* @param file {@link OCFile} of interest for listener.
|
|
*/
|
|
public void removeDatatransferProgressListener(OnDatatransferProgressListener listener, OCFile file) {
|
|
if (file == null || listener == null) {
|
|
return;
|
|
}
|
|
Long fileId = file.getFileId();
|
|
if (mBoundListeners.get(fileId) == listener) {
|
|
mBoundListeners.remove(fileId);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onTransferProgress(long progressRate, long totalTransferredSoFar,
|
|
long totalToTransfer, String fileName) {
|
|
OnDatatransferProgressListener boundListener =
|
|
mBoundListeners.get(mCurrentDownload.getFile().getFileId());
|
|
if (boundListener != null) {
|
|
boundListener.onTransferProgress(progressRate, totalTransferredSoFar,
|
|
totalToTransfer, fileName);
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* Download worker. Performs the pending downloads in the order they were requested.
|
|
|
|
* Created with the Looper of a new thread, started in {@link FileUploader#onCreate()}.
|
|
*/
|
|
private static class ServiceHandler extends Handler {
|
|
// don't make it a final class, and don't remove the static ; lint will warn about a
|
|
// possible memory leak
|
|
FileDownloader mService;
|
|
|
|
public ServiceHandler(Looper looper, FileDownloader service) {
|
|
super(looper);
|
|
if (service == null) {
|
|
throw new IllegalArgumentException("Received invalid NULL in parameter 'service'");
|
|
}
|
|
mService = service;
|
|
}
|
|
|
|
@Override
|
|
public void handleMessage(Message msg) {
|
|
@SuppressWarnings("unchecked")
|
|
AbstractList<String> requestedDownloads = (AbstractList<String>) msg.obj;
|
|
if (msg.obj != null) {
|
|
Iterator<String> it = requestedDownloads.iterator();
|
|
while (it.hasNext()) {
|
|
String next = it.next();
|
|
mService.downloadFile(next);
|
|
}
|
|
}
|
|
mService.mStartedDownload=false;
|
|
(new Handler()).postDelayed(new Runnable(){
|
|
public void run() {
|
|
if(!mService.mStartedDownload){
|
|
mService.mNotificationManager.cancel(R.string.downloader_download_in_progress_ticker);
|
|
}
|
|
}}, 2000);
|
|
|
|
|
|
Log_OC.d(TAG, "Stopping after command with id " + msg.arg1);
|
|
mService.mNotificationManager.cancel(FOREGROUND_SERVICE_ID);
|
|
mService.stopForeground(true);
|
|
mService.stopSelf(msg.arg1);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* Core download method: requests a file to download and stores it.
|
|
*
|
|
* @param downloadKey Key to access the download to perform, contained in mPendingDownloads
|
|
*/
|
|
private void downloadFile(String downloadKey) {
|
|
|
|
mStartedDownload = true;
|
|
mCurrentDownload = mPendingDownloads.get(downloadKey);
|
|
|
|
if (mCurrentDownload != null) {
|
|
// Detect if the account exists
|
|
if (accountManager.exists(mCurrentDownload.getAccount())) {
|
|
Log_OC.d(TAG, "Account " + mCurrentDownload.getAccount().name + " exists");
|
|
|
|
notifyDownloadStart(mCurrentDownload);
|
|
|
|
RemoteOperationResult downloadResult = null;
|
|
try {
|
|
/// prepare client object to send the request to the ownCloud server
|
|
if (mCurrentAccount == null ||
|
|
!mCurrentAccount.equals(mCurrentDownload.getAccount())) {
|
|
mCurrentAccount = mCurrentDownload.getAccount();
|
|
mStorageManager = new FileDataStorageManager(
|
|
mCurrentAccount,
|
|
getContentResolver()
|
|
);
|
|
} // else, reuse storage manager from previous operation
|
|
|
|
// always get client from client manager, to get fresh credentials in case
|
|
// of update
|
|
OwnCloudAccount ocAccount = new OwnCloudAccount(mCurrentAccount, this);
|
|
mDownloadClient = OwnCloudClientManagerFactory.getDefaultSingleton().
|
|
getClientFor(ocAccount, this);
|
|
|
|
|
|
/// perform the download
|
|
downloadResult = mCurrentDownload.execute(mDownloadClient);
|
|
if (downloadResult.isSuccess()) {
|
|
saveDownloadedFile();
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
Log_OC.e(TAG, "Error downloading", e);
|
|
downloadResult = new RemoteOperationResult(e);
|
|
|
|
} finally {
|
|
Pair<DownloadFileOperation, String> removeResult = mPendingDownloads.removePayload(
|
|
mCurrentAccount.name, mCurrentDownload.getRemotePath());
|
|
|
|
if (downloadResult == null) {
|
|
downloadResult = new RemoteOperationResult(new RuntimeException("Error downloading…"));
|
|
}
|
|
|
|
/// notify result
|
|
notifyDownloadResult(mCurrentDownload, downloadResult);
|
|
|
|
sendBroadcastDownloadFinished(mCurrentDownload, downloadResult, removeResult.second);
|
|
}
|
|
|
|
} else {
|
|
// Cancel the transfer
|
|
Log_OC.d(TAG, "Account " + mCurrentDownload.getAccount().toString() +
|
|
" doesn't exist");
|
|
cancelDownloadsForAccount(mCurrentDownload.getAccount());
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* Updates the OC File after a successful download.
|
|
*
|
|
* TODO move to DownloadFileOperation
|
|
* unify with code from {@link DocumentsStorageProvider} and {@link DownloadTask}.
|
|
*/
|
|
private void saveDownloadedFile() {
|
|
OCFile file = mStorageManager.getFileById(mCurrentDownload.getFile().getFileId());
|
|
|
|
if (file == null) {
|
|
// try to get file via path, needed for overwriting existing files on conflict dialog
|
|
file = mStorageManager.getFileByDecryptedRemotePath(mCurrentDownload.getFile().getRemotePath());
|
|
}
|
|
|
|
if (file == null) {
|
|
Log_OC.e(this, "Could not save " + mCurrentDownload.getFile().getRemotePath());
|
|
return;
|
|
}
|
|
|
|
long syncDate = System.currentTimeMillis();
|
|
file.setLastSyncDateForProperties(syncDate);
|
|
file.setLastSyncDateForData(syncDate);
|
|
file.setUpdateThumbnailNeeded(true);
|
|
file.setModificationTimestamp(mCurrentDownload.getModificationTimestamp());
|
|
file.setModificationTimestampAtLastSyncForData(mCurrentDownload.getModificationTimestamp());
|
|
file.setEtag(mCurrentDownload.getEtag());
|
|
file.setMimeType(mCurrentDownload.getMimeType());
|
|
file.setStoragePath(mCurrentDownload.getSavePath());
|
|
file.setFileLength(new File(mCurrentDownload.getSavePath()).length());
|
|
file.setRemoteId(mCurrentDownload.getFile().getRemoteId());
|
|
mStorageManager.saveFile(file);
|
|
if (MimeTypeUtil.isMedia(mCurrentDownload.getMimeType())) {
|
|
FileDataStorageManager.triggerMediaScan(file.getStoragePath(), file);
|
|
}
|
|
mStorageManager.saveConflict(file, null);
|
|
}
|
|
|
|
/**
|
|
* Creates a status notification to show the download progress
|
|
*
|
|
* @param download Download operation starting.
|
|
*/
|
|
private void notifyDownloadStart(DownloadFileOperation download) {
|
|
/// create status notification with a progress bar
|
|
mLastPercent = 0;
|
|
mNotificationBuilder = NotificationUtils.newNotificationBuilder(this);
|
|
mNotificationBuilder
|
|
.setSmallIcon(R.drawable.notification_icon)
|
|
.setTicker(getString(R.string.downloader_download_in_progress_ticker))
|
|
.setContentTitle(getString(R.string.downloader_download_in_progress_ticker))
|
|
.setOngoing(true)
|
|
.setProgress(100, 0, download.getSize() < 0)
|
|
.setContentText(
|
|
String.format(getString(R.string.downloader_download_in_progress_content), 0,
|
|
new File(download.getSavePath()).getName())
|
|
);
|
|
|
|
if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.O) {
|
|
mNotificationBuilder.setChannelId(NotificationUtils.NOTIFICATION_CHANNEL_DOWNLOAD);
|
|
}
|
|
|
|
/// includes a pending intent in the notification showing the details view of the file
|
|
Intent showDetailsIntent = null;
|
|
if (PreviewImageFragment.canBePreviewed(download.getFile())) {
|
|
showDetailsIntent = new Intent(this, PreviewImageActivity.class);
|
|
} else {
|
|
showDetailsIntent = new Intent(this, FileDisplayActivity.class);
|
|
}
|
|
showDetailsIntent.putExtra(FileActivity.EXTRA_FILE, download.getFile());
|
|
showDetailsIntent.putExtra(FileActivity.EXTRA_ACCOUNT, download.getAccount());
|
|
showDetailsIntent.setFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
|
|
|
|
mNotificationBuilder.setContentIntent(PendingIntent.getActivity(this, (int) System.currentTimeMillis(),
|
|
showDetailsIntent, 0));
|
|
|
|
|
|
if (mNotificationManager == null) {
|
|
mNotificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
|
|
}
|
|
if (mNotificationManager != null) {
|
|
mNotificationManager.notify(R.string.downloader_download_in_progress_ticker, mNotificationBuilder.build());
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* Callback method to update the progress bar in the status notification.
|
|
*/
|
|
@Override
|
|
public void onTransferProgress(long progressRate, long totalTransferredSoFar,
|
|
long totalToTransfer, String filePath) {
|
|
int percent = (int) (100.0 * ((double) totalTransferredSoFar) / ((double) totalToTransfer));
|
|
if (percent != mLastPercent) {
|
|
mNotificationBuilder.setProgress(100, percent, totalToTransfer < 0);
|
|
String fileName = filePath.substring(filePath.lastIndexOf(FileUtils.PATH_SEPARATOR) + 1);
|
|
String text = String.format(getString(R.string.downloader_download_in_progress_content), percent, fileName);
|
|
mNotificationBuilder.setContentText(text);
|
|
|
|
if (mNotificationManager == null) {
|
|
mNotificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
|
|
}
|
|
|
|
if (mNotificationManager != null) {
|
|
mNotificationManager.notify(R.string.downloader_download_in_progress_ticker,
|
|
mNotificationBuilder.build());
|
|
}
|
|
}
|
|
mLastPercent = percent;
|
|
}
|
|
|
|
|
|
/**
|
|
* Updates the status notification with the result of a download operation.
|
|
*
|
|
* @param downloadResult Result of the download operation.
|
|
* @param download Finished download operation
|
|
*/
|
|
@SuppressFBWarnings("DMI")
|
|
private void notifyDownloadResult(DownloadFileOperation download,
|
|
RemoteOperationResult downloadResult) {
|
|
if (mNotificationManager == null) {
|
|
mNotificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
|
|
}
|
|
|
|
if (!downloadResult.isCancelled()) {
|
|
if (downloadResult.isSuccess()) {
|
|
// Dont show notification except an error has occured.
|
|
return;
|
|
}
|
|
int tickerId = downloadResult.isSuccess() ?
|
|
R.string.downloader_download_succeeded_ticker : R.string.downloader_download_failed_ticker;
|
|
|
|
boolean needsToUpdateCredentials = ResultCode.UNAUTHORIZED.equals(downloadResult.getCode());
|
|
tickerId = needsToUpdateCredentials ?
|
|
R.string.downloader_download_failed_credentials_error : tickerId;
|
|
|
|
mNotificationBuilder
|
|
.setTicker(getString(tickerId))
|
|
.setContentTitle(getString(tickerId))
|
|
.setAutoCancel(true)
|
|
.setOngoing(false)
|
|
.setProgress(0, 0, false);
|
|
|
|
if (needsToUpdateCredentials) {
|
|
configureUpdateCredentialsNotification(download.getAccount());
|
|
|
|
} else {
|
|
// TODO put something smart in showDetailsIntent
|
|
Intent showDetailsIntent = new Intent();
|
|
mNotificationBuilder.setContentIntent(PendingIntent.getActivity(this, (int) System.currentTimeMillis(),
|
|
showDetailsIntent, 0));
|
|
}
|
|
|
|
mNotificationBuilder.setContentText(ErrorMessageAdapter.getErrorCauseMessage(downloadResult,
|
|
download, getResources()));
|
|
|
|
if (mNotificationManager != null) {
|
|
mNotificationManager.notify((new SecureRandom()).nextInt(), mNotificationBuilder.build());
|
|
|
|
// Remove success notification
|
|
if (downloadResult.isSuccess()) {
|
|
if (conflictUploadId > 0) {
|
|
uploadsStorageManager.removeUpload(conflictUploadId);
|
|
}
|
|
|
|
// Sleep 2 seconds, so show the notification before remove it
|
|
NotificationUtils.cancelWithDelay(mNotificationManager,
|
|
R.string.downloader_download_succeeded_ticker, 2000);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private void configureUpdateCredentialsNotification(Account account) {
|
|
// let the user update credentials with one click
|
|
Intent updateAccountCredentials = new Intent(this, AuthenticatorActivity.class);
|
|
updateAccountCredentials.putExtra(AuthenticatorActivity.EXTRA_ACCOUNT, account);
|
|
updateAccountCredentials.putExtra(
|
|
AuthenticatorActivity.EXTRA_ACTION,
|
|
AuthenticatorActivity.ACTION_UPDATE_EXPIRED_TOKEN
|
|
);
|
|
updateAccountCredentials.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
|
|
updateAccountCredentials.addFlags(Intent.FLAG_ACTIVITY_EXCLUDE_FROM_RECENTS);
|
|
updateAccountCredentials.addFlags(Intent.FLAG_FROM_BACKGROUND);
|
|
mNotificationBuilder.setContentIntent(PendingIntent.getActivity(this, (int) System.currentTimeMillis(),
|
|
updateAccountCredentials, PendingIntent.FLAG_ONE_SHOT));
|
|
}
|
|
|
|
|
|
/**
|
|
* Sends a broadcast when a download finishes in order to the interested activities can
|
|
* update their view
|
|
*
|
|
* @param download Finished download operation
|
|
* @param downloadResult Result of the download operation
|
|
* @param unlinkedFromRemotePath Path in the downloads tree where the download was unlinked from
|
|
*/
|
|
private void sendBroadcastDownloadFinished(
|
|
DownloadFileOperation download,
|
|
RemoteOperationResult downloadResult,
|
|
String unlinkedFromRemotePath) {
|
|
|
|
Intent end = new Intent(getDownloadFinishMessage());
|
|
end.putExtra(EXTRA_DOWNLOAD_RESULT, downloadResult.isSuccess());
|
|
end.putExtra(ACCOUNT_NAME, download.getAccount().name);
|
|
end.putExtra(EXTRA_REMOTE_PATH, download.getRemotePath());
|
|
end.putExtra(OCFileListFragment.DOWNLOAD_BEHAVIOUR, download.getBehaviour());
|
|
end.putExtra(SendShareDialog.ACTIVITY_NAME, download.getActivityName());
|
|
end.putExtra(SendShareDialog.PACKAGE_NAME, download.getPackageName());
|
|
if (unlinkedFromRemotePath != null) {
|
|
end.putExtra(EXTRA_LINKED_TO_PATH, unlinkedFromRemotePath);
|
|
}
|
|
end.setPackage(getPackageName());
|
|
localBroadcastManager.sendBroadcast(end);
|
|
}
|
|
|
|
|
|
/**
|
|
* Sends a broadcast when a new download is added to the queue.
|
|
*
|
|
* @param download Added download operation
|
|
* @param linkedToRemotePath Path in the downloads tree where the download was linked to
|
|
*/
|
|
private void sendBroadcastNewDownload(DownloadFileOperation download,
|
|
String linkedToRemotePath) {
|
|
Intent added = new Intent(getDownloadAddedMessage());
|
|
added.putExtra(ACCOUNT_NAME, download.getAccount().name);
|
|
added.putExtra(EXTRA_REMOTE_PATH, download.getRemotePath());
|
|
added.putExtra(EXTRA_LINKED_TO_PATH, linkedToRemotePath);
|
|
added.setPackage(getPackageName());
|
|
localBroadcastManager.sendBroadcast(added);
|
|
}
|
|
|
|
/**
|
|
* Remove downloads of an account
|
|
*
|
|
* @param account Downloads account to remove
|
|
*/
|
|
private void cancelDownloadsForAccount(Account account) {
|
|
// Cancel pending downloads
|
|
mPendingDownloads.remove(account.name);
|
|
}
|
|
}
|