mirror of
https://gitlab.winehq.org/wine/wine-gecko.git
synced 2024-09-13 09:24:08 -07:00
122 lines
4.0 KiB
JavaScript
122 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";
|
|
|
|
const Cc = Components.classes;
|
|
const Ci = Components.interfaces;
|
|
const Cu = Components.utils;
|
|
const Cr = Components.results;
|
|
|
|
Cu.import("resource://gre/modules/XPCOMUtils.jsm");
|
|
Cu.import("resource://gre/modules/Services.jsm");
|
|
|
|
XPCOMUtils.defineLazyGetter(this, "ppmm", function() {
|
|
return Cc["@mozilla.org/parentprocessmessagemanager;1"].getService(Ci.nsIFrameMessageManager);
|
|
});
|
|
|
|
// Limit the number of pending messages for a given page.
|
|
let kMaxPendingMessages;
|
|
try {
|
|
kMaxPendingMessages = Services.prefs.getIntPref("dom.messages.maxPendingMessages");
|
|
} catch(e) {
|
|
// getIntPref throws when the pref is not set.
|
|
kMaxPendingMessages = 5;
|
|
}
|
|
|
|
function debug(aMsg) {
|
|
//dump("-- SystemMessageInternal " + Date.now() + " : " + aMsg + "\n");
|
|
}
|
|
|
|
// Implementation of the component used by internal users.
|
|
|
|
function SystemMessageInternal() {
|
|
// The set of pages registered by installed apps. We keep the
|
|
// list of pending messages for each page here also.
|
|
this._pages = [];
|
|
Services.obs.addObserver(this, "xpcom-shutdown", false);
|
|
ppmm.addMessageListener("SystemMessageManager:GetPending", this);
|
|
}
|
|
|
|
SystemMessageInternal.prototype = {
|
|
sendMessage: function sendMessage(aType, aMessage, aManifestURI) {
|
|
debug("Broadcasting " + aType + " " + JSON.stringify(aMessage));
|
|
ppmm.sendAsyncMessage("SystemMessageManager:Message" , { type: aType,
|
|
msg: aMessage,
|
|
manifest: aManifestURI.spec });
|
|
|
|
// Queue the message for pages that registered an handler for this type.
|
|
this._pages.forEach(function sendMess_openPage(aPage) {
|
|
if (aPage.type != aType || aPage.manifest != aManifestURI.spec) {
|
|
return;
|
|
}
|
|
|
|
aPage.pending.push(aMessage);
|
|
if (aPage.pending.length > kMaxPendingMessages) {
|
|
aPage.pending.splice(0, 1);
|
|
}
|
|
|
|
// We don't need to send the full object to observers.
|
|
let page = { uri: aPage.uri, manifest: aPage.manifest };
|
|
debug("Asking to open " + JSON.stringify(page));
|
|
Services.obs.notifyObservers(this, "system-messages-open-app", JSON.stringify(page));
|
|
}.bind(this))
|
|
},
|
|
|
|
registerPage: function registerPage(aType, aPageURI, aManifestURI) {
|
|
if (!aPageURI || !aManifestURI) {
|
|
throw Cr.NS_ERROR_INVALID_ARG;
|
|
}
|
|
|
|
this._pages.push({ type: aType,
|
|
uri: aPageURI.spec,
|
|
manifest: aManifestURI.spec,
|
|
pending: [] });
|
|
},
|
|
|
|
receiveMessage: function receiveMessage(aMessage) {
|
|
debug("received SystemMessageManager:GetPending " + aMessage.json.type + " for " + aMessage.json.uri + " @ " + aMessage.json.manifest);
|
|
// This is a sync call, use to return the pending message for a page.
|
|
let msg = aMessage.json;
|
|
debug(JSON.stringify(msg));
|
|
|
|
// Find the right page.
|
|
let page = null;
|
|
this._pages.some(function(aPage) {
|
|
if (aPage.uri == msg.uri &&
|
|
aPage.type == msg.type &&
|
|
aPage.manifest == msg.manifest) {
|
|
page = aPage;
|
|
}
|
|
return page !== null;
|
|
});
|
|
|
|
if (!page) {
|
|
return null;
|
|
}
|
|
|
|
let pending = page.pending;
|
|
// Clear the pending queue for this page.
|
|
// This is ok since we'll store pending events in SystemMessageManager.js
|
|
page.pending = [];
|
|
|
|
return pending;
|
|
},
|
|
|
|
observe: function observe(aSubject, aTopic, aData) {
|
|
if (aTopic == "xpcom-shutdown") {
|
|
ppmm.removeMessageListener("SystemMessageManager:GetPending", this);
|
|
Services.obs.removeObserver(this, "xpcom-shutdown");
|
|
ppmm = null;
|
|
this._pages = null;
|
|
}
|
|
},
|
|
|
|
classID: Components.ID("{70589ca5-91ac-4b9e-b839-d6a88167d714}"),
|
|
|
|
QueryInterface: XPCOMUtils.generateQI([Ci.nsISystemMessagesInternal, Ci.nsIObserver])
|
|
}
|
|
|
|
const NSGetFactory = XPCOMUtils.generateNSGetFactory([SystemMessageInternal]);
|