src/com/owncloud/android/files/services/FileDownloader.java

   1 /* ownCloud Android client application
   2  *   Copyright (C) 2012 Bartek Przybylski
   3  *   Copyright (C) 2012-2013 ownCloud Inc.
   4  *
   5  *   This program is free software: you can redistribute it and/or modify
   6  *   it under the terms of the GNU General Public License version 2,
   7  *   as published by the Free Software Foundation.
   8  *
   9  *   This program is distributed in the hope that it will be useful,
  10  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12  *   GNU General Public License for more details.
  13  *
  14  *   You should have received a copy of the GNU General Public License
  15  *   along with this program.  If not, see <http://www.gnu.org/licenses/>.
  16  *
  17  */
  18
  19 package com.owncloud.android.files.services;
  20
  21 import java.io.File;
  22 import java.io.IOException;
  23 import java.util.AbstractList;
  24 import java.util.HashMap;
  25 import java.util.Iterator;
  26 import java.util.Map;
  27 import java.util.Vector;
  28 import java.util.concurrent.ConcurrentHashMap;
  29 import java.util.concurrent.ConcurrentMap;
  30
  31 import com.owncloud.android.R;
  32 import com.owncloud.android.authentication.AuthenticatorActivity;
  33 import com.owncloud.android.datamodel.FileDataStorageManager;
  34 import com.owncloud.android.datamodel.OCFile;
  35
  36 import com.owncloud.android.oc_framework.network.webdav.OnDatatransferProgressListener;
  37 import com.owncloud.android.oc_framework.network.webdav.OwnCloudClientFactory;
  38 import com.owncloud.android.oc_framework.network.webdav.WebdavClient;
  39 import com.owncloud.android.operations.DownloadFileOperation;
  40 import com.owncloud.android.oc_framework.operations.RemoteOperationResult;
  41 import com.owncloud.android.oc_framework.operations.RemoteOperationResult.ResultCode;
  42 import com.owncloud.android.ui.activity.FileActivity;
  43 import com.owncloud.android.ui.activity.FileDisplayActivity;
  44 import com.owncloud.android.ui.preview.PreviewImageActivity;
  45 import com.owncloud.android.ui.preview.PreviewImageFragment;
  46 import com.owncloud.android.utils.Log_OC;
  47
  48 import android.accounts.Account;
  49 import android.accounts.AccountsException;
  50 import android.app.Notification;
  51 import android.app.NotificationManager;
  52 import android.app.PendingIntent;
  53 import android.app.Service;
  54 import android.content.Intent;
  55 import android.os.Binder;
  56 import android.os.Handler;
  57 import android.os.HandlerThread;
  58 import android.os.IBinder;
  59 import android.os.Looper;
  60 import android.os.Message;
  61 import android.os.Process;
  62 import android.widget.RemoteViews;
  63
  64 public class FileDownloader extends Service implements OnDatatransferProgressListener {
  65
  66     public static final String EXTRA_ACCOUNT = "ACCOUNT";
  67     public static final String EXTRA_FILE = "FILE";
  68
  69     private static final String DOWNLOAD_ADDED_MESSAGE = "DOWNLOAD_ADDED";
  70     private static final String DOWNLOAD_FINISH_MESSAGE = "DOWNLOAD_FINISH";
  71     public static final String EXTRA_DOWNLOAD_RESULT = "RESULT";
  72     public static final String EXTRA_FILE_PATH = "FILE_PATH";
  73     public static final String EXTRA_REMOTE_PATH = "REMOTE_PATH";
  74     public static final String ACCOUNT_NAME = "ACCOUNT_NAME";
  75
  76     private static final String TAG = "FileDownloader";
  77
  78     private Looper mServiceLooper;
  79     private ServiceHandler mServiceHandler;
  80     private IBinder mBinder;
  81     private WebdavClient mDownloadClient = null;
  82     private Account mLastAccount = null;
  83     private FileDataStorageManager mStorageManager;
  84
  85     private ConcurrentMap<String, DownloadFileOperation> mPendingDownloads = new ConcurrentHashMap<String, DownloadFileOperation>();
  86     private DownloadFileOperation mCurrentDownload = null;
  87
  88     private NotificationManager mNotificationManager;
  89     private Notification mNotification;
  90     private int mLastPercent;
  91
  92
  93     public static String getDownloadAddedMessage() {
  94         return FileDownloader.class.getName().toString() + DOWNLOAD_ADDED_MESSAGE;
  95     }
  96
  97     public static String getDownloadFinishMessage() {
  98         return FileDownloader.class.getName().toString() + DOWNLOAD_FINISH_MESSAGE;
  99     }
 100
 101     /**
 102      * Builds a key for mPendingDownloads from the account and file to download
 103      *
 104      * @param account   Account where the file to download is stored
 105      * @param file      File to download
 106      */
 107     private String buildRemoteName(Account account, OCFile file) {
 108         return account.name + file.getRemotePath();
 109     }
 110
 111
 112     /**
 113      * Service initialization
 114      */
 115     @Override
 116     public void onCreate() {
 117         super.onCreate();
 118         mNotificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
 119         HandlerThread thread = new HandlerThread("FileDownloaderThread",
 120                 Process.THREAD_PRIORITY_BACKGROUND);
 121         thread.start();
 122         mServiceLooper = thread.getLooper();
 123         mServiceHandler = new ServiceHandler(mServiceLooper, this);
 124         mBinder = new FileDownloaderBinder();
 125     }
 126
 127     /**
 128      * Entry point to add one or several files to the queue of downloads.
 129      *
 130      * New downloads are added calling to startService(), resulting in a call to this method. This ensures the service will keep on working
 131      * although the caller activity goes away.
 132      */
 133     @Override
 134     public int onStartCommand(Intent intent, int flags, int startId) {
 135         if (    !intent.hasExtra(EXTRA_ACCOUNT) ||
 136                 !intent.hasExtra(EXTRA_FILE)
 137                 /*!intent.hasExtra(EXTRA_FILE_PATH) ||
 138                 !intent.hasExtra(EXTRA_REMOTE_PATH)*/
 139            ) {
 140             Log_OC.e(TAG, "Not enough information provided in intent");
 141             return START_NOT_STICKY;
 142         }
 143         Account account = intent.getParcelableExtra(EXTRA_ACCOUNT);
 144         OCFile file = intent.getParcelableExtra(EXTRA_FILE);
 145
 146         AbstractList<String> requestedDownloads = new Vector<String>(); // dvelasco: now this always contains just one element, but that can change in a near future (download of multiple selection)
 147         String downloadKey = buildRemoteName(account, file);
 148         try {
 149             DownloadFileOperation newDownload = new DownloadFileOperation(account, file);
 150             mPendingDownloads.putIfAbsent(downloadKey, newDownload);
 151             newDownload.addDatatransferProgressListener(this);
 152             newDownload.addDatatransferProgressListener((FileDownloaderBinder)mBinder);
 153             requestedDownloads.add(downloadKey);
 154             sendBroadcastNewDownload(newDownload);
 155
 156         } catch (IllegalArgumentException e) {
 157             Log_OC.e(TAG, "Not enough information provided in intent: " + e.getMessage());
 158             return START_NOT_STICKY;
 159         }
 160
 161         if (requestedDownloads.size() > 0) {
 162             Message msg = mServiceHandler.obtainMessage();
 163             msg.arg1 = startId;
 164             msg.obj = requestedDownloads;
 165             mServiceHandler.sendMessage(msg);
 166         }
 167
 168         return START_NOT_STICKY;
 169     }
 170
 171
 172     /**
 173      * Provides a binder object that clients can use to perform operations on the queue of downloads, excepting the addition of new files.
 174      *
 175      * Implemented to perform cancellation, pause and resume of existing downloads.
 176      */
 177     @Override
 178     public IBinder onBind(Intent arg0) {
 179         return mBinder;
 180     }
 181
 182
 183     /**
 184      * Called when ALL the bound clients were onbound.
 185      */
 186     @Override
 187     public boolean onUnbind(Intent intent) {
 188         ((FileDownloaderBinder)mBinder).clearListeners();
 189         return false;   // not accepting rebinding (default behaviour)
 190     }
 191
 192
 193     /**
 194      *  Binder to let client components to perform operations on the queue of downloads.
 195      *
 196      *  It provides by itself the available operations.
 197      */
 198     public class FileDownloaderBinder extends Binder implements OnDatatransferProgressListener {
 199
 200         /**
 201          * Map of listeners that will be reported about progress of downloads from a {@link FileDownloaderBinder} instance
 202          */
 203         private Map<String, OnDatatransferProgressListener> mBoundListeners = new HashMap<String, OnDatatransferProgressListener>();
 204
 205
 206         /**
 207          * Cancels a pending or current download of a remote file.
 208          *
 209          * @param account       Owncloud account where the remote file is stored.
 210          * @param file          A file in the queue of pending downloads
 211          */
 212         public void cancel(Account account, OCFile file) {
 213             DownloadFileOperation download = null;
 214             synchronized (mPendingDownloads) {
 215                 download = mPendingDownloads.remove(buildRemoteName(account, file));
 216             }
 217             if (download != null) {
 218                 download.cancel();
 219             }
 220         }
 221
 222
 223         public void clearListeners() {
 224             mBoundListeners.clear();
 225         }
 226
 227
 228         /**
 229          * Returns True when the file described by 'file' in the ownCloud account 'account' is downloading or waiting to download.
 230          *
 231          * If 'file' is a directory, returns 'true' if some of its descendant files is downloading or waiting to download.
 232          *
 233          * @param account       Owncloud account where the remote file is stored.
 234          * @param file          A file that could be in the queue of downloads.
 235          */
 236         public boolean isDownloading(Account account, OCFile file) {
 237             if (account == null || file == null) return false;
 238             String targetKey = buildRemoteName(account, file);
 239             synchronized (mPendingDownloads) {
 240                 if (file.isFolder()) {
 241                     // this can be slow if there are many downloads :(
 242                     Iterator<String> it = mPendingDownloads.keySet().iterator();
 243                     boolean found = false;
 244                     while (it.hasNext() && !found) {
 245                         found = it.next().startsWith(targetKey);
 246                     }
 247                     return found;
 248                 } else {
 249                     return (mPendingDownloads.containsKey(targetKey));
 250                 }
 251             }
 252         }
 253
 254
 255         /**
 256          * Adds a listener interested in the progress of the download for a concrete file.
 257          *
 258          * @param listener      Object to notify about progress of transfer.
 259          * @param account       ownCloud account holding the file of interest.
 260          * @param file          {@link OCfile} of interest for listener.
 261          */
 262         public void addDatatransferProgressListener (OnDatatransferProgressListener listener, Account account, OCFile file) {
 263             if (account == null || file == null || listener == null) return;
 264             String targetKey = buildRemoteName(account, file);
 265             mBoundListeners.put(targetKey, listener);
 266         }
 267
 268
 269         /**
 270          * Removes a listener interested in the progress of the download for a concrete file.
 271          *
 272          * @param listener      Object to notify about progress of transfer.
 273          * @param account       ownCloud account holding the file of interest.
 274          * @param file          {@link OCfile} of interest for listener.
 275          */
 276         public void removeDatatransferProgressListener (OnDatatransferProgressListener listener, Account account, OCFile file) {
 277             if (account == null || file == null || listener == null) return;
 278             String targetKey = buildRemoteName(account, file);
 279             if (mBoundListeners.get(targetKey) == listener) {
 280                 mBoundListeners.remove(targetKey);
 281             }
 282         }
 283
 284
 285         @Override
 286         public void onTransferProgress(long progressRate) {
 287             // old way, should not be in use any more
 288         }
 289
 290
 291         @Override
 292         public void onTransferProgress(long progressRate, long totalTransferredSoFar, long totalToTransfer,
 293                 String fileName) {
 294             String key = buildRemoteName(mCurrentDownload.getAccount(), mCurrentDownload.getFile());
 295             OnDatatransferProgressListener boundListener = mBoundListeners.get(key);
 296             if (boundListener != null) {
 297                 boundListener.onTransferProgress(progressRate, totalTransferredSoFar, totalToTransfer, fileName);
 298             }
 299         }
 300
 301     }
 302
 303
 304     /**
 305      * Download worker. Performs the pending downloads in the order they were requested.
 306      *
 307      * Created with the Looper of a new thread, started in {@link FileUploader#onCreate()}.
 308      */
 309     private static class ServiceHandler extends Handler {
 310         // don't make it a final class, and don't remove the static ; lint will warn about a possible memory leak
 311         FileDownloader mService;
 312         public ServiceHandler(Looper looper, FileDownloader service) {
 313             super(looper);
 314             if (service == null)
 315                 throw new IllegalArgumentException("Received invalid NULL in parameter 'service'");
 316             mService = service;
 317         }
 318
 319         @Override
 320         public void handleMessage(Message msg) {
 321             @SuppressWarnings("unchecked")
 322             AbstractList<String> requestedDownloads = (AbstractList<String>) msg.obj;
 323             if (msg.obj != null) {
 324                 Iterator<String> it = requestedDownloads.iterator();
 325                 while (it.hasNext()) {
 326                     mService.downloadFile(it.next());
 327                 }
 328             }
 329             mService.stopSelf(msg.arg1);
 330         }
 331     }
 332
 333
 334     /**
 335      * Core download method: requests a file to download and stores it.
 336      *
 337      * @param downloadKey   Key to access the download to perform, contained in mPendingDownloads
 338      */
 339     private void downloadFile(String downloadKey) {
 340
 341         synchronized(mPendingDownloads) {
 342             mCurrentDownload = mPendingDownloads.get(downloadKey);
 343         }
 344
 345         if (mCurrentDownload != null) {
 346
 347             notifyDownloadStart(mCurrentDownload);
 348
 349             RemoteOperationResult downloadResult = null;
 350             try {
 351                 /// prepare client object to send the request to the ownCloud server
 352                 if (mDownloadClient == null || !mLastAccount.equals(mCurrentDownload.getAccount())) {
 353                     mLastAccount = mCurrentDownload.getAccount();
 354                     mStorageManager = new FileDataStorageManager(mLastAccount, getContentResolver());
 355                     mDownloadClient = OwnCloudClientFactory.createOwnCloudClient(mLastAccount, getApplicationContext());
 356                 }
 357
 358                 /// perform the download
 359                 downloadResult = mCurrentDownload.execute(mDownloadClient);
 360                 if (downloadResult.isSuccess()) {
 361                     saveDownloadedFile();
 362                 }
 363
 364             } catch (AccountsException e) {
 365                 Log_OC.e(TAG, "Error while trying to get autorization for " + mLastAccount.name, e);
 366                 downloadResult = new RemoteOperationResult(e);
 367             } catch (IOException e) {
 368                 Log_OC.e(TAG, "Error while trying to get autorization for " + mLastAccount.name, e);
 369                 downloadResult = new RemoteOperationResult(e);
 370
 371             } finally {
 372                 synchronized(mPendingDownloads) {
 373                     mPendingDownloads.remove(downloadKey);
 374                 }
 375             }
 376
 377
 378             /// notify result
 379             notifyDownloadResult(mCurrentDownload, downloadResult);
 380
 381             sendBroadcastDownloadFinished(mCurrentDownload, downloadResult);
 382         }
 383     }
 384
 385
 386     /**
 387      * Updates the OC File after a successful download.
 388      */
 389     private void saveDownloadedFile() {
 390         OCFile file = mCurrentDownload.getFile();
 391         long syncDate = System.currentTimeMillis();
 392         file.setLastSyncDateForProperties(syncDate);
 393         file.setLastSyncDateForData(syncDate);
 394         file.setModificationTimestamp(mCurrentDownload.getModificationTimestamp());
 395         file.setModificationTimestampAtLastSyncForData(mCurrentDownload.getModificationTimestamp());
 396         // file.setEtag(mCurrentDownload.getEtag());    // TODO Etag, where available
 397         file.setMimetype(mCurrentDownload.getMimeType());
 398         file.setStoragePath(mCurrentDownload.getSavePath());
 399         file.setFileLength((new File(mCurrentDownload.getSavePath()).length()));
 400         mStorageManager.saveFile(file);
 401     }
 402
 403
 404     /**
 405      * Creates a status notification to show the download progress
 406      *
 407      * @param download  Download operation starting.
 408      */
 409     private void notifyDownloadStart(DownloadFileOperation download) {
 410         /// create status notification with a progress bar
 411         mLastPercent = 0;
 412         mNotification = new Notification(R.drawable.icon, getString(R.string.downloader_download_in_progress_ticker), System.currentTimeMillis());
 413         mNotification.flags |= Notification.FLAG_ONGOING_EVENT;
 414         mNotification.contentView = new RemoteViews(getApplicationContext().getPackageName(), R.layout.progressbar_layout);
 415         mNotification.contentView.setProgressBar(R.id.status_progress, 100, 0, download.getSize() < 0);
 416         mNotification.contentView.setTextViewText(R.id.status_text, String.format(getString(R.string.downloader_download_in_progress_content), 0, new File(download.getSavePath()).getName()));
 417         mNotification.contentView.setImageViewResource(R.id.status_icon, R.drawable.icon);
 418
 419         /// includes a pending intent in the notification showing the details view of the file
 420         Intent showDetailsIntent = null;
 421         if (PreviewImageFragment.canBePreviewed(download.getFile())) {
 422             showDetailsIntent = new Intent(this, PreviewImageActivity.class);
 423         } else {
 424             showDetailsIntent = new Intent(this, FileDisplayActivity.class);
 425         }
 426         showDetailsIntent.putExtra(FileActivity.EXTRA_FILE, download.getFile());
 427         showDetailsIntent.putExtra(FileActivity.EXTRA_ACCOUNT, download.getAccount());
 428         showDetailsIntent.setFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
 429         mNotification.contentIntent = PendingIntent.getActivity(getApplicationContext(), (int)System.currentTimeMillis(), showDetailsIntent, 0);
 430
 431         mNotificationManager.notify(R.string.downloader_download_in_progress_ticker, mNotification);
 432     }
 433
 434
 435     /**
 436      * Callback method to update the progress bar in the status notification.
 437      */
 438     @Override
 439     public void onTransferProgress(long progressRate, long totalTransferredSoFar, long totalToTransfer, String fileName) {
 440         int percent = (int)(100.0*((double)totalTransferredSoFar)/((double)totalToTransfer));
 441         if (percent != mLastPercent) {
 442           mNotification.contentView.setProgressBar(R.id.status_progress, 100, percent, totalToTransfer < 0);
 443           String text = String.format(getString(R.string.downloader_download_in_progress_content), percent, fileName);
 444           mNotification.contentView.setTextViewText(R.id.status_text, text);
 445           mNotificationManager.notify(R.string.downloader_download_in_progress_ticker, mNotification);
 446         }
 447         mLastPercent = percent;
 448     }
 449
 450
 451     /**
 452      * Callback method to update the progress bar in the status notification (old version)
 453      */
 454     @Override
 455     public void onTransferProgress(long progressRate) {
 456         // NOTHING TO DO HERE ANYMORE
 457     }
 458
 459
 460     /**
 461      * Updates the status notification with the result of a download operation.
 462      *
 463      * @param downloadResult    Result of the download operation.
 464      * @param download          Finished download operation
 465      */
 466     private void notifyDownloadResult(DownloadFileOperation download, RemoteOperationResult downloadResult) {
 467         mNotificationManager.cancel(R.string.downloader_download_in_progress_ticker);
 468         if (!downloadResult.isCancelled()) {
 469             int tickerId = (downloadResult.isSuccess()) ? R.string.downloader_download_succeeded_ticker : R.string.downloader_download_failed_ticker;
 470             int contentId = (downloadResult.isSuccess()) ? R.string.downloader_download_succeeded_content : R.string.downloader_download_failed_content;
 471             Notification finalNotification = new Notification(R.drawable.icon, getString(tickerId), System.currentTimeMillis());
 472             finalNotification.flags |= Notification.FLAG_AUTO_CANCEL;
 473             boolean needsToUpdateCredentials = (downloadResult.getCode() == ResultCode.UNAUTHORIZED ||
 474                                                 // (downloadResult.isTemporalRedirection() && downloadResult.isIdPRedirection()
 475                                                   (downloadResult.isIdPRedirection()
 476                                                         && mDownloadClient.getCredentials() == null));
 477                                                         //&& MainApp.getAuthTokenTypeSamlSessionCookie().equals(mDownloadClient.getAuthTokenType())));
 478             if (needsToUpdateCredentials) {
 479                 // let the user update credentials with one click
 480                 Intent updateAccountCredentials = new Intent(this, AuthenticatorActivity.class);
 481                 updateAccountCredentials.putExtra(AuthenticatorActivity.EXTRA_ACCOUNT, download.getAccount());
 482                 updateAccountCredentials.putExtra(AuthenticatorActivity.EXTRA_ENFORCED_UPDATE, true);
 483                 updateAccountCredentials.putExtra(AuthenticatorActivity.EXTRA_ACTION, AuthenticatorActivity.ACTION_UPDATE_TOKEN);
 484                 updateAccountCredentials.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
 485                 updateAccountCredentials.addFlags(Intent.FLAG_ACTIVITY_EXCLUDE_FROM_RECENTS);
 486                 updateAccountCredentials.addFlags(Intent.FLAG_FROM_BACKGROUND);
 487                 finalNotification.contentIntent = PendingIntent.getActivity(this, (int)System.currentTimeMillis(), updateAccountCredentials, PendingIntent.FLAG_ONE_SHOT);
 488                 finalNotification.setLatestEventInfo(   getApplicationContext(),
 489                                                         getString(tickerId),
 490                                                         String.format(getString(contentId), new File(download.getSavePath()).getName()),
 491                                                         finalNotification.contentIntent);
 492                 mDownloadClient = null;   // grant that future retries on the same account will get the fresh credentials
 493
 494             } else {
 495                 Intent showDetailsIntent = null;
 496                 if (downloadResult.isSuccess()) {
 497                     if (PreviewImageFragment.canBePreviewed(download.getFile())) {
 498                         showDetailsIntent = new Intent(this, PreviewImageActivity.class);
 499                     } else {
 500                         showDetailsIntent = new Intent(this, FileDisplayActivity.class);
 501                     }
 502                     showDetailsIntent.putExtra(FileActivity.EXTRA_FILE, download.getFile());
 503                     showDetailsIntent.putExtra(FileActivity.EXTRA_ACCOUNT, download.getAccount());
 504                     showDetailsIntent.setFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
 505
 506                 } else {
 507                     // TODO put something smart in showDetailsIntent
 508                     showDetailsIntent = new Intent();
 509                 }
 510                 finalNotification.contentIntent = PendingIntent.getActivity(getApplicationContext(), (int)System.currentTimeMillis(), showDetailsIntent, 0);
 511                 finalNotification.setLatestEventInfo(getApplicationContext(), getString(tickerId), String.format(getString(contentId), new File(download.getSavePath()).getName()), finalNotification.contentIntent);
 512             }
 513             mNotificationManager.notify(tickerId, finalNotification);
 514         }
 515     }
 516
 517
 518     /**
 519      * Sends a broadcast when a download finishes in order to the interested activities can update their view
 520      *
 521      * @param download          Finished download operation
 522      * @param downloadResult    Result of the download operation
 523      */
 524     private void sendBroadcastDownloadFinished(DownloadFileOperation download, RemoteOperationResult downloadResult) {
 525         Intent end = new Intent(getDownloadFinishMessage());
 526         end.putExtra(EXTRA_DOWNLOAD_RESULT, downloadResult.isSuccess());
 527         end.putExtra(ACCOUNT_NAME, download.getAccount().name);
 528         end.putExtra(EXTRA_REMOTE_PATH, download.getRemotePath());
 529         end.putExtra(EXTRA_FILE_PATH, download.getSavePath());
 530         sendStickyBroadcast(end);
 531     }
 532
 533
 534     /**
 535      * Sends a broadcast when a new download is added to the queue.
 536      *
 537      * @param download          Added download operation
 538      */
 539     private void sendBroadcastNewDownload(DownloadFileOperation download) {
 540         Intent added = new Intent(getDownloadAddedMessage());
 541         added.putExtra(ACCOUNT_NAME, download.getAccount().name);
 542         added.putExtra(EXTRA_REMOTE_PATH, download.getRemotePath());
 543         added.putExtra(EXTRA_FILE_PATH, download.getSavePath());
 544         sendStickyBroadcast(added);
 545     }
 546
 547 }