135 lines
4.0 KiB
JavaScript
135 lines
4.0 KiB
JavaScript
/* 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/. */
|
|
|
|
'use strict';
|
|
|
|
function debug(s) {
|
|
//dump('DEBUG RequestSyncManager: ' + s + '\n');
|
|
}
|
|
|
|
const {classes: Cc, interfaces: Ci, utils: Cu, results: Cr} = Components;
|
|
|
|
Cu.import("resource://gre/modules/DOMRequestHelper.jsm");
|
|
Cu.import('resource://gre/modules/XPCOMUtils.jsm');
|
|
Cu.import('resource://gre/modules/RequestSyncApp.jsm');
|
|
Cu.import('resource://gre/modules/RequestSyncTask.jsm');
|
|
|
|
XPCOMUtils.defineLazyServiceGetter(this, "cpmm",
|
|
"@mozilla.org/childprocessmessagemanager;1",
|
|
"nsIMessageSender");
|
|
|
|
function RequestSyncManager() {
|
|
debug('created');
|
|
}
|
|
|
|
RequestSyncManager.prototype = {
|
|
__proto__: DOMRequestIpcHelper.prototype,
|
|
|
|
classDescription: 'RequestSyncManager XPCOM Component',
|
|
classID: Components.ID('{e6f55080-e549-4e30-9d00-15f240fb763c}'),
|
|
contractID: '@mozilla.org/dom/request-sync-manager;1',
|
|
QueryInterface: XPCOMUtils.generateQI([Ci.nsISupportsWeakReference,
|
|
Ci.nsIObserver,
|
|
Ci.nsIDOMGlobalPropertyInitializer]),
|
|
|
|
_messages: [ "RequestSyncManager:Registrations:Return",
|
|
"RequestSyncManager:SetPolicy:Return",
|
|
"RequestSyncManager:RunTask:Return" ],
|
|
|
|
init: function(aWindow) {
|
|
debug("init");
|
|
|
|
// DOMRequestIpcHelper.initHelper sets this._window
|
|
this.initDOMRequestHelper(aWindow, this._messages);
|
|
},
|
|
|
|
sendMessage: function(aMsg, aObj) {
|
|
let self = this;
|
|
return this.createPromiseWithId(function(aResolverId) {
|
|
aObj.requestID = aResolverId;
|
|
cpmm.sendAsyncMessage(aMsg, aObj, null,
|
|
self._window.document.nodePrincipal);
|
|
});
|
|
},
|
|
|
|
registrations: function() {
|
|
debug('registrations');
|
|
return this.sendMessage("RequestSyncManager:Registrations", {});
|
|
},
|
|
|
|
setPolicy: function(aTask, aOrigin, aManifestURL, aIsInBrowserElement,
|
|
aState, aOverwrittenMinInterval) {
|
|
debug('setPolicy');
|
|
|
|
return this.sendMessage("RequestSyncManager:SetPolicy",
|
|
{ task: aTask,
|
|
origin: aOrigin,
|
|
manifestURL: aManifestURL,
|
|
isInBrowserElement: aIsInBrowserElement,
|
|
state: aState,
|
|
overwrittenMinInterval: aOverwrittenMinInterval });
|
|
},
|
|
|
|
runTask: function(aTask, aOrigin, aManifestURL, aIsInBrowserElement) {
|
|
debug('runTask');
|
|
|
|
return this.sendMessage("RequestSyncManager:RunTask",
|
|
{ task: aTask,
|
|
origin: aOrigin,
|
|
manifestURL: aManifestURL,
|
|
isInBrowserElement: aIsInBrowserElement });
|
|
},
|
|
|
|
registrationsResult: function(aData) {
|
|
debug("registrationsResult");
|
|
|
|
let results = new this._window.Array();
|
|
for (let i = 0; i < aData.length; ++i) {
|
|
if (!("app" in aData[i])) {
|
|
dump("ERROR - Serialization error in RequestSyncManager.\n");
|
|
continue;
|
|
}
|
|
|
|
let app = new RequestSyncApp(aData[i].app);
|
|
let exposedApp =
|
|
this._window.RequestSyncApp._create(this._window, app);
|
|
|
|
let task = new RequestSyncTask(this, this._window, exposedApp, aData[i]);
|
|
let exposedTask =
|
|
this._window.RequestSyncTask._create(this._window, task);
|
|
|
|
results.push(exposedTask);
|
|
}
|
|
return results;
|
|
},
|
|
|
|
receiveMessage: function(aMessage) {
|
|
debug('receiveMessage');
|
|
|
|
let req = this.getPromiseResolver(aMessage.data.requestID);
|
|
if (!req) {
|
|
return;
|
|
}
|
|
|
|
if ('error' in aMessage.data) {
|
|
req.reject(Cu.cloneInto(aMessage.data.error, this._window));
|
|
return;
|
|
}
|
|
|
|
if (aMessage.name == 'RequestSyncManager:Registrations:Return') {
|
|
req.resolve(this.registrationsResult(aMessage.data.results));
|
|
return;
|
|
}
|
|
|
|
if ('results' in aMessage.data) {
|
|
req.resolve(Cu.cloneInto(aMessage.data.results, this._window));
|
|
return;
|
|
}
|
|
|
|
req.resolve();
|
|
}
|
|
};
|
|
|
|
this.NSGetFactory = XPCOMUtils.generateNSGetFactory([RequestSyncManager]);
|