The Tor Browser: browser/metro/base/content/bindings/browser.js@7e26c7da4463 (annotated)

browser/metro/base/content/bindings/browser.js@7e26c7da4463 (annotated)

browser/metro/base/content/bindings/browser.js

Wed, 31 Dec 2014 06:55:50 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Wed, 31 Dec 2014 06:55:50 +0100
changeset 2: 7e26c7da4463
permissions: -rw-r--r--

Added tag UPSTREAM_283F7C6 for changeset ca08bd8f51b2

 // -*- 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/. */
 let Cc = Components.classes;
 let Ci = Components.interfaces;
 let Cu = Components.utils;
 Cu.import("resource://gre/modules/Services.jsm");
 Cu.import("resource://gre/modules/FormData.jsm");
 Cu.import("resource://gre/modules/ScrollPosition.jsm");
 Cu.import("resource://gre/modules/Timer.jsm", this);
 let WebProgressListener = {
   _lastLocation: null,
   _firstPaint: false,
   init: function() {
     let flags = Ci.nsIWebProgress.NOTIFY_LOCATION |
                 Ci.nsIWebProgress.NOTIFY_SECURITY |
                 Ci.nsIWebProgress.NOTIFY_STATE_WINDOW |
                 Ci.nsIWebProgress.NOTIFY_STATE_NETWORK |
                 Ci.nsIWebProgress.NOTIFY_STATE_DOCUMENT;
     let webProgress = docShell.QueryInterface(Ci.nsIInterfaceRequestor).getInterface(Ci.nsIWebProgress);
     webProgress.addProgressListener(this, flags);
   },
   onStateChange: function onStateChange(aWebProgress, aRequest, aStateFlags, aStatus) {
     if (content != aWebProgress.DOMWindow)
       return;
     sendAsyncMessage("Content:StateChange", {
       contentWindowId: this.contentWindowId,
       stateFlags: aStateFlags,
       status: aStatus
     });
   },
   onLocationChange: function onLocationChange(aWebProgress, aRequest, aLocationURI, aFlags) {
     if (content != aWebProgress.DOMWindow)
       return;
     let spec = aLocationURI ? aLocationURI.spec : "";
     let location = spec.split("#")[0];
     let charset = content.document.characterSet;
     sendAsyncMessage("Content:LocationChange", {
       contentWindowId: this.contentWindowId,
       documentURI:     aWebProgress.DOMWindow.document.documentURIObject.spec,
       location:        spec,
       canGoBack:       docShell.canGoBack,
       canGoForward:    docShell.canGoForward,
       charset:         charset.toString()
     });
     this._firstPaint = false;
     let self = this;
     // Keep track of hash changes
     this.hashChanged = (location == this._lastLocation);
     this._lastLocation = location;
     // When a new page is loaded fire a message for the first paint
     addEventListener("MozAfterPaint", function(aEvent) {
       removeEventListener("MozAfterPaint", arguments.callee, true);
       self._firstPaint = true;
       let scrollOffset = ContentScroll.getScrollOffset(content);
       sendAsyncMessage("Browser:FirstPaint", scrollOffset);
     }, true);
   },
   onStatusChange: function onStatusChange(aWebProgress, aRequest, aStatus, aMessage) {
   },
   onSecurityChange: function onSecurityChange(aWebProgress, aRequest, aState) {
     if (content != aWebProgress.DOMWindow)
       return;
     let serialization = SecurityUI.getSSLStatusAsString();
     sendAsyncMessage("Content:SecurityChange", {
       contentWindowId: this.contentWindowId,
       SSLStatusAsString: serialization,
       state: aState
     });
   },
   get contentWindowId() {
     return content.QueryInterface(Ci.nsIInterfaceRequestor)
                   .getInterface(Ci.nsIDOMWindowUtils)
                   .currentInnerWindowID;
   },
   QueryInterface: function QueryInterface(aIID) {
     if (aIID.equals(Ci.nsIWebProgressListener) ||
         aIID.equals(Ci.nsISupportsWeakReference) ||
         aIID.equals(Ci.nsISupports)) {
         return this;
     }
     throw Components.results.NS_ERROR_NO_INTERFACE;
   }
 };
 WebProgressListener.init();
 let SecurityUI = {
   getSSLStatusAsString: function() {
     let status = docShell.securityUI.QueryInterface(Ci.nsISSLStatusProvider).SSLStatus;
     if (status) {
       let serhelper = Cc["@mozilla.org/network/serialization-helper;1"]
                       .getService(Ci.nsISerializationHelper);
       status.QueryInterface(Ci.nsISerializable);
       return serhelper.serializeToString(status);
     }
     return null;
   }
 };
 let WebNavigation =  {
   _webNavigation: docShell.QueryInterface(Ci.nsIWebNavigation),
   _timer: null,
   init: function() {
     addMessageListener("WebNavigation:GoBack", this);
     addMessageListener("WebNavigation:GoForward", this);
     addMessageListener("WebNavigation:GotoIndex", this);
     addMessageListener("WebNavigation:LoadURI", this);
     addMessageListener("WebNavigation:Reload", this);
     addMessageListener("WebNavigation:Stop", this);
   },
   receiveMessage: function(message) {
     switch (message.name) {
       case "WebNavigation:GoBack":
         this.goBack();
         break;
       case "WebNavigation:GoForward":
         this.goForward();
         break;
       case "WebNavigation:GotoIndex":
         this.gotoIndex(message);
         break;
       case "WebNavigation:LoadURI":
         this.loadURI(message);
         break;
       case "WebNavigation:Reload":
         this.reload(message);
         break;
       case "WebNavigation:Stop":
         this.stop(message);
         break;
     }
   },
   goBack: function() {
     if (this._webNavigation.canGoBack)
       this._webNavigation.goBack();
   },
   goForward: function() {
     if (this._webNavigation.canGoForward)
       this._webNavigation.goForward();
   },
   gotoIndex: function(message) {
     this._webNavigation.gotoIndex(message.index);
   },
   loadURI: function(message) {
     let flags = message.json.flags || this._webNavigation.LOAD_FLAGS_NONE;
     this._webNavigation.loadURI(message.json.uri, flags, null, null, null);
     let tabData = message.json;
     if (tabData.entries) {
       // We are going to load from history so kill the current load. We do not
       // want the load added to the history anyway. We reload after resetting history
       this._webNavigation.stop(this._webNavigation.STOP_ALL);
       this._restoreHistory(tabData, 0);
     }
   },
   reload: function(message) {
     let flags = message.json.flags || this._webNavigation.LOAD_FLAGS_NONE;
     this._webNavigation.reload(flags);
   },
   stop: function(message) {
     let flags = message.json.flags || this._webNavigation.STOP_ALL;
     this._webNavigation.stop(flags);
   },
   _restoreHistory: function _restoreHistory(aTabData, aCount) {
     // We need to wait for the sessionHistory to be initialized and there
     // is no good way to do this. We'll try a wait loop like desktop
     try {
       if (!this._webNavigation.sessionHistory)
         throw new Error();
     } catch (ex) {
       if (aCount < 10) {
         let self = this;
         this._timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer);
         this._timer.initWithCallback(function(aTimer) {
           self._timer = null;
           self._restoreHistory(aTabData, aCount + 1);
         }, 100, Ci.nsITimer.TYPE_ONE_SHOT);
         return;
       }
     }
     let history = this._webNavigation.sessionHistory;
     if (history.count > 0)
       history.PurgeHistory(history.count);
     history.QueryInterface(Ci.nsISHistoryInternal);
     // helper hashes for ensuring unique frame IDs and unique document
     // identifiers.
     let idMap = { used: {} };
     let docIdentMap = {};
     for (let i = 0; i < aTabData.entries.length; i++) {
       if (!aTabData.entries[i].url)
         continue;
       history.addEntry(this._deserializeHistoryEntry(aTabData.entries[i], idMap, docIdentMap), true);
     }
     // We need to force set the active history item and cause it to reload since
     // we stop the load above
     let activeIndex = (aTabData.index || aTabData.entries.length) - 1;
     history.getEntryAtIndex(activeIndex, true);
     history.QueryInterface(Ci.nsISHistory).reloadCurrentEntry();
   },
   _deserializeHistoryEntry: function _deserializeHistoryEntry(aEntry, aIdMap, aDocIdentMap) {
     let shEntry = Cc["@mozilla.org/browser/session-history-entry;1"].createInstance(Ci.nsISHEntry);
     shEntry.setURI(Services.io.newURI(aEntry.url, null, null));
     shEntry.setTitle(aEntry.title || aEntry.url);
     if (aEntry.subframe)
       shEntry.setIsSubFrame(aEntry.subframe || false);
     shEntry.loadType = Ci.nsIDocShellLoadInfo.loadHistory;
     if (aEntry.contentType)
       shEntry.contentType = aEntry.contentType;
     if (aEntry.referrer)
       shEntry.referrerURI = Services.io.newURI(aEntry.referrer, null, null);
     if (aEntry.cacheKey) {
       let cacheKey = Cc["@mozilla.org/supports-PRUint32;1"].createInstance(Ci.nsISupportsPRUint32);
       cacheKey.data = aEntry.cacheKey;
       shEntry.cacheKey = cacheKey;
     }
     if (aEntry.ID) {
       // get a new unique ID for this frame (since the one from the last
       // start might already be in use)
       let id = aIdMap[aEntry.ID] || 0;
       if (!id) {
         for (id = Date.now(); id in aIdMap.used; id++);
         aIdMap[aEntry.ID] = id;
         aIdMap.used[id] = true;
       }
       shEntry.ID = id;
     }
     if (aEntry.docshellID)
       shEntry.docshellID = aEntry.docshellID;
     if (aEntry.structuredCloneState && aEntry.structuredCloneVersion) {
       shEntry.stateData =
         Cc["@mozilla.org/docshell/structured-clone-container;1"].
         createInstance(Ci.nsIStructuredCloneContainer);
       shEntry.stateData.initFromBase64(aEntry.structuredCloneState, aEntry.structuredCloneVersion);
     }
     if (aEntry.scroll) {
       let scrollPos = aEntry.scroll.split(",");
       scrollPos = [parseInt(scrollPos[0]) || 0, parseInt(scrollPos[1]) || 0];
       shEntry.setScrollPosition(scrollPos[0], scrollPos[1]);
     }
     let childDocIdents = {};
     if (aEntry.docIdentifier) {
       // If we have a serialized document identifier, try to find an SHEntry
       // which matches that doc identifier and adopt that SHEntry's
       // BFCacheEntry.  If we don't find a match, insert shEntry as the match
       // for the document identifier.
       let matchingEntry = aDocIdentMap[aEntry.docIdentifier];
       if (!matchingEntry) {
         matchingEntry = {shEntry: shEntry, childDocIdents: childDocIdents};
         aDocIdentMap[aEntry.docIdentifier] = matchingEntry;
       } else {
         shEntry.adoptBFCacheEntry(matchingEntry.shEntry);
         childDocIdents = matchingEntry.childDocIdents;
       }
     }
     if (aEntry.owner_b64) {
       let ownerInput = Cc["@mozilla.org/io/string-input-stream;1"].createInstance(Ci.nsIStringInputStream);
       let binaryData = atob(aEntry.owner_b64);
       ownerInput.setData(binaryData, binaryData.length);
       let binaryStream = Cc["@mozilla.org/binaryinputstream;1"].createInstance(Ci.nsIObjectInputStream);
       binaryStream.setInputStream(ownerInput);
       try { // Catch possible deserialization exceptions
         shEntry.owner = binaryStream.readObject(true);
       } catch (ex) { dump(ex); }
     }
     if (aEntry.children && shEntry instanceof Ci.nsISHContainer) {
       for (let i = 0; i < aEntry.children.length; i++) {
         if (!aEntry.children[i].url)
           continue;
         // We're getting sessionrestore.js files with a cycle in the
         // doc-identifier graph, likely due to bug 698656.  (That is, we have
         // an entry where doc identifier A is an ancestor of doc identifier B,
         // and another entry where doc identifier B is an ancestor of A.)
         //
         // If we were to respect these doc identifiers, we'd create a cycle in
         // the SHEntries themselves, which causes the docshell to loop forever
         // when it looks for the root SHEntry.
         //
         // So as a hack to fix this, we restrict the scope of a doc identifier
         // to be a node's siblings and cousins, and pass childDocIdents, not
         // aDocIdents, to _deserializeHistoryEntry.  That is, we say that two
         // SHEntries with the same doc identifier have the same document iff
         // they have the same parent or their parents have the same document.
         shEntry.AddChild(this._deserializeHistoryEntry(aEntry.children[i], aIdMap, childDocIdents), i);
       }
     }
     return shEntry;
   },
   sendHistory: function sendHistory() {
     // We need to package up the session history and send it to the sessionstore
     let entries = [];
     let history = docShell.QueryInterface(Ci.nsIWebNavigation).sessionHistory;
     for (let i = 0; i < history.count; i++) {
       let entry = this._serializeHistoryEntry(history.getEntryAtIndex(i, false));
       // If someone directly navigates to one of these URLs and they switch to Desktop,
       // we need to make the page load-able.
       if (entry.url == "about:home" || entry.url == "about:start") {
         entry.url = "about:newtab";
       }
       entries.push(entry);
     }
     let index = history.index + 1;
     sendAsyncMessage("Content:SessionHistory", { entries: entries, index: index });
   },
   _serializeHistoryEntry: function _serializeHistoryEntry(aEntry) {
     let entry = { url: aEntry.URI.spec };
     if (Util.isURLEmpty(entry.url)) {
       entry.title = Util.getEmptyURLTabTitle();
     } else {
       entry.title = aEntry.title;
     }
     if (!(aEntry instanceof Ci.nsISHEntry))
       return entry;
     let cacheKey = aEntry.cacheKey;
     if (cacheKey && cacheKey instanceof Ci.nsISupportsPRUint32 && cacheKey.data != 0)
       entry.cacheKey = cacheKey.data;
     entry.ID = aEntry.ID;
     entry.docshellID = aEntry.docshellID;
     if (aEntry.referrerURI)
       entry.referrer = aEntry.referrerURI.spec;
     if (aEntry.contentType)
       entry.contentType = aEntry.contentType;
     let x = {}, y = {};
     aEntry.getScrollPosition(x, y);
     if (x.value != 0 || y.value != 0)
       entry.scroll = x.value + "," + y.value;
     if (aEntry.owner) {
       try {
         let binaryStream = Cc["@mozilla.org/binaryoutputstream;1"].createInstance(Ci.nsIObjectOutputStream);
         let pipe = Cc["@mozilla.org/pipe;1"].createInstance(Ci.nsIPipe);
         pipe.init(false, false, 0, 0xffffffff, null);
         binaryStream.setOutputStream(pipe.outputStream);
         binaryStream.writeCompoundObject(aEntry.owner, Ci.nsISupports, true);
         binaryStream.close();
         // Now we want to read the data from the pipe's input end and encode it.
         let scriptableStream = Cc["@mozilla.org/binaryinputstream;1"].createInstance(Ci.nsIBinaryInputStream);
         scriptableStream.setInputStream(pipe.inputStream);
         let ownerBytes = scriptableStream.readByteArray(scriptableStream.available());
         // We can stop doing base64 encoding once our serialization into JSON
         // is guaranteed to handle all chars in strings, including embedded
         // nulls.
         entry.owner_b64 = btoa(String.fromCharCode.apply(null, ownerBytes));
       } catch (e) { dump(e); }
     }
     entry.docIdentifier = aEntry.BFCacheEntry.ID;
     if (aEntry.stateData != null) {
       entry.structuredCloneState = aEntry.stateData.getDataAsBase64();
       entry.structuredCloneVersion = aEntry.stateData.formatVersion;
     }
     if (!(aEntry instanceof Ci.nsISHContainer))
       return entry;
     if (aEntry.childCount > 0) {
       entry.children = [];
       for (let i = 0; i < aEntry.childCount; i++) {
         let child = aEntry.GetChildAt(i);
         if (child)
           entry.children.push(this._serializeHistoryEntry(child));
         else // to maintain the correct frame order, insert a dummy entry
           entry.children.push({ url: "about:blank" });
         // don't try to restore framesets containing wyciwyg URLs (cf. bug 424689 and bug 450595)
         if (/^wyciwyg:\/\//.test(entry.children[i].url)) {
           delete entry.children;
           break;
         }
       }
     }
     return entry;
   }
 };
 WebNavigation.init();
 let DOMEvents =  {
   _timeout: null,
   _sessionEvents: new Set(),
   _sessionEventMap: {"SessionStore:collectFormdata" : FormData.collect,
                      "SessionStore:collectScrollPosition" : ScrollPosition.collect},
   init: function() {
     addEventListener("DOMContentLoaded", this, false);
     addEventListener("DOMTitleChanged", this, false);
     addEventListener("DOMLinkAdded", this, false);
     addEventListener("DOMWillOpenModalDialog", this, false);
     addEventListener("DOMModalDialogClosed", this, true);
     addEventListener("DOMWindowClose", this, false);
     addEventListener("DOMPopupBlocked", this, false);
     addEventListener("pageshow", this, false);
     addEventListener("pagehide", this, false);
     addEventListener("input", this, true);
     addEventListener("change", this, true);
     addEventListener("scroll", this, true);
     addMessageListener("SessionStore:restoreSessionTabData", this);
   },
   receiveMessage: function(message) {
     switch (message.name) {
       case "SessionStore:restoreSessionTabData":
         if (message.json.formdata)
           FormData.restore(content, message.json.formdata);
         if (message.json.scroll)
           ScrollPosition.restore(content, message.json.scroll.scroll);
         break;
     }
   },
   handleEvent: function(aEvent) {
     let document = content.document;
     switch (aEvent.type) {
       case "DOMContentLoaded":
         if (document.documentURIObject.spec == "about:blank")
           return;
         sendAsyncMessage("DOMContentLoaded", { });
         // Send the session history now too
         WebNavigation.sendHistory();
         break;
       case "pageshow":
       case "pagehide": {
         if (aEvent.target.defaultView != content)
           break;
         let util = aEvent.target.defaultView.QueryInterface(Ci.nsIInterfaceRequestor)
                                             .getInterface(Ci.nsIDOMWindowUtils);
         let json = {
           contentWindowWidth: content.innerWidth,
           contentWindowHeight: content.innerHeight,
           windowId: util.outerWindowID,
           persisted: aEvent.persisted
         };
         // Clear onload focus to prevent the VKB to be shown unexpectingly
         // but only if the location has really changed and not only the
         // fragment identifier
         let contentWindowID = content.QueryInterface(Ci.nsIInterfaceRequestor).getInterface(Ci.nsIDOMWindowUtils).currentInnerWindowID;
         if (!WebProgressListener.hashChanged && contentWindowID == util.currentInnerWindowID) {
           let focusManager = Cc["@mozilla.org/focus-manager;1"].getService(Ci.nsIFocusManager);
           focusManager.clearFocus(content);
         }
         sendAsyncMessage(aEvent.type, json);
         break;
       }
       case "DOMPopupBlocked": {
         let util = aEvent.requestingWindow.QueryInterface(Ci.nsIInterfaceRequestor)
                                           .getInterface(Ci.nsIDOMWindowUtils);
         let json = {
           windowId: util.outerWindowID,
           popupWindowURI: {
             spec: aEvent.popupWindowURI.spec,
             charset: aEvent.popupWindowURI.originCharset
           },
           popupWindowFeatures: aEvent.popupWindowFeatures,
           popupWindowName: aEvent.popupWindowName
         };
         sendAsyncMessage("DOMPopupBlocked", json);
         break;
       }
       case "DOMTitleChanged":
         sendAsyncMessage("DOMTitleChanged", { title: document.title });
         break;
       case "DOMLinkAdded":
         let target = aEvent.originalTarget;
         if (!target.href || target.disabled)
           return;
         let json = {
           windowId: target.ownerDocument.defaultView.QueryInterface(Ci.nsIInterfaceRequestor).getInterface(Ci.nsIDOMWindowUtils).currentInnerWindowID,
           href: target.href,
           charset: document.characterSet,
           title: target.title,
           rel: target.rel,
           type: target.type
         };
         // rel=icon can also have a sizes attribute
         if (target.hasAttribute("sizes"))
           json.sizes = target.getAttribute("sizes");
         sendAsyncMessage("DOMLinkAdded", json);
         break;
       case "DOMWillOpenModalDialog":
       case "DOMModalDialogClosed":
       case "DOMWindowClose":
         let retvals = sendSyncMessage(aEvent.type, { });
         for (let i in retvals) {
           if (retvals[i].preventDefault) {
             aEvent.preventDefault();
             break;
           }
         }
         break;
       case "input":
       case "change":
         this._sessionEvents.add("SessionStore:collectFormdata");
         this._sendUpdates();
         break;
       case "scroll":
         this._sessionEvents.add("SessionStore:collectScrollPosition");
         this._sendUpdates();
         break;
     }
   },
   _sendUpdates: function() {
     if (!this._timeout) {
       // Wait a little before sending the message to batch multiple changes.
       this._timeout = setTimeout(function() {
         for (let eventType of this._sessionEvents) {
           sendAsyncMessage(eventType, {
             data: this._sessionEventMap[eventType](content)
           });
         }
         this._sessionEvents.clear();
         clearTimeout(this._timeout);
         this._timeout = null;
       }.bind(this), 1000);
     }
   }
 };
 DOMEvents.init();
 let ContentScroll =  {
   // The most recent offset set by APZC for the root scroll frame
   _scrollOffset: { x: 0, y: 0 },
   init: function() {
     addMessageListener("Content:SetWindowSize", this);
     addEventListener("pagehide", this, false);
     addEventListener("MozScrolledAreaChanged", this, false);
   },
   getScrollOffset: function(aWindow) {
     let cwu = aWindow.QueryInterface(Ci.nsIInterfaceRequestor).getInterface(Ci.nsIDOMWindowUtils);
     let scrollX = {}, scrollY = {};
     cwu.getScrollXY(false, scrollX, scrollY);
     return { x: scrollX.value, y: scrollY.value };
   },
   getScrollOffsetForElement: function(aElement) {
     if (aElement.parentNode == aElement.ownerDocument)
       return this.getScrollOffset(aElement.ownerDocument.defaultView);
     return { x: aElement.scrollLeft, y: aElement.scrollTop };
   },
   receiveMessage: function(aMessage) {
     let json = aMessage.json;
     switch (aMessage.name) {
       case "Content:SetWindowSize": {
         let cwu = content.QueryInterface(Ci.nsIInterfaceRequestor).getInterface(Ci.nsIDOMWindowUtils);
         cwu.setCSSViewport(json.width, json.height);
         sendAsyncMessage("Content:SetWindowSize:Complete", {});
         break;
       }
     }
   },
   handleEvent: function(aEvent) {
     switch (aEvent.type) {
       case "pagehide":
         this._scrollOffset = { x: 0, y: 0 };
         break;
       case "MozScrolledAreaChanged": {
         let doc = aEvent.originalTarget;
         if (content != doc.defaultView) // We are only interested in root scroll pane changes
           return;
         sendAsyncMessage("MozScrolledAreaChanged", {
           width: aEvent.width,
           height: aEvent.height,
           left: aEvent.x + content.scrollX
         });
         // Send event only after painting to make sure content views in the parent process have
         // been updated.
         addEventListener("MozAfterPaint", function afterPaint() {
           removeEventListener("MozAfterPaint", afterPaint, false);
           sendAsyncMessage("Content:UpdateDisplayPort");
         }, false);
         break;
       }
     }
   }
 };
 this.ContentScroll = ContentScroll;
 ContentScroll.init();
 let ContentActive =  {
   init: function() {
     addMessageListener("Content:Activate", this);
     addMessageListener("Content:Deactivate", this);
   },
   receiveMessage: function(aMessage) {
     let json = aMessage.json;
     switch (aMessage.name) {
       case "Content:Deactivate":
         docShell.isActive = false;
         let cwu = content.QueryInterface(Ci.nsIInterfaceRequestor).getInterface(Ci.nsIDOMWindowUtils);
         if (json.keepviewport)
           break;
         cwu.setDisplayPortForElement(0, 0, 0, 0, content.document.documentElement, 0);
         break;
       case "Content:Activate":
         docShell.isActive = true;
         break;
     }
   }
 };
 ContentActive.init();
 /**
  * Helper class for IndexedDB, child part. Listens using
  * the observer service for events regarding IndexedDB
  * prompts, and sends messages to the parent to actually
  * show the prompts.
  */
 let IndexedDB = {
   _permissionsPrompt: "indexedDB-permissions-prompt",
   _permissionsResponse: "indexedDB-permissions-response",
   _quotaPrompt: "indexedDB-quota-prompt",
   _quotaResponse: "indexedDB-quota-response",
   _quotaCancel: "indexedDB-quota-cancel",
   waitingObservers: [],
   init: function IndexedDBPromptHelper_init() {
     let os = Services.obs;
     os.addObserver(this, this._permissionsPrompt, false);
     os.addObserver(this, this._quotaPrompt, false);
     os.addObserver(this, this._quotaCancel, false);
     addMessageListener("IndexedDB:Response", this);
   },
   observe: function IndexedDBPromptHelper_observe(aSubject, aTopic, aData) {
     if (aTopic != this._permissionsPrompt && aTopic != this._quotaPrompt && aTopic != this._quotaCancel) {
       throw new Error("Unexpected topic!");
     }
     let requestor = aSubject.QueryInterface(Ci.nsIInterfaceRequestor);
     let observer = requestor.getInterface(Ci.nsIObserver);
     let contentWindow = requestor.getInterface(Ci.nsIDOMWindow);
     let contentDocument = contentWindow.document;
     if (aTopic == this._quotaCancel) {
       observer.observe(null, this._quotaResponse, Ci.nsIPermissionManager.UNKNOWN_ACTION);
       return;
     }
     // Remote to parent
     sendAsyncMessage("IndexedDB:Prompt", {
       topic: aTopic,
       host: contentDocument.documentURIObject.asciiHost,
       location: contentDocument.location.toString(),
       data: aData,
       observerId: this.addWaitingObserver(observer)
     });
   },
   receiveMessage: function(aMessage) {
     let payload = aMessage.json;
     switch (aMessage.name) {
       case "IndexedDB:Response":
         let observer = this.getAndRemoveWaitingObserver(payload.observerId);
         observer.observe(null, payload.responseTopic, payload.permission);
     }
   },
   addWaitingObserver: function(aObserver) {
     let observerId = 0;
     while (observerId in this.waitingObservers)
       observerId++;
     this.waitingObservers[observerId] = aObserver;
     return observerId;
   },
   getAndRemoveWaitingObserver: function(aObserverId) {
     let observer = this.waitingObservers[aObserverId];
     delete this.waitingObservers[aObserverId];
     return observer;
   }
 };
 IndexedDB.init();