gecko/browser/metro/base/content/downloads.js

657 lines
22 KiB
JavaScript

// -*- Mode: js2; tab-width: 2; indent-tabs-mode: nil; js2-basic-offset: 2; js2-skip-preprocessor-directives: t; -*-
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
const URI_GENERIC_ICON_DOWNLOAD = "chrome://browser/skin/images/alert-downloads-30.png";
var MetroDownloadsView = {
/**
* _downloadCount keeps track of the number of downloads that a single
* notification bar groups together. A download is grouped with other
* downloads if it starts before other downloads have completed.
*/
_downloadCount: 0,
_downloadsInProgress: 0,
_lastDownload: null,
_inited: false,
_progressAlert: null,
_lastSec: Infinity,
_progressNotificationInfo: new Map(),
_runDownloadBooleanMap: new Map(),
get manager() {
return Cc["@mozilla.org/download-manager;1"]
.getService(Ci.nsIDownloadManager);
},
_getReferrerOrSource: function dh__getReferrerOrSource(aDownload) {
return aDownload.referrer.spec || aDownload.source.spec;
},
_getLocalFile: function dh__getLocalFile(aFileURI) {
// XXX it's possible that using a null char-set here is bad
let spec = ('string' == typeof aFileURI) ? aFileURI : aFileURI.spec;
let fileUrl;
try {
fileUrl = Services.io.newURI(spec, null, null).QueryInterface(Ci.nsIFileURL);
} catch (ex) {
Util.dumpLn("_getLocalFile: Caught exception creating newURI from file spec: "+aFileURI.spec+": " + ex.message);
return;
}
return fileUrl.file.clone().QueryInterface(Ci.nsILocalFile);
},
init: function dh_init() {
if (this._inited)
return;
this._inited = true;
Services.obs.addObserver(this, "dl-start", true);
Services.obs.addObserver(this, "dl-done", true);
Services.obs.addObserver(this, "dl-run", true);
Services.obs.addObserver(this, "dl-failed", true);
this._progress = new DownloadProgressListener(this);
this.manager.addListener(this._progress);
Elements.tabList.addEventListener("TabClose", this, false);
this._downloadProgressIndicator = document.getElementById("download-progress");
if (this.manager.activeDownloadCount) {
setTimeout (this._restartWithActiveDownloads.bind(this), 0);
}
},
uninit: function dh_uninit() {
if (this._inited) {
Services.obs.removeObserver(this, "dl-start");
Services.obs.removeObserver(this, "dl-done");
Services.obs.removeObserver(this, "dl-run");
Services.obs.removeObserver(this, "dl-failed");
if (Elements && Elements.tabList)
Elements.tabList.removeEventListener("TabClose", this);
}
},
get _notificationBox() {
return Browser.getNotificationBox(Browser.selectedBrowser);
},
get _notificationBoxes() {
let currentBox = this._notificationBox;
let boxes = [
currentBox
];
for (let { linkedBrowser } of Elements.tabList.children) {
if (linkedBrowser !== Browser.selectedBrowser) {
let notificationBox = Browser.getNotificationBox(linkedBrowser);
if (notificationBox)
boxes.push(notificationBox);
}
}
return boxes;
},
get _progressNotification() {
let notn = this._getNotificationWithValue("download-progress");
let currentBox = this._notificationBox;
// move the progress notification if attached to a different browser
if (notn && notn.parentNode !== currentBox) {
notn.parentNode.removeNotification(notn);
currentBox.insertBefore(notn, currentBox.firstChild);
}
return notn;
},
_getNotificationWithValue: function(aValue) {
let notn;
let allNotificationBoxes = this._notificationBoxes;
for(let box of allNotificationBoxes) {
notn = box.getNotificationWithValue(aValue);
if (notn) {
break;
}
}
return notn;
},
_restartWithActiveDownloads: function() {
let activeDownloads = this.manager.activeDownloads;
while (activeDownloads.hasMoreElements()) {
let dl = activeDownloads.getNext();
switch (dl.state) {
case 0: // Downloading
case 5: // Queued
this.watchDownload(dl);
this.updateInfobar();
break;
}
}
if (this.manager.activeDownloadCount) {
ContextUI.displayNavbar();
}
},
openDownload: function dh_openDownload(aDownload) {
let fileURI = aDownload.target
if (!(fileURI && fileURI.spec)) {
Util.dumpLn("Cant open download "+id+", fileURI is invalid");
return;
}
let file = this._getLocalFile(fileURI);
try {
file && Services.metro.launchInDesktop(aDownload.target.spec, "");
} catch (ex) {
Util.dumpLn("Failed to open download, with id: "+id+", download target URI spec: " + fileURI.spec);
Util.dumpLn("Failed download source:"+(aDownload.source && aDownload.source.spec));
}
},
removeDownload: function dh_removeDownload(aDownload) {
// aDownload is the XUL element here,
// and .target currently returns the target attribute (string value)
let id = aDownload.getAttribute("downloadId");
let download = this.manager.getDownload(id);
if (download) {
this.manager.removeDownload(id);
}
},
cancelDownload: function dh_cancelDownload(aDownload) {
let fileURI = aDownload.target;
if (!(fileURI && fileURI.spec)) {
Util.dumpLn("Cant remove download file for: "+aDownload.id+", fileURI is invalid");
}
try {
let file = this._getLocalFile(fileURI);
if (file && file.exists())
file.remove(false);
this.manager.cancelDownload(aDownload.id);
// If cancelling was successful, stop tracking the download.
this._progressNotificationInfo.delete(aDownload.guid);
this._runDownloadBooleanMap.delete(aDownload.targetFile.path);
this._downloadCount--;
this._downloadsInProgress--;
let notn = this._progressNotification;
if (notn && this._downloadsInProgress <= 0) {
this._notificationBox.removeNotification(notn);
}
} catch (ex) {
Util.dumpLn("Failed to cancel download, with id: "+aDownload.id+", download target URI spec: " + fileURI.spec);
Util.dumpLn("Failed download source:"+(aDownload.source && aDownload.source.spec));
}
},
// Cancels all downloads.
cancelDownloads: function dh_cancelDownloads() {
for (let [guid, info] of this._progressNotificationInfo) {
this.cancelDownload(info.download);
}
this._downloadCount = 0;
this._progressNotificationInfo.clear();
this._runDownloadBooleanMap.clear();
},
pauseDownload: function dh_pauseDownload(aDownload) {
let id = aDownload.getAttribute("downloadId");
this.manager.pauseDownload(id);
},
resumeDownload: function dh_resumeDownload(aDownload) {
let id = aDownload.getAttribute("downloadId");
this.manager.resumeDownload(id);
},
showPage: function dh_showPage(aDownload) {
let id = aDownload.getAttribute("downloadId");
let download = this.manager.getDownload(id);
let uri = this._getReferrerOrSource(download);
if (uri)
BrowserUI.addAndShowTab(uri, Browser.selectedTab);
},
showAlert: function dh_showAlert(aName, aMessage, aTitle, aObserver) {
var notifier = Cc["@mozilla.org/alerts-service;1"]
.getService(Ci.nsIAlertsService);
if (!aTitle)
aTitle = Strings.browser.GetStringFromName("alertDownloads");
notifier.showAlertNotification("", aTitle, aMessage, true, "", aObserver, aName);
},
showNotification: function dh_showNotification(title, msg, buttons, priority) {
let notification = this._notificationBox.appendNotification(msg,
title,
URI_GENERIC_ICON_DOWNLOAD,
priority,
buttons);
return notification;
},
_showDownloadFailedNotification: function (aDownload) {
let tryAgainButtonText =
Strings.browser.GetStringFromName("downloadTryAgain");
let cancelButtonText =
Strings.browser.GetStringFromName("downloadCancel");
let message = Strings.browser.formatStringFromName("alertDownloadFailed",
[aDownload.displayName], 1);
let buttons = [
{
isDefault: true,
label: tryAgainButtonText,
accessKey: "",
callback: function() {
MetroDownloadsView.manager.retryDownload(aDownload.id);
}
},
{
label: cancelButtonText,
accessKey: "",
callback: function() {
MetroDownloadsView.cancelDownload(aDownload);
MetroDownloadsView._downloadProgressIndicator.reset();
}
}
];
this.showNotification("download-failed", message, buttons,
this._notificationBox.PRIORITY_WARNING_HIGH);
},
_showDownloadCompleteNotification: function () {
let message = "";
let showInFilesButtonText = Strings.browser.GetStringFromName("downloadShowInFiles");
let buttons = [
{
label: showInFilesButtonText,
accessKey: "",
callback: function() {
let fileURI = MetroDownloadsView._lastDownload.target;
let file = MetroDownloadsView._getLocalFile(fileURI);
file.reveal();
MetroDownloadsView._resetCompletedDownloads();
}
}
];
if (this._downloadCount > 1) {
message = PluralForm.get(this._downloadCount,
Strings.browser.GetStringFromName("alertMultipleDownloadsComplete"))
.replace("#1", this._downloadCount)
} else {
let runButtonText =
Strings.browser.GetStringFromName("downloadOpen");
message = Strings.browser.formatStringFromName("alertDownloadsDone2",
[this._lastDownload.displayName], 1);
buttons.unshift({
isDefault: true,
label: runButtonText,
accessKey: "",
callback: function() {
MetroDownloadsView.openDownload(MetroDownloadsView._lastDownload);
MetroDownloadsView._resetCompletedDownloads();
}
});
}
this._removeNotification("download-complete");
this.showNotification("download-complete", message, buttons,
this._notificationBox.PRIORITY_WARNING_MEDIUM);
},
_showDownloadCompleteToast: function () {
let name = "DownloadComplete";
let msg = "";
let title = "";
let observer = null;
if (this._downloadCount > 1) {
title = PluralForm.get(this._downloadCount,
Strings.browser.GetStringFromName("alertMultipleDownloadsComplete"))
.replace("#1", this._downloadCount)
msg = PluralForm.get(2, Strings.browser.GetStringFromName("downloadShowInFiles"));
observer = {
observe: function (aSubject, aTopic, aData) {
switch (aTopic) {
case "alertclickcallback":
let fileURI = MetroDownloadsView._lastDownload.target;
let file = MetroDownloadsView._getLocalFile(fileURI);
file.reveal();
MetroDownloadsView._resetCompletedDownloads();
break;
}
}
}
} else {
title = Strings.browser.formatStringFromName("alertDownloadsDone",
[this._lastDownload.displayName], 1);
msg = Strings.browser.GetStringFromName("downloadOpenNow");
observer = {
observe: function (aSubject, aTopic, aData) {
switch (aTopic) {
case "alertclickcallback":
MetroDownloadsView.openDownload(MetroDownloadsView._lastDownload);
MetroDownloadsView._resetCompletedDownloads();
break;
}
}
}
}
this.showAlert(name, msg, title, observer);
},
_resetCompletedDownloads: function () {
this._progressNotificationInfo.clear();
this._downloadCount = 0;
this._lastDownload = null;
this._downloadProgressIndicator.reset();
this._removeNotification("download-complete");
},
_updateCircularProgressMeter: function dv_updateCircularProgressMeter() {
if (!this._progressNotificationInfo) {
return;
}
let totPercent = 0;
for (let [guid, info] of this._progressNotificationInfo) {
// info.download => nsIDownload
totPercent += info.download.percentComplete;
}
let percentComplete = totPercent / this._progressNotificationInfo.size;
this._downloadProgressIndicator.updateProgress(percentComplete);
},
_computeDownloadProgressString: function dv_computeDownloadProgressString() {
let totTransferred = 0, totSize = 0, totSecondsLeft = 0;
let guid, info;
for ([guid, info] of this._progressNotificationInfo) {
let size = info.download.size;
let amountTransferred = info.download.amountTransferred;
let speed = info.download.speed;
totTransferred += amountTransferred;
totSize += size;
totSecondsLeft += ((size - amountTransferred) / speed);
}
// Compute progress in bytes.
let amountTransferred = Util.getDownloadSize(totTransferred);
let size = Util.getDownloadSize(totSize);
let progress = amountTransferred + "/" + size;
// Compute progress in time.;
let [timeLeft, newLast] = DownloadUtils.getTimeLeft(totSecondsLeft, this._lastSec);
this._lastSec = newLast;
if (this._downloadCount == 1) {
return Strings.browser.GetStringFromName("alertDownloadsStart2")
.replace("#1", info.download.displayName)
.replace("#2", progress)
.replace("#3", timeLeft)
}
let numDownloads = this._downloadCount;
return PluralForm.get(numDownloads,
Strings.browser.GetStringFromName("alertDownloadMultiple"))
.replace("#1", numDownloads)
.replace("#2", progress)
.replace("#3", timeLeft);
},
_saveDownloadData: function dv_saveDownloadData(aDownload) {
if (!this._progressNotificationInfo.get(aDownload.guid)) {
this._progressNotificationInfo.set(aDownload.guid, {});
}
let infoObj = this._progressNotificationInfo.get(aDownload.guid);
infoObj.download = aDownload;
this._progressNotificationInfo.set(aDownload.guid, infoObj);
},
onDownloadButton: function dv_onDownloadButton() {
let progressNotification = this._getNotificationWithValue("download-progress");
let wasProgressVisible = (progressNotification &&
progressNotification.parentNode == this._notificationBox);
let completeNotification = this._getNotificationWithValue("download-complete");
let wasCompleteVisible = (completeNotification &&
completeNotification.parentNode == this._notificationBox);
this._removeNotification("download-complete");
this._removeNotification("download-progress");
if (this._downloadsInProgress && !wasProgressVisible) {
this.updateInfobar();
} else if (this._downloadCount && !wasCompleteVisible) {
this._showDownloadCompleteNotification();
}
},
_removeNotification: function (aValue) {
let notification = this._getNotificationWithValue(aValue);
return notification &&
notification.parentNode.removeNotification(notification);
},
updateInfobar: function dv_updateInfobar() {
let message = this._computeDownloadProgressString();
this._updateCircularProgressMeter();
let notn = this._progressNotification;
if (!notn) {
let cancelButtonText =
Strings.browser.GetStringFromName("downloadCancel");
let buttons = [
{
isDefault: false,
label: cancelButtonText,
accessKey: "",
callback: function() {
MetroDownloadsView.cancelDownloads();
MetroDownloadsView._downloadProgressIndicator.reset();
}
}
];
notn = this.showNotification("download-progress", message, buttons,
this._notificationBox.PRIORITY_WARNING_LOW);
ContextUI.displayNavbar();
} else {
notn.label = message;
}
},
updateDownload: function dv_updateDownload(aDownload) {
this._saveDownloadData(aDownload);
let notn = this._progressNotification;
if (notn) {
notn.label =
this._computeDownloadProgressString(aDownload);
}
this._updateCircularProgressMeter();
},
watchDownload: function dv_watchDownload(aDownload) {
this._saveDownloadData(aDownload);
this._downloadCount++;
this._downloadsInProgress++;
if (!this._progressNotificationInfo.get(aDownload.guid)) {
this._progressNotificationInfo.set(aDownload.guid, {});
}
if (!this._progressAlert) {
this._progressAlert = new AlertDownloadProgressListener();
this.manager.addListener(this._progressAlert);
}
},
observe: function (aSubject, aTopic, aData) {
let message = "";
let msgTitle = "";
switch (aTopic) {
case "dl-run":
let file = aSubject.QueryInterface(Ci.nsIFile);
this._runDownloadBooleanMap.set(file.path, (aData == 'true'));
break;
case "dl-start":
let download = aSubject.QueryInterface(Ci.nsIDownload);
this.watchDownload(download);
this.updateInfobar();
break;
case "dl-done":
this._downloadsInProgress--;
download = aSubject.QueryInterface(Ci.nsIDownload);
this._lastDownload = download;
let runAfterDownload = this._runDownloadBooleanMap.get(download.targetFile.path);
if (runAfterDownload) {
this.openDownload(download);
}
this._runDownloadBooleanMap.delete(download.targetFile.path);
if (this._downloadsInProgress == 0) {
if (this._downloadCount > 1 || !runAfterDownload) {
this._showDownloadCompleteToast();
this._showDownloadCompleteNotification();
}
let notn = this._progressNotification;
if (notn)
this._notificationBox.removeNotification(notn);
ContextUI.displayNavbar();
}
this._downloadProgressIndicator.notify();
break;
case "dl-failed":
download = aSubject.QueryInterface(Ci.nsIDownload);
this._showDownloadFailedNotification(download);
break;
}
},
handleEvent: function(aEvent) {
switch (aEvent.type) {
case 'TabClose': {
let browser = aEvent.originalTarget.linkedBrowser;
let tab = Browser.getTabForBrowser(browser);
let notificationBox = Browser.getNotificationBox(browser);
// move any download-related notification before the tab and its notificationBox goes away
// The 3 possible values should be mutually exclusive
for(let name of ["download-progress",
"save-download",
"download-complete"]) {
let notn = notificationBox.getNotificationWithValue(name);
if (!notn) {
continue;
}
let nextTab = Browser.getNextTab(tab);
let nextBox = nextTab && Browser.getNotificationBox(nextTab.browser);
if (nextBox) {
// move notification to the next tab
nextBox.adoptNotification(notn);
} else {
// Alas, no browser to move the notifications to.
}
}
break;
}
}
},
QueryInterface: function (aIID) {
if (!aIID.equals(Ci.nsIObserver) &&
!aIID.equals(Ci.nsISupportsWeakReference) &&
!aIID.equals(Ci.nsISupports))
throw Components.results.NS_ERROR_NO_INTERFACE;
return this;
}
};
/**
* Notifies Downloads object about updates in the state of various downloads.
*
* @param aDownloads An instance of Downloads.
*/
function DownloadProgressListener(aDownloads) {
this._downloads = aDownloads;
}
DownloadProgressListener.prototype = {
_downloads: null,
//////////////////////////////////////////////////////////////////////////////
//// nsIDownloadProgressListener
onDownloadStateChange: function dPL_onDownloadStateChange(aState, aDownload) {
// TODO: Use DownloadProgressListener instead of observers in the Downloads object.
this._downloads.updateDownload(aDownload);
},
onProgressChange: function dPL_onProgressChange(aWebProgress, aRequest, aCurSelfProgress, aMaxSelfProgress, aCurTotalProgress, aMaxTotalProgress, aDownload) {
// TODO <jwilde>: Add more detailed progress information.
this._downloads.updateDownload(aDownload);
},
onStateChange: function(aWebProgress, aRequest, aState, aStatus, aDownload) { },
onSecurityChange: function(aWebProgress, aRequest, aState, aDownload) { },
//////////////////////////////////////////////////////////////////////////////
//// nsISupports
QueryInterface: XPCOMUtils.generateQI([Ci.nsIDownloadProgressListener])
};
/**
* Tracks download progress so that additional information can be displayed
* about its download in alert popups.
*/
function AlertDownloadProgressListener() { }
AlertDownloadProgressListener.prototype = {
//////////////////////////////////////////////////////////////////////////////
//// nsIDownloadProgressListener
onProgressChange: function(aWebProgress, aRequest, aCurSelfProgress, aMaxSelfProgress, aCurTotalProgress, aMaxTotalProgress, aDownload) {
let strings = Strings.browser;
let availableSpace = -1;
try {
// diskSpaceAvailable is not implemented on all systems
let availableSpace = aDownload.targetFile.diskSpaceAvailable;
} catch(ex) { }
let contentLength = aDownload.size;
if (availableSpace > 0 && contentLength > 0 && contentLength > availableSpace) {
MetroDownloadsView.showAlert(aDownload.target.spec.replace("file:", "download:"),
strings.GetStringFromName("alertDownloadsNoSpace"),
strings.GetStringFromName("alertDownloadsSize"));
MetroDownloadsView.cancelDownload(aDownload);
}
},
onDownloadStateChange: function(aState, aDownload) { },
onStateChange: function(aWebProgress, aRequest, aState, aStatus, aDownload) { },
onSecurityChange: function(aWebProgress, aRequest, aState, aDownload) { },
//////////////////////////////////////////////////////////////////////////////
//// nsISupports
QueryInterface: XPCOMUtils.generateQI([Ci.nsIDownloadProgressListener])
};