dom/requestsync/RequestSyncManager.js

   1 /* This Source Code Form is subject to the terms of the Mozilla Public
   2  * License, v. 2.0. If a copy of the MPL was not distributed with this file,
   3  * You can obtain one at http://mozilla.org/MPL/2.0/. */
   4
   5 'use strict';
   6
   7 function debug(s) {
   8   //dump('DEBUG RequestSyncManager: ' + s + '\n');
   9 }
  10
  11 const {classes: Cc, interfaces: Ci, utils: Cu, results: Cr} = Components;
  12
  13 Cu.import("resource://gre/modules/DOMRequestHelper.jsm");
  14 Cu.import('resource://gre/modules/XPCOMUtils.jsm');
  15 Cu.import('resource://gre/modules/RequestSyncApp.jsm');
  16 Cu.import('resource://gre/modules/RequestSyncTask.jsm');
  17
  18 XPCOMUtils.defineLazyServiceGetter(this, "cpmm",
  19                                    "@mozilla.org/childprocessmessagemanager;1",
  20                                    "nsIMessageSender");
  21
  22 function RequestSyncManager() {
  23   debug('created');
  24 }
  25
  26 RequestSyncManager.prototype = {
  27   __proto__: DOMRequestIpcHelper.prototype,
  28
  29   classDescription: 'RequestSyncManager XPCOM Component',
  30   classID: Components.ID('{e6f55080-e549-4e30-9d00-15f240fb763c}'),
  31   contractID: '@mozilla.org/dom/request-sync-manager;1',
  32   QueryInterface: XPCOMUtils.generateQI([Ci.nsISupportsWeakReference,
  33                                          Ci.nsIObserver,
  34                                          Ci.nsIDOMGlobalPropertyInitializer]),
  35
  36   _messages: [ "RequestSyncManager:Registrations:Return",
  37                "RequestSyncManager:SetPolicy:Return",
  38                "RequestSyncManager:RunTask:Return" ],
  39
  40   init: function(aWindow) {
  41     debug("init");
  42
  43     // DOMRequestIpcHelper.initHelper sets this._window
  44     this.initDOMRequestHelper(aWindow, this._messages);
  45   },
  46
  47   sendMessage: function(aMsg, aObj) {
  48     let self = this;
  49     return this.createPromise(function(aResolve, aReject) {
  50       aObj.requestID =
  51         self.getPromiseResolverId({ resolve: aResolve, reject: aReject });
  52       cpmm.sendAsyncMessage(aMsg, aObj, null,
  53                             self._window.document.nodePrincipal);
  54     });
  55   },
  56
  57   registrations: function() {
  58     debug('registrations');
  59     return this.sendMessage("RequestSyncManager:Registrations", {});
  60   },
  61
  62   setPolicy: function(aTask, aOrigin, aManifestURL, aIsInBrowserElement,
  63                       aState, aOverwrittenMinInterval) {
  64     debug('setPolicy');
  65
  66     return this.sendMessage("RequestSyncManager:SetPolicy",
  67       { task: aTask,
  68         origin: aOrigin,
  69         manifestURL: aManifestURL,
  70         isInBrowserElement: aIsInBrowserElement,
  71         state: aState,
  72         overwrittenMinInterval: aOverwrittenMinInterval });
  73   },
  74
  75   runTask: function(aTask, aOrigin, aManifestURL, aIsInBrowserElement) {
  76     debug('runTask');
  77
  78     return this.sendMessage("RequestSyncManager:RunTask",
  79       { task: aTask,
  80         origin: aOrigin,
  81         manifestURL: aManifestURL,
  82         isInBrowserElement: aIsInBrowserElement });
  83   },
  84
  85   registrationsResult: function(aData) {
  86     debug("registrationsResult");
  87
  88     let results = new this._window.Array();
  89     for (let i = 0; i < aData.length; ++i) {
  90       if (!("app" in aData[i])) {
  91         dump("ERROR - Serialization error in RequestSyncManager.\n");
  92         continue;
  93       }
  94
  95       let app = new RequestSyncApp(aData[i].app);
  96       let exposedApp =
  97         this._window.RequestSyncApp._create(this._window, app);
  98
  99       let task = new RequestSyncTask(this, this._window, exposedApp, aData[i]);
 100       let exposedTask =
 101         this._window.RequestSyncTask._create(this._window, task);
 102
 103       results.push(exposedTask);
 104     }
 105     return results;
 106   },
 107
 108   receiveMessage: function(aMessage) {
 109     debug('receiveMessage');
 110
 111     let req = this.getPromiseResolver(aMessage.data.requestID);
 112     if (!req) {
 113       return;
 114     }
 115
 116     if ('error' in aMessage.data) {
 117       req.reject(Cu.cloneInto(aMessage.data.error, this._window));
 118       return;
 119     }
 120
 121     if (aMessage.name == 'RequestSyncManager:Registrations:Return') {
 122       req.resolve(this.registrationsResult(aMessage.data.results));
 123       return;
 124     }
 125
 126     if ('results' in aMessage.data) {
 127       req.resolve(Cu.cloneInto(aMessage.data.results, this._window));
 128       return;
 129     }
 130
 131     req.resolve();
 132   }
 133 };
 134
 135 this.NSGetFactory = XPCOMUtils.generateNSGetFactory([RequestSyncManager]);