Issue 1706 - Move first-run page to adblockplusui repository

ext/common.js

+/*
+ * This file is part of Adblock Plus <http://adblockplus.org/>,
+ * Copyright (C) 2006-2014 Eyeo GmbH
+ *
+ * Adblock Plus is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 3 as
+ * published by the Free Software Foundation.
+ *
+ * Adblock Plus is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Adblock Plus.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+(function(global)
+{
+  const Ci = Components.interfaces;
+
+  var holder = {
+    get Page()
+    {
+      delete this.Page;
+      this.Page = (typeof require == "function" ?
+          require("ext_background").Page :
+          function() {});
+      return this.Page;
+    }
+  };
+
+  function getSender(origin)
+  {
+    if (origin instanceof Ci.nsIDOMXULElement)
+      return origin.messageManager;
+    else if (origin instanceof Ci.nsIMessageSender)
+      return origin;
+    else
+      return null;
+  }
+
+  function MessageProxy(messageManager, messageTarget)
+  {
+    this._messageManager = messageManager;
+    this._messageTarget = messageTarget;
+    this._callbacks = new Map();
+    this._responseCallbackCounter = 0;
+
+    this._handleRequest = this._handleRequest.bind(this);
+    this._handleResponse = this._handleResponse.bind(this);
+    this._messageManager.addMessageListener("AdblockPlus:Message", this._handleRequest);
+    this._messageManager.addMessageListener("AdblockPlus:Response", this._handleResponse);
+  }
+  MessageProxy.prototype = {
+    _disconnect: function()
+    {
+      this._messageManager.removeMessageListener("AdblockPlus:Message", this._handleRequest);
+      this._messageManager.removeMessageListener("AdblockPlus:Response", this._handleResponse);
+    },
+
+    _sendResponse: function(sender, callbackId, response)
+    {
+      this._responseSent = true;
+
+      if (sender instanceof Ci.nsIMessageSender)
+      {
+        sender.sendAsyncMessage("AdblockPlus:Response", {
+          callbackId: callbackId,
+          responseSent: typeof response != "undefined",
+          payload: response
+        });
+      }
+    },
+
+    _handleRequest: function(message)
+    {
+      var sender = getSender(message.target);
+      var request = message.data;
+      var sendResponse;
+      if (sender && "callbackId" in request)
+        sendResponse = this._sendResponse.bind(this, sender, request.callbackId);
+      else
+        sendResponse = function() {};
+
+      this._responseSent = false;
+      var result = this._messageTarget._dispatch(request.payload, {
+        page: new holder.Page(sender)
+      }, sendResponse);
+      if (!result && !this._responseSent)
+        sendResponse(undefined);
+    },
+
+    _handleResponse: function(message)
+    {
+      var response = message.data;
+      var callback = this._callbacks.get(response.callbackId);
+      if (callback)
+      {
+        this._callbacks.delete(response.callbackId);
+        if (response.responseSent)
+          callback(response.payload);
+      }
+    },
+
+    sendMessage: function(message, responseCallback)
+    {
+      if (!(this._messageManager instanceof Ci.nsIMessageSender))
+        throw new Error("Not implemented");
+
+      var request = {
+        payload: message
+      };
+      if (responseCallback)
+      {
+        request.callbackId = ++this._responseCallbackCounter;
+        this._callbacks.set(request.callbackId, responseCallback);
+      }
+
+      this._messageManager.sendAsyncMessage("AdblockPlus:Message", request);
+    }
+  };
+
+  function EventTarget()
+  {
+    this._listeners = [];
+  };
+  EventTarget.prototype = {
+    addListener: function(listener)
+    {
+      if (this._listeners.indexOf(listener) == -1)
+        this._listeners.push(listener);
+    },
+    removeListener: function(listener)
+    {
+      var idx = this._listeners.indexOf(listener);
+      if (idx != -1)
+        this._listeners.splice(idx, 1);
+    },
+    _dispatch: function()
+    {
+      var result = null;
+
+      for (var i = 0; i < this._listeners.length; i++)
+        result = this._listeners[i].apply(null, arguments);
+
+      return result;
+    }
+  };
+
+  if (typeof exports == "object")
+  {
+    exports.MessageProxy = MessageProxy;
+    exports.EventTarget = EventTarget;
+    exports.getSender = getSender;
+  }
+  else
+  {
+    if (!global.ext)
+      global.ext = {};
+    global.ext._MessageProxy = MessageProxy;
+    global.ext._EventTarget = EventTarget;
+  }
+})(this);