269 lines
9.0 KiB
JavaScript
269 lines
9.0 KiB
JavaScript
// -*- indent-tabs-mode: nil; js-indent-level: 2 -*-
|
|
// 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/.
|
|
|
|
this.EXPORTED_SYMBOLS = ["RemoteWebProgressManager"];
|
|
|
|
const Ci = Components.interfaces;
|
|
const Cc = Components.classes;
|
|
const Cu = Components.utils;
|
|
|
|
Cu.import("resource://gre/modules/XPCOMUtils.jsm");
|
|
|
|
function newURI(spec)
|
|
{
|
|
return Cc["@mozilla.org/network/io-service;1"].getService(Ci.nsIIOService)
|
|
.newURI(spec, null, null);
|
|
}
|
|
|
|
function RemoteWebProgressRequest(spec, originalSpec, requestCPOW)
|
|
{
|
|
this.wrappedJSObject = this;
|
|
|
|
this._uri = newURI(spec);
|
|
this._originalURI = newURI(originalSpec);
|
|
this._requestCPOW = requestCPOW;
|
|
}
|
|
|
|
RemoteWebProgressRequest.prototype = {
|
|
QueryInterface : XPCOMUtils.generateQI([Ci.nsIChannel]),
|
|
|
|
get URI() { return this._uri.clone(); },
|
|
get originalURI() { return this._originalURI.clone(); }
|
|
};
|
|
|
|
function RemoteWebProgress(aManager, aIsTopLevel) {
|
|
this.wrappedJSObject = this;
|
|
|
|
this._manager = aManager;
|
|
|
|
this._isLoadingDocument = false;
|
|
this._DOMWindow = null;
|
|
this._DOMWindowID = 0;
|
|
this._isTopLevel = aIsTopLevel;
|
|
this._loadType = 0;
|
|
}
|
|
|
|
RemoteWebProgress.prototype = {
|
|
NOTIFY_STATE_REQUEST: 0x00000001,
|
|
NOTIFY_STATE_DOCUMENT: 0x00000002,
|
|
NOTIFY_STATE_NETWORK: 0x00000004,
|
|
NOTIFY_STATE_WINDOW: 0x00000008,
|
|
NOTIFY_STATE_ALL: 0x0000000f,
|
|
NOTIFY_PROGRESS: 0x00000010,
|
|
NOTIFY_STATUS: 0x00000020,
|
|
NOTIFY_SECURITY: 0x00000040,
|
|
NOTIFY_LOCATION: 0x00000080,
|
|
NOTIFY_REFRESH: 0x00000100,
|
|
NOTIFY_ALL: 0x000001ff,
|
|
|
|
get isLoadingDocument() { return this._isLoadingDocument },
|
|
get DOMWindow() { return this._DOMWindow; },
|
|
get DOMWindowID() { return this._DOMWindowID; },
|
|
get isTopLevel() { return this._isTopLevel },
|
|
get loadType() { return this._loadType; },
|
|
|
|
addProgressListener: function (aListener) {
|
|
this._manager.addProgressListener(aListener);
|
|
},
|
|
|
|
removeProgressListener: function (aListener) {
|
|
this._manager.removeProgressListener(aListener);
|
|
}
|
|
};
|
|
|
|
function RemoteWebProgressManager (aBrowser) {
|
|
this._topLevelWebProgress = new RemoteWebProgress(this, true);
|
|
this._progressListeners = [];
|
|
|
|
this.swapBrowser(aBrowser);
|
|
}
|
|
|
|
RemoteWebProgressManager.argumentsForAddonListener = function(kind, args) {
|
|
function checkType(arg, typ) {
|
|
if (!arg) {
|
|
return false;
|
|
}
|
|
return (arg instanceof typ) ||
|
|
(arg instanceof Ci.nsISupports && arg.wrappedJSObject instanceof typ);
|
|
}
|
|
|
|
// Arguments for a tabs listener are shifted over one since the
|
|
// <browser> element is passed as the first argument.
|
|
let webProgressIndex = 0;
|
|
let requestIndex = 1;
|
|
if (kind == "tabs") {
|
|
webProgressIndex = 1;
|
|
requestIndex = 2;
|
|
}
|
|
|
|
if (checkType(args[webProgressIndex], RemoteWebProgress)) {
|
|
args[webProgressIndex] = args[webProgressIndex].wrappedJSObject._webProgressCPOW;
|
|
}
|
|
|
|
if (checkType(args[requestIndex], RemoteWebProgressRequest)) {
|
|
args[requestIndex] = args[requestIndex].wrappedJSObject._requestCPOW;
|
|
}
|
|
|
|
return args;
|
|
};
|
|
|
|
RemoteWebProgressManager.prototype = {
|
|
swapBrowser: function(aBrowser) {
|
|
if (this._messageManager) {
|
|
this._messageManager.removeMessageListener("Content:StateChange", this);
|
|
this._messageManager.removeMessageListener("Content:LocationChange", this);
|
|
this._messageManager.removeMessageListener("Content:SecurityChange", this);
|
|
this._messageManager.removeMessageListener("Content:StatusChange", this);
|
|
this._messageManager.removeMessageListener("Content:ProgressChange", this);
|
|
}
|
|
|
|
this._browser = aBrowser;
|
|
this._messageManager = aBrowser.messageManager;
|
|
this._messageManager.addMessageListener("Content:StateChange", this);
|
|
this._messageManager.addMessageListener("Content:LocationChange", this);
|
|
this._messageManager.addMessageListener("Content:SecurityChange", this);
|
|
this._messageManager.addMessageListener("Content:StatusChange", this);
|
|
this._messageManager.addMessageListener("Content:ProgressChange", this);
|
|
},
|
|
|
|
get topLevelWebProgress() {
|
|
return this._topLevelWebProgress;
|
|
},
|
|
|
|
addProgressListener: function (aListener) {
|
|
let listener = aListener.QueryInterface(Ci.nsIWebProgressListener);
|
|
this._progressListeners.push(listener);
|
|
},
|
|
|
|
removeProgressListener: function (aListener) {
|
|
this._progressListeners =
|
|
this._progressListeners.filter(l => l != aListener);
|
|
},
|
|
|
|
_fixSSLStatusAndState: function (aStatus, aState) {
|
|
let deserialized = null;
|
|
if (aStatus) {
|
|
let helper = Cc["@mozilla.org/network/serialization-helper;1"]
|
|
.getService(Components.interfaces.nsISerializationHelper);
|
|
|
|
deserialized = helper.deserializeObject(aStatus)
|
|
deserialized.QueryInterface(Ci.nsISSLStatus);
|
|
}
|
|
|
|
return [deserialized, aState];
|
|
},
|
|
|
|
setCurrentURI: function (aURI) {
|
|
// This function is simpler than nsDocShell::SetCurrentURI since
|
|
// it doesn't have to deal with child docshells.
|
|
let remoteWebNav = this._browser._remoteWebNavigationImpl;
|
|
remoteWebNav._currentURI = aURI;
|
|
|
|
let webProgress = this.topLevelWebProgress;
|
|
for (let p of this._progressListeners) {
|
|
p.onLocationChange(webProgress, null, aURI);
|
|
}
|
|
},
|
|
|
|
_callProgressListeners: function(methodName, ...args) {
|
|
for (let p of this._progressListeners) {
|
|
if (p[methodName]) {
|
|
try {
|
|
p[methodName].apply(p, args);
|
|
} catch (ex) {
|
|
Cu.reportError("RemoteWebProgress failed to call " + methodName + ": " + ex + "\n");
|
|
}
|
|
}
|
|
}
|
|
},
|
|
|
|
receiveMessage: function (aMessage) {
|
|
let json = aMessage.json;
|
|
let objects = aMessage.objects;
|
|
|
|
let webProgress = null;
|
|
let isTopLevel = json.webProgress && json.webProgress.isTopLevel;
|
|
// The top-level WebProgress is always the same, but because we don't
|
|
// really have a concept of subframes/content we always create a new object
|
|
// for those.
|
|
if (json.webProgress) {
|
|
webProgress = isTopLevel ? this._topLevelWebProgress
|
|
: new RemoteWebProgress(this, false);
|
|
|
|
// Update the actual WebProgress fields.
|
|
webProgress._isLoadingDocument = json.webProgress.isLoadingDocument;
|
|
webProgress._DOMWindow = objects.DOMWindow;
|
|
webProgress._DOMWindowID = json.webProgress.DOMWindowID;
|
|
webProgress._loadType = json.webProgress.loadType;
|
|
webProgress._webProgressCPOW = objects.webProgress;
|
|
}
|
|
|
|
// The WebProgressRequest object however is always dynamic.
|
|
let request = null;
|
|
if (json.requestURI) {
|
|
request = new RemoteWebProgressRequest(json.requestURI,
|
|
json.originalRequestURI,
|
|
objects.request);
|
|
}
|
|
|
|
if (isTopLevel) {
|
|
this._browser._contentWindow = objects.contentWindow;
|
|
this._browser._documentContentType = json.documentContentType;
|
|
}
|
|
|
|
switch (aMessage.name) {
|
|
case "Content:StateChange":
|
|
this._callProgressListeners("onStateChange", webProgress, request, json.stateFlags, json.status);
|
|
break;
|
|
|
|
case "Content:LocationChange":
|
|
let location = newURI(json.location);
|
|
let flags = json.flags;
|
|
let remoteWebNav = this._browser._remoteWebNavigationImpl;
|
|
|
|
// These properties can change even for a sub-frame navigation.
|
|
remoteWebNav.canGoBack = json.canGoBack;
|
|
remoteWebNav.canGoForward = json.canGoForward;
|
|
|
|
if (isTopLevel) {
|
|
remoteWebNav._currentURI = location;
|
|
this._browser._characterSet = json.charset;
|
|
this._browser._documentURI = newURI(json.documentURI);
|
|
this._browser._contentTitle = json.title;
|
|
this._browser._imageDocument = null;
|
|
this._browser._mayEnableCharacterEncodingMenu = json.mayEnableCharacterEncodingMenu;
|
|
this._browser._contentPrincipal = json.principal;
|
|
this._browser._isSyntheticDocument = json.synthetic;
|
|
this._browser._innerWindowID = json.innerWindowID;
|
|
}
|
|
|
|
this._callProgressListeners("onLocationChange", webProgress, request, location, flags);
|
|
break;
|
|
|
|
case "Content:SecurityChange":
|
|
let [status, state] = this._fixSSLStatusAndState(json.status, json.state);
|
|
|
|
if (isTopLevel) {
|
|
// Invoking this getter triggers the generation of the underlying object,
|
|
// which we need to access with ._securityUI, because .securityUI returns
|
|
// a wrapper that makes _update inaccessible.
|
|
void this._browser.securityUI;
|
|
this._browser._securityUI._update(status, state);
|
|
}
|
|
|
|
this._callProgressListeners("onSecurityChange", webProgress, request, state);
|
|
break;
|
|
|
|
case "Content:StatusChange":
|
|
this._callProgressListeners("onStatusChange", webProgress, request, json.status, json.message);
|
|
break;
|
|
|
|
case "Content:ProgressChange":
|
|
this._callProgressListeners("onProgressChange", webProgress, request, json.curSelf, json.maxSelf, json.curTotal, json.maxTotal);
|
|
break;
|
|
}
|
|
},
|
|
};
|